Uses of Class
org.apache.cassandra.locator.ReplicaPlan.ForWrite
-
Packages that use ReplicaPlan.ForWrite Package Description org.apache.cassandra.locator org.apache.cassandra.service org.apache.cassandra.service.reads.repair -
-
Uses of ReplicaPlan.ForWrite in org.apache.cassandra.locator
Subclasses of ReplicaPlan.ForWrite in org.apache.cassandra.locator Modifier and Type Class Description static classReplicaPlan.ForPaxosWriteMethods in org.apache.cassandra.locator that return ReplicaPlan.ForWrite Modifier and Type Method Description static ReplicaPlan.ForWriteReplicaPlans. forBatchlogWrite(boolean isAny)Requires that the provided endpoints are alive.static ReplicaPlan.ForWriteReplicaPlans. 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.ForWriteReplicaPlans. forLocalBatchlogWrite()static ReplicaPlan.ForWriteReplicaPlans. forReadRepair(Token token, ReplicaPlan<?,?> readPlan)static ReplicaPlan.ForWriteReplicaPlans. forSingleReplicaWrite(Keyspace keyspace, Token token, Replica replica)Construct a ReplicaPlan for writing to exactly one node, with CL.ONE.static ReplicaPlan.ForWriteReplicaPlans. forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, Token token, ReplicaPlans.Selector selector)static ReplicaPlan.ForWriteReplicaPlans. forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, EndpointsForToken natural, EndpointsForToken pending, java.util.function.Predicate<Replica> isAlive, ReplicaPlans.Selector selector)static ReplicaPlan.ForWriteReplicaPlans. forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, ReplicaLayout.ForTokenWrite liveAndDown, ReplicaLayout.ForTokenWrite live, ReplicaPlans.Selector selector)static ReplicaPlan.ForWriteReplicaPlans. forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, ReplicaLayout.ForTokenWrite liveAndDown, ReplicaPlans.Selector selector)ReplicaPlan.ForWriteReplicaPlan.ForWrite. withContacts(EndpointsForToken newContact)Methods in org.apache.cassandra.locator with parameters of type ReplicaPlan.ForWrite Modifier and Type Method Description <T> AbstractWriteResponseHandler<T>AbstractReplicationStrategy. getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, java.lang.Runnable callback, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)<T> AbstractWriteResponseHandler<T>AbstractReplicationStrategy. getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, java.lang.Runnable callback, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime, ConsistencyLevel idealConsistencyLevel) -
Uses of ReplicaPlan.ForWrite in org.apache.cassandra.service
Fields in org.apache.cassandra.service declared as ReplicaPlan.ForWrite Modifier and Type Field Description protected ReplicaPlan.ForWriteAbstractWriteResponseHandler. replicaPlanMethods in org.apache.cassandra.service with parameters of type ReplicaPlan.ForWrite Modifier and Type Method Description voidStorageProxy.WritePerformer. apply(IMutation mutation, ReplicaPlan.ForWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, java.lang.String localDataCenter, Dispatcher.RequestTime requestTime)static voidStorageProxy. sendToHintedReplicas(Mutation mutation, ReplicaPlan.ForWrite plan, AbstractWriteResponseHandler<IMutation> responseHandler, java.lang.String localDataCenter, Stage stage, Dispatcher.RequestTime requestTime)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.ForWrite Constructor Description AbstractWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, java.lang.Runnable callback, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)DatacenterSyncWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, java.lang.Runnable callback, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)DatacenterWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, java.lang.Runnable callback, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, java.lang.Runnable callback, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, WriteType writeType, java.util.function.Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime) -
Uses of ReplicaPlan.ForWrite in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type ReplicaPlan.ForWrite Modifier and Type Method Description voidBlockingReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)voidNoopReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)voidReadOnlyReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)voidReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)Repairs a partition _after_ receiving data responses.Constructors in org.apache.cassandra.service.reads.repair with parameters of type ReplicaPlan.ForWrite Constructor Description BlockingPartitionRepair(DecoratedKey key, java.util.Map<Replica,Mutation> repairs, ReplicaPlan.ForWrite writePlan)
-