Modifier and Type | Class and Description |
---|---|
static class |
DataRange.Paging
Specialized
DataRange used for the paging case. |
Modifier and Type | Method and Description |
---|---|
static DataRange |
DataRange.allData(IPartitioner partitioner)
Creates a
DataRange to query all data (over the whole ring). |
static DataRange |
DataRange.allData(IPartitioner partitioner,
ClusteringIndexFilter filter)
Creates a
DataRange to query all partitions of the ring using the provided
clustering index filter. |
DataRange |
PartitionRangeReadCommand.dataRange() |
DataRange |
PartitionRangeReadQuery.dataRange() |
DataRange |
VirtualTablePartitionRangeReadQuery.dataRange() |
DataRange |
DataRange.Serializer.deserialize(DataInputPlus in,
int version,
TableMetadata metadata) |
static DataRange |
DataRange.forKeyRange(Range<PartitionPosition> keyRange)
Creates a
DataRange to query all rows over the provided key range. |
DataRange |
DataRange.forPaging(AbstractBounds<PartitionPosition> range,
ClusteringComparator comparator,
Clustering<?> lastReturned,
boolean inclusive)
Returns a new
DataRange for use when paging this range. |
DataRange |
DataRange.forSubRange(AbstractBounds<PartitionPosition> range)
Returns a new
DataRange equivalent to this one but restricted to the provided sub-range. |
DataRange |
DataRange.Paging.forSubRange(AbstractBounds<PartitionPosition> range) |
static DataRange |
DataRange.forTokenRange(Range<Token> tokenRange)
Creates a
DataRange to query all rows over the provided token range. |
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) |
Memtable.MemtableUnfilteredPartitionIterator |
Memtable.makePartitionIterator(ColumnFilter columnFilter,
DataRange dataRange) |
void |
DataRange.Serializer.serialize(DataRange range,
DataOutputPlus out,
int version,
TableMetadata metadata) |
long |
DataRange.Serializer.serializedSize(DataRange range,
int version,
TableMetadata metadata) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
PartitionRangeReadQuery |
PartitionRangeReadQuery.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange)
Creates a new
PartitionRangeReadQuery with the updated limits and data range. |
PartitionRangeReadQuery |
VirtualTablePartitionRangeReadQuery.withUpdatedLimitsAndDataRange(DataLimits newLimits,
DataRange newDataRange) |
Constructor and Description |
---|
MemtableUnfilteredPartitionIterator(ColumnFamilyStore cfs,
java.util.Iterator<java.util.Map.Entry<PartitionPosition,AtomicBTreePartition>> iter,
int minLocalDeletionTime,
ColumnFilter columnFilter,
DataRange dataRange) |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<AbstractVirtualTable.Partition> |
AbstractVirtualTable.DataSet.getPartitions(DataRange range) |
java.util.Iterator<AbstractVirtualTable.Partition> |
AbstractVirtualTable.AbstractDataSet.getPartitions(DataRange dataRange) |
UnfilteredPartitionIterator |
AbstractVirtualTable.select(DataRange dataRange,
ColumnFilter columnFilter) |
UnfilteredPartitionIterator |
VirtualTable.select(DataRange dataRange,
ColumnFilter columnFilter)
Selects the rows from a range of partitions.
|
Modifier and Type | Method and Description |
---|---|
DataRange |
QueryController.dataRange() |
Modifier and Type | Method and Description |
---|---|
abstract ISSTableScanner |
SSTableReader.getScanner(ColumnFilter columns,
DataRange dataRange,
SSTableReadsListener listener) |
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) |
Copyright © 2009-2022 The Apache Software Foundation