Package | Description |
---|---|
org.apache.cassandra.cql | |
org.apache.cassandra.db | |
org.apache.cassandra.net | |
org.apache.cassandra.service | |
org.apache.cassandra.sink | |
org.apache.cassandra.triggers |
Modifier and Type | Method and Description |
---|---|
java.util.List<IMutation> |
BatchStatement.getMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.util.List<java.nio.ByteBuffer> variables) |
abstract java.util.List<IMutation> |
AbstractModification.prepareRowMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.util.List<java.nio.ByteBuffer> variables)
Convert statement into a list of mutations to apply on the server
|
java.util.List<IMutation> |
DeleteStatement.prepareRowMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.util.List<java.nio.ByteBuffer> variables) |
java.util.List<IMutation> |
UpdateStatement.prepareRowMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.util.List<java.nio.ByteBuffer> variables)
Convert statement into a list of mutations to apply on the server
|
abstract java.util.List<IMutation> |
AbstractModification.prepareRowMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.lang.Long timestamp,
java.util.List<java.nio.ByteBuffer> variables)
Convert statement into a list of mutations to apply on the server
|
java.util.List<IMutation> |
DeleteStatement.prepareRowMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.lang.Long timestamp,
java.util.List<java.nio.ByteBuffer> variables) |
java.util.List<IMutation> |
UpdateStatement.prepareRowMutations(java.lang.String keyspace,
ThriftClientState clientState,
java.lang.Long timestamp,
java.util.List<java.nio.ByteBuffer> variables)
Convert statement into a list of mutations to apply on the server
|
Modifier and Type | Class and Description |
---|---|
class |
CounterMutation |
class |
RowMutation |
Modifier and Type | Method and Description |
---|---|
void |
CounterMutation.addAll(IMutation m) |
void |
IMutation.addAll(IMutation m) |
void |
RowMutation.addAll(IMutation m) |
Modifier and Type | Method and Description |
---|---|
int |
MessagingService.addCallback(IAsyncCallback cb,
MessageOut<? extends IMutation> message,
java.net.InetAddress to,
long timeout,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
int |
MessagingService.sendRR(MessageOut<? extends IMutation> message,
java.net.InetAddress to,
AbstractWriteResponseHandler handler,
boolean allowHints)
Send a mutation message to a given endpoint.
|
Modifier and Type | Method and Description |
---|---|
void |
StorageProxy.WritePerformer.apply(IMutation mutation,
java.lang.Iterable<java.net.InetAddress> targets,
AbstractWriteResponseHandler responseHandler,
java.lang.String localDataCenter,
ConsistencyLevel consistency_level) |
static AbstractWriteResponseHandler |
StorageProxy.performWrite(IMutation mutation,
ConsistencyLevel consistency_level,
java.lang.String localDataCenter,
StorageProxy.WritePerformer performer,
java.lang.Runnable callback,
WriteType writeType)
Perform the write of a mutation given a WritePerformer.
|
Modifier and Type | Method and Description |
---|---|
static void |
StorageProxy.mutate(java.util.Collection<? extends IMutation> mutations,
ConsistencyLevel consistency_level)
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) |
Modifier and Type | Method and Description |
---|---|
IMutation |
IRequestSink.handleWriteRequest(IMutation mutation)
Transform or drop a write request (represented by a RowMutation).
|
static IMutation |
SinkManager.processWriteRequest(IMutation mutation) |
Modifier and Type | Method and Description |
---|---|
IMutation |
IRequestSink.handleWriteRequest(IMutation mutation)
Transform or drop a write request (represented by a RowMutation).
|
static IMutation |
SinkManager.processWriteRequest(IMutation mutation) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<RowMutation> |
TriggerExecutor.execute(java.util.Collection<? extends IMutation> mutations) |
Copyright © 2014 The Apache Software Foundation