Uses of Interface
org.apache.cassandra.db.PartitionPosition
Packages that use PartitionPosition
Package
Description
-
Uses of PartitionPosition in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions that return types with arguments of type PartitionPositionModifier and TypeMethodDescriptionStatementRestrictions.getPartitionKeyBounds(QueryOptions options) Returns the partition key bounds. -
Uses of PartitionPosition in org.apache.cassandra.db
Classes in org.apache.cassandra.db that implement PartitionPositionModifier and TypeClassDescriptionclassclassclassRepresents a decorated key, handy for certain operations where just working with strings gets slow.classclassFields in org.apache.cassandra.db with type parameters of type PartitionPositionModifier and TypeFieldDescriptionprotected final AbstractBounds<PartitionPosition>DataRange.keyRangefinal com.google.common.collect.ImmutableList<PartitionPosition>DiskBoundaries.positionsMethods in org.apache.cassandra.db that return PartitionPositionModifier and TypeMethodDescriptionPartitionPosition.RowPositionSerializer.deserialize(DataInput in, IPartitioner p, int version) static PartitionPositionPartitionPosition.ForKey.get(ByteBuffer key, IPartitioner p) DataRange.startKey()The start of the partition key range queried by thisDataRange.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 PartitionPositionModifier and TypeMethodDescriptionDataRange.keyRange()The range of partition key queried by thisDataRange.Methods in org.apache.cassandra.db with parameters of type PartitionPositionModifier and TypeMethodDescriptionintDecoratedKey.compareTo(PartitionPosition pos) static intDecoratedKey.compareTo(IPartitioner partitioner, ByteBuffer key, PartitionPosition position) booleanDataRange.contains(PartitionPosition pos) Whether the provided ring position is covered by thisDataRange.voidPartitionPosition.RowPositionSerializer.serialize(PartitionPosition pos, DataOutputPlus out, int version) longPartitionPosition.RowPositionSerializer.serializedSize(PartitionPosition pos, int version) Method parameters in org.apache.cassandra.db with type arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic DataRangeDataRange.forKeyRange(Range<PartitionPosition> keyRange) Creates aDataRangeto query all rows over the provided key range.DataRange.forPaging(AbstractBounds<PartitionPosition> range, ClusteringComparator comparator, Clustering<?> lastReturned, boolean inclusive) Returns a newDataRangefor use when pagingthisrange.DataRange.forSubRange(AbstractBounds<PartitionPosition> range) Returns a newDataRangeequivalent tothisone but restricted to the provided sub-range.DataRange.Paging.forSubRange(AbstractBounds<PartitionPosition> range) PartitionRangeReadCommand.forSubRange(AbstractBounds<PartitionPosition> range, boolean isRangeContinuation) Returns an equivalent command but that only queries data within the provided range.voidColumnFamilyStore.writeAndAddMemtableRanges(TimeUUID repairSessionID, Supplier<Collection<Range<PartitionPosition>>> rangesSupplier, Refs<SSTableReader> placeIntoRefs) Constructor parameters in org.apache.cassandra.db with type arguments of type PartitionPositionModifierConstructorDescriptionDataRange(AbstractBounds<PartitionPosition> range, ClusteringIndexFilter clusteringIndexFilter) Creates aDataRangegiven a range of partition keys and a clustering index filter.DiskBoundaries(ColumnFamilyStore cfs, Directories.DataDirectory[] directories, List<PartitionPosition> positions, long ringVersion, int diskVersion) -
Uses of PartitionPosition in org.apache.cassandra.db.compaction
Methods in org.apache.cassandra.db.compaction with parameters of type PartitionPositionModifier and TypeMethodDescriptionShardManager.coveringRange(PartitionPosition first, PartitionPosition last) default doubleShardManager.rangeSpanned(PartitionPosition first, PartitionPosition last) doubleShardManagerDiskAware.BoundaryTrackerDiskAware.rangeSpanned(PartitionPosition first, PartitionPosition last) doubleShardManagerNoDisks.BoundaryTracker.rangeSpanned(PartitionPosition first, PartitionPosition last) doubleShardTracker.rangeSpanned(PartitionPosition first, PartitionPosition last) -
Uses of PartitionPosition in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle that return types with arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic List<Interval<PartitionPosition,SSTableReader>> SSTableIntervalTree.buildIntervals(Collection<SSTableReader> sstables) static Interval<PartitionPosition,SSTableReader>[] SSTableIntervalTree.buildIntervalsArray(Collection<SSTableReader> sstables) Methods in org.apache.cassandra.db.lifecycle with parameters of type PartitionPositionModifier and TypeMethodDescriptionView.liveSSTablesInBounds(PartitionPosition left, PartitionPosition right) Returns the sstables that have any partition betweenleftandright, when both bounds are taken inclusively.static List<SSTableReader>View.sstablesInBounds(PartitionPosition left, PartitionPosition right, SSTableIntervalTree intervalTree) Method parameters in org.apache.cassandra.db.lifecycle with type arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic com.google.common.base.Function<View,Iterable<SSTableReader>> View.selectLive(AbstractBounds<PartitionPosition> rowBounds) -
Uses of PartitionPosition in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable that return PartitionPositionModifier and TypeMethodDescriptionMemtable.FlushablePartitionSet.from()Memtable.FlushablePartitionSet.to()Methods in org.apache.cassandra.db.memtable with parameters of type PartitionPositionModifier and TypeMethodDescriptionMemtable.getFlushSet(PartitionPosition from, PartitionPosition to) Get the collection of data between the given partition boundaries in a form suitable for flushing.ShardedSkipListMemtable.getFlushSet(PartitionPosition from, PartitionPosition to) SkipListMemtable.getFlushSet(PartitionPosition from, PartitionPosition to) Memtable.FlushablePartitionSet<org.apache.cassandra.db.memtable.TrieMemtable.MemtablePartition>TrieMemtable.getFlushSet(PartitionPosition from, PartitionPosition to) intShardBoundaries.getShardForKey(PartitionPosition key) Computes the shard to use for the provided key. -
Uses of PartitionPosition in org.apache.cassandra.dht
Classes in org.apache.cassandra.dht that implement PartitionPositionFields in org.apache.cassandra.dht with type parameters of type PartitionPositionModifier and TypeFieldDescriptionstatic final IPartitionerDependentSerializer<AbstractBounds<PartitionPosition>>AbstractBounds.rowPositionSerializerMethods in org.apache.cassandra.dht that return types with arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic 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 -
Uses of PartitionPosition in org.apache.cassandra.index.sai.disk
Methods in org.apache.cassandra.index.sai.disk that return types with arguments of type PartitionPositionModifier and TypeMethodDescriptionEmptyIndex.bounds()abstract AbstractBounds<PartitionPosition>SSTableIndex.bounds()Returns the key bounds of the index.Method parameters in org.apache.cassandra.index.sai.disk with type arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic IndexSearchResultIteratorIndexSearchResultIterator.build(Expression expression, Collection<MemtableIndex> memtableIndexes, Collection<SSTableIndex> sstableIndexes, AbstractBounds<PartitionPosition> keyRange, QueryContext queryContext, boolean includeMemtables, Runnable onClose) Builds a newIndexSearchResultIteratorthat wraps aKeyRangeUnionIteratorover the results of searching theMemtableIndexes and theSSTableIndexes.static IndexSearchResultIteratorIndexSearchResultIterator.build(QueryViewBuilder.QueryExpressionView queryView, AbstractBounds<PartitionPosition> keyRange, QueryContext queryContext, boolean includeMemtables, Runnable onClose) Builds a newIndexSearchResultIteratorthat wraps aKeyRangeUnionIteratorover the results of searching theQueryViewBuilder.QueryExpressionView.EmptyIndex.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context) abstract List<CloseableIterator<PrimaryKeyWithScore>>SSTableIndex.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context) EmptyIndex.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext context) abstract List<KeyRangeIterator>SSTableIndex.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext context) Perform a search on the index for a single expression and keyRange. -
Uses of PartitionPosition in org.apache.cassandra.index.sai.disk.v1
Methods in org.apache.cassandra.index.sai.disk.v1 that return types with arguments of type PartitionPositionMethod parameters in org.apache.cassandra.index.sai.disk.v1 with type arguments of type PartitionPositionModifier and TypeMethodDescriptionV1SSTableIndex.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context) V1SSTableIndex.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext context) -
Uses of PartitionPosition in org.apache.cassandra.index.sai.disk.v1.segment
Method parameters in org.apache.cassandra.index.sai.disk.v1.segment with type arguments of type PartitionPositionModifier and TypeMethodDescriptionbooleanSegment.intersects(AbstractBounds<PartitionPosition> keyRange) IndexSegmentSearcher.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context) Order the rows by the given expression.Segment.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context) Order the on-disk index synchronously and produce an iterator in score orderVectorIndexSegmentSearcher.orderBy(Expression orderer, AbstractBounds<PartitionPosition> keyRange, QueryContext context) abstract KeyRangeIteratorIndexSegmentSearcher.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext queryContext) Search on-disk index synchronously.LiteralIndexSegmentSearcher.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext queryContext) NumericIndexSegmentSearcher.search(Expression exp, AbstractBounds<PartitionPosition> keyRange, QueryContext context) Segment.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext context) Search on-disk index synchronouslyVectorIndexSegmentSearcher.search(Expression expression, AbstractBounds<PartitionPosition> keyRange, QueryContext queryContext) -
Uses of PartitionPosition in org.apache.cassandra.index.sai.memory
Method parameters in org.apache.cassandra.index.sai.memory with type arguments of type PartitionPositionModifier and TypeMethodDescriptionMemtableIndex.orderBy(QueryContext queryContext, Expression orderer, AbstractBounds<PartitionPosition> keyRange) MemtableOrdering.orderBy(QueryContext queryContext, Expression orderer, AbstractBounds<PartitionPosition> keyRange) Order the index based on the given orderer (expression).TrieMemoryIndex.orderBy(QueryContext queryContext, Expression orderer, AbstractBounds<PartitionPosition> keyRange) VectorMemoryIndex.orderBy(QueryContext queryContext, Expression expr, AbstractBounds<PartitionPosition> keyRange) abstract KeyRangeIteratorMemoryIndex.search(QueryContext queryContext, Expression expression, AbstractBounds<PartitionPosition> keyRange) MemtableIndex.search(QueryContext queryContext, Expression expression, AbstractBounds<PartitionPosition> keyRange) TrieMemoryIndex.search(QueryContext queryContext, Expression expression, AbstractBounds<PartitionPosition> keyRange) Search for an expression in the in-memory index within theAbstractBoundsdefined by keyRange.VectorMemoryIndex.search(QueryContext queryContext, Expression expression, AbstractBounds<PartitionPosition> keyRange) Constructor parameters in org.apache.cassandra.index.sai.memory with type arguments of type PartitionPositionModifierConstructorDescriptionFilteringInMemoryKeyRangeIterator(SortedSet<PrimaryKey> keys, AbstractBounds<PartitionPosition> keyRange) -
Uses of PartitionPosition in org.apache.cassandra.index.sai.plan
Methods in org.apache.cassandra.index.sai.plan that return types with arguments of type PartitionPosition -
Uses of PartitionPosition in org.apache.cassandra.index.sai.utils
Method parameters in org.apache.cassandra.index.sai.utils with type arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic booleanRangeUtil.coversFullRing(AbstractBounds<PartitionPosition> keyRange) -
Uses of PartitionPosition in org.apache.cassandra.io.sstable.format
Fields in org.apache.cassandra.io.sstable.format with type parameters of type PartitionPositionModifier and TypeFieldDescriptionprotected final Iterator<AbstractBounds<PartitionPosition>>SSTableScanner.rangeIteratorMethods in org.apache.cassandra.io.sstable.format that return types with arguments of type PartitionPositionModifier and TypeMethodDescriptionSSTableReader.getInterval()protected static List<AbstractBounds<PartitionPosition>>SSTableScanner.makeBounds(SSTableReader sstable, DataRange dataRange) Methods in org.apache.cassandra.io.sstable.format with parameters of type PartitionPositionModifier and TypeMethodDescriptionabstract DecoratedKeySSTableReader.firstKeyBeyond(PartitionPosition token) Finds and returns the first key beyond a given token in this SSTable or null if no such key exists.final longSSTableReader.getPosition(PartitionPosition key, SSTableReader.Operator op) Retrieves the position while updating the key cache and the stats.final longSSTableReader.getPosition(PartitionPosition key, SSTableReader.Operator op, boolean updateStats) protected longSSTableReader.getPosition(PartitionPosition key, SSTableReader.Operator op, boolean updateStats, SSTableReadsListener listener) Retrieve a position in data file according to the provided key and operator.final longSSTableReader.getPosition(PartitionPosition key, SSTableReader.Operator op, SSTableReadsListener listener) protected abstract AbstractRowIndexEntrySSTableReader.getRowIndexEntry(PartitionPosition key, SSTableReader.Operator op, boolean updateStats, SSTableReadsListener listener) Retrieve an index entry for the partition found according to the provided key and operator.Method parameters in org.apache.cassandra.io.sstable.format with type arguments of type PartitionPositionModifier and TypeMethodDescriptionSSTableReader.getPositionsForBounds(AbstractBounds<PartitionPosition> bounds) Determine the data positions in this SSTable that cover the given bounds.SSTableReader.getPositionsForBoundsIterator(Iterator<AbstractBounds<PartitionPosition>> boundsList) Get a list of data positions in this SSTable that correspond to the given list of bounds.SSTableReader.getScanner(Iterator<AbstractBounds<PartitionPosition>> boundsIterator) Direct I/O SSTableScanner over an iterator of bounds.Constructor parameters in org.apache.cassandra.io.sstable.format with type arguments of type PartitionPositionModifierConstructorDescriptionprotectedSSTableScanner(S sstable, ColumnFilter columns, DataRange dataRange, Iterator<AbstractBounds<PartitionPosition>> rangeIterator, SSTableReadsListener listener) -
Uses of PartitionPosition in org.apache.cassandra.io.sstable.format.big
Methods in org.apache.cassandra.io.sstable.format.big with parameters of type PartitionPositionModifier and TypeMethodDescriptionBigTableReader.firstKeyBeyond(PartitionPosition token) Finds and returns the first key beyond a given token in this SSTable or null if no such key exists.protected longBigTableReader.getPosition(PartitionPosition key, SSTableReader.Operator op, boolean updateCacheAndStats, SSTableReadsListener listener) final RowIndexEntryBigTableReader.getRowIndexEntry(PartitionPosition key, SSTableReader.Operator op) Retrieves the position while updating the key cache and the stats.BigTableReader.getRowIndexEntry(PartitionPosition key, SSTableReader.Operator operator, boolean updateStats, SSTableReadsListener listener) -
Uses of PartitionPosition in org.apache.cassandra.io.sstable.format.bti
Methods in org.apache.cassandra.io.sstable.format.bti with parameters of type PartitionPositionModifier and TypeMethodDescription<ResultType>
ResultTypePartitionIndex.Reader.ceiling(PartitionPosition key, PartitionIndex.Acceptor<PartitionPosition, ResultType> acceptor) BtiTableReader.firstKeyBeyond(PartitionPosition token) <ResultType>
ResultTypePartitionIndex.Reader.floor(PartitionPosition key, PartitionIndex.Acceptor<PartitionPosition, ResultType> acceptor) protected org.apache.cassandra.io.sstable.format.bti.TrieIndexEntryBtiTableReader.getRowIndexEntry(PartitionPosition key, SSTableReader.Operator operator, boolean updateStats, SSTableReadsListener listener) Method parameters in org.apache.cassandra.io.sstable.format.bti with type arguments of type PartitionPositionModifier and TypeMethodDescription<ResultType>
ResultTypePartitionIndex.Reader.ceiling(PartitionPosition key, PartitionIndex.Acceptor<PartitionPosition, ResultType> acceptor) <ResultType>
ResultTypePartitionIndex.Reader.floor(PartitionPosition key, PartitionIndex.Acceptor<PartitionPosition, ResultType> acceptor) -
Uses of PartitionPosition in org.apache.cassandra.io.sstable.indexsummary
Methods in org.apache.cassandra.io.sstable.indexsummary with parameters of type PartitionPositionModifier and TypeMethodDescriptionintIndexSummary.binarySearch(PartitionPosition key) longIndexSummary.getScanPosition(PartitionPosition key) -
Uses of PartitionPosition in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return types with arguments of type PartitionPositionModifier and TypeMethodDescriptionReplicaLayout.ForRange.range()ReplicaLayout.ForRangeRead.range()ReplicaPlan.ForRangeRead.range()Method parameters in org.apache.cassandra.locator with type arguments of type PartitionPositionModifier and TypeMethodDescriptionstatic ReplicaPlan.ForRangeReadReplicaPlans.forFullRangeRead(Keyspace keyspace, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, Set<InetAddressAndPort> endpointsToContact, int vnodeCount) Construct a plan for reading the provided range at the provided consistency level on given endpoints.static ReplicaPlan.ForRangeReadReplicaPlans.forRangeRead(Keyspace keyspace, Index.QueryPlan indexQueryPlan, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, int vnodeCount) Construct a plan for reading the provided range at the provided consistency level.static ReplicaPlan.ForRangeReadReplicaPlans.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 PartitionPositionModifierConstructorDescriptionForFullRangeRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, EndpointsForRange candidates, EndpointsForRange contact, int vnodeCount) ForRangeRead(AbstractReplicationStrategy replicationStrategy, AbstractBounds<PartitionPosition> range, EndpointsForRange natural) ForRangeRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, EndpointsForRange candidates, EndpointsForRange contact, int vnodeCount) -
Uses of PartitionPosition in org.apache.cassandra.schema
Method parameters in org.apache.cassandra.schema with type arguments of type PartitionPositionModifier and TypeMethodDescriptionintPartitionDenylist.getDeniedKeysInRangeCount(String keyspace, String table, AbstractBounds<PartitionPosition> range) intPartitionDenylist.getDeniedKeysInRangeCount(TableId tid, AbstractBounds<PartitionPosition> range)