Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.service |
Modifier and Type | Method and Description |
---|---|
CounterMutation |
CounterMutation.CounterMutationSerializer.deserialize(DataInputPlus in,
int version) |
Modifier and Type | Method and Description |
---|---|
MessageOut<CounterMutation> |
CounterMutation.makeMutationMessage() |
Modifier and Type | Method and Description |
---|---|
void |
CounterMutation.CounterMutationSerializer.serialize(CounterMutation cm,
DataOutputPlus out,
int version) |
long |
CounterMutation.CounterMutationSerializer.serializedSize(CounterMutation cm,
int version) |
Modifier and Type | Method and Description |
---|---|
void |
CounterMutationVerbHandler.doVerb(MessageIn<CounterMutation> message,
int id) |
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.
|
Copyright © 2020 The Apache Software Foundation