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 static ConsistencyLevelCassandraAuthorizer. authReadConsistencyLevel()static ConsistencyLevelCassandraAuthorizer. authWriteConsistencyLevel()protected static ConsistencyLevelCassandraRoleManager. consistencyForRole(java.lang.String role)protected static ConsistencyLevelCassandraRoleManager. consistencyForRoleRead(java.lang.String role)protected static ConsistencyLevelCassandraRoleManager. consistencyForRoleWrite(java.lang.String role)Allows selective overriding of the consistency level for specific roles.ConsistencyLevelAuthProperties. getReadConsistencyLevel()ConsistencyLevelAuthPropertiesMXBean. getReadConsistencyLevel()ConsistencyLevelAuthProperties. getWriteConsistencyLevel()ConsistencyLevelAuthPropertiesMXBean. getWriteConsistencyLevel()Methods in org.apache.cassandra.auth with parameters of type ConsistencyLevel Modifier and Type Method Description voidAuthProperties. 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 ConsistencyLevel Constructor Description AuthProperties(ConsistencyLevel writeConsistencyLevel, ConsistencyLevel readConsistencyLevel, boolean registerMBean) -
Uses of ConsistencyLevel in org.apache.cassandra.config
Fields in org.apache.cassandra.config declared as ConsistencyLevel Modifier and Type Field Description ConsistencyLevelConfig. 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.ConsistencyLevelConfig. 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 ConsistencyLevel Modifier and Type Field Description java.util.Set<ConsistencyLevel>Config. read_consistency_levels_disallowedjava.util.Set<ConsistencyLevel>Config. read_consistency_levels_warnedjava.util.Set<ConsistencyLevel>Config. write_consistency_levels_disallowedjava.util.Set<ConsistencyLevel>Config. write_consistency_levels_warnedMethods in org.apache.cassandra.config that return ConsistencyLevel Modifier and Type Method Description static ConsistencyLevelDatabaseDescriptor. getAuthReadConsistencyLevel()static ConsistencyLevelDatabaseDescriptor. getAuthWriteConsistencyLevel()Deprecated.static ConsistencyLevelDatabaseDescriptor. getDenylistConsistencyLevel()static ConsistencyLevelDatabaseDescriptor. getIdealConsistencyLevel()Methods in org.apache.cassandra.config that return types with arguments of type ConsistencyLevel Modifier and Type Method Description java.util.Set<ConsistencyLevel>GuardrailsOptions. getReadConsistencyLevelsDisallowed()java.util.Set<ConsistencyLevel>GuardrailsOptions. getReadConsistencyLevelsWarned()java.util.Set<ConsistencyLevel>GuardrailsOptions. getWriteConsistencyLevelsDisallowed()java.util.Set<ConsistencyLevel>GuardrailsOptions. getWriteConsistencyLevelsWarned()Methods in org.apache.cassandra.config with parameters of type ConsistencyLevel Modifier and Type Method Description static 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 ConsistencyLevel Modifier and Type Method Description voidGuardrailsOptions. setReadConsistencyLevelsDisallowed(java.util.Set<ConsistencyLevel> consistencyLevels)voidGuardrailsOptions. setReadConsistencyLevelsWarned(java.util.Set<ConsistencyLevel> consistencyLevels)voidGuardrailsOptions. setWriteConsistencyLevelsDisallowed(java.util.Set<ConsistencyLevel> consistencyLevels)voidGuardrailsOptions. setWriteConsistencyLevelsWarned(java.util.Set<ConsistencyLevel> consistencyLevels) -
Uses of ConsistencyLevel in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that return ConsistencyLevel Modifier and Type Method Description ConsistencyLevelBatchQueryOptions. getConsistency()abstract ConsistencyLevelQueryOptions. getConsistency()ConsistencyLevelBatchQueryOptions. getSerialConsistency()ConsistencyLevelQueryOptions. getSerialConsistency()Serial consistency for conditional updates.Methods in org.apache.cassandra.cql3 with parameters of type ConsistencyLevel Modifier and Type Method Description static QueryOptionsQueryOptions. 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 QueryOptionsQueryOptions. 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 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(java.lang.String query, ConsistencyLevel cl, java.lang.Object... values)static UntypedResultSetQueryProcessor. execute(java.lang.String query, ConsistencyLevel cl, QueryState state, java.lang.Object... values)static QueryOptionsQueryOptions. forInternalCalls(ConsistencyLevel consistency, java.util.List<java.nio.ByteBuffer> values)static QueryOptionsQueryOptions. forInternalCallsWithNowInSec(int nowInSec, ConsistencyLevel consistency, java.util.List<java.nio.ByteBuffer> values)static UntypedResultSetQueryProcessor. process(java.lang.String query, ConsistencyLevel cl)static UntypedResultSetQueryProcessor. process(java.lang.String query, ConsistencyLevel cl, java.util.List<java.nio.ByteBuffer> values)static ResultMessageQueryProcessor. process(java.lang.String queryString, ConsistencyLevel cl, QueryState queryState, Dispatcher.RequestTime requestTime) -
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.BuilderUpdatesCollector. 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 ConsistencyLevelCounterMutation. consistency()static ConsistencyLevelConsistencyLevel. fromCode(int code)static ConsistencyLevelConsistencyLevel. fromString(java.lang.String str)static ConsistencyLevelConsistencyLevel. 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 PartitionIteratorPartitionRangeReadCommand. execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)PartitionIteratorPartitionRangeReadCommand.VirtualTablePartitionRangeReadCommand. execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)PartitionIteratorReadQuery. execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)Executes the query at the provided consistency level.PartitionIteratorSinglePartitionReadCommand. execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)PartitionIteratorSinglePartitionReadCommand.Group. execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)PartitionIteratorSinglePartitionReadCommand.VirtualTableGroup. execute(ConsistencyLevel consistency, ClientState state, Dispatcher.RequestTime requestTime)PartitionIteratorSinglePartitionReadCommand.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 Constructor Description CounterMutation(Mutation mutation, ConsistencyLevel consistency) -
Uses of ConsistencyLevel in org.apache.cassandra.db.guardrails
Fields in org.apache.cassandra.db.guardrails with type parameters of type ConsistencyLevel Modifier and Type Field Description static Values<ConsistencyLevel>Guardrails. readConsistencyLevelsGuardrail on read consistency levels.static Values<ConsistencyLevel>Guardrails. writeConsistencyLevelsGuardrail on write consistency levels.Methods in org.apache.cassandra.db.guardrails that return types with arguments of type ConsistencyLevel Modifier and Type Method Description java.util.Set<ConsistencyLevel>GuardrailsConfig. getReadConsistencyLevelsDisallowed()java.util.Set<ConsistencyLevel>GuardrailsConfig. getReadConsistencyLevelsWarned()java.util.Set<ConsistencyLevel>GuardrailsConfig. getWriteConsistencyLevelsDisallowed()java.util.Set<ConsistencyLevel>GuardrailsConfig. getWriteConsistencyLevelsWarned() -
Uses of ConsistencyLevel in org.apache.cassandra.exceptions
Fields in org.apache.cassandra.exceptions declared as ConsistencyLevel Modifier and Type Field Description ConsistencyLevelCasWriteUnknownResultException. consistencyConsistencyLevelRequestFailureException. consistencyConsistencyLevelRequestTimeoutException. consistencyConsistencyLevelUnavailableException. consistencyMethods in org.apache.cassandra.exceptions with parameters of type ConsistencyLevel Modifier and Type Method Description static 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, 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)ReadAbortException(java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)ReadFailureException(java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)ReadFailureException(ConsistencyLevel consistency, int received, int blockFor, boolean dataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)ReadSizeAbortException(java.lang.String msg, 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, java.lang.String msg, ConsistencyLevel consistency, int received, int blockFor, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)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)TombstoneAbortException(int nodes, long tombstones, java.lang.String cql, boolean dataPresent, ConsistencyLevel consistency, int received, int blockFor, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint)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 ConsistencyLevelReplicaPlan.AbstractReplicaPlan. consistencyLevelMethods in org.apache.cassandra.locator that return ConsistencyLevel Modifier and Type Method Description ConsistencyLevelReplicaPlan.AbstractReplicaPlan. consistencyLevel()ConsistencyLevelReplicaPlan. consistencyLevel()Methods in org.apache.cassandra.locator with parameters of type ConsistencyLevel Modifier and Type Method Description 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, 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, 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, java.util.function.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, java.lang.Runnable callback, WriteType writeType, java.util.function.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 {@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)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 ConsistencyLevel Modifier and Type Field Description static java.util.Map<ConsistencyLevel,ClientRequestMetrics>ClientRequestsMetricsHolder. readMetricsMapstatic java.util.Map<ConsistencyLevel,ClientWriteRequestMetrics>ClientRequestsMetricsHolder. writeMetricsMapMethods in org.apache.cassandra.metrics with parameters of type ConsistencyLevel Modifier and Type Method Description static 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 ConsistencyLevel Modifier and Type Method Description ConsistencyLevelAbstractWriteResponseHandler. consistencyLevel()Methods in org.apache.cassandra.service with parameters of type ConsistencyLevel Modifier and Type Method Description static RowIteratorStorageProxy. cas(java.lang.String keyspaceName, java.lang.String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, int 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(java.lang.String keyspaceName, java.lang.String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, int nowInSeconds, Dispatcher.RequestTime requestTime)static voidStorageProxy. mutate(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, Dispatcher.RequestTime requestTime)Use this method to have these Mutations applied across all replicas.static voidStorageProxy. mutateAtomically(java.util.Collection<Mutation> mutations, ConsistencyLevel consistency_level, boolean requireQuorumForRemove, Dispatcher.RequestTime requestTime)See mutate.static voidStorageProxy. mutateWithTriggers(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, boolean mutateAtomically, Dispatcher.RequestTime requestTime)static AbstractWriteResponseHandler<IMutation>StorageProxy. performWrite(IMutation mutation, ConsistencyLevel consistencyLevel, java.lang.String localDataCenter, StorageProxy.WritePerformer performer, java.lang.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, java.lang.Throwable cause) -
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 PartitionIteratorAggregationQueryPager. fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)PartitionIteratorMultiPartitionPager. fetchPage(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime)PartitionIteratorQueryPager. 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 ConsistencyLevel Constructor Description AggregationPartitionIterator(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 ConsistencyLevel Modifier and Type Method Description static ConsistencyLevelPaxos. consistency(Ballot ballot)Methods in org.apache.cassandra.service.paxos with parameters of type ConsistencyLevel Modifier and Type Method Description static 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 ConsistencyLevel Constructor Description PaxosCommit(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 ConsistencyLevel Modifier and Type Method Description ConsistencyLevelPaxosKeyState. getConsistencyLevel()ConsistencyLevelUncommittedPaxosKey. getConsistencyLevel() -
Uses of ConsistencyLevel in org.apache.cassandra.service.paxos.v1
Constructors in org.apache.cassandra.service.paxos.v1 with parameters of type ConsistencyLevel Constructor Description AbstractPaxosCallback(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 ConsistencyLevel Modifier and Type Method Description static 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 ConsistencyLevel Modifier and Type Method Description static 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 ConsistencyLevel Modifier and Type Method Description static 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 ConsistencyLevel Modifier and Type Method Description voidWarningsSnapshot. maybeAbort(ReadCommand command, ConsistencyLevel cl, int received, int blockFor, boolean isDataPresent, java.util.Map<InetAddressAndPort,RequestFailureReason> failureReasonByEndpoint) -
Uses of ConsistencyLevel in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport that return ConsistencyLevel Modifier and Type Method Description static ConsistencyLevelCBUtil. readConsistencyLevel(io.netty.buffer.ByteBuf cb)Methods in org.apache.cassandra.transport with parameters of type ConsistencyLevel Modifier and Type Method Description ResultMessageSimpleClient. execute(java.lang.String query, java.util.List<java.nio.ByteBuffer> values, ConsistencyLevel consistencyLevel)ResultMessageSimpleClient. execute(java.lang.String query, ConsistencyLevel consistency)ResultMessageSimpleClient. executePrepared(ResultMessage.Prepared prepared, java.util.List<java.nio.ByteBuffer> values, ConsistencyLevel consistency)static intCBUtil. sizeOfConsistencyLevel(ConsistencyLevel consistency)static voidCBUtil. writeConsistencyLevel(ConsistencyLevel consistency, io.netty.buffer.ByteBuf cb)
-