Package | Description |
---|---|
org.apache.cassandra.locator | |
org.apache.cassandra.service | |
org.apache.cassandra.service.reads.repair |
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forBatchlogWrite(boolean isAny)
Requires that the provided endpoints are alive.
|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forForwardingCounterWrite(Keyspace keyspace,
Token token,
Replica replica)
A forwarding counter write is always sent to a single owning coordinator for the range, by the original coordinator
(if it is not itself an owner)
|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forLocalBatchlogWrite() |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forReadRepair(Token token,
ReplicaPlan.ForRead<?> readPlan) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forSingleReplicaWrite(Keyspace keyspace,
Token token,
Replica replica)
Construct a ReplicaPlan for writing to exactly one node, with CL.ONE.
|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
EndpointsForToken natural,
EndpointsForToken pending,
java.util.function.Predicate<Replica> isAlive,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaLayout.ForTokenWrite liveAndDown,
ReplicaLayout.ForTokenWrite live,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaLayout.ForTokenWrite liveAndDown,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
Token token,
ReplicaPlans.Selector selector) |
ReplicaPlan.ForTokenWrite |
ReplicaPlan.ForTokenWrite.withContact(EndpointsForToken newContact) |
Modifier and Type | Method and Description |
---|---|
<T> AbstractWriteResponseHandler<T> |
AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
<T> AbstractWriteResponseHandler<T> |
AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime,
ConsistencyLevel idealConsistencyLevel) |
Modifier and Type | Field and Description |
---|---|
protected ReplicaPlan.ForTokenWrite |
AbstractWriteResponseHandler.replicaPlan |
Modifier and Type | Method and Description |
---|---|
void |
StorageProxy.WritePerformer.apply(IMutation mutation,
ReplicaPlan.ForTokenWrite targets,
AbstractWriteResponseHandler<IMutation> responseHandler,
java.lang.String localDataCenter) |
static void |
StorageProxy.sendToHintedReplicas(Mutation mutation,
ReplicaPlan.ForTokenWrite plan,
AbstractWriteResponseHandler<IMutation> responseHandler,
java.lang.String localDataCenter,
Stage stage)
Send the mutations to the right targets, write it locally if it corresponds or writes a hint when the node
is not available.
|
Constructor and Description |
---|
AbstractWriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DatacenterSyncWriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DatacenterWriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
WriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
WriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
WriteType writeType,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
void |
BlockingReadRepair.repairPartition(DecoratedKey partitionKey,
java.util.Map<Replica,Mutation> mutations,
ReplicaPlan.ForTokenWrite writePlan) |
void |
NoopReadRepair.repairPartition(DecoratedKey partitionKey,
java.util.Map<Replica,Mutation> mutations,
ReplicaPlan.ForTokenWrite writePlan) |
void |
ReadOnlyReadRepair.repairPartition(DecoratedKey partitionKey,
java.util.Map<Replica,Mutation> mutations,
ReplicaPlan.ForTokenWrite writePlan) |
void |
ReadRepair.repairPartition(DecoratedKey partitionKey,
java.util.Map<Replica,Mutation> mutations,
ReplicaPlan.ForTokenWrite writePlan)
Repairs a partition _after_ receiving data responses.
|
Constructor and Description |
---|
BlockingPartitionRepair(DecoratedKey key,
java.util.Map<Replica,Mutation> repairs,
ReplicaPlan.ForTokenWrite writePlan) |
BlockingPartitionRepair(DecoratedKey key,
java.util.Map<Replica,Mutation> repairs,
ReplicaPlan.ForTokenWrite writePlan,
java.util.function.Predicate<InetAddressAndPort> shouldBlockOn) |
Copyright © 2009-2022 The Apache Software Foundation