Modifier and Type | Method and Description |
---|---|
ColumnFilter |
Selection.Selectors.getColumnFilter()
Returns the
ColumnFilter corresponding to those selectors |
Modifier and Type | Method and 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).
|
Modifier and Type | Method and Description |
---|---|
ReadQuery |
SelectStatement.getQuery(QueryOptions options,
ColumnFilter columnFilter,
int nowInSec,
int userLimit,
int perPartitionLimit,
int pageSize) |
Modifier and Type | Method and 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() |
Modifier and Type | Method and 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 VirtualTablePartitionRangeReadQuery |
VirtualTablePartitionRangeReadQuery.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DataRange dataRange) |
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 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 VirtualTableSinglePartitionReadQuery |
VirtualTableSinglePartitionReadQuery.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter) |
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 VirtualTableSinglePartitionReadQuery.Group |
VirtualTableSinglePartitionReadQuery.Group.create(TableMetadata metadata,
int nowInSec,
ColumnFilter columnFilter,
RowFilter rowFilter,
DataLimits limits,
java.util.List<DecoratedKey> partitionKeys,
ClusteringIndexFilter clusteringIndexFilter) |
static SinglePartitionReadCommand |
SinglePartitionReadCommand.create(TableMetadata metadata,
int nowInSec,
DecoratedKey key,
ColumnFilter columnFilter,
ClusteringIndexFilter filter)
Creates a new read command on a single partition.
|
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.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) |
Constructor and 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) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFilter |
AbstractSSTableIterator.columns |
Constructor and 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) |
Modifier and Type | Field and Description |
---|---|
static ColumnFilter |
ColumnFilter.NONE |
Modifier and Type | Method and 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.Serializer.maybeUpdateForBackwardCompatility(ColumnFilter selection,
int version) |
static ColumnFilter |
ColumnFilter.selection(RegularAndStaticColumns columns)
A filter that only fetches/queries the provided columns.
|
static ColumnFilter |
ColumnFilter.selection(TableMetadata metadata,
RegularAndStaticColumns queried)
A filter that fetches all columns for the provided table, but returns
only the queried ones.
|
Modifier and Type | Method and 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) |
static ColumnFilter |
ColumnFilter.Serializer.maybeUpdateForBackwardCompatility(ColumnFilter selection,
int version) |
void |
ColumnFilter.Serializer.serialize(ColumnFilter selection,
DataOutputPlus out,
int version) |
long |
ColumnFilter.Serializer.serializedSize(ColumnFilter selection,
int version) |
Modifier and Type | Method and 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.
|
SearchIterator<Clustering,Row> |
AbstractBTreePartition.searchIterator(ColumnFilter columns,
boolean reversed) |
SearchIterator<Clustering,Row> |
AtomicBTreePartition.searchIterator(ColumnFilter columns,
boolean reversed) |
SearchIterator<Clustering,Row> |
Partition.searchIterator(ColumnFilter columns,
boolean reversed)
Returns an iterator that allows to search specific rows efficiently.
|
void |
UnfilteredPartitionIterators.Serializer.serialize(UnfilteredPartitionIterator iter,
ColumnFilter selection,
DataOutputPlus out,
int version) |
UnfilteredRowIterator |
AbstractBTreePartition.unfilteredIterator(AbstractBTreePartition.Holder current,
ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
AtomicBTreePartition.unfilteredIterator(AbstractBTreePartition.Holder current,
ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
AbstractBTreePartition.unfilteredIterator(ColumnFilter selection,
Slices slices,
boolean reversed) |
UnfilteredRowIterator |
AtomicBTreePartition.unfilteredIterator(ColumnFilter selection,
Slices slices,
boolean reversed) |
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.
|
Modifier and Type | Method and 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 |
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 by
filter . |
ComplexColumnData |
ComplexColumnData.filter(ColumnFilter filter,
DeletionTime activeDeletion,
DroppedColumn dropped,
LivenessInfo rowLiveness) |
Row |
BTreeRow.filter(ColumnFilter filter,
TableMetadata metadata) |
Row |
Row.filter(ColumnFilter filter,
TableMetadata metadata)
Returns a copy of this row that:
1) only includes the data for the column included by
filter . |
void |
UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator,
ColumnFilter selection,
DataOutputPlus out,
int version) |
void |
UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator,
ColumnFilter selection,
DataOutputPlus out,
int version,
int rowEstimate) |
void |
UnfilteredRowIteratorSerializer.serialize(UnfilteredRowIterator iterator,
SerializationHeader header,
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 by
filter , excluding anything _fetched_ for
internal reasons but not queried by the user (see ColumnFilter 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).
|
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
UnfilteredPartitionIterator |
AbstractVirtualTable.select(DataRange dataRange,
ColumnFilter columnFilter) |
UnfilteredPartitionIterator |
VirtualTable.select(DataRange dataRange,
ColumnFilter columnFilter)
Selects the rows from a range of partitions.
|
UnfilteredPartitionIterator |
AbstractVirtualTable.select(DecoratedKey partitionKey,
ClusteringIndexFilter clusteringIndexFilter,
ColumnFilter columnFilter) |
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) |
Modifier and Type | Method and 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) |
Modifier and Type | Method and 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) |
Copyright © 2009-2020 The Apache Software Foundation