Uses of Class
org.apache.cassandra.service.AbstractWriteResponseHandler

Packages that use AbstractWriteResponseHandler

Package	Description
org.apache.cassandra.locator
org.apache.cassandra.net
org.apache.cassandra.service

Uses of AbstractWriteResponseHandler in org.apache.cassandra.locator

Methods in org.apache.cassandra.locator that return AbstractWriteResponseHandler

Modifier and Type	Method	Description
<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 AbstractWriteResponseHandler in org.apache.cassandra.net

Methods in org.apache.cassandra.net with parameters of type AbstractWriteResponseHandler

Modifier and Type	Method	Description
void	RequestCallbacks.addWithExpiration(AbstractWriteResponseHandler<?> cb, Message<?> message, Replica to)
void	MessagingService.sendWriteWithCallback(Message message, Replica to, AbstractWriteResponseHandler<?> handler)	Send a mutation message or a Paxos Commit to a given endpoint.

Uses of AbstractWriteResponseHandler in org.apache.cassandra.service

Subclasses of AbstractWriteResponseHandler in org.apache.cassandra.service

Modifier and Type	Class	Description
class	BatchlogResponseHandler<T>
class	DatacenterSyncWriteResponseHandler<T>	This class blocks for a quorum of responses _in all datacenters_ (CL.EACH_QUORUM).
class	DatacenterWriteResponseHandler<T>	This class blocks for a quorum of responses _in the local datacenter only_ (CL.LOCAL_QUORUM).
class	WriteResponseHandler<T>	Handles blocking writes for ONE, ANY, TWO, THREE, QUORUM, and ALL consistency levels.

Methods in org.apache.cassandra.service that return AbstractWriteResponseHandler

Modifier and Type	Method	Description
static AbstractWriteResponseHandler<IMutation>	StorageProxy.applyCounterMutationOnCoordinator(CounterMutation cm, String localDataCenter, Dispatcher.RequestTime requestTime)
static AbstractWriteResponseHandler<IMutation>	StorageProxy.applyCounterMutationOnLeader(CounterMutation cm, String localDataCenter, Runnable callback, Dispatcher.RequestTime requestTime)
static AbstractWriteResponseHandler<IMutation>	StorageProxy.mutateCounter(CounterMutation cm, String localDataCenter, Dispatcher.RequestTime requestTime)	Handle counter mutation on the coordinator host.
static AbstractWriteResponseHandler<IMutation>	StorageProxy.performWrite(IMutation mutation, ConsistencyLevel consistencyLevel, String localDataCenter, StorageProxy.WritePerformer performer, Runnable callback, WriteType writeType, Dispatcher.RequestTime requestTime)	Perform the write of a mutation given a WritePerformer.

Methods in org.apache.cassandra.service with parameters of type AbstractWriteResponseHandler

Modifier and Type	Method	Description
void	StorageProxy.WritePerformer.apply(IMutation mutation, ReplicaPlan.ForWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, String localDataCenter, Dispatcher.RequestTime requestTime)
static void	StorageProxy.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.
void	AbstractWriteResponseHandler.setIdealCLResponseHandler(AbstractWriteResponseHandler handler)	Set a delegate ideal CL write response handler.
static void	StorageProxy.submitHint(Mutation mutation, Replica target, AbstractWriteResponseHandler<IMutation> responseHandler)

Constructors in org.apache.cassandra.service with parameters of type AbstractWriteResponseHandler

Modifier	Constructor	Description
	BatchlogResponseHandler(AbstractWriteResponseHandler<T> wrapped, int requiredBeforeFinish, BatchlogResponseHandler.BatchlogCleanup cleanup, Dispatcher.RequestTime requestTime)