Uses of Class
org.apache.cassandra.locator.ReplicaPlan.ForWrite
Packages that use ReplicaPlan.ForWrite
Package
Description
-
Uses of ReplicaPlan.ForWrite in org.apache.cassandra.locator
Subclasses of ReplicaPlan.ForWrite in org.apache.cassandra.locatorMethods in org.apache.cassandra.locator that return ReplicaPlan.ForWriteModifier and TypeMethodDescriptionstatic 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, 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.ForWrite.withContacts(EndpointsForToken newContact) Methods in org.apache.cassandra.locator with parameters of type ReplicaPlan.ForWriteModifier and TypeMethodDescription<T> AbstractWriteResponseHandler<T>AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime) <T> AbstractWriteResponseHandler<T>AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, 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.ForWriteModifier and TypeFieldDescriptionprotected final ReplicaPlan.ForWriteAbstractWriteResponseHandler.replicaPlanMethods in org.apache.cassandra.service with parameters of type ReplicaPlan.ForWriteModifier and TypeMethodDescriptionvoidStorageProxy.WritePerformer.apply(IMutation mutation, ReplicaPlan.ForWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, String localDataCenter, Dispatcher.RequestTime requestTime) static voidStorageProxy.sendToHintedReplicas(Mutation mutation, ReplicaPlan.ForWrite plan, AbstractWriteResponseHandler<IMutation> responseHandler, 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.ForWriteModifierConstructorDescriptionprotectedAbstractWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime) DatacenterSyncWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime) DatacenterWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime) WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime) WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, WriteType writeType, 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.ForWriteModifier and TypeMethodDescriptionvoidBlockingReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) voidNoopReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) voidReadOnlyReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica, Mutation> mutations, ReplicaPlan.ForWrite writePlan) voidReadRepair.repairPartition(DecoratedKey partitionKey, 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.ForWriteModifierConstructorDescriptionBlockingPartitionRepair(DecoratedKey key, Map<Replica, Mutation> repairs, ReplicaPlan.ForWrite writePlan)