Uses of Class
org.apache.cassandra.db.ConsistencyLevel
-
-
Uses of ConsistencyLevel in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth that return ConsistencyLevel Modifier and Type Method Description protected static ConsistencyLevel
CassandraRoleManager. consistencyForRole(java.lang.String role)
-
Uses of ConsistencyLevel in org.apache.cassandra.config
Fields in org.apache.cassandra.config declared as ConsistencyLevel Modifier and Type Field Description ConsistencyLevel
Config. ideal_consistency_level
Maintain statistics on whether writes achieve the ideal consistency level before expiring and becoming hintsMethods in org.apache.cassandra.config that return ConsistencyLevel Modifier and Type Method Description static ConsistencyLevel
DatabaseDescriptor. getIdealConsistencyLevel()
Methods in org.apache.cassandra.config with parameters of type ConsistencyLevel Modifier and Type Method Description static void
DatabaseDescriptor. setIdealConsistencyLevel(ConsistencyLevel cl)
-
Uses of ConsistencyLevel in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return ConsistencyLevel Modifier and Type Method Description ConsistencyLevel
BatchQueryOptions. getConsistency()
abstract ConsistencyLevel
QueryOptions. getConsistency()
ConsistencyLevel
BatchQueryOptions. getSerialConsistency()
ConsistencyLevel
QueryOptions. getSerialConsistency()
Serial consistency for conditional updates.Methods in org.apache.cassandra.cql3 with parameters of type ConsistencyLevel Modifier and Type Method 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)
-
Uses of ConsistencyLevel in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type ConsistencyLevel Modifier and Type Method Description PartitionUpdate.Builder
UpdatesCollector. getPartitionUpdateBuilder(TableMetadata metadata, DecoratedKey dk, ConsistencyLevel consistency)
-
Uses of ConsistencyLevel in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return ConsistencyLevel Modifier and Type Method 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.Methods in org.apache.cassandra.db with parameters of type ConsistencyLevel Modifier and Type Method 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.Constructors in org.apache.cassandra.db with parameters of type ConsistencyLevel Constructor Description CounterMutation(Mutation mutation, ConsistencyLevel consistency)
-
Uses of ConsistencyLevel in org.apache.cassandra.exceptions
Fields in org.apache.cassandra.exceptions declared as ConsistencyLevel Modifier and Type Field Description ConsistencyLevel
CasWriteUnknownResultException. consistency
ConsistencyLevel
RequestFailureException. consistency
ConsistencyLevel
RequestTimeoutException. consistency
ConsistencyLevel
UnavailableException. consistency
Methods in org.apache.cassandra.exceptions with parameters of type ConsistencyLevel Modifier and Type Method 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)
Constructors in org.apache.cassandra.exceptions with parameters of type ConsistencyLevel Constructor 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)
-
Uses of ConsistencyLevel in org.apache.cassandra.locator
Fields in org.apache.cassandra.locator declared as ConsistencyLevel Modifier and Type Field Description protected ConsistencyLevel
ReplicaPlan. consistencyLevel
Methods in org.apache.cassandra.locator that return ConsistencyLevel Modifier and Type Method Description ConsistencyLevel
ReplicaPlan. consistencyLevel()
Methods in org.apache.cassandra.locator with parameters of type ConsistencyLevel Modifier and Type Method 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, Token token, ReplicaPlans.Selector selector)
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)
<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>>
EReplicaPlans.Selector. select(ConsistencyLevel consistencyLevel, L liveAndDown, L live)
Select theEndpoints
from {@param liveAndDown} and {@param live} to contact according to the consistency level.Constructors in org.apache.cassandra.locator with parameters of type ConsistencyLevel Constructor 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)
-
Uses of ConsistencyLevel in org.apache.cassandra.metrics
Methods in org.apache.cassandra.metrics with parameters of type ConsistencyLevel Modifier and Type Method Description static ClientRequestMetrics
ClientRequestsMetricsHolder. readMetricsForLevel(ConsistencyLevel level)
static ClientWriteRequestMetrics
ClientRequestsMetricsHolder. writeMetricsForLevel(ConsistencyLevel level)
-
Uses of ConsistencyLevel in org.apache.cassandra.net
Methods in org.apache.cassandra.net with parameters of type ConsistencyLevel Modifier and Type Method Description void
RequestCallbacks. addWithExpiration(AbstractWriteResponseHandler<?> cb, Message<?> message, Replica to, ConsistencyLevel consistencyLevel, boolean allowHints)
-
Uses of ConsistencyLevel in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return ConsistencyLevel Modifier and Type Method Description ConsistencyLevel
AbstractWriteResponseHandler. consistencyLevel()
Methods in org.apache.cassandra.service with parameters of type ConsistencyLevel Modifier and Type Method 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, long queryStartNanoTime)
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 RowIterator
StorageProxy. readOne(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, long queryStartNanoTime)
static RowIterator
StorageProxy. readOne(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, ClientState state, long queryStartNanoTime)
-
Uses of ConsistencyLevel in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type ConsistencyLevel Modifier and Type Method 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.Constructors in org.apache.cassandra.service.pager with parameters of type ConsistencyLevel Constructor Description AggregationPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, long queryStartNanoTime)
GroupByPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, long queryStartNanoTime)
-
Uses of ConsistencyLevel in org.apache.cassandra.service.paxos
Constructors in org.apache.cassandra.service.paxos with parameters of type ConsistencyLevel Constructor 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)
-
Uses of ConsistencyLevel in org.apache.cassandra.service.reads
Methods in org.apache.cassandra.service.reads with parameters of type ConsistencyLevel Modifier and Type Method Description static AbstractReadExecutor
AbstractReadExecutor. getReadExecutor(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, long queryStartNanoTime)
-
Uses of ConsistencyLevel in org.apache.cassandra.service.reads.range
Methods in org.apache.cassandra.service.reads.range with parameters of type ConsistencyLevel Modifier and Type Method Description static PartitionIterator
RangeCommands. partitions(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, long queryStartNanoTime)
-
Uses of ConsistencyLevel in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type ConsistencyLevel Modifier and Type Method 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. -
Uses of ConsistencyLevel in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport that return ConsistencyLevel Modifier and Type Method Description static ConsistencyLevel
CBUtil. readConsistencyLevel(io.netty.buffer.ByteBuf cb)
Methods in org.apache.cassandra.transport with parameters of type ConsistencyLevel Modifier and Type Method Description ResultMessage
SimpleClient. execute(java.lang.String query, java.util.List<java.nio.ByteBuffer> values, ConsistencyLevel consistencyLevel)
ResultMessage
SimpleClient. execute(java.lang.String query, ConsistencyLevel consistency)
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)
-