Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.view | |
org.apache.cassandra.net | |
org.apache.cassandra.service | |
org.apache.cassandra.triggers |
Modifier and Type | Class and Description |
---|---|
class |
CounterMutation |
class |
Mutation |
Modifier and Type | Method and Description |
---|---|
boolean |
ViewManager.updatesAffectView(java.util.Collection<? extends IMutation> mutations,
boolean coordinatorBatchlog) |
Modifier and Type | Method and Description |
---|---|
void |
MessagingService.incrementDroppedMutations(java.util.Optional<IMutation> mutationOpt,
long timeTaken) |
Modifier and Type | Method and 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 consistency_level,
java.lang.String localDataCenter,
StorageProxy.WritePerformer performer,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime)
Perform the write of a mutation given a WritePerformer.
|
Modifier and Type | Method and Description |
---|---|
void |
StorageProxy.WritePerformer.apply(IMutation mutation,
java.lang.Iterable<java.net.InetAddress> targets,
AbstractWriteResponseHandler<IMutation> responseHandler,
java.lang.String localDataCenter,
ConsistencyLevel consistencyLevel) |
static AbstractWriteResponseHandler<IMutation> |
StorageProxy.performWrite(IMutation mutation,
ConsistencyLevel consistency_level,
java.lang.String localDataCenter,
StorageProxy.WritePerformer performer,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime)
Perform the write of a mutation given a WritePerformer.
|
Modifier and Type | Method and Description |
---|---|
void |
StorageProxy.WritePerformer.apply(IMutation mutation,
java.lang.Iterable<java.net.InetAddress> targets,
AbstractWriteResponseHandler<IMutation> responseHandler,
java.lang.String localDataCenter,
ConsistencyLevel consistencyLevel) |
static void |
StorageProxy.mutate(java.util.Collection<? extends IMutation> mutations,
ConsistencyLevel consistency_level,
long queryStartNanoTime)
Use this method to have these Mutations applied
across all replicas.
|
static void |
StorageProxy.mutateWithTriggers(java.util.Collection<? extends IMutation> mutations,
ConsistencyLevel consistencyLevel,
boolean mutateAtomically,
long queryStartNanoTime) |
static void |
StorageProxy.sendToHintedEndpoints(Mutation mutation,
java.lang.Iterable<java.net.InetAddress> targets,
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,
java.util.Collection<java.net.InetAddress> targets,
AbstractWriteResponseHandler<IMutation> responseHandler) |
static java.util.concurrent.Future<java.lang.Void> |
StorageProxy.submitHint(Mutation mutation,
java.net.InetAddress target,
AbstractWriteResponseHandler<IMutation> responseHandler) |
Modifier and Type | Method and 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.
|
Copyright © 2020 The Apache Software Foundation