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)