Uses of Interface
org.apache.cassandra.db.PartitionPosition
-
-
Uses of PartitionPosition in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions that return types with arguments of type PartitionPosition Modifier and Type Method Description AbstractBounds<PartitionPosition>
StatementRestrictions. getPartitionKeyBounds(QueryOptions options)
Returns the partition key bounds. -
Uses of PartitionPosition in org.apache.cassandra.db
Classes in org.apache.cassandra.db that implement PartitionPosition Modifier and Type Class 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
Fields in org.apache.cassandra.db with type parameters of type PartitionPosition Modifier and Type Field Description protected AbstractBounds<PartitionPosition>
DataRange. keyRange
com.google.common.collect.ImmutableList<PartitionPosition>
DiskBoundaries. positions
Methods in org.apache.cassandra.db that return PartitionPosition Modifier and Type Method 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 thisDataRange
.PartitionPosition
DataRange. stopKey()
The end of the partition key range queried by thisDataRange
.Methods in org.apache.cassandra.db that return types with arguments of type PartitionPosition Modifier and Type Method Description AbstractBounds<PartitionPosition>
DataRange. keyRange()
The range of partition key queried by thisDataRange
.Methods in org.apache.cassandra.db with parameters of type PartitionPosition Modifier and Type Method Description int
DecoratedKey. compareTo(PartitionPosition pos)
static int
DecoratedKey. compareTo(IPartitioner partitioner, java.nio.ByteBuffer key, PartitionPosition position)
boolean
DataRange. contains(PartitionPosition pos)
Whether the provided ring position is covered by thisDataRange
.void
PartitionPosition.RowPositionSerializer. serialize(PartitionPosition pos, DataOutputPlus out, int version)
long
PartitionPosition.RowPositionSerializer. serializedSize(PartitionPosition pos, int version)
Method parameters in org.apache.cassandra.db with type arguments of type PartitionPosition Modifier and Type Method Description static DataRange
DataRange. forKeyRange(Range<PartitionPosition> keyRange)
Creates aDataRange
to query all rows over the provided key range.DataRange
DataRange. forPaging(AbstractBounds<PartitionPosition> range, ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive)
Returns a newDataRange
for use when pagingthis
range.DataRange
DataRange. forSubRange(AbstractBounds<PartitionPosition> range)
Returns a newDataRange
equivalent tothis
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 parameters in org.apache.cassandra.db with type arguments of type PartitionPosition Constructor Description DataRange(AbstractBounds<PartitionPosition> range, ClusteringIndexFilter clusteringIndexFilter)
Creates aDataRange
given a range of partition keys and a clustering index filter.DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, java.util.List<PartitionPosition> positions, long ringVersion, int diskVersion)
MemtableUnfilteredPartitionIterator(ColumnFamilyStore cfs, java.util.Iterator<java.util.Map.Entry<PartitionPosition,AtomicBTreePartition>> iter, int minLocalDeletionTime, ColumnFilter columnFilter, DataRange dataRange)
-
Uses of PartitionPosition in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle that return types with arguments of type PartitionPosition Modifier and Type Method Description static java.util.List<Interval<PartitionPosition,SSTableReader>>
SSTableIntervalTree. buildIntervals(java.lang.Iterable<SSTableReader> sstables)
Methods in org.apache.cassandra.db.lifecycle with parameters of type PartitionPosition Modifier and Type Method Description java.lang.Iterable<SSTableReader>
View. liveSSTablesInBounds(PartitionPosition left, PartitionPosition right)
Returns the sstables that have any partition betweenleft
andright
, when both bounds are taken inclusively.static java.util.List<SSTableReader>
View. sstablesInBounds(PartitionPosition left, PartitionPosition right, SSTableIntervalTree intervalTree)
Method parameters in org.apache.cassandra.db.lifecycle with type arguments of type PartitionPosition Modifier and Type Method Description static com.google.common.base.Function<View,java.lang.Iterable<SSTableReader>>
View. selectLive(AbstractBounds<PartitionPosition> rowBounds)
-
Uses of PartitionPosition in org.apache.cassandra.dht
Classes in org.apache.cassandra.dht that implement PartitionPosition Modifier and Type Class Description static class
Token.KeyBound
Fields in org.apache.cassandra.dht with type parameters of type PartitionPosition Modifier and Type Field Description static IPartitionerDependentSerializer<AbstractBounds<PartitionPosition>>
AbstractBounds. rowPositionSerializer
Methods in org.apache.cassandra.dht that return types with arguments of type PartitionPosition Modifier and Type Method 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.Methods in org.apache.cassandra.dht with parameters of type PartitionPosition Modifier and Type Method Description int
Token.KeyBound. compareTo(PartitionPosition pos)
-
Uses of PartitionPosition in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable with parameters of type PartitionPosition Modifier and Type Method Description int
IndexSummary. binarySearch(PartitionPosition key)
-
Uses of PartitionPosition in org.apache.cassandra.io.sstable.format
Methods in org.apache.cassandra.io.sstable.format with parameters of type PartitionPosition Modifier and Type Method 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.Method parameters in org.apache.cassandra.io.sstable.format with type arguments of type PartitionPosition Modifier and Type Method Description abstract ISSTableScanner
SSTableReader. getScanner(java.util.Iterator<AbstractBounds<PartitionPosition>> rangeIterator)
Direct I/O SSTableScanner over an iterator of bounds. -
Uses of PartitionPosition in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type PartitionPosition Modifier and Type Method Description protected RowIndexEntry
BigTableReader. getPosition(PartitionPosition key, SSTableReader.Operator op, boolean updateCacheAndStats, boolean permitMatchPastLast, SSTableReadsListener listener)
Method parameters in org.apache.cassandra.io.sstable.format.big with type arguments of type PartitionPosition Modifier and Type Method 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)
-
Uses of PartitionPosition in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return types with arguments of type PartitionPosition Modifier and Type Method Description AbstractBounds<PartitionPosition>
ReplicaLayout.ForRange. range()
AbstractBounds<PartitionPosition>
ReplicaLayout.ForRangeRead. range()
AbstractBounds<PartitionPosition>
ReplicaPlan.ForRangeRead. range()
Method parameters in org.apache.cassandra.locator with type arguments of type PartitionPosition Modifier and Type Method Description static ReplicaPlan.ForRangeRead
ReplicaPlans. forRangeRead(Keyspace keyspace, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, int vnodeCount)
Construct a plan for reading the provided range at the provided consistency level.static ReplicaPlan.ForRangeRead
ReplicaPlans. forSingleReplicaRead(Keyspace keyspace, AbstractBounds<PartitionPosition> range, Replica replica, int vnodeCount)
Construct a plan for reading from a single node - this permits no speculation or read-repairConstructor parameters in org.apache.cassandra.locator with type arguments of type PartitionPosition Constructor Description ForRangeRead(AbstractReplicationStrategy replicationStrategy, AbstractBounds<PartitionPosition> range, EndpointsForRange natural)
ForRangeRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, EndpointsForRange candidates, EndpointsForRange contact, int vnodeCount)
-