Modifier and Type | Method and Description |
---|---|
AbstractBounds<PartitionPosition> |
StatementRestrictions.getPartitionKeyBounds(QueryOptions options)
Returns the partition key bounds.
|
Modifier and Type | Field and Description |
---|---|
protected AbstractBounds<PartitionPosition> |
DataRange.keyRange |
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 |
---|---|
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. |
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 |
---|---|
class |
Bounds<T extends RingPosition<T>>
AbstractBounds containing both its endpoints: [left, right].
|
class |
ExcludingBounds<T extends RingPosition<T>>
AbstractBounds containing neither of its endpoints: (left, right).
|
class |
IncludingExcludingBounds<T extends RingPosition<T>>
AbstractBounds containing only its left endpoint: [left, right).
|
class |
Range<T extends RingPosition<T>>
A representation of the range that a node is responsible for on the DHT ring.
|
Modifier and Type | Field and Description |
---|---|
static IPartitionerDependentSerializer<AbstractBounds<PartitionPosition>> |
AbstractBounds.rowPositionSerializer |
static IPartitionerDependentSerializer<AbstractBounds<Token>> |
AbstractBounds.tokenSerializer |
Modifier and Type | Method and Description |
---|---|
static <T extends RingPosition<T>> |
AbstractBounds.bounds(AbstractBounds.Boundary<T> min,
AbstractBounds.Boundary<T> max) |
static <T extends RingPosition<T>> |
AbstractBounds.bounds(T min,
boolean inclusiveMin,
T max,
boolean inclusiveMax) |
AbstractBounds<T> |
AbstractBounds.AbstractBoundsSerializer.deserialize(java.io.DataInput in,
IPartitioner p,
int version) |
abstract AbstractBounds<T> |
AbstractBounds.withNewRight(T newRight) |
AbstractBounds<T> |
Bounds.withNewRight(T newRight) |
AbstractBounds<T> |
ExcludingBounds.withNewRight(T newRight) |
AbstractBounds<T> |
IncludingExcludingBounds.withNewRight(T newRight) |
AbstractBounds<T> |
Range.withNewRight(T newRight) |
Modifier and Type | Method and Description |
---|---|
abstract Pair<AbstractBounds<T>,AbstractBounds<T>> |
AbstractBounds.split(T position)
Given token T and AbstractBounds ?L,R?, returns Pair(?L,T], (T,R?),
where ? means that the same type of AbstractBounds is returned as the original.
|
abstract Pair<AbstractBounds<T>,AbstractBounds<T>> |
AbstractBounds.split(T position)
Given token T and AbstractBounds ?L,R?, returns Pair(?L,T], (T,R?),
where ? means that the same type of AbstractBounds is returned as the original.
|
Pair<AbstractBounds<T>,AbstractBounds<T>> |
Bounds.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
Bounds.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
ExcludingBounds.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
ExcludingBounds.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
IncludingExcludingBounds.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
IncludingExcludingBounds.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
Range.split(T position) |
Pair<AbstractBounds<T>,AbstractBounds<T>> |
Range.split(T position) |
abstract java.util.List<? extends AbstractBounds<T>> |
AbstractBounds.unwrap() |
java.util.List<? extends AbstractBounds<T>> |
Bounds.unwrap() |
java.util.List<? extends AbstractBounds<T>> |
ExcludingBounds.unwrap() |
java.util.List<? extends AbstractBounds<T>> |
IncludingExcludingBounds.unwrap() |
Modifier and Type | Method and Description |
---|---|
boolean |
Range.intersects(AbstractBounds<T> that) |
void |
AbstractBounds.AbstractBoundsSerializer.serialize(AbstractBounds<T> range,
DataOutputPlus out,
int version) |
long |
AbstractBounds.AbstractBoundsSerializer.serializedSize(AbstractBounds<T> ab,
int version) |
static void |
IPartitioner.validate(AbstractBounds<?> bounds) |
Modifier and Type | Method and Description |
---|---|
static <T extends RingPosition<T>> |
AbstractBounds.noneStrictlyWrapsAround(java.util.Collection<AbstractBounds<T>> bounds) |
static void |
IPartitioner.validate(java.util.Collection<? extends AbstractBounds<?>> allBounds) |
Modifier and Type | Method and Description |
---|---|
AbstractBounds<Token> |
SSTable.getBounds() |
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 |
---|---|
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 |
---|---|
AbstractBounds<PartitionPosition> |
ReplicaLayout.ForRangeRead.range() |
AbstractBounds<PartitionPosition> |
ReplicaLayout.ForRange.range() |
AbstractBounds<PartitionPosition> |
ReplicaPlan.ForRangeRead.range() |
Modifier and Type | Method and 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-repair
|
Constructor and 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) |
Modifier and Type | Class and Description |
---|---|
static class |
MerkleTree.TreeRange
The public interface to a range in the tree.
|
Copyright © 2009-2022 The Apache Software Foundation