Modifier and Type | Method and Description |
---|---|
protected static ConsistencyLevel |
CassandraRoleManager.consistencyForRole(java.lang.String role) |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
BatchQueryOptions.getConsistency() |
abstract ConsistencyLevel |
QueryOptions.getConsistency() |
ConsistencyLevel |
BatchQueryOptions.getSerialConsistency() |
ConsistencyLevel |
QueryOptions.getSerialConsistency()
Serial consistency for conditional updates.
|
Modifier and Type | Method and Description |
---|---|
static QueryOptions |
QueryOptions.create(ConsistencyLevel consistency,
java.util.List<java.nio.ByteBuffer> values,
boolean skipMetadata,
int pageSize,
PagingState pagingState,
ConsistencyLevel serialConsistency,
ProtocolVersion version) |
static UntypedResultSet |
QueryProcessor.execute(java.lang.String query,
ConsistencyLevel cl,
java.lang.Object... values) |
static UntypedResultSet |
QueryProcessor.execute(java.lang.String query,
ConsistencyLevel cl,
QueryState state,
java.lang.Object... values) |
static QueryOptions |
QueryOptions.forInternalCalls(ConsistencyLevel consistency,
java.util.List<java.nio.ByteBuffer> values) |
static UntypedResultSet |
QueryProcessor.process(java.lang.String query,
ConsistencyLevel cl) |
static UntypedResultSet |
QueryProcessor.process(java.lang.String query,
ConsistencyLevel cl,
java.util.List<java.nio.ByteBuffer> values) |
static ResultMessage |
QueryProcessor.process(java.lang.String queryString,
ConsistencyLevel cl,
QueryState queryState,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
CounterMutation.consistency() |
static ConsistencyLevel |
ConsistencyLevel.fromCode(int code) |
static ConsistencyLevel |
ConsistencyLevel.valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.
|
static ConsistencyLevel[] |
ConsistencyLevel.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
PartitionRangeReadCommand.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
ReadQuery.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime)
Executes the query at the provided consistency level.
|
PartitionIterator |
SinglePartitionReadCommand.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
SinglePartitionReadCommand.Group.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
Constructor and Description |
---|
CounterMutation(Mutation mutation,
ConsistencyLevel consistency) |
Modifier and Type | Field and Description |
---|---|
ConsistencyLevel |
RequestFailureException.consistency |
ConsistencyLevel |
RequestTimeoutException.consistency |
ConsistencyLevel |
UnavailableException.consistency |
Constructor and Description |
---|
ReadFailureException(ConsistencyLevel consistency,
int received,
int blockFor,
boolean dataPresent,
java.util.Map<java.net.InetAddress,RequestFailureReason> failureReasonByEndpoint) |
ReadTimeoutException(ConsistencyLevel consistency,
int received,
int blockFor,
boolean dataPresent) |
RequestFailureException(ExceptionCode code,
ConsistencyLevel consistency,
int received,
int blockFor,
java.util.Map<java.net.InetAddress,RequestFailureReason> failureReasonByEndpoint) |
RequestTimeoutException(ExceptionCode code,
ConsistencyLevel consistency,
int received,
int blockFor) |
UnavailableException(ConsistencyLevel consistency,
int required,
int alive) |
UnavailableException(ConsistencyLevel consistency,
java.lang.String dc,
int required,
int alive) |
UnavailableException(java.lang.String msg,
ConsistencyLevel consistency,
int required,
int alive) |
WriteFailureException(ConsistencyLevel consistency,
int received,
int blockFor,
WriteType writeType,
java.util.Map<java.net.InetAddress,RequestFailureReason> failureReasonByEndpoint) |
WriteTimeoutException(WriteType writeType,
ConsistencyLevel consistency,
int received,
int blockFor) |
Modifier and Type | Method and Description |
---|---|
<T> AbstractWriteResponseHandler<T> |
AbstractReplicationStrategy.getWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistency_level,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
int |
MessagingService.addCallback(IAsyncCallback cb,
MessageOut<?> message,
java.net.InetAddress to,
long timeout,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
Constructor and Description |
---|
WriteCallbackInfo(java.net.InetAddress target,
IAsyncCallback callback,
MessageOut message,
IVersionedSerializer<?> serializer,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
Modifier and Type | Field and Description |
---|---|
protected ConsistencyLevel |
ResponseResolver.consistency |
ConsistencyLevel |
AbstractWriteResponseHandler.consistencyLevel |
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 RowIterator |
StorageProxy.cas(java.lang.String keyspaceName,
java.lang.String cfName,
DecoratedKey key,
CASRequest request,
ConsistencyLevel consistencyForPaxos,
ConsistencyLevel consistencyForCommit,
ClientState state,
long queryStartNanoTime)
Apply @param updates if and only if the current values in the row for @param key
match the provided @param conditions.
|
static PartitionIterator |
StorageProxy.getRangeSlice(PartitionRangeReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
static AbstractReadExecutor |
AbstractReadExecutor.getReadExecutor(SinglePartitionReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
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.mutateAtomically(java.util.Collection<Mutation> mutations,
ConsistencyLevel consistency_level,
boolean requireQuorumForRemove,
long queryStartNanoTime)
See mutate.
|
static void |
StorageProxy.mutateWithTriggers(java.util.Collection<? extends IMutation> mutations,
ConsistencyLevel consistencyLevel,
boolean mutateAtomically,
long queryStartNanoTime) |
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.
|
static PartitionIterator |
StorageProxy.read(SinglePartitionReadCommand.Group group,
ConsistencyLevel consistencyLevel,
ClientState state,
long queryStartNanoTime)
Performs the actual reading of a row out of the StorageService, fetching
a specific set of column names from a given column family.
|
static PartitionIterator |
StorageProxy.read(SinglePartitionReadCommand.Group group,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
static RowIterator |
StorageProxy.readOne(SinglePartitionReadCommand command,
ConsistencyLevel consistencyLevel,
ClientState state,
long queryStartNanoTime) |
static RowIterator |
StorageProxy.readOne(SinglePartitionReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
Constructor and Description |
---|
AbstractWriteResponseHandler(Keyspace keyspace,
java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DatacenterSyncWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DatacenterWriteResponseHandler(java.util.Collection<java.net.InetAddress> naturalEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
DigestResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
NeverSpeculatingReadExecutor(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistencyLevel,
java.util.List<java.net.InetAddress> targetReplicas,
long queryStartNanoTime) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
int blockfor,
ReadCommand command,
Keyspace keyspace,
java.util.List<java.net.InetAddress> endpoints,
long queryStartNanoTime) |
ReadCallback(ResponseResolver resolver,
ConsistencyLevel consistencyLevel,
ReadCommand command,
java.util.List<java.net.InetAddress> filteredEndpoints,
long queryStartNanoTime)
Constructor when response count has to be calculated and blocked for.
|
ResponseResolver(Keyspace keyspace,
ReadCommand command,
ConsistencyLevel consistency,
int maxResponseCount) |
WriteResponseHandler(java.util.Collection<java.net.InetAddress> writeEndpoints,
java.util.Collection<java.net.InetAddress> pendingEndpoints,
ConsistencyLevel consistencyLevel,
Keyspace keyspace,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
PartitionIterator |
AggregationQueryPager.fetchPage(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
MultiPartitionPager.fetchPage(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
QueryPager.fetchPage(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime)
Fetches the next page.
|
Constructor and Description |
---|
AggregationPartitionIterator(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
GroupByPartitionIterator(int pageSize,
ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
Constructor and Description |
---|
AbstractPaxosCallback(int targets,
ConsistencyLevel consistency,
long queryStartNanoTime) |
PrepareCallback(DecoratedKey key,
CFMetaData metadata,
int targets,
ConsistencyLevel consistency,
long queryStartNanoTime) |
ProposeCallback(int totalTargets,
int requiredTargets,
boolean failFast,
ConsistencyLevel consistency,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
static ConsistencyLevel |
CBUtil.readConsistencyLevel(io.netty.buffer.ByteBuf cb) |
Modifier and Type | Method and Description |
---|---|
ResultMessage |
SimpleClient.execute(java.lang.String query,
ConsistencyLevel consistency) |
ResultMessage |
SimpleClient.execute(java.lang.String query,
java.util.List<java.nio.ByteBuffer> values,
ConsistencyLevel consistencyLevel) |
ResultMessage |
SimpleClient.executePrepared(byte[] statementId,
java.util.List<java.nio.ByteBuffer> values,
ConsistencyLevel consistency) |
static int |
CBUtil.sizeOfConsistencyLevel(ConsistencyLevel consistency) |
static void |
CBUtil.writeConsistencyLevel(ConsistencyLevel consistency,
io.netty.buffer.ByteBuf cb) |
Copyright © 2018 The Apache Software Foundation