Uses of Class
org.apache.cassandra.db.Mutation

Packages that use Mutation

Package	Description
org.apache.cassandra.batchlog
org.apache.cassandra.db
org.apache.cassandra.db.commitlog
org.apache.cassandra.db.partitions
org.apache.cassandra.db.view
org.apache.cassandra.db.virtual
org.apache.cassandra.hints	Hints subsystem consists of several components.
org.apache.cassandra.locator
org.apache.cassandra.schema
org.apache.cassandra.service
org.apache.cassandra.service.paxos
org.apache.cassandra.service.reads.repair
org.apache.cassandra.triggers

Uses of Mutation in org.apache.cassandra.batchlog

Method parameters in org.apache.cassandra.batchlog with type arguments of type Mutation

Modifier and Type	Method	Description
static Batch	Batch.createLocal(TimeUUID id, long creationTime, Collection<Mutation> mutations)	Creates a 'local' batch - with all enclosed mutations in decoded form (as Mutation instances)

Uses of Mutation in org.apache.cassandra.db

Methods in org.apache.cassandra.db that return Mutation

Modifier and Type	Method	Description
Mutation	CounterMutation.applyCounterMutation()	Applies the counter mutation, returns the result Mutation (for replication to other nodes).
Mutation	Mutation.PartitionUpdateCollector.build()
Mutation	Mutation.SimpleBuilder.build()	Build the mutation represented by this builder.
Mutation	SimpleBuilders.MutationBuilder.build()
Mutation	SimpleBuilders.PartitionUpdateBuilder.buildAsMutation()
Mutation	Mutation.MutationSerializer.deserialize(DataInputPlus in, int version)
Mutation	Mutation.MutationSerializer.deserialize(DataInputPlus in, int version, DeserializationHelper.Flag flag)
Mutation	Mutation.get()
Mutation	CounterMutation.getMutation()
static Mutation	Mutation.merge(List<Mutation> mutations)	Creates a new mutation that merges all the provided mutations.
Mutation	Mutation.without(Set<TableId> tableIds)
Mutation	Mutation.without(TableId tableId)

Methods in org.apache.cassandra.db that return types with arguments of type Mutation

Modifier and Type	Method	Description
Supplier<Mutation>	CounterMutation.hintOnFailure()
Supplier<Mutation>	IMutation.hintOnFailure()
Supplier<Mutation>	Mutation.hintOnFailure()

Methods in org.apache.cassandra.db with parameters of type Mutation

Modifier and Type	Method	Description
void	Keyspace.apply(Mutation mutation, boolean writeCommitLog)
void	Keyspace.apply(Mutation mutation, boolean writeCommitLog, boolean updateIndexes)
void	Keyspace.apply(Mutation mutation, boolean makeDurable, boolean updateIndexes, boolean isDroppable)	If apply is blocking, apply must not be deferred Otherwise there is a race condition where ALL mutation workers are beeing blocked ending in a complete deadlock of the mutation stage.
Future<?>	Keyspace.applyFuture(Mutation mutation, boolean writeCommitLog, boolean updateIndexes)
Future<?>	Keyspace.applyFuture(Mutation mutation, boolean writeCommitLog, boolean updateIndexes, boolean isDroppable, boolean isDeferrable)
WriteContext	CassandraKeyspaceWriteHandler.beginWrite(Mutation mutation, boolean makeDurable)
WriteContext	KeyspaceWriteHandler.beginWrite(Mutation mutation, boolean makeDurable)
void	Mutation.MutationSerializer.prepareSerializedBuffer(Mutation mutation, int version)	Called early during request processing to prevent that Mutation.MutationSerializer.serialization(Mutation, int) is called concurrently.
void	Mutation.MutationSerializer.serialize(Mutation mutation, DataOutputPlus out, int version)
long	Mutation.MutationSerializer.serializedSize(Mutation mutation, int version)

Method parameters in org.apache.cassandra.db with type arguments of type Mutation

Modifier and Type	Method	Description
protected void	MutationVerbHandler.applyMutation(Message<Mutation> message, InetAddressAndPort respondToAddress)
void	MutationVerbHandler.doVerb(Message<Mutation> message)
void	ReadRepairVerbHandler.doVerb(Message<Mutation> message)
static Mutation	Mutation.merge(List<Mutation> mutations)	Creates a new mutation that merges all the provided mutations.

Constructors in org.apache.cassandra.db with parameters of type Mutation

Modifier	Constructor	Description
	CounterMutation(Mutation mutation, ConsistencyLevel consistency)

Uses of Mutation in org.apache.cassandra.db.commitlog

Methods in org.apache.cassandra.db.commitlog with parameters of type Mutation

Modifier and Type	Method	Description
CommitLogPosition	CommitLog.add(Mutation mutation)	Add a Mutation to the commit log.
abstract CommitLogSegment.Allocation	AbstractCommitLogSegmentManager.allocate(Mutation mutation, int size)	Allocate a segment within this CLSM.
CommitLogSegment.Allocation	CommitLogSegmentManagerCDC.allocate(Mutation mutation, int size)	Reserve space in the current segment for the provided mutation or, if there isn't space available, create a new segment.
CommitLogSegment.Allocation	CommitLogSegmentManagerStandard.allocate(Mutation mutation, int size)	Reserve space in the current segment for the provided mutation or, if there isn't space available, create a new segment.
void	CommitLogReadHandler.handleMutation(Mutation m, int size, int entryLocation, CommitLogDescriptor desc)	Process a deserialized mutation
void	CommitLogReplayer.handleMutation(Mutation m, int size, int entryLocation, CommitLogDescriptor desc)
protected Future<Integer>	CommitLogReplayer.MutationInitiator.initiateMutation(Mutation mutation, long segmentId, int serializedSize, int entryLocation, CommitLogReplayer commitLogReplayer)
protected boolean	CommitLogReplayer.pointInTimeExceeded(Mutation fm)

Uses of Mutation in org.apache.cassandra.db.partitions

Methods in org.apache.cassandra.db.partitions that return Mutation

Modifier and Type	Method	Description
Mutation	PartitionUpdate.SimpleBuilder.buildAsMutation()	As shortcut for new Mutation(build()).

Uses of Mutation in org.apache.cassandra.db.view

Methods in org.apache.cassandra.db.view that return types with arguments of type Mutation

Modifier and Type	Method	Description
Iterator<Collection<Mutation>>	TableViews.generateViewUpdates(Collection<View> views, UnfilteredRowIterator updates, UnfilteredRowIterator existings, long nowInSec, boolean separateUpdates)	Given some updates on the base table of this object and the existing values for the rows affected by that update, generates the mutation to be applied to the provided views.

Uses of Mutation in org.apache.cassandra.db.virtual

Methods in org.apache.cassandra.db.virtual that return types with arguments of type Mutation

Modifier and Type	Method	Description
Supplier<Mutation>	VirtualMutation.hintOnFailure()

Uses of Mutation in org.apache.cassandra.hints

Methods in org.apache.cassandra.hints with parameters of type Mutation

Modifier and Type	Method	Description
static Hint	Hint.create(Mutation mutation, long creationTime)
static Hint	Hint.create(Mutation mutation, long creationTime, int gcgs)

Uses of Mutation in org.apache.cassandra.locator

Method parameters in org.apache.cassandra.locator with type arguments of type Mutation

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 Mutation in org.apache.cassandra.schema

Methods in org.apache.cassandra.schema that return types with arguments of type Mutation

Modifier and Type	Method	Description
Collection<Mutation>	SchemaMutationsSerializer.deserialize(DataInputPlus in, int version)

Method parameters in org.apache.cassandra.schema with type arguments of type Mutation

Modifier and Type	Method	Description
void	SchemaPushVerbHandler.doVerb(Message<Collection<Mutation>> message)
void	SchemaPushVerbHandler.register(Consumer<Message<Collection<Mutation>>> handler)
void	SchemaMutationsSerializer.serialize(Collection<Mutation> schema, DataOutputPlus out, int version)
long	SchemaMutationsSerializer.serializedSize(Collection<Mutation> schema, int version)

Uses of Mutation in org.apache.cassandra.service

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

Modifier and Type	Method	Description
boolean	StorageProxy.appliesLocally(Mutation mutation)
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.
static void	StorageProxy.submitHint(Mutation mutation, Replica target, AbstractWriteResponseHandler<IMutation> responseHandler)

Method parameters in org.apache.cassandra.service with type arguments of type Mutation

Modifier and Type	Method	Description
static void	StorageProxy.mutateAtomically(Collection<Mutation> mutations, ConsistencyLevel consistency_level, boolean requireQuorumForRemove, Dispatcher.RequestTime requestTime)	See mutate.
static void	StorageProxy.mutateMV(ByteBuffer dataKey, Collection<Mutation> mutations, boolean writeCommitLog, AtomicLong baseComplete, Dispatcher.RequestTime requestTime)	Use this method to have these Mutations applied across all replicas.

Constructor parameters in org.apache.cassandra.service with type arguments of type Mutation

Modifier	Constructor	Description
protected	AbstractWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	DatacenterSyncWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	DatacenterWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)
	WriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime)

Uses of Mutation in org.apache.cassandra.service.paxos

Methods in org.apache.cassandra.service.paxos that return Mutation

Modifier and Type	Method	Description
Mutation	Commit.makeMutation()

Uses of Mutation in org.apache.cassandra.service.reads.repair

Methods in org.apache.cassandra.service.reads.repair that return Mutation

Modifier and Type	Method	Description
static Mutation	BlockingReadRepairs.createRepairMutation(PartitionUpdate update, ConsistencyLevel consistency, InetAddressAndPort destination, boolean suppressException)	Create a read repair mutation from the given update, if the mutation is not larger than the maximum mutation size, otherwise return null.

Method parameters in org.apache.cassandra.service.reads.repair with type arguments of type Mutation

Modifier and Type	Method	Description
void	BlockingReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)
void	NoopReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)
void	ReadOnlyReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)
void	ReadRepair.repairPartition(DecoratedKey partitionKey, Map<Replica,Mutation> mutations, ReplicaPlan.ForWrite writePlan)	Repairs a partition _after_ receiving data responses.
protected void	BlockingPartitionRepair.sendRR(Message<Mutation> message, InetAddressAndPort endpoint)

Constructor parameters in org.apache.cassandra.service.reads.repair with type arguments of type Mutation

Modifier	Constructor	Description
	BlockingPartitionRepair(DecoratedKey key, Map<Replica,Mutation> repairs, ReplicaPlan.ForWrite writePlan)

Uses of Mutation in org.apache.cassandra.triggers

Methods in org.apache.cassandra.triggers that return types with arguments of type Mutation

Modifier and Type	Method	Description
Collection<Mutation>	ITrigger.augment(Partition update)	Called exactly once per CF update, returned mutations are atomically updated.
Collection<Mutation>	TriggerExecutor.execute(Collection<? extends IMutation> mutations)	Takes a collection of mutations and possibly augments it by adding extra mutations generated by configured triggers.