Uses of Class
org.apache.cassandra.db.filter.ColumnFilter
-
-
Uses of ColumnFilter in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection that return ColumnFilter Modifier and Type Method Description ColumnFilter
Selection.Selectors. getColumnFilter()
Returns theColumnFilter
corresponding to those selectors -
Uses of ColumnFilter in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return ColumnFilter Modifier and Type Method Description ColumnFilter
SelectStatement. queriedColumns()
The columns to fetch internally for this SELECT statement (which can be more than the one selected by the user as it also include any restricted column in particular).Methods in org.apache.cassandra.cql3.statements with parameters of type ColumnFilter Modifier and Type Method Description ReadQuery
SelectStatement. getQuery(QueryOptions options, ColumnFilter columnFilter, int nowInSec, int userLimit, int perPartitionLimit, int pageSize)
-
Uses of ColumnFilter in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return ColumnFilter Modifier and Type Method Description ColumnFilter
ReadQuery. columnFilter()
A filter on which (non-PK) columns must be returned by the query.ColumnFilter
SinglePartitionReadQuery.Group. columnFilter()
protected ColumnFilter
AbstractReadCommandBuilder. makeColumnFilter()
Methods in org.apache.cassandra.db with parameters of type ColumnFilter Modifier and Type Method Description static PartitionRangeReadCommand
PartitionRangeReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)
static ReadQuery
PartitionRangeReadQuery. create(TableMetadata table, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)
static SinglePartitionReadCommand
SinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter)
Creates a new read command on a single partition.static SinglePartitionReadCommand
SinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)
Creates a new read command on a single partition.static SinglePartitionReadCommand
SinglePartitionReadCommand. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata indexMetadata)
Creates a new read command on a single partition.static SinglePartitionReadCommand.Group
SinglePartitionReadCommand.Group. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)
static SinglePartitionReadQuery
SinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter)
Creates a new read query on a single partition.static SinglePartitionReadQuery
SinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)
Creates a new read query on a single partition.static VirtualTablePartitionRangeReadQuery
VirtualTablePartitionRangeReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange)
static VirtualTableSinglePartitionReadQuery
VirtualTableSinglePartitionReadQuery. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter)
static VirtualTableSinglePartitionReadQuery.Group
VirtualTableSinglePartitionReadQuery.Group. create(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)
static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery>
SinglePartitionReadQuery. createGroup(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, java.util.List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter)
abstract ReadCommand
ReadCommand.SelectionDeserializer. deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, IndexMetadata index)
SerializationHeader
SerializationHeader.Serializer. deserializeForMessaging(DataInputPlus in, TableMetadata metadata, ColumnFilter selection, boolean hasStatic)
Memtable.MemtableUnfilteredPartitionIterator
Memtable. makePartitionIterator(ColumnFilter columnFilter, DataRange dataRange)
UnfilteredRowIterator
StorageHook. makeRowIterator(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)
UnfilteredRowIteratorWithLowerBound
StorageHook. makeRowIteratorWithLowerBound(ColumnFamilyStore cfs, DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener)
long
SerializationHeader.Serializer. serializedSizeForMessaging(SerializationHeader header, ColumnFilter selection, boolean hasStatic)
void
SerializationHeader.Serializer. serializeForMessaging(SerializationHeader header, ColumnFilter selection, DataOutputPlus out, boolean hasStatic)
Constructors in org.apache.cassandra.db with parameters of type ColumnFilter Constructor Description MemtableUnfilteredPartitionIterator(ColumnFamilyStore cfs, java.util.Iterator<java.util.Map.Entry<PartitionPosition,AtomicBTreePartition>> iter, int minLocalDeletionTime, ColumnFilter columnFilter, DataRange dataRange)
ReadCommand(ReadCommand.Kind kind, boolean isDigestQuery, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, IndexMetadata index)
SinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, IndexMetadata index)
VirtualTableReadQuery(TableMetadata metadata, int nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits)
-
Uses of ColumnFilter in org.apache.cassandra.db.columniterator
Fields in org.apache.cassandra.db.columniterator declared as ColumnFilter Modifier and Type Field Description protected ColumnFilter
AbstractSSTableIterator. columns
Constructors in org.apache.cassandra.db.columniterator with parameters of type ColumnFilter Constructor Description AbstractSSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columnFilter, FileHandle ifile)
SSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columns, FileHandle ifile)
SSTableReversedIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter columns, FileHandle ifile)
-
Uses of ColumnFilter in org.apache.cassandra.db.filter
Subclasses of ColumnFilter in org.apache.cassandra.db.filter Modifier and Type Class Description static class
ColumnFilter.SelectionColumnFilter
ColumnFilter
sub-class for queries with selected columns.static class
ColumnFilter.WildCardColumnFilter
ColumnFilter
sub-class for wildcard queries.Fields in org.apache.cassandra.db.filter declared as ColumnFilter Modifier and Type Field Description static ColumnFilter
ColumnFilter. NONE
Methods in org.apache.cassandra.db.filter that return ColumnFilter Modifier and Type Method Description static ColumnFilter
ColumnFilter. all(TableMetadata metadata)
A filter that includes all columns for the provided table.ColumnFilter
ColumnFilter.Builder. build()
ColumnFilter
ColumnFilter.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata)
static ColumnFilter
ColumnFilter. selection(RegularAndStaticColumns columns)
A filter that only fetches/queries the provided columns.static ColumnFilter
ColumnFilter. selection(TableMetadata metadata, RegularAndStaticColumns queried, boolean returnStaticContentOnPartitionWithNoRows)
A filter that fetches all columns for the provided table, but returns only the queried ones.Methods in org.apache.cassandra.db.filter with parameters of type ColumnFilter Modifier and Type Method Description UnfilteredRowIterator
ClusteringIndexFilter. filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator)
Returns an iterator that only returns the rows of the provided iterator that this filter selects.UnfilteredRowIterator
ClusteringIndexNamesFilter. filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator)
UnfilteredRowIterator
ClusteringIndexSliceFilter. filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator)
UnfilteredRowIterator
ClusteringIndexFilter. getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition)
Given a partition, returns a row iterator for the rows of this partition that are selected by this filter.UnfilteredRowIterator
ClusteringIndexNamesFilter. getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition)
UnfilteredRowIterator
ClusteringIndexSliceFilter. getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition)
void
ColumnFilter.Serializer. serialize(ColumnFilter selection, DataOutputPlus out, int version)
long
ColumnFilter.Serializer. serializedSize(ColumnFilter selection, int version)
-
Uses of ColumnFilter in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions with parameters of type ColumnFilter Modifier and Type Method Description UnfilteredPartitionIterator
UnfilteredPartitionIterators.Serializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)
static PartitionUpdate
PartitionUpdate. fromIterator(RowIterator iterator, ColumnFilter filter)
Turns the given iterator into an update.static PartitionUpdate
PartitionUpdate. fromIterator(UnfilteredRowIterator iterator, ColumnFilter filter)
Turns the given iterator into an update.void
UnfilteredPartitionIterators.Serializer. serialize(UnfilteredPartitionIterator iter, ColumnFilter selection, DataOutputPlus out, int version)
UnfilteredRowIterator
AbstractBTreePartition. unfilteredIterator(ColumnFilter selection, java.util.NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed)
UnfilteredRowIterator
AbstractBTreePartition. unfilteredIterator(ColumnFilter selection, Slices slices, boolean reversed)
UnfilteredRowIterator
AbstractBTreePartition. unfilteredIterator(AbstractBTreePartition.Holder current, ColumnFilter selection, Slices slices, boolean reversed)
UnfilteredRowIterator
AtomicBTreePartition. unfilteredIterator(ColumnFilter selection, java.util.NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed)
UnfilteredRowIterator
AtomicBTreePartition. unfilteredIterator(ColumnFilter selection, Slices slices, boolean reversed)
UnfilteredRowIterator
AtomicBTreePartition. unfilteredIterator(AbstractBTreePartition.Holder current, ColumnFilter selection, Slices slices, boolean reversed)
UnfilteredRowIterator
Partition. unfilteredIterator(ColumnFilter columns, java.util.NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed)
Returns an UnfilteredRowIterator over the rows/RT contained by this partition selected by the provided clusterings.UnfilteredRowIterator
Partition. unfilteredIterator(ColumnFilter columns, Slices slices, boolean reversed)
Returns an UnfilteredRowIterator over the rows/RT contained by this partition selected by the provided slices. -
Uses of ColumnFilter in org.apache.cassandra.db.rows
Methods in org.apache.cassandra.db.rows with parameters of type ColumnFilter Modifier and Type Method Description UnfilteredRowIterator
UnfilteredRowIteratorSerializer. deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)
UnfilteredRowIteratorSerializer.Header
UnfilteredRowIteratorSerializer. deserializeHeader(TableMetadata metadata, ColumnFilter selection, DataInputPlus in, int version, DeserializationHelper.Flag flag)
Row
BTreeRow. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)
Row
BTreeRow. filter(ColumnFilter filter, TableMetadata metadata)
ComplexColumnData
ComplexColumnData. filter(ColumnFilter filter, DeletionTime activeDeletion, DroppedColumn dropped, LivenessInfo rowLiveness)
Row
Row. filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata)
Returns a copy of this row that: 1) only includes the data for the column included byfilter
.Row
Row. filter(ColumnFilter filter, TableMetadata metadata)
Returns a copy of this row that: 1) only includes the data for the column included byfilter
.void
UnfilteredRowIteratorSerializer. serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version)
void
UnfilteredRowIteratorSerializer. serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version, int rowEstimate)
long
UnfilteredRowIteratorSerializer. serializedSize(UnfilteredRowIterator iterator, ColumnFilter selection, int version, int rowEstimate)
Row
BTreeRow. withOnlyQueriedData(ColumnFilter filter)
ComplexColumnData
ComplexColumnData. withOnlyQueriedData(ColumnFilter filter)
Row
Row. withOnlyQueriedData(ColumnFilter filter)
Returns a copy of this row which only include the data queried byfilter
, excluding anything _fetched_ for internal reasons but not queried by the user (seeColumnFilter
for details).static RowIterator
RowIterators. withOnlyQueriedData(RowIterator iterator, ColumnFilter filter)
Filter the provided iterator to only include cells that are selected by the user.static UnfilteredRowIterator
UnfilteredRowIterators. withOnlyQueriedData(UnfilteredRowIterator iterator, ColumnFilter filter)
Filter the provided iterator to exclude cells that have been fetched but are not queried by the user (see ColumnFilter for detailes).Constructors in org.apache.cassandra.db.rows with parameters of type ColumnFilter Constructor Description DeserializationHelper(TableMetadata metadata, int version, DeserializationHelper.Flag flag, ColumnFilter columnsToFetch)
RowAndDeletionMergeIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, ColumnFilter selection, Row staticRow, boolean isReversed, EncodingStats stats, java.util.Iterator<Row> rows, java.util.Iterator<RangeTombstone> ranges, boolean removeShadowedData)
UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener)
WithOnlyQueriedData(ColumnFilter filter)
-
Uses of ColumnFilter in org.apache.cassandra.db.virtual
Methods in org.apache.cassandra.db.virtual with parameters of type ColumnFilter Modifier and Type Method Description UnfilteredPartitionIterator
AbstractVirtualTable. select(DataRange dataRange, ColumnFilter columnFilter)
UnfilteredPartitionIterator
AbstractVirtualTable. select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter)
UnfilteredPartitionIterator
VirtualTable. select(DataRange dataRange, ColumnFilter columnFilter)
Selects the rows from a range of partitions.UnfilteredPartitionIterator
VirtualTable. select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter)
Selects the rows from a single partition.UnfilteredRowIterator
AbstractVirtualTable.Partition. toRowIterator(TableMetadata metadata, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter, long now)
-
Uses of ColumnFilter in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format with parameters of type ColumnFilter Modifier and Type Method Description abstract ISSTableScanner
SSTableReader. getScanner(ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener)
abstract UnfilteredRowIterator
SSTableReader. iterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)
abstract UnfilteredRowIterator
SSTableReader. iterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed)
-
Uses of ColumnFilter in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type ColumnFilter Modifier and Type Method Description ISSTableScanner
BigTableReader. getScanner(ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener)
static ISSTableScanner
BigTableScanner. getScanner(SSTableReader sstable, ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener)
UnfilteredRowIterator
BigTableReader. iterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener)
UnfilteredRowIterator
BigTableReader. iterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed)
-