Uses of Interface
org.apache.cassandra.db.IMutation
-
-
Uses of IMutation in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return types with arguments of type IMutation Modifier and Type Method Description java.util.List<? extends IMutation>
BatchStatement. getMutations(BatchQueryOptions options, boolean local, long batchTimestamp, int nowInSeconds, long queryStartNanoTime)
java.util.List<IMutation>
UpdatesCollector. toMutations()
-
Uses of IMutation in org.apache.cassandra.db
Classes in org.apache.cassandra.db that implement IMutation Modifier and Type Class Description class
CounterMutation
class
Mutation
Method parameters in org.apache.cassandra.db with type arguments of type IMutation Modifier and Type Method Description static long
IMutation. dataSize(java.util.Collection<? extends IMutation> mutations)
Computes the total data size of the specified mutations. -
Uses of IMutation in org.apache.cassandra.db.view
Method parameters in org.apache.cassandra.db.view with type arguments of type IMutation Modifier and Type Method Description boolean
ViewManager. updatesAffectView(java.util.Collection<? extends IMutation> mutations, boolean coordinatorBatchlog)
-
Uses of IMutation in org.apache.cassandra.db.virtual
Classes in org.apache.cassandra.db.virtual that implement IMutation Modifier and Type Class Description class
VirtualMutation
A specialised IMutation implementation for virtual keyspaces. -
Uses of IMutation in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return types with arguments of type IMutation Modifier and Type Method Description static AbstractWriteResponseHandler<IMutation>
StorageProxy. applyCounterMutationOnCoordinator(CounterMutation cm, java.lang.String localDataCenter, long queryStartNanoTime)
static AbstractWriteResponseHandler<IMutation>
StorageProxy. applyCounterMutationOnLeader(CounterMutation cm, java.lang.String localDataCenter, java.lang.Runnable callback, long queryStartNanoTime)
static AbstractWriteResponseHandler<IMutation>
StorageProxy. mutateCounter(CounterMutation cm, java.lang.String localDataCenter, long queryStartNanoTime)
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, long queryStartNanoTime)
Perform the write of a mutation given a WritePerformer.Methods in org.apache.cassandra.service with parameters of type IMutation Modifier and Type Method Description void
StorageProxy.WritePerformer. apply(IMutation mutation, ReplicaPlan.ForTokenWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, java.lang.String localDataCenter)
void
AbstractWriteResponseHandler. maybeTryAdditionalReplicas(IMutation mutation, StorageProxy.WritePerformer writePerformer, java.lang.String localDC)
Cheap Quorum backup.static AbstractWriteResponseHandler<IMutation>
StorageProxy. performWrite(IMutation mutation, ConsistencyLevel consistencyLevel, java.lang.String localDataCenter, StorageProxy.WritePerformer performer, java.lang.Runnable callback, WriteType writeType, long queryStartNanoTime)
Perform the write of a mutation given a WritePerformer.Method parameters in org.apache.cassandra.service with type arguments of type IMutation Modifier and Type Method Description void
StorageProxy.WritePerformer. apply(IMutation mutation, ReplicaPlan.ForTokenWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, java.lang.String localDataCenter)
static void
StorageProxy. mutate(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, long queryStartNanoTime)
Use this method to have these Mutations applied across all replicas.static void
StorageProxy. mutateWithTriggers(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, boolean mutateAtomically, long queryStartNanoTime)
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.static java.util.concurrent.Future<java.lang.Void>
StorageProxy. submitHint(Mutation mutation, EndpointsForToken targets, AbstractWriteResponseHandler<IMutation> responseHandler)
static java.util.concurrent.Future<java.lang.Void>
StorageProxy. submitHint(Mutation mutation, Replica target, AbstractWriteResponseHandler<IMutation> responseHandler)
-
Uses of IMutation in org.apache.cassandra.triggers
Method parameters in org.apache.cassandra.triggers with type arguments of type IMutation Modifier and Type Method Description java.util.Collection<Mutation>
TriggerExecutor. execute(java.util.Collection<? extends IMutation> mutations)
Takes a collection of mutations and possibly augments it by adding extra mutations generated by configured triggers.
-