Modifier and Type | Method and Description |
---|---|
RowMutation |
CFMetaData.dropFromSchema(long timestamp)
Remove all CF attributes from schema
|
RowMutation |
KSMetaData.dropFromSchema(long timestamp) |
RowMutation |
CFMetaData.toSchema(long timestamp)
Convert current metadata into schema mutation
|
RowMutation |
KSMetaData.toSchema(long timestamp) |
RowMutation |
CFMetaData.toSchemaUpdate(CFMetaData newState,
long modificationTimestamp,
boolean fromThrift)
Create schema mutations to update this metadata to provided new state.
|
RowMutation |
KSMetaData.toSchemaUpdate(KSMetaData newState,
long modificationTimestamp) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnDefinition.deleteFromSchema(RowMutation rm,
java.lang.String cfName,
AbstractType<?> comparator,
long timestamp)
Drop specified column from the schema using given row.
|
void |
TriggerDefinition.deleteFromSchema(RowMutation rm,
java.lang.String cfName,
long timestamp)
Drop specified trigger from the schema using given row.
|
void |
CFMetaData.toSchema(RowMutation rm,
long timestamp) |
void |
ColumnDefinition.toSchema(RowMutation rm,
java.lang.String cfName,
AbstractType<?> comparator,
long timestamp) |
void |
TriggerDefinition.toSchema(RowMutation rm,
java.lang.String cfName,
long timestamp)
Add specified trigger to the schema using given row.
|
Modifier and Type | Method and Description |
---|---|
RowMutation |
DeleteStatement.mutationForKey(java.nio.ByteBuffer key,
java.lang.String keyspace,
java.lang.Long timestamp,
ThriftClientState clientState,
java.util.List<java.nio.ByteBuffer> variables,
CFMetaData metadata) |
Modifier and Type | Method and Description |
---|---|
RowMutation |
RowMutation.RowMutationSerializer.deserialize(java.io.DataInput in,
int version) |
RowMutation |
RowMutation.RowMutationSerializer.deserialize(java.io.DataInput in,
int version,
ColumnSerializer.Flag flag) |
static RowMutation |
BatchlogManager.getBatchlogMutationFor(java.util.Collection<RowMutation> mutations,
java.util.UUID uuid) |
RowMutation |
HintedHandOffManager.hintFor(RowMutation mutation,
int ttl,
java.util.UUID targetId)
Returns a mutation representing a Hint to be sent to
targetId
as soon as it becomes available again. |
RowMutation |
CounterMutation.makeReplicationMutation() |
RowMutation |
CounterMutation.rowMutation() |
RowMutation |
RowMutation.without(java.util.UUID cfId) |
Modifier and Type | Method and Description |
---|---|
MessageOut<RowMutation> |
RowMutation.createMessage() |
MessageOut<RowMutation> |
RowMutation.createMessage(MessagingService.Verb verb) |
static java.util.Collection<RowMutation> |
SystemKeyspace.serializeSchema() |
Modifier and Type | Method and Description |
---|---|
void |
Keyspace.apply(RowMutation mutation,
boolean writeCommitLog) |
void |
Keyspace.apply(RowMutation mutation,
boolean writeCommitLog,
boolean updateIndexes)
This method appends a row to the global CommitLog, then updates memtables and indexes.
|
static int |
HintedHandOffManager.calculateHintTTL(RowMutation mutation) |
RowMutation |
HintedHandOffManager.hintFor(RowMutation mutation,
int ttl,
java.util.UUID targetId)
Returns a mutation representing a Hint to be sent to
targetId
as soon as it becomes available again. |
void |
RowMutation.RowMutationSerializer.serialize(RowMutation rm,
java.io.DataOutput out,
int version) |
long |
RowMutation.RowMutationSerializer.serializedSize(RowMutation rm,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
DefinitionsUpdateVerbHandler.doVerb(MessageIn<java.util.Collection<RowMutation>> message,
int id) |
void |
ReadRepairVerbHandler.doVerb(MessageIn<RowMutation> message,
int id) |
void |
RowMutationVerbHandler.doVerb(MessageIn<RowMutation> message,
int id) |
static RowMutation |
BatchlogManager.getBatchlogMutationFor(java.util.Collection<RowMutation> mutations,
java.util.UUID uuid) |
static void |
DefsTables.mergeSchema(java.util.Collection<RowMutation> mutations)
Merge remote schema in form of row mutations with local and mutate ks/cf metadata objects
(which also involves fs operations on add/drop ks/cf)
|
Constructor and Description |
---|
CounterMutation(RowMutation rowMutation,
ConsistencyLevel consistency) |
Modifier and Type | Method and Description |
---|---|
void |
CommitLog.add(RowMutation rm)
Add a RowMutation to the commit log.
|
protected boolean |
CommitLogReplayer.pointInTimeExceeded(RowMutation frm) |
ReplayPosition |
CommitLogSegment.write(RowMutation mutation)
Appends a row mutation onto the commit log.
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<RowMutation> |
MigrationManager.MigrationsSerializer.deserialize(java.io.DataInput in,
int version) |
Modifier and Type | Method and Description |
---|---|
static void |
StorageProxy.sendToHintedEndpoints(RowMutation rm,
java.lang.Iterable<java.net.InetAddress> targets,
AbstractWriteResponseHandler responseHandler,
java.lang.String localDataCenter)
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(RowMutation mutation,
java.net.InetAddress target,
AbstractWriteResponseHandler responseHandler) |
static void |
StorageProxy.writeHintForMutation(RowMutation mutation,
int ttl,
java.net.InetAddress target) |
Modifier and Type | Method and Description |
---|---|
static void |
StorageProxy.mutateAtomically(java.util.Collection<RowMutation> mutations,
ConsistencyLevel consistency_level)
See mutate.
|
void |
MigrationManager.MigrationsSerializer.serialize(java.util.Collection<RowMutation> schema,
java.io.DataOutput out,
int version) |
long |
MigrationManager.MigrationsSerializer.serializedSize(java.util.Collection<RowMutation> schema,
int version) |
Modifier and Type | Method and Description |
---|---|
RowMutation |
Commit.makeMutation() |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<RowMutation> |
ITrigger.augment(java.nio.ByteBuffer key,
ColumnFamily update)
Called exactly once per CF update, returned mutations are atomically updated.
|
java.util.Collection<RowMutation> |
TriggerExecutor.execute(java.util.Collection<? extends IMutation> updates) |
Copyright © 2014 The Apache Software Foundation