Uses of Class
org.apache.cassandra.db.filter.ColumnFilter
Packages that use ColumnFilter
Package
Description
-
Uses of ColumnFilter in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection that return ColumnFilterModifier and TypeMethodDescriptionSelection.Selectors.getColumnFilter()Returns theColumnFiltercorresponding to those selectors -
Uses of ColumnFilter in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return ColumnFilterModifier and TypeMethodDescriptionSelectStatement.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 ColumnFilterModifier and TypeMethodDescriptionSelectStatement.getQuery(QueryOptions options, ClientState state, ColumnFilter columnFilter, long nowInSec, int userLimit, int perPartitionLimit, int pageSize, AggregationSpecification aggregationSpec) SelectStatement.getQuery(QueryOptions options, ClientState state, ColumnFilter columnFilter, long nowInSec, DataLimits limit) -
Uses of ColumnFilter in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return ColumnFilterModifier and TypeMethodDescriptionReadQuery.columnFilter()A filter on which (non-PK) columns must be returned by the query.SinglePartitionReadQuery.Group.columnFilter()protected ColumnFilterAbstractReadCommandBuilder.makeColumnFilter()Methods in org.apache.cassandra.db with parameters of type ColumnFilterModifier and TypeMethodDescriptionstatic PartitionRangeReadCommandPartitionRangeReadCommand.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange) static ReadQueryPartitionRangeReadQuery.create(TableMetadata table, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange) static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter) Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter) Creates a new read command on a single partition.static SinglePartitionReadCommandSinglePartitionReadCommand.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan) Creates a new read command on a single partition.SinglePartitionReadCommand.Group.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter) static SinglePartitionReadQuerySinglePartitionReadQuery.create(TableMetadata metadata, long nowInSec, DecoratedKey key, ColumnFilter columnFilter, ClusteringIndexFilter filter) Creates a new read query on a single partition.static SinglePartitionReadQuerySinglePartitionReadQuery.create(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter) Creates a new read query on a single partition.static SinglePartitionReadQuery.Group<? extends SinglePartitionReadQuery>SinglePartitionReadQuery.createGroup(TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, List<DecoratedKey> partitionKeys, ClusteringIndexFilter clusteringIndexFilter) static ReadResponseReadResponse.createSimpleDataResponse(UnfilteredPartitionIterator data, ColumnFilter selection) abstract ReadCommandReadCommand.SelectionDeserializer.deserialize(DataInputPlus in, int version, boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan) SerializationHeader.Serializer.deserializeForMessaging(DataInputPlus in, TableMetadata metadata, ColumnFilter selection, boolean hasStatic) StorageHook.makeRowIterator(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) StorageHook.makeRowIteratorWithLowerBound(ColumnFamilyStore cfs, SSTableReader sstable, DecoratedKey partitionKey, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener) longSerializationHeader.Serializer.serializedSizeForMessaging(SerializationHeader header, ColumnFilter selection, boolean hasStatic) voidSerializationHeader.Serializer.serializeForMessaging(SerializationHeader header, ColumnFilter selection, DataOutputPlus out, boolean hasStatic) Constructors in org.apache.cassandra.db with parameters of type ColumnFilterModifierConstructorDescriptionprotectedPartitionRangeReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DataRange dataRange, Index.QueryPlan indexQueryPlan, boolean trackWarnings) protectedReadCommand(ReadCommand.Kind kind, boolean isDigestQuery, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange) protectedSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange) protectedVirtualTableSinglePartitionReadCommand(boolean isDigest, int digestVersion, boolean acceptsTransient, TableMetadata metadata, long nowInSec, ColumnFilter columnFilter, RowFilter rowFilter, DataLimits limits, DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, Index.QueryPlan indexQueryPlan, boolean trackWarnings, DataRange dataRange) -
Uses of ColumnFilter in org.apache.cassandra.db.filter
Subclasses of ColumnFilter in org.apache.cassandra.db.filterModifier and TypeClassDescriptionstatic classColumnFiltersub-class for queries with selected columns.static classColumnFiltersub-class for wildcard queries.Fields in org.apache.cassandra.db.filter declared as ColumnFilterMethods in org.apache.cassandra.db.filter that return ColumnFilterModifier and TypeMethodDescriptionstatic ColumnFilterColumnFilter.all(TableMetadata metadata) A filter that includes all columns for the provided table.ColumnFilter.Builder.build()ColumnFilter.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata) static ColumnFilterColumnFilter.selection(RegularAndStaticColumns columns) A filter that only fetches/queries the provided columns.static ColumnFilterColumnFilter.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 ColumnFilterModifier and TypeMethodDescriptionClusteringIndexFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) Returns an iterator that only returns the rows of the provided iterator that this filter selects.ClusteringIndexNamesFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) ClusteringIndexSliceFilter.filterNotIndexed(ColumnFilter columnFilter, UnfilteredRowIterator iterator) 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.ClusteringIndexNamesFilter.getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition) ClusteringIndexSliceFilter.getUnfilteredRowIterator(ColumnFilter columnFilter, Partition partition) voidColumnFilter.Serializer.serialize(ColumnFilter selection, DataOutputPlus out, int version) longColumnFilter.Serializer.serializedSize(ColumnFilter selection, int version) -
Uses of ColumnFilter in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable with parameters of type ColumnFilterModifier and TypeMethodDescriptionShardedSkipListMemtable.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener readsListener) org.apache.cassandra.db.memtable.SkipListMemtable.MemtableUnfilteredPartitionIteratorSkipListMemtable.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener readsListener) org.apache.cassandra.db.memtable.TrieMemtable.MemtableUnfilteredPartitionIteratorTrieMemtable.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener readsListener) ShardedSkipListMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) SkipListMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) TrieMemtable.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) Constructors in org.apache.cassandra.db.memtable with parameters of type ColumnFilterModifierConstructorDescriptionMemtableUnfilteredPartitionIterator(TableMetadata metadata, Iterator<AtomicBTreePartition> iterator, ColumnFilter columnFilter, DataRange dataRange) -
Uses of ColumnFilter in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions with parameters of type ColumnFilterModifier and TypeMethodDescriptionUnfilteredPartitionIterators.Serializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag) static PartitionUpdatePartitionUpdate.fromIterator(RowIterator iterator, ColumnFilter filter) Turns the given iterator into an update.static PartitionUpdatePartitionUpdate.fromIterator(UnfilteredRowIterator iterator, ColumnFilter filter) Turns the given iterator into an update.voidUnfilteredPartitionIterators.Serializer.serialize(UnfilteredPartitionIterator iter, ColumnFilter selection, DataOutputPlus out, int version) AbstractBTreePartition.unfilteredIterator(ColumnFilter selection, NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed) AbstractBTreePartition.unfilteredIterator(ColumnFilter selection, Slices slices, boolean reversed) AbstractBTreePartition.unfilteredIterator(BTreePartitionData current, ColumnFilter selection, Slices slices, boolean reversed) AtomicBTreePartition.unfilteredIterator(BTreePartitionData current, ColumnFilter selection, Slices slices, boolean reversed) Partition.unfilteredIterator(ColumnFilter columns, NavigableSet<Clustering<?>> clusteringsInQueryOrder, boolean reversed) Returns an UnfilteredRowIterator over the rows/RT contained by this partition selected by the provided clusterings.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 ColumnFilterModifier and TypeMethodDescriptionUnfilteredRowIteratorSerializer.deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag) UnfilteredRowIteratorSerializer.deserializeHeader(TableMetadata metadata, ColumnFilter selection, DataInputPlus in, int version, DeserializationHelper.Flag flag) BTreeRow.filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata) BTreeRow.filter(ColumnFilter filter, TableMetadata metadata) ComplexColumnData.filter(ColumnFilter filter, DeletionTime activeDeletion, DroppedColumn dropped, LivenessInfo rowLiveness) 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.filter(ColumnFilter filter, TableMetadata metadata) Returns a copy of this row that: 1) only includes the data for the column included byfilter.UnfilteredSource.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener listener) Returns a partition iterator for the given data range.UnfilteredSource.rowIterator(DecoratedKey key, Slices slices, ColumnFilter columnFilter, boolean reversed, SSTableReadsListener listener) Returns a row iterator for the given partition, applying the specified row and column filters.voidUnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version) voidUnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator, ColumnFilter selection, DataOutputPlus out, int version, int rowEstimate) longUnfilteredRowIteratorSerializer.serializedSize(UnfilteredRowIterator iterator, ColumnFilter selection, int version, int rowEstimate) BTreeRow.withOnlyQueriedData(ColumnFilter filter) ComplexColumnData.withOnlyQueriedData(ColumnFilter filter) 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 (seeColumnFilterfor details).static RowIteratorRowIterators.withOnlyQueriedData(RowIterator iterator, ColumnFilter filter) Filter the provided iterator to only include cells that are selected by the user.static UnfilteredRowIteratorUnfilteredRowIterators.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 ColumnFilterModifierConstructorDescriptionDeserializationHelper(TableMetadata metadata, int version, DeserializationHelper.Flag flag, ColumnFilter columnsToFetch) RowAndDeletionMergeIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, ColumnFilter selection, Row staticRow, boolean isReversed, EncodingStats stats, Iterator<Row> rows, Iterator<RangeTombstone> ranges, boolean removeShadowedData) UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, ClusteringIndexFilter filter, ColumnFilter selectedColumns, SSTableReadsListener listener) UnfilteredRowIteratorWithLowerBound(DecoratedKey partitionKey, SSTableReader sstable, Slices slices, boolean isReverseOrder, 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 ColumnFilterModifier and TypeMethodDescriptionAbstractVirtualTable.select(DataRange dataRange, ColumnFilter columnFilter) AbstractVirtualTable.select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter) VirtualTable.select(DataRange dataRange, ColumnFilter columnFilter) Selects the rows from a range of partitions.VirtualTable.select(DecoratedKey partitionKey, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter) Selects the rows from a single partition.AbstractVirtualTable.Partition.toRowIterator(TableMetadata metadata, ClusteringIndexFilter clusteringIndexFilter, ColumnFilter columnFilter, long now) -
Uses of ColumnFilter in org.apache.cassandra.index.sai.utils
Methods in org.apache.cassandra.index.sai.utils with parameters of type ColumnFilterModifier and TypeMethodDescriptionRowWithSource.filter(ColumnFilter filter, DeletionTime activeDeletion, boolean setActiveDeletionToRow, TableMetadata metadata) RowWithSource.filter(ColumnFilter filter, TableMetadata metadata) RowWithSource.withOnlyQueriedData(ColumnFilter filter) -
Uses of ColumnFilter in org.apache.cassandra.io.sstable
Fields in org.apache.cassandra.io.sstable declared as ColumnFilterConstructors in org.apache.cassandra.io.sstable with parameters of type ColumnFilterModifierConstructorDescriptionprotectedAbstractSSTableIterator(SSTableReader sstable, FileDataInput file, DecoratedKey key, RIE indexEntry, Slices slices, ColumnFilter columnFilter, FileHandle ifile) -
Uses of ColumnFilter in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format declared as ColumnFilterConstructors in org.apache.cassandra.io.sstable.format with parameters of type ColumnFilterModifierConstructorDescriptionprotectedSSTableScanner(S sstable, ColumnFilter columns, DataRange dataRange, Iterator<AbstractBounds<PartitionPosition>> rangeIterator, SSTableReadsListener listener) -
Uses of ColumnFilter in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type ColumnFilterModifier and TypeMethodDescriptionstatic ISSTableScannerBigTableScanner.getScanner(BigTableReader sstable, ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener) BigTableReader.partitionIterator(ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener) BigTableReader.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) BigTableReader.rowIterator(FileDataInput file, DecoratedKey key, RowIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed) Constructors in org.apache.cassandra.io.sstable.format.big with parameters of type ColumnFilterModifierConstructorDescriptionSSTableIterator(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.io.sstable.format.bti
Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type ColumnFilterModifier and TypeMethodDescriptionstatic BtiTableScannerBtiTableScanner.getScanner(BtiTableReader sstable, ColumnFilter columns, DataRange dataRange, SSTableReadsListener listener) BtiTableReader.partitionIterator(ColumnFilter columnFilter, DataRange dataRange, SSTableReadsListener listener) BtiTableReader.rowIterator(DecoratedKey key, Slices slices, ColumnFilter selectedColumns, boolean reversed, SSTableReadsListener listener) BtiTableReader.rowIterator(FileDataInput dataFileInput, DecoratedKey key, org.apache.cassandra.io.sstable.format.bti.TrieIndexEntry indexEntry, Slices slices, ColumnFilter selectedColumns, boolean reversed)