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, 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 AbstractWriteResponseHandler in org.apache.cassandra.net
Methods in org.apache.cassandra.net with parameters of type AbstractWriteResponseHandler Modifier and Type Method Description voidRequestCallbacks. addWithExpiration(AbstractWriteResponseHandler<?> cb, Message<?> message, Replica to)voidMessagingService. 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 classBatchlogResponseHandler<T>classDatacenterSyncWriteResponseHandler<T>This class blocks for a quorum of responses _in all datacenters_ (CL.EACH_QUORUM).classDatacenterWriteResponseHandler<T>This class blocks for a quorum of responses _in the local datacenter only_ (CL.LOCAL_QUORUM).classWriteResponseHandler<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, java.lang.String localDataCenter, Dispatcher.RequestTime requestTime)static AbstractWriteResponseHandler<IMutation>StorageProxy. applyCounterMutationOnLeader(CounterMutation cm, java.lang.String localDataCenter, java.lang.Runnable callback, Dispatcher.RequestTime requestTime)static AbstractWriteResponseHandler<IMutation>StorageProxy. mutateCounter(CounterMutation cm, java.lang.String localDataCenter, Dispatcher.RequestTime requestTime)Handle counter mutation on the coordinator host.static AbstractWriteResponseHandler<IMutation>StorageProxy. performWrite(IMutation mutation, ConsistencyLevel consistencyLevel, java.lang.String localDataCenter, StorageProxy.WritePerformer performer, java.lang.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 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.voidAbstractWriteResponseHandler. setIdealCLResponseHandler(AbstractWriteResponseHandler handler)Set a delegate ideal CL write response handler.static voidStorageProxy. submitHint(Mutation mutation, Replica target, AbstractWriteResponseHandler<IMutation> responseHandler)Constructors in org.apache.cassandra.service with parameters of type AbstractWriteResponseHandler Constructor Description BatchlogResponseHandler(AbstractWriteResponseHandler<T> wrapped, int requiredBeforeFinish, BatchlogResponseHandler.BatchlogCleanup cleanup, Dispatcher.RequestTime requestTime)
-