Uses of Class
org.apache.cassandra.db.ConsistencyLevel

Packages that use ConsistencyLevel

Package	Description
org.apache.cassandra.auth
org.apache.cassandra.config
org.apache.cassandra.cql3
org.apache.cassandra.cql3.statements
org.apache.cassandra.db
org.apache.cassandra.exceptions
org.apache.cassandra.locator
org.apache.cassandra.metrics
org.apache.cassandra.net
org.apache.cassandra.service
org.apache.cassandra.service.pager
org.apache.cassandra.service.paxos
org.apache.cassandra.service.reads
org.apache.cassandra.service.reads.range
org.apache.cassandra.service.reads.repair
org.apache.cassandra.transport

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 hints

Methods 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>> E	ReplicaPlans.Selector.select(ConsistencyLevel consistencyLevel, L liveAndDown, L live)	Select the Endpoints 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)