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 classCounterMutationclassMutationMethod parameters in org.apache.cassandra.db with type arguments of type IMutation Modifier and Type Method Description static longIMutation. 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 booleanViewManager. 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 classVirtualMutationA 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 voidStorageProxy.WritePerformer. apply(IMutation mutation, ReplicaPlan.ForTokenWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, java.lang.String localDataCenter)voidAbstractWriteResponseHandler. 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 voidStorageProxy.WritePerformer. apply(IMutation mutation, ReplicaPlan.ForTokenWrite targets, AbstractWriteResponseHandler<IMutation> responseHandler, java.lang.String localDataCenter)static voidStorageProxy. mutate(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, long queryStartNanoTime)Use this method to have these Mutations applied across all replicas.static voidStorageProxy. mutateWithTriggers(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, boolean mutateAtomically, long queryStartNanoTime)static voidStorageProxy. 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.
-