Uses of Enum Class
org.apache.cassandra.db.ConsistencyLevel
Packages that use ConsistencyLevel
Package
Description
-
Uses of ConsistencyLevel in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth that return ConsistencyLevelModifier and TypeMethodDescriptionstatic ConsistencyLevelCassandraAuthorizer.authReadConsistencyLevel()static ConsistencyLevelCassandraAuthorizer.authWriteConsistencyLevel()protected static ConsistencyLevelCassandraRoleManager.consistencyForRole(String role) protected static ConsistencyLevelCassandraRoleManager.consistencyForRoleRead(String role) protected static ConsistencyLevelCassandraRoleManager.consistencyForRoleWrite(String role) Allows selective overriding of the consistency level for specific roles.AuthProperties.getReadConsistencyLevel()AuthPropertiesMXBean.getReadConsistencyLevel()AuthProperties.getWriteConsistencyLevel()AuthPropertiesMXBean.getWriteConsistencyLevel()Methods in org.apache.cassandra.auth with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionvoidAuthProperties.setReadConsistencyLevel(ConsistencyLevel cl) voidAuthPropertiesMXBean.setReadConsistencyLevel(ConsistencyLevel cl) voidAuthProperties.setWriteConsistencyLevel(ConsistencyLevel cl) voidAuthPropertiesMXBean.setWriteConsistencyLevel(ConsistencyLevel cl) Constructors in org.apache.cassandra.auth with parameters of type ConsistencyLevelModifierConstructorDescriptionAuthProperties(ConsistencyLevel writeConsistencyLevel, ConsistencyLevel readConsistencyLevel, boolean registerMBean) -
Uses of ConsistencyLevel in org.apache.cassandra.config
Fields in org.apache.cassandra.config declared as ConsistencyLevelModifier and TypeFieldDescriptionConfig.denylist_consistency_levelSince the denylist in many ways serves to protect the health of the cluster from partitions operators have identified as being in a bad state, we usually want more robustness than just CL.ONE on operations to/from these tables to ensure that these safeguards are in place.Config.ideal_consistency_levelMaintain statistics on whether writes achieve the ideal consistency level before expiring and becoming hintsFields in org.apache.cassandra.config with type parameters of type ConsistencyLevelModifier and TypeFieldDescriptionMethods in org.apache.cassandra.config that return ConsistencyLevelModifier and TypeMethodDescriptionstatic ConsistencyLevelDatabaseDescriptor.getAuthReadConsistencyLevel()static ConsistencyLevelDatabaseDescriptor.getAuthWriteConsistencyLevel()Deprecated.See CASSANDRA-17195static ConsistencyLevelDatabaseDescriptor.getDenylistConsistencyLevel()static ConsistencyLevelDatabaseDescriptor.getIdealConsistencyLevel()Methods in org.apache.cassandra.config that return types with arguments of type ConsistencyLevelModifier and TypeMethodDescriptionGuardrailsOptions.getReadConsistencyLevelsDisallowed()GuardrailsOptions.getReadConsistencyLevelsWarned()GuardrailsOptions.getWriteConsistencyLevelsDisallowed()GuardrailsOptions.getWriteConsistencyLevelsWarned()Methods in org.apache.cassandra.config with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic voidDatabaseDescriptor.setAuthReadConsistencyLevel(ConsistencyLevel cl) static voidDatabaseDescriptor.setAuthWriteConsistencyLevel(ConsistencyLevel cl) static voidDatabaseDescriptor.setDenylistConsistencyLevel(ConsistencyLevel cl) static voidDatabaseDescriptor.setIdealConsistencyLevel(ConsistencyLevel cl) Method parameters in org.apache.cassandra.config with type arguments of type ConsistencyLevelModifier and TypeMethodDescriptionvoidGuardrailsOptions.setReadConsistencyLevelsDisallowed(Set<ConsistencyLevel> consistencyLevels) voidGuardrailsOptions.setReadConsistencyLevelsWarned(Set<ConsistencyLevel> consistencyLevels) voidGuardrailsOptions.setWriteConsistencyLevelsDisallowed(Set<ConsistencyLevel> consistencyLevels) voidGuardrailsOptions.setWriteConsistencyLevelsWarned(Set<ConsistencyLevel> consistencyLevels) -
Uses of ConsistencyLevel in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return ConsistencyLevelModifier and TypeMethodDescriptionBatchQueryOptions.getConsistency()abstract ConsistencyLevelQueryOptions.getConsistency()BatchQueryOptions.getSerialConsistency()QueryOptions.getSerialConsistency()Serial consistency for conditional updates.Methods in org.apache.cassandra.cql3 with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic QueryOptionsQueryOptions.create(ConsistencyLevel consistency, List<ByteBuffer> values, boolean skipMetadata, int pageSize, PagingState pagingState, ConsistencyLevel serialConsistency, ProtocolVersion version, String keyspace) static QueryOptionsQueryOptions.create(ConsistencyLevel consistency, List<ByteBuffer> values, boolean skipMetadata, int pageSize, PagingState pagingState, ConsistencyLevel serialConsistency, ProtocolVersion version, String keyspace, long timestamp, long nowInSeconds) static UntypedResultSetUntypedResultSet.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 UntypedResultSetQueryProcessor.execute(String query, ConsistencyLevel cl, Object... values) static UntypedResultSetQueryProcessor.execute(String query, ConsistencyLevel cl, QueryState state, Object... values) static QueryOptionsQueryOptions.forInternalCalls(ConsistencyLevel consistency, List<ByteBuffer> values) static QueryOptionsQueryOptions.forInternalCallsWithNowInSec(long nowInSec, ConsistencyLevel consistency, List<ByteBuffer> values) static UntypedResultSetQueryProcessor.process(String query, ConsistencyLevel cl) static UntypedResultSetQueryProcessor.process(String query, ConsistencyLevel cl, List<ByteBuffer> values) static ResultMessageQueryProcessor.process(String queryString, ConsistencyLevel cl, QueryState queryState, Dispatcher.RequestTime requestTime) static QueryOptionsQueryOptions.withConsistencyLevel(QueryOptions options, ConsistencyLevel consistencyLevel) -
Uses of ConsistencyLevel in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionUpdatesCollector.getPartitionUpdateBuilder(TableMetadata metadata, DecoratedKey dk, ConsistencyLevel consistency) -
Uses of ConsistencyLevel in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return ConsistencyLevelModifier and TypeMethodDescriptionCounterMutation.consistency()static ConsistencyLevelConsistencyLevel.fromCode(int code) static ConsistencyLevelConsistencyLevel.fromString(String str) static ConsistencyLevelReturns the enum constant of this class with the specified name.static ConsistencyLevel[]ConsistencyLevel.values()Returns an array containing the constants of this enum class, in the order they are declared.Methods in org.apache.cassandra.db with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionPartitionRangeReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) PartitionRangeReadCommand.VirtualTablePartitionRangeReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) ReadQuery.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) Executes the query at the provided consistency level.SinglePartitionReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) SinglePartitionReadCommand.Group.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) SinglePartitionReadCommand.VirtualTableGroup.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) SinglePartitionReadCommand.VirtualTableSinglePartitionReadCommand.execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime) booleanConsistencyLevel.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 -
Uses of ConsistencyLevel in org.apache.cassandra.db.guardrails
Fields in org.apache.cassandra.db.guardrails with type parameters of type ConsistencyLevelModifier and TypeFieldDescriptionstatic final Values<ConsistencyLevel>Guardrails.readConsistencyLevelsGuardrail on read consistency levels.static final Values<ConsistencyLevel>Guardrails.writeConsistencyLevelsGuardrail on write consistency levels.Methods in org.apache.cassandra.db.guardrails that return types with arguments of type ConsistencyLevelModifier and TypeMethodDescriptionGuardrailsConfig.getReadConsistencyLevelsDisallowed()GuardrailsConfig.getReadConsistencyLevelsWarned()GuardrailsConfig.getWriteConsistencyLevelsDisallowed()GuardrailsConfig.getWriteConsistencyLevelsWarned() -
Uses of ConsistencyLevel in org.apache.cassandra.exceptions
Fields in org.apache.cassandra.exceptions declared as ConsistencyLevelModifier and TypeFieldDescriptionfinal ConsistencyLevelCasWriteUnknownResultException.consistencyfinal ConsistencyLevelRequestFailureException.consistencyfinal ConsistencyLevelRequestTimeoutException.consistencyfinal ConsistencyLevelUnavailableException.consistencyMethods in org.apache.cassandra.exceptions with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic UnavailableExceptionUnavailableException.create(ConsistencyLevel consistency, int required, int alive) static UnavailableExceptionUnavailableException.create(ConsistencyLevel consistency, int required, int requiredFull, int alive, int aliveFull) static UnavailableExceptionUnavailableException.create(ConsistencyLevel consistency, String dc, int required, int requiredFull, int alive, int aliveFull) Constructors in org.apache.cassandra.exceptions with parameters of type ConsistencyLevelModifierConstructorDescriptionCasWriteTimeoutException(WriteType writeType, ConsistencyLevel consistency, int received, int blockFor, int contentions) CasWriteUnknownResultException(ConsistencyLevel consistency, int received, int blockFor) QueryReferencesTooManyIndexesAbortException(String msg, int nodes, long maxValue, boolean dataPresent, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) protectedReadAbortException(String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) protectedReadFailureException(String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) ReadFailureException(ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) ReadSizeAbortException(String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) ReadTimeoutException(ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent) RequestFailureException(ExceptionCode code, String msg, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) protectedRequestFailureException(ExceptionCode code, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) protectedRequestTimeoutException(ExceptionCode code, ConsistencyLevel consistency, int received, int blockFor) protectedRequestTimeoutException(ExceptionCode code, ConsistencyLevel consistency, int received, int blockFor, String msg) TombstoneAbortException(String message, int nodes, long tombstones, boolean dataPresent, ConsistencyLevel consistency, int received, int blockFor, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) UnavailableException(String msg, ConsistencyLevel consistency, int required, int alive) WriteFailureException(ConsistencyLevel consistency, int received, int blockFor, WriteType writeType, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) WriteTimeoutException(WriteType writeType, ConsistencyLevel consistency, int received, int blockFor) WriteTimeoutException(WriteType writeType, ConsistencyLevel consistency, int received, int blockFor, String msg) -
Uses of ConsistencyLevel in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type ConsistencyLevelModifier and TypeMethodDescription<E extends Endpoints<E>>
EIndexStatusManager.filterForQuery(E liveEndpoints, Keyspace keyspace, Index.QueryPlan indexQueryPlan, ConsistencyLevel level) Remove endpoints whose indexes are not queryable for the specifiedIndex.QueryPlan. -
Uses of ConsistencyLevel in org.apache.cassandra.locator
Fields in org.apache.cassandra.locator declared as ConsistencyLevelModifier and TypeFieldDescriptionprotected final ConsistencyLevelReplicaPlan.AbstractReplicaPlan.consistencyLevelMethods in org.apache.cassandra.locator that return ConsistencyLevelModifier and TypeMethodDescriptionReplicaPlan.AbstractReplicaPlan.consistencyLevel()ReplicaPlan.consistencyLevel()Methods in org.apache.cassandra.locator with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic ReplicaPlan.ForRangeReadReplicaPlans.forFullRangeRead(Keyspace keyspace, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, Set<InetAddressAndPort> endpointsToContact, int vnodeCount) Construct a plan for reading the provided range at the provided consistency level on given endpoints.static ReplicaPlan.ForPaxosWriteReplicaPlans.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.ForRangeReadReplicaPlans.forRangeRead(Keyspace keyspace, Index.QueryPlan indexQueryPlan, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, int vnodeCount) Construct a plan for reading the provided range at the provided consistency level.static ReplicaPlan.ForTokenReadReplicaPlans.forRead(Keyspace keyspace, Token token, Index.QueryPlan indexQueryPlan, ConsistencyLevel consistencyLevel, SpeculativeRetryPolicy retry) Construct a plan for reading the provided token at the provided consistency level.static ReplicaPlan.ForWriteReplicaPlans.forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, Token token, ReplicaPlans.Selector selector) static ReplicaPlan.ForWriteReplicaPlans.forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, EndpointsForToken natural, EndpointsForToken pending, Predicate<Replica> isAlive, ReplicaPlans.Selector selector) static ReplicaPlan.ForWriteReplicaPlans.forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, ReplicaLayout.ForTokenWrite liveAndDown, ReplicaLayout.ForTokenWrite live, ReplicaPlans.Selector selector) static ReplicaPlan.ForWriteReplicaPlans.forWrite(Keyspace keyspace, ConsistencyLevel consistencyLevel, ReplicaLayout.ForTokenWrite liveAndDown, ReplicaPlans.Selector selector) <T> AbstractWriteResponseHandler<T>AbstractReplicationStrategy.getWriteResponseHandler(ReplicaPlan.ForWrite replicaPlan, Runnable callback, WriteType writeType, Supplier<Mutation> hintOnFailure, Dispatcher.RequestTime requestTime, ConsistencyLevel idealConsistencyLevel) static booleanReplicaPlans.isSufficientLiveReplicasForRead(AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, Endpoints<?> liveReplicas) static ReplicaPlan.ForRangeReadReplicaPlans.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 theEndpointsfrom and to contact according to the consistency level.Constructors in org.apache.cassandra.locator with parameters of type ConsistencyLevelModifierConstructorDescriptionForFullRangeRead(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, AbstractBounds<PartitionPosition> range, EndpointsForRange candidates, EndpointsForRange contact, int vnodeCount) 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) ForWrite(Keyspace keyspace, AbstractReplicationStrategy replicationStrategy, ConsistencyLevel consistencyLevel, EndpointsForToken pending, EndpointsForToken liveAndDown, EndpointsForToken live, EndpointsForToken contact) -
Uses of ConsistencyLevel in org.apache.cassandra.metrics
Fields in org.apache.cassandra.metrics with type parameters of type ConsistencyLevelModifier and TypeFieldDescriptionstatic final Map<ConsistencyLevel,ClientRequestMetrics> ClientRequestsMetricsHolder.readMetricsMapstatic final Map<ConsistencyLevel,ClientWriteRequestMetrics> ClientRequestsMetricsHolder.writeMetricsMapMethods in org.apache.cassandra.metrics with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic ClientRequestMetricsClientRequestsMetricsHolder.readMetricsForLevel(ConsistencyLevel level) static ClientWriteRequestMetricsClientRequestsMetricsHolder.writeMetricsForLevel(ConsistencyLevel level) -
Uses of ConsistencyLevel in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return ConsistencyLevelMethods in org.apache.cassandra.service with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic RowIteratorStorageProxy.cas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime) Apply @param updates if and only if the current values in the row for @param key match the provided @param conditions.static PartitionIteratorStorageProxy.getRangeSlice(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime) static RowIteratorStorageProxy.legacyCas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime) static voidStorageProxy.mutate(List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime) Use this method to have these Mutations applied across all replicas.static voidStorageProxy.mutateAtomically(Collection<Mutation> mutations, ConsistencyLevel consistency_level, boolean requireQuorumForRemove, Dispatcher.RequestTime requestTime) See mutate.static voidStorageProxy.mutateWithTriggers(List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, boolean mutateAtomically, Dispatcher.RequestTime requestTime) StorageProxy.performWrite(IMutation mutation, ConsistencyLevel consistencyLevel, String localDataCenter, StorageProxy.WritePerformer performer, Runnable callback, WriteType writeType, Dispatcher.RequestTime requestTime) Perform the write of a mutation given a WritePerformer.static PartitionIteratorStorageProxy.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime) Performs the actual reading of a row out of the StorageService, fetching a specific set of column names from a given column family.static RowIteratorStorageProxy.readOne(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime) static voidStorageProxy.recordReadRegularAbort(ConsistencyLevel consistencyLevel, Throwable cause) -
Uses of ConsistencyLevel in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionAggregationQueryPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) MultiPartitionPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) QueryPager.fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) Fetches the next page.Constructors in org.apache.cassandra.service.pager with parameters of type ConsistencyLevelModifierConstructorDescriptionAggregationPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) GroupByPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) -
Uses of ConsistencyLevel in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos that return ConsistencyLevelMethods in org.apache.cassandra.service.paxos with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic BallotPaxos.ballotForConsistency(long whenInMicros, ConsistencyLevel consistency) Create a ballot uuid with the consistency level encoded in the timestamp.static RowIteratorPaxos.cas(DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForConsensus, ConsistencyLevel consistencyForCommit, ClientState clientState) Apply @param updates if and only if the current values in the row for @param key match the provided @param conditions.static RowIteratorPaxos.cas(DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForConsensus, ConsistencyLevel consistencyForCommit, ClientState clientState, long proposeDeadline, long commitDeadline) static PaxosRepairPaxosRepair.create(ConsistencyLevel consistency, DecoratedKey partitionKey, Ballot incompleteBallot, TableMetadata table) static PaxosOperationLockPaxosState.lock(DecoratedKey partitionKey, TableMetadata metadata, long deadline, ConsistencyLevel consistencyForConsensus, boolean isWrite) static BallotPaxos.newBallot(Ballot minimumBallot, ConsistencyLevel consistency) static PartitionIteratorPaxos.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, long deadline) static PartitionIteratorPaxos.read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, Dispatcher.RequestTime requestTime) Constructors in org.apache.cassandra.service.paxos with parameters of type ConsistencyLevelModifierConstructorDescriptionPaxosCommit(Commit.Agreed commit, boolean allowHints, ConsistencyLevel consistencyForConsensus, ConsistencyLevel consistencyForCommit, org.apache.cassandra.service.paxos.Paxos.Participants participants, OnDone onDone) -
Uses of ConsistencyLevel in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted that return ConsistencyLevelModifier and TypeMethodDescriptionPaxosKeyState.getConsistencyLevel()UncommittedPaxosKey.getConsistencyLevel() -
Uses of ConsistencyLevel in org.apache.cassandra.service.paxos.v1
Constructors in org.apache.cassandra.service.paxos.v1 with parameters of type ConsistencyLevelModifierConstructorDescriptionAbstractPaxosCallback(int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime) PrepareCallback(DecoratedKey key, TableMetadata metadata, int targets, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime) ProposeCallback(int totalTargets, int requiredTargets, boolean failFast, ConsistencyLevel consistency, Dispatcher.RequestTime requestTime) -
Uses of ConsistencyLevel in org.apache.cassandra.service.reads
Methods in org.apache.cassandra.service.reads with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic AbstractReadExecutorAbstractReadExecutor.getReadExecutor(SinglePartitionReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime) -
Uses of ConsistencyLevel in org.apache.cassandra.service.reads.range
Methods in org.apache.cassandra.service.reads.range with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic PartitionIteratorRangeCommands.partitions(PartitionRangeReadCommand command, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime) static booleanRangeCommands.sufficientLiveNodesForSelectStar(TableMetadata metadata, ConsistencyLevel consistency) Added specifically to check for sufficient nodes live to serve partition denylist queries -
Uses of ConsistencyLevel in org.apache.cassandra.service.reads.repair
Methods in org.apache.cassandra.service.reads.repair with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionstatic MutationBlockingReadRepairs.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.service.reads.thresholds
Methods in org.apache.cassandra.service.reads.thresholds with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionvoidWarningsSnapshot.maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, Map<InetAddressAndPort, RequestFailureReason> failureReasonByEndpoint) -
Uses of ConsistencyLevel in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport that return ConsistencyLevelModifier and TypeMethodDescriptionstatic ConsistencyLevelCBUtil.readConsistencyLevel(io.netty.buffer.ByteBuf cb) Methods in org.apache.cassandra.transport with parameters of type ConsistencyLevelModifier and TypeMethodDescriptionSimpleClient.execute(String query, List<ByteBuffer> values, ConsistencyLevel consistencyLevel) SimpleClient.execute(String query, ConsistencyLevel consistency) SimpleClient.executePrepared(ResultMessage.Prepared prepared, List<ByteBuffer> values, ConsistencyLevel consistency) static intCBUtil.sizeOfConsistencyLevel(ConsistencyLevel consistency) static voidCBUtil.writeConsistencyLevel(ConsistencyLevel consistency, io.netty.buffer.ByteBuf cb)