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.hints Hints subsystem consists of several components.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(java.util.UUID id, long creationTime, java.util.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
CounterMutation. getMutation()
static Mutation
Mutation. merge(java.util.List<Mutation> mutations)
Creates a new mutation that merges all the provided mutations.Mutation
Mutation. without(java.util.Set<TableId> tableIds)
Mutation
Mutation. without(TableId tableId)
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.java.util.concurrent.CompletableFuture<?>
Keyspace. applyFuture(Mutation mutation, boolean writeCommitLog, boolean updateIndexes)
java.util.concurrent.CompletableFuture<?>
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. 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 void
MutationVerbHandler. doVerb(Message<Mutation> message)
void
ReadRepairVerbHandler. doVerb(Message<Mutation> message)
static Mutation
Mutation. merge(java.util.List<Mutation> mutations)
Creates a new mutation that merges all the provided mutations.Constructors in org.apache.cassandra.db with parameters of type Mutation 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 mutationvoid
CommitLogReplayer. handleMutation(Mutation m, int size, int entryLocation, CommitLogDescriptor desc)
protected java.util.concurrent.Future<java.lang.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 fornew 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 java.util.Iterator<java.util.Collection<Mutation>>
TableViews. generateViewUpdates(java.util.Collection<View> views, UnfilteredRowIterator updates, UnfilteredRowIterator existings, int 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.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.schema
Fields in org.apache.cassandra.schema with type parameters of type Mutation Modifier and Type Field Description java.util.Collection<Mutation>
Schema.TransformationResult. mutations
Methods in org.apache.cassandra.schema that return types with arguments of type Mutation Modifier and Type Method Description java.util.Collection<Mutation>
MigrationManager.MigrationsSerializer. deserialize(DataInputPlus in, int version)
static java.util.Optional<Mutation>
MigrationManager. evolveSystemKeyspace(KeyspaceMetadata keyspace, long generation)
We have a set of non-local, distributed system keyspaces, e.g.java.util.Collection<Mutation>
Schema. schemaKeyspaceAsMutations()
See CASSANDRA-16856/16996.Methods in org.apache.cassandra.schema with parameters of type Mutation Modifier and Type Method Description static void
MigrationManager. announce(Mutation change)
Method parameters in org.apache.cassandra.schema with type arguments of type Mutation Modifier and Type Method Description static void
MigrationManager. announce(java.util.Collection<Mutation> schema)
static java.util.concurrent.Future<?>
MigrationManager. announceWithoutPush(java.util.Collection<Mutation> schema)
void
SchemaPushVerbHandler. doVerb(Message<java.util.Collection<Mutation>> message)
void
Schema. mergeAndAnnounceVersion(java.util.Collection<Mutation> mutations)
Merge remote schema in form of mutations with local and mutate ks/cf metadata objects (which also involves fs operations on add/drop ks/cf)protected void
MigrationCoordinator. mergeSchemaFrom(InetAddressAndPort endpoint, java.util.Collection<Mutation> mutations)
void
MigrationManager.MigrationsSerializer. serialize(java.util.Collection<Mutation> schema, DataOutputPlus out, int version)
long
MigrationManager.MigrationsSerializer. serializedSize(java.util.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.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)
Method parameters in org.apache.cassandra.service with type arguments of type Mutation Modifier and Type Method Description static void
StorageProxy. mutateAtomically(java.util.Collection<Mutation> mutations, ConsistencyLevel consistency_level, boolean requireQuorumForRemove, long queryStartNanoTime)
See mutate.static void
StorageProxy. mutateMV(java.nio.ByteBuffer dataKey, java.util.Collection<Mutation> mutations, boolean writeCommitLog, java.util.concurrent.atomic.AtomicLong baseComplete, long queryStartNanoTime)
Use this method to have these Mutations applied across all replicas. -
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, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForTokenWrite writePlan)
void
NoopReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForTokenWrite writePlan)
void
ReadOnlyReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForTokenWrite writePlan)
void
ReadRepair. repairPartition(DecoratedKey partitionKey, java.util.Map<Replica,Mutation> mutations, ReplicaPlan.ForTokenWrite 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 Constructor Description BlockingPartitionRepair(DecoratedKey key, java.util.Map<Replica,Mutation> repairs, ReplicaPlan.ForTokenWrite writePlan)
BlockingPartitionRepair(DecoratedKey key, java.util.Map<Replica,Mutation> repairs, ReplicaPlan.ForTokenWrite writePlan, java.util.function.Predicate<InetAddressAndPort> shouldBlockOn)
-
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 java.util.Collection<Mutation>
ITrigger. augment(Partition update)
Called exactly once per CF update, returned mutations are atomically updated.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.
-