Modifier and Type | Method and Description |
---|---|
protected static ConsistencyLevel |
CassandraRoleManager.consistencyForRole(java.lang.String role) |
Modifier and Type | Field and Description |
---|---|
ConsistencyLevel |
Config.ideal_consistency_level
Maintain statistics on whether writes achieve the ideal consistency level
before expiring and becoming hints
|
Modifier and Type | Method and Description |
---|---|
static ConsistencyLevel |
DatabaseDescriptor.getIdealConsistencyLevel() |
Modifier and Type | Method and Description |
---|---|
static void |
DatabaseDescriptor.setIdealConsistencyLevel(ConsistencyLevel cl) |
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,
java.lang.String keyspace) |
static QueryOptions |
QueryOptions.create(ConsistencyLevel consistency,
java.util.List<java.nio.ByteBuffer> values,
boolean skipMetadata,
int pageSize,
PagingState pagingState,
ConsistencyLevel serialConsistency,
ProtocolVersion version,
java.lang.String keyspace,
long timestamp,
int nowInSeconds) |
static UntypedResultSet |
UntypedResultSet.create(SelectStatement select,
ConsistencyLevel cl,
ClientState clientState,
QueryPager pager,
int pageSize)
This method is intended for testing purposes, since it executes query on cluster
and not on the local node only.
|
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 |
---|---|
PartitionUpdate.Builder |
UpdatesCollector.getPartitionUpdateBuilder(TableMetadata metadata,
DecoratedKey dk,
ConsistencyLevel consistency) |
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) |
PartitionIterator |
VirtualTableReadQuery.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
PartitionIterator |
VirtualTableSinglePartitionReadQuery.Group.execute(ConsistencyLevel consistency,
ClientState clientState,
long queryStartNanoTime) |
boolean |
ConsistencyLevel.satisfies(ConsistencyLevel other,
AbstractReplicationStrategy replicationStrategy)
Determine if this consistency level meets or exceeds the consistency requirements of the given cl for the given keyspace
WARNING: this is not locality aware; you cannot safely use this with mixed locality consistency levels (e.g.
|
Constructor and Description |
---|
CounterMutation(Mutation mutation,
ConsistencyLevel consistency) |
Modifier and Type | Field and Description |
---|---|
ConsistencyLevel |
CasWriteUnknownResultException.consistency |
ConsistencyLevel |
RequestFailureException.consistency |
ConsistencyLevel |
RequestTimeoutException.consistency |
ConsistencyLevel |
UnavailableException.consistency |
Modifier and Type | Method and Description |
---|---|
static UnavailableException |
UnavailableException.create(ConsistencyLevel consistency,
int required,
int alive) |
static UnavailableException |
UnavailableException.create(ConsistencyLevel consistency,
int required,
int requiredFull,
int alive,
int aliveFull) |
static UnavailableException |
UnavailableException.create(ConsistencyLevel consistency,
java.lang.String dc,
int required,
int requiredFull,
int alive,
int aliveFull) |
Constructor and Description |
---|
CasWriteTimeoutException(WriteType writeType,
ConsistencyLevel consistency,
int received,
int blockFor,
int contentions) |
CasWriteUnknownResultException(ConsistencyLevel consistency,
int received,
int blockFor) |
ReadFailureException(ConsistencyLevel consistency,
int received,
int blockFor,
boolean dataPresent,
java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint) |
ReadTimeoutException(ConsistencyLevel consistency,
int received,
int blockFor,
boolean dataPresent) |
RequestFailureException(ExceptionCode code,
ConsistencyLevel consistency,
int received,
int blockFor,
java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint) |
RequestTimeoutException(ExceptionCode code,
ConsistencyLevel consistency,
int received,
int blockFor) |
RequestTimeoutException(ExceptionCode code,
ConsistencyLevel consistency,
int received,
int blockFor,
java.lang.String msg) |
UnavailableException(java.lang.String msg,
ConsistencyLevel consistency,
int required,
int alive) |
WriteFailureException(ConsistencyLevel consistency,
int received,
int blockFor,
WriteType writeType,
java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint) |
WriteTimeoutException(WriteType writeType,
ConsistencyLevel consistency,
int received,
int blockFor) |
WriteTimeoutException(WriteType writeType,
ConsistencyLevel consistency,
int received,
int blockFor,
java.lang.String msg) |
Modifier and Type | Field and Description |
---|---|
protected ConsistencyLevel |
ReplicaPlan.consistencyLevel |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
ReplicaPlan.consistencyLevel() |
Modifier and Type | Method and Description |
---|---|
static ReplicaPlan.ForPaxosWrite |
ReplicaPlans.forPaxos(Keyspace keyspace,
DecoratedKey key,
ConsistencyLevel consistencyForPaxos)
Construct the plan for a paxos round - NOT the write or read consistency level for either the write or comparison,
but for the paxos linearisation agreement.
|
static ReplicaPlan.ForRangeRead |
ReplicaPlans.forRangeRead(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
AbstractBounds<PartitionPosition> range,
int vnodeCount)
Construct a plan for reading the provided range at the provided consistency level.
|
static ReplicaPlan.ForTokenRead |
ReplicaPlans.forRead(Keyspace keyspace,
Token token,
ConsistencyLevel consistencyLevel,
SpeculativeRetryPolicy retry)
Construct a plan for reading the provided token at the provided consistency level.
|
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
EndpointsForToken natural,
EndpointsForToken pending,
java.util.function.Predicate<Replica> isAlive,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaLayout.ForTokenWrite liveAndDown,
ReplicaLayout.ForTokenWrite live,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaLayout.ForTokenWrite liveAndDown,
ReplicaPlans.Selector selector) |
static ReplicaPlan.ForTokenWrite |
ReplicaPlans.forWrite(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
Token token,
ReplicaPlans.Selector selector) |
<T> AbstractWriteResponseHandler<T> |
AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForTokenWrite replicaPlan,
java.lang.Runnable callback,
WriteType writeType,
long queryStartNanoTime,
ConsistencyLevel idealConsistencyLevel) |
static boolean |
ReplicaPlans.isSufficientLiveReplicasForRead(AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
Endpoints<?> liveReplicas) |
static ReplicaPlan.ForRangeRead |
ReplicaPlans.maybeMerge(Keyspace keyspace,
ConsistencyLevel consistencyLevel,
ReplicaPlan.ForRangeRead left,
ReplicaPlan.ForRangeRead right)
Take two range read plans for adjacent ranges, and check if it is OK (and worthwhile) to combine them into a single plan
|
<E extends Endpoints<E>,L extends ReplicaLayout.ForWrite<E>> |
ReplicaPlans.Selector.select(ConsistencyLevel consistencyLevel,
L liveAndDown,
L live)
Select the
Endpoints from and to contact according to the consistency level. |
Constructor and Description |
---|
ForRangeRead(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
AbstractBounds<PartitionPosition> range,
EndpointsForRange candidates,
EndpointsForRange contact,
int vnodeCount) |
ForTokenRead(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
EndpointsForToken candidates,
EndpointsForToken contacts) |
ForTokenWrite(Keyspace keyspace,
AbstractReplicationStrategy replicationStrategy,
ConsistencyLevel consistencyLevel,
EndpointsForToken pending,
EndpointsForToken liveAndDown,
EndpointsForToken live,
EndpointsForToken contact) |
Modifier and Type | Method and Description |
---|---|
static ClientRequestMetrics |
ClientRequestsMetricsHolder.readMetricsForLevel(ConsistencyLevel level) |
static ClientWriteRequestMetrics |
ClientRequestsMetricsHolder.writeMetricsForLevel(ConsistencyLevel level) |
Modifier and Type | Method and Description |
---|---|
void |
RequestCallbacks.addWithExpiration(AbstractWriteResponseHandler<?> cb,
Message<?> message,
Replica to,
ConsistencyLevel consistencyLevel,
boolean allowHints) |
Modifier and Type | Method and Description |
---|---|
ConsistencyLevel |
AbstractWriteResponseHandler.consistencyLevel() |
Modifier and Type | Method and Description |
---|---|
static RowIterator |
StorageProxy.cas(java.lang.String keyspaceName,
java.lang.String cfName,
DecoratedKey key,
CASRequest request,
ConsistencyLevel consistencyForPaxos,
ConsistencyLevel consistencyForCommit,
ClientState state,
int nowInSeconds,
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 void |
StorageProxy.mutate(java.util.List<? extends IMutation> mutations,
ConsistencyLevel consistencyLevel,
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.List<? extends IMutation> mutations,
ConsistencyLevel consistencyLevel,
boolean mutateAtomically,
long queryStartNanoTime) |
static AbstractWriteResponseHandler<IMutation> |
StorageProxy.performWrite(IMutation mutation,
ConsistencyLevel consistencyLevel,
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) |
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,
TableMetadata 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 AbstractReadExecutor |
AbstractReadExecutor.getReadExecutor(SinglePartitionReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
static PartitionIterator |
RangeCommands.partitions(PartitionRangeReadCommand command,
ConsistencyLevel consistencyLevel,
long queryStartNanoTime) |
Modifier and Type | Method and Description |
---|---|
static Mutation |
BlockingReadRepairs.createRepairMutation(PartitionUpdate update,
ConsistencyLevel consistency,
InetAddressAndPort destination,
boolean suppressException)
Create a read repair mutation from the given update, if the mutation is not larger than the maximum
mutation size, otherwise return null.
|
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(ResultMessage.Prepared prepared,
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 © 2009-2022 The Apache Software Foundation