Modifier and Type | Method and Description |
---|---|
AbstractBounds<PartitionPosition> |
StatementRestrictions.getPartitionKeyBounds(QueryOptions options)
Returns the partition key bounds.
|
Modifier and Type | Class and Description |
---|---|
class |
BufferDecoratedKey |
class |
CachedHashDecoratedKey |
class |
DecoratedKey
Represents a decorated key, handy for certain operations
where just working with strings gets slow.
|
class |
NativeDecoratedKey |
class |
PreHashedDecoratedKey |
Modifier and Type | Field and Description |
---|---|
protected AbstractBounds<PartitionPosition> |
DataRange.keyRange |
Modifier and Type | Method and Description |
---|---|
PartitionPosition |
PartitionPosition.RowPositionSerializer.deserialize(java.io.DataInput in,
IPartitioner p,
int version) |
static PartitionPosition |
PartitionPosition.ForKey.get(java.nio.ByteBuffer key,
IPartitioner p) |
PartitionPosition |
DataRange.startKey()
The start of the partition key range queried by this
DataRange . |
PartitionPosition |
DataRange.stopKey()
The end of the partition key range queried by this
DataRange . |
Modifier and Type | Method and Description |
---|---|
AbstractBounds<PartitionPosition> |
DataRange.keyRange()
The range of partition key queried by this
DataRange . |
Modifier and Type | Method and Description |
---|---|
static int |
DecoratedKey.compareTo(IPartitioner partitioner,
java.nio.ByteBuffer key,
PartitionPosition position) |
int |
DecoratedKey.compareTo(PartitionPosition pos) |
boolean |
DataRange.contains(PartitionPosition pos)
Whether the provided ring position is covered by this
DataRange . |
void |
PartitionPosition.RowPositionSerializer.serialize(PartitionPosition pos,
DataOutputPlus out,
int version) |
long |
PartitionPosition.RowPositionSerializer.serializedSize(PartitionPosition pos,
int version) |
Modifier and Type | Method and Description |
---|---|
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) |
PartitionRangeReadCommand |
PartitionRangeReadCommand.forSubRange(AbstractBounds<PartitionPosition> range,
boolean isRangeContinuation)
Returns an equivalent command but that only queries data within the provided range.
|
Constructor and Description |
---|
DataRange(AbstractBounds<PartitionPosition> range,
ClusteringIndexFilter clusteringIndexFilter)
Creates a
DataRange given a range of partition keys and a clustering index filter. |
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 |
---|---|
static java.util.List<Interval<PartitionPosition,SSTableReader>> |
SSTableIntervalTree.buildIntervals(java.lang.Iterable<SSTableReader> sstables) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<SSTableReader> |
View.liveSSTablesInBounds(PartitionPosition left,
PartitionPosition right)
Returns the sstables that have any partition between
left and right , when both bounds are taken inclusively. |
static java.util.List<SSTableReader> |
View.sstablesInBounds(PartitionPosition left,
PartitionPosition right,
SSTableIntervalTree intervalTree) |
Modifier and Type | Method and Description |
---|---|
static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>> |
View.selectLive(AbstractBounds<PartitionPosition> rowBounds) |
Modifier and Type | Class and Description |
---|---|
static class |
Token.KeyBound |
Modifier and Type | Field and Description |
---|---|
static IPartitionerDependentSerializer<AbstractBounds<PartitionPosition>> |
AbstractBounds.rowPositionSerializer |
Modifier and Type | Method and Description |
---|---|
static Bounds<PartitionPosition> |
Bounds.makeRowBounds(Token left,
Token right)
Compute a bounds of keys corresponding to a given bounds of token.
|
static Range<PartitionPosition> |
Range.makeRowRange(Range<Token> tokenBounds) |
static Range<PartitionPosition> |
Range.makeRowRange(Token left,
Token right)
Compute a range of keys corresponding to a given range of token.
|
Modifier and Type | Method and Description |
---|---|
int |
Token.KeyBound.compareTo(PartitionPosition pos) |
Modifier and Type | Method and Description |
---|---|
int |
IndexSummary.binarySearch(PartitionPosition key) |
Modifier and Type | Method and Description |
---|---|
DecoratedKey |
SSTableReader.firstKeyBeyond(PartitionPosition token)
Finds and returns the first key beyond a given token in this SSTable or null if no such key exists.
|
long |
SSTableReader.getIndexScanPosition(PartitionPosition key)
Gets the position in the index file to start scanning to find the given key (at most indexInterval keys away,
modulo downsampling of the index summary).
|
RowIndexEntry |
SSTableReader.getPosition(PartitionPosition key,
SSTableReader.Operator op)
Retrieves the position while updating the key cache and the stats.
|
RowIndexEntry |
SSTableReader.getPosition(PartitionPosition key,
SSTableReader.Operator op,
boolean updateCacheAndStats) |
protected abstract RowIndexEntry |
SSTableReader.getPosition(PartitionPosition key,
SSTableReader.Operator op,
boolean updateCacheAndStats,
boolean permitMatchPastLast,
SSTableReadsListener listener) |
RowIndexEntry |
SSTableReader.getPosition(PartitionPosition key,
SSTableReader.Operator op,
SSTableReadsListener listener)
Retrieves the position while updating the key cache and the stats.
|
Modifier and Type | Method and Description |
---|---|
abstract ISSTableScanner |
SSTableReader.getScanner(java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator)
Direct I/O SSTableScanner over an iterator of bounds.
|
Modifier and Type | Method and Description |
---|---|
protected RowIndexEntry |
BigTableReader.getPosition(PartitionPosition key,
SSTableReader.Operator op,
boolean updateCacheAndStats,
boolean permitMatchPastLast,
SSTableReadsListener listener) |
Modifier and Type | Method and Description |
---|---|
ISSTableScanner |
BigTableReader.getScanner(java.util.Iterator<AbstractBounds<PartitionPosition>> boundsIterator)
Direct I/O SSTableScanner over an iterator of bounds.
|
static ISSTableScanner |
BigTableScanner.getScanner(SSTableReader sstable,
java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<PartitionPosition> |
StorageService.getDiskBoundaries(ColumnFamilyStore cfs) |
static java.util.List<PartitionPosition> |
StorageService.getDiskBoundaries(ColumnFamilyStore cfs,
Directories.DataDirectory[] directories) |
static java.util.List<PartitionPosition> |
StorageService.getDiskBoundaries(java.util.List<Range<Token>> localRanges,
IPartitioner partitioner,
Directories.DataDirectory[] dataDirectories)
Returns a list of disk boundaries, the result will differ depending on whether vnodes are enabled or not.
|
Copyright © 2018 The Apache Software Foundation