Uses of Class
org.apache.cassandra.db.partitions.PartitionUpdate
-
-
Uses of PartitionUpdate in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return PartitionUpdate Modifier and Type Method Description PartitionUpdate
CQL3CasRequest. makeUpdates(FilteredPartition current)
-
Uses of PartitionUpdate in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return PartitionUpdate Modifier and Type Method Description PartitionUpdate
SimpleBuilders.PartitionUpdateBuilder. build()
PartitionUpdate
Mutation. getPartitionUpdate(TableMetadata table)
Methods in org.apache.cassandra.db that return types with arguments of type PartitionUpdate Modifier and Type Method Description java.util.Collection<PartitionUpdate>
CounterMutation. getPartitionUpdates()
java.util.Collection<PartitionUpdate>
IMutation. getPartitionUpdates()
com.google.common.collect.ImmutableCollection<PartitionUpdate>
Mutation. getPartitionUpdates()
Methods in org.apache.cassandra.db with parameters of type PartitionUpdate Modifier and Type Method Description Mutation.PartitionUpdateCollector
Mutation.PartitionUpdateCollector. add(PartitionUpdate partitionUpdate)
void
ColumnFamilyStore. apply(PartitionUpdate update, UpdateTransaction indexer, OpOrder.Group opGroup, CommitLogPosition commitLogPosition)
Insert/Update the column family for this key.void
StorageHook. reportWrite(TableId tableId, PartitionUpdate partitionUpdate)
void
CassandraTableWriteHandler. write(PartitionUpdate update, WriteContext context, UpdateTransaction updateTransaction)
void
TableWriteHandler. write(PartitionUpdate update, WriteContext context, UpdateTransaction updateTransaction)
Constructors in org.apache.cassandra.db with parameters of type PartitionUpdate Constructor Description Mutation(PartitionUpdate update)
Constructor parameters in org.apache.cassandra.db with type arguments of type PartitionUpdate Constructor Description Mutation(java.lang.String keyspaceName, DecoratedKey key, com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications, long approxCreatedAtNanos)
Mutation(java.lang.String keyspaceName, DecoratedKey key, com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications, long approxCreatedAtNanos, boolean cdcEnabled)
-
Uses of PartitionUpdate in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions that return PartitionUpdate Modifier and Type Method Description PartitionUpdate
PartitionUpdate.Builder. build()
PartitionUpdate
PartitionUpdate.SimpleBuilder. build()
Build the update represented by this builder.PartitionUpdate
PartitionUpdate.PartitionUpdateSerializer. deserialize(DataInputPlus in, int version, DeserializationHelper.Flag flag)
static PartitionUpdate
PartitionUpdate. emptyUpdate(TableMetadata metadata, DecoratedKey key)
Creates a empty immutable partition update.static PartitionUpdate
PartitionUpdate. fromBytes(java.nio.ByteBuffer bytes, int version)
Deserialize a partition update from a provided byte buffer.static PartitionUpdate
PartitionUpdate. fromIterator(RowIterator iterator, ColumnFilter filter)
Turns the given iterator into an update.static PartitionUpdate
PartitionUpdate. fromIterator(UnfilteredRowIterator iterator, ColumnFilter filter)
Turns the given iterator into an update.static PartitionUpdate
PartitionUpdate. fullPartitionDelete(TableMetadata metadata, java.nio.ByteBuffer key, long timestamp, int nowInSec)
Creates a partition update that entirely deletes a given partition.static PartitionUpdate
PartitionUpdate. fullPartitionDelete(TableMetadata metadata, DecoratedKey key, long timestamp, int nowInSec)
Creates an immutable partition update that entirely deletes a given partition.static PartitionUpdate
PartitionUpdate. merge(java.util.List<PartitionUpdate> updates)
Merges the provided updates, yielding a new update that incorporates all those updates.static PartitionUpdate
PartitionUpdate. singleRowUpdate(TableMetadata metadata, java.nio.ByteBuffer key, Row row)
Creates an immutable partition update that contains a single row update.static PartitionUpdate
PartitionUpdate. singleRowUpdate(TableMetadata metadata, DecoratedKey key, Row row)
Creates an immutable partition update that contains a single row update.static PartitionUpdate
PartitionUpdate. singleRowUpdate(TableMetadata metadata, DecoratedKey key, Row row, Row staticRow)
Creates an immutable partition update that contains a single row update.Methods in org.apache.cassandra.db.partitions with parameters of type PartitionUpdate Modifier and Type Method Description long[]
AtomicBTreePartition. addAllWithSizeDelta(PartitionUpdate update, OpOrder.Group writeOp, UpdateTransaction indexer)
Adds a given update to this in-memtable partition.void
PartitionUpdate.PartitionUpdateSerializer. serialize(PartitionUpdate update, DataOutputPlus out, int version)
long
PartitionUpdate.PartitionUpdateSerializer. serializedSize(PartitionUpdate update, int version)
static java.nio.ByteBuffer
PartitionUpdate. toBytes(PartitionUpdate update, int version)
Serialize a partition update as a byte buffer.Method parameters in org.apache.cassandra.db.partitions with type arguments of type PartitionUpdate Modifier and Type Method Description static PartitionUpdate
PartitionUpdate. merge(java.util.List<PartitionUpdate> updates)
Merges the provided updates, yielding a new update that incorporates all those updates.Constructors in org.apache.cassandra.db.partitions with parameters of type PartitionUpdate Constructor Description Builder(PartitionUpdate base, int initialRowCapacity)
-
Uses of PartitionUpdate in org.apache.cassandra.db.view
Methods in org.apache.cassandra.db.view that return types with arguments of type PartitionUpdate Modifier and Type Method Description java.util.Collection<PartitionUpdate>
ViewUpdateGenerator. generateViewUpdates()
Returns the updates that needs to be done to the view given the base table updates passed toViewUpdateGenerator.addBaseTableUpdate(org.apache.cassandra.db.rows.Row, org.apache.cassandra.db.rows.Row)
.Methods in org.apache.cassandra.db.view with parameters of type PartitionUpdate Modifier and Type Method Description void
TableViews. pushViewReplicaUpdates(PartitionUpdate update, boolean writeCommitLog, java.util.concurrent.atomic.AtomicLong baseComplete)
Calculates and pushes updates to the views replicas.java.util.Collection<View>
TableViews. updatedViews(PartitionUpdate updates)
Return the views that are potentially updated by the provided updates. -
Uses of PartitionUpdate in org.apache.cassandra.db.virtual
Methods in org.apache.cassandra.db.virtual that return types with arguments of type PartitionUpdate Modifier and Type Method Description java.util.Collection<PartitionUpdate>
VirtualMutation. getPartitionUpdates()
Methods in org.apache.cassandra.db.virtual with parameters of type PartitionUpdate Modifier and Type Method Description void
AbstractVirtualTable. apply(PartitionUpdate update)
void
VirtualTable. apply(PartitionUpdate update)
Applies the specified update.Constructors in org.apache.cassandra.db.virtual with parameters of type PartitionUpdate Constructor Description VirtualMutation(PartitionUpdate update)
Constructor parameters in org.apache.cassandra.db.virtual with type arguments of type PartitionUpdate Constructor Description VirtualMutation(java.lang.String keyspaceName, DecoratedKey partitionKey, com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications)
-
Uses of PartitionUpdate in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type PartitionUpdate Modifier and Type Method Description UpdateTransaction
SecondaryIndexManager. newUpdateTransaction(PartitionUpdate update, WriteContext ctx, int nowInSec)
Transaction for updates on the write path.void
Index. validate(PartitionUpdate update)
Called at write time to ensure that values present in the update are valid according to the rules of all registered indexes which will process it.void
IndexRegistry. validate(PartitionUpdate update)
Called at write time to ensure that values present in the update are valid according to the rules of all registered indexes which will process it.void
SecondaryIndexManager. validate(PartitionUpdate update)
Called at write time to ensure that values present in the update are valid according to the rules of all registered indexes which will process it. -
Uses of PartitionUpdate in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal with parameters of type PartitionUpdate Modifier and Type Method Description void
CassandraIndex. validate(PartitionUpdate update)
-
Uses of PartitionUpdate in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type PartitionUpdate Modifier and Type Method Description void
SASIIndex. validate(PartitionUpdate update)
-
Uses of PartitionUpdate in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return PartitionUpdate Modifier and Type Method Description PartitionUpdate
CASRequest. makeUpdates(FilteredPartition current)
The updates to perform of a CAS success. -
Uses of PartitionUpdate in org.apache.cassandra.service.paxos
Fields in org.apache.cassandra.service.paxos declared as PartitionUpdate Modifier and Type Field Description PartitionUpdate
Commit. update
Methods in org.apache.cassandra.service.paxos with parameters of type PartitionUpdate Modifier and Type Method Description static Commit
Commit. newProposal(java.util.UUID ballot, PartitionUpdate update)
Constructors in org.apache.cassandra.service.paxos with parameters of type PartitionUpdate Constructor Description Commit(java.util.UUID ballot, PartitionUpdate update)
-
Uses of PartitionUpdate in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type PartitionUpdate 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. -
Uses of PartitionUpdate in org.apache.cassandra.triggers
Methods in org.apache.cassandra.triggers that return PartitionUpdate Modifier and Type Method Description PartitionUpdate
TriggerExecutor. execute(PartitionUpdate updates)
Augment a partition update by executing triggers to generate an intermediate set of mutations, then merging the update from each mutation with those supplied.Methods in org.apache.cassandra.triggers with parameters of type PartitionUpdate Modifier and Type Method Description PartitionUpdate
TriggerExecutor. execute(PartitionUpdate updates)
Augment a partition update by executing triggers to generate an intermediate set of mutations, then merging the update from each mutation with those supplied.
-