Uses of Class
org.apache.cassandra.locator.Endpoints
-
Packages that use Endpoints Package Description org.apache.cassandra.db org.apache.cassandra.locator org.apache.cassandra.service.reads org.apache.cassandra.service.reads.repair -
-
Uses of Endpoints in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type Endpoints Modifier and Type Method Description int
ConsistencyLevel. blockForWrite(AbstractReplicationStrategy replicationStrategy, Endpoints<?> pending)
static com.carrotsearch.hppc.ObjectIntHashMap<java.lang.String>
ConsistencyLevel. eachQuorumForWrite(AbstractReplicationStrategy replicationStrategy, Endpoints<?> pendingWithDown)
-
Uses of Endpoints in org.apache.cassandra.locator
Classes in org.apache.cassandra.locator with type parameters of type Endpoints Modifier and Type Class Description class
Endpoints<E extends Endpoints<E>>
A collection of Endpoints for a given ring position.class
ReplicaLayout<E extends Endpoints<E>>
The relevant replicas for an operation over a given range or token.static class
ReplicaLayout.ForWrite<E extends Endpoints<E>>
class
ReplicaPlan<E extends Endpoints<E>>
static class
ReplicaPlan.ForRead<E extends Endpoints<E>>
static class
ReplicaPlan.ForWrite<E extends Endpoints<E>>
static interface
ReplicaPlan.Shared<E extends Endpoints<E>,P extends ReplicaPlan<E>>
Used by AbstractReadExecutor, {Data,Digest}Resolver and ReadRepair to share a ReplicaPlan whose 'contacts' replicas we progressively modify via various forms of speculation (initial speculation, rr-read and rr-write) The internal reference is not volatile, despite being shared between threads.Subclasses of Endpoints in org.apache.cassandra.locator Modifier and Type Class Description class
EndpointsForRange
A ReplicaCollection where all Replica are required to cover a range that fully contains the range() defined in the builder().static class
EndpointsForRange.Builder
class
EndpointsForToken
A ReplicaCollection where all Replica are required to cover a range that fully contains the token() defined in the builder().static class
EndpointsForToken.Builder
Methods in org.apache.cassandra.locator with type parameters of type Endpoints Modifier and Type Method Description static <E extends Endpoints<E>>
EEndpoints. append(E replicas, Replica extraReplica)
static <E extends Endpoints<E>>
EEndpoints. concat(E natural, E pending)
Care must be taken to ensure no conflicting ranges occur in pending and natural.<E extends Endpoints<E>,L extends ReplicaLayout.ForWrite<E>>
EReplicaPlans.Selector. select(ConsistencyLevel consistencyLevel, L liveAndDown, L live)
Select theEndpoints
from {@param liveAndDown} and {@param live} to contact according to the consistency level.Methods in org.apache.cassandra.locator with parameters of type Endpoints Modifier and Type Method Description static boolean
ReplicaPlans. isSufficientLiveReplicasForRead(AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, Endpoints<?> liveReplicas)
-
Uses of Endpoints in org.apache.cassandra.service.reads
Classes in org.apache.cassandra.service.reads with type parameters of type Endpoints Modifier and Type Class Description class
DataResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
class
DigestResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
class
ReadCallback<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
class
ReplicaFilteringProtection<E extends Endpoints<E>>
Helper in charge of collecting additional queries to be done on the coordinator to protect against invalid results being included due to replica-side filtering (secondary indexes orALLOW * FILTERING
).class
ResponseResolver<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
-
Uses of Endpoints in org.apache.cassandra.service.reads.repair
Classes in org.apache.cassandra.service.reads.repair with type parameters of type Endpoints Modifier and Type Class Description class
AbstractReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
class
BlockingReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
'Classic' read repair.class
NoopReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
Bypasses the read repair path for short read protection and testingclass
PartitionIteratorMergeListener<E extends Endpoints<E>>
class
ReadOnlyReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
Only performs the collection of data responses and reconciliation of them, doesn't send repair mutations to replicas.interface
ReadRepair<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
class
RowIteratorMergeListener<E extends Endpoints<E>>
Methods in org.apache.cassandra.service.reads.repair with type parameters of type Endpoints Modifier and Type Method Description static <E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
ReadRepair<E,P>ReadRepair. create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
<E extends Endpoints<E>,P extends ReplicaPlan.ForRead<E>>
ReadRepair<E,P>ReadRepair.Factory. create(ReadCommand command, ReplicaPlan.Shared<E,P> replicaPlan, long queryStartNanoTime)
-