Uses of Class
org.apache.cassandra.locator.ReplicaPlan.ForTokenWrite
-
Packages that use ReplicaPlan.ForTokenWrite Package Description org.apache.cassandra.locator org.apache.cassandra.service org.apache.cassandra.service.reads.repair -
-
Uses of ReplicaPlan.ForTokenWrite in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator that return ReplicaPlan.ForTokenWrite Modifier and Type Method 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, Token token, ReplicaPlans.Selector selector)
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)
ReplicaPlan.ForTokenWrite
ReplicaPlan.ForTokenWrite. withContact(EndpointsForToken newContact)
Methods in org.apache.cassandra.locator with parameters of type ReplicaPlan.ForTokenWrite Modifier and Type Method 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)
-
Uses of ReplicaPlan.ForTokenWrite in org.apache.cassandra.service
Fields in org.apache.cassandra.service declared as ReplicaPlan.ForTokenWrite Modifier and Type Field Description protected ReplicaPlan.ForTokenWrite
AbstractWriteResponseHandler. replicaPlan
Methods in org.apache.cassandra.service with parameters of type ReplicaPlan.ForTokenWrite Modifier and Type Method 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.Constructors in org.apache.cassandra.service with parameters of type ReplicaPlan.ForTokenWrite Constructor 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)
-
Uses of ReplicaPlan.ForTokenWrite in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type ReplicaPlan.ForTokenWrite Modifier and Type Method 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.Constructors in org.apache.cassandra.service.reads.repair with parameters of type ReplicaPlan.ForTokenWrite Constructor 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)
-