Package | Description |
---|---|
org.apache.cassandra.locator | |
org.apache.cassandra.service |
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
|
ReplicaPlan.ForRangeRead |
ReplicaPlan.SharedForRangeRead.get() |
ReplicaPlan.ForRangeRead |
ReplicaPlan.SharedForRangeRead.getWithContacts(EndpointsForRange newContact) |
static ReplicaPlan.ForRangeRead |
ReplicaPlans.maybeMerge(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaPlan.ForRangeRead left,
ReplicaPlan.ForRangeRead right)
Take two range read plans for adjacent ranges, and check if it is OK (and worthwhile) to combine them into a single plan
|
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.ForRangeRead |
ReplicaPlans.maybeMerge(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaPlan.ForRangeRead left,
ReplicaPlan.ForRangeRead right)
Take two range read plans for adjacent ranges, and check if it is OK (and worthwhile) to combine them into a single plan
|
static ReplicaPlan.SharedForRangeRead |
ReplicaPlan.shared(ReplicaPlan.ForRangeRead replicaPlan) |
Modifier and Type | Method and Description |
---|---|
protected ReplicaPlan.ForRangeRead |
StorageProxy.RangeIterator.computeNext() |
protected ReplicaPlan.ForRangeRead |
StorageProxy.RangeMerger.computeNext() |
Constructor and Description |
---|
RangeCommandIterator(java.util.Iterator<ReplicaPlan.ForRangeRead> ranges,
PartitionRangeReadCommand command,
int concurrencyFactor,
int maxConcurrencyFactor,
int totalRangeCount,
long queryStartNanoTime) |
RangeMerger(java.util.Iterator<ReplicaPlan.ForRangeRead> iterator,
Keyspace keyspace,
ConsistencyLevel consistency) |
Copyright © 2009-2020 The Apache Software Foundation