Package | Description |
---|---|
org.apache.cassandra.locator | |
org.apache.cassandra.service | |
org.apache.cassandra.service.reads |
Modifier and Type | Class and Description |
---|---|
static class |
EndpointsForToken.Builder |
Modifier and Type | Method and Description |
---|---|
EndpointsForToken |
EndpointsForToken.Builder.build() |
static EndpointsForToken |
EndpointsForToken.copyOf(Token token,
java.util.Collection<Replica> replicas) |
static EndpointsForToken |
EndpointsForToken.empty(Token token) |
EndpointsForToken |
EndpointsForRange.forToken(Token token) |
EndpointsForToken |
AbstractReplicationStrategy.getNaturalReplicasForToken(RingPosition<?> searchPosition)
get the (possibly cached) endpoints that should store the given Token.
|
EndpointsForToken |
TokenMetadata.getWriteEndpoints(Token token,
java.lang.String keyspaceName,
EndpointsForToken natural)
Deprecated.
retained for benefit of old tests
|
static EndpointsForToken |
EndpointsForToken.of(Token token,
Replica... replicas) |
static EndpointsForToken |
EndpointsForToken.of(Token token,
Replica replica) |
EndpointsForToken |
PendingRangeMaps.pendingEndpointsFor(Token token) |
EndpointsForToken |
TokenMetadata.pendingEndpointsForToken(Token token,
java.lang.String keyspaceName) |
EndpointsForToken |
EndpointsForToken.snapshot() |
EndpointsForToken |
EndpointsForToken.Builder.snapshot() |
protected EndpointsForToken |
EndpointsForToken.snapshot(AbstractReplicaCollection.ReplicaList newList) |
Modifier and Type | Method and Description |
---|---|
static ReplicaLayout.ForTokenWrite |
ReplicaLayout.forTokenWrite(AbstractReplicationStrategy replicationStrategy,
EndpointsForToken natural,
EndpointsForToken pending) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
EndpointsForToken natural,
EndpointsForToken pending,
java.util.function.Predicate<Replica> isAlive,
ReplicaPlans.Selector selector) |
ReplicaPlan.ForTokenRead |
ReplicaPlan.SharedForTokenRead.getWithContacts(EndpointsForToken newContact) |
EndpointsForToken |
TokenMetadata.getWriteEndpoints(Token token,
java.lang.String keyspaceName,
EndpointsForToken natural)
Deprecated.
retained for benefit of old tests
|
ReplicaPlan.ForTokenWrite |
ReplicaPlan.ForTokenWrite.withContact(EndpointsForToken newContact) |
Constructor and Description |
---|
ForTokenRead(AbstractReplicationStrategy replicationStrategy,
EndpointsForToken natural) |
ForTokenRead(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
EndpointsForToken candidates,
EndpointsForToken contacts) |
ForTokenWrite(AbstractReplicationStrategy replicationStrategy,
EndpointsForToken natural,
EndpointsForToken pending) |
ForTokenWrite(AbstractReplicationStrategy replicationStrategy,
EndpointsForToken natural,
EndpointsForToken pending,
EndpointsForToken all) |
ForTokenWrite(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
EndpointsForToken pending,
EndpointsForToken liveAndDown,
EndpointsForToken live,
EndpointsForToken contact) |
Modifier and Type | Method and Description |
---|---|
EndpointsForToken |
StorageService.getNaturalReplicasForToken(java.lang.String keyspaceName,
java.nio.ByteBuffer key) |
EndpointsForToken |
StorageService.getNaturalReplicasForToken(java.lang.String keyspaceName,
java.lang.String cf,
java.lang.String key) |
Modifier and Type | Method and Description |
---|---|
static java.util.concurrent.Future<java.lang.Void> |
StorageProxy.submitHint(Mutation mutation,
EndpointsForToken targets,
AbstractWriteResponseHandler<IMutation> responseHandler) |
Modifier and Type | Field and Description |
---|---|
protected DigestResolver<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.digestResolver |
protected ReadCallback<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.handler |
protected ReadRepair<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.readRepair |
Modifier and Type | Method and Description |
---|---|
ReadRepair<EndpointsForToken,ReplicaPlan.ForTokenRead> |
AbstractReadExecutor.getReadRepair() |
Copyright © 2009-2022 The Apache Software Foundation