Uses of Class
org.apache.cassandra.service.ClientState
Packages that use ClientState
Package
Description
-
Uses of ClientState in org.apache.cassandra.auth
Methods in org.apache.cassandra.auth with parameters of type ClientStateModifier and TypeMethodDescriptiondefault AuthenticateMessageIAuthenticator.getAuthenticateMessage(ClientState clientState) Allows custom authenticators to return their ownAuthenticateMessagebased onClientStateinformation. -
Uses of ClientState in org.apache.cassandra.cql3
Fields in org.apache.cassandra.cql3 declared as ClientStateMethods in org.apache.cassandra.cql3 with parameters of type ClientStateModifier and TypeMethodDescriptionvoidCQLStatement.authorize(ClientState state) Perform any access verification necessary for the statement.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 CQLStatementQueryProcessor.getStatement(String queryStr, ClientState clientState) static QueryHandler.PreparedQueryProcessor.parseAndPrepare(String query, ClientState clientState, boolean isInternal) static QueryHandler.PreparedQueryProcessor.parseAndPrepare(String query, ClientState clientState, boolean isInternal, boolean measure) static CQLStatementQueryProcessor.parseStatement(String queryStr, ClientState clientState) abstract CQLStatementCQLStatement.Raw.prepare(ClientState state) CustomPayloadMirroringQueryHandler.prepare(String query, ClientState clientState, Map<String, ByteBuffer> customPayload) QueryHandler.prepare(String query, ClientState clientState, Map<String, ByteBuffer> customPayload) QueryProcessor.prepare(String queryString, ClientState clientState) This method got slightly out of hand, but this is with best intentions: to allow users to be upgraded from any prior version, and help implementers avoid previous mistakes by clearly separating fully qualified and non-fully qualified statement behaviour.QueryProcessor.prepare(String query, ClientState clientState, Map<String, ByteBuffer> customPayload) abstract voidCQL3Type.Raw.validate(ClientState state, String name) voidCQLStatement.validate(ClientState state) Perform additional validation required by the statment.Constructors in org.apache.cassandra.cql3 with parameters of type ClientStateModifierConstructorDescriptionUpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, long nowInSec, int ttl, Map<DecoratedKey, Partition> prefetchedRows) -
Uses of ClientState in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions with parameters of type ClientStateModifier and TypeMethodDescriptionStatementRestrictions.getClusteringColumns(QueryOptions options, ClientState state) Returns the requested clustering columns.StatementRestrictions.getPartitionKeys(QueryOptions options, ClientState state) Returns the partition keys for which the data is requested.TokenRestriction.EQRestriction.values(QueryOptions options, ClientState state) TokenRestriction.SliceRestriction.values(QueryOptions options, ClientState state) Constructors in org.apache.cassandra.cql3.restrictions with parameters of type ClientStateModifierConstructorDescriptionStatementRestrictions(ClientState state, StatementType type, TableMetadata table, WhereClause whereClause, VariableSpecifications boundNames, List<Ordering> orderings, boolean selectsOnlyStaticColumns, boolean allowFiltering, boolean forView) StatementRestrictions(ClientState state, StatementType type, TableMetadata table, WhereClause whereClause, VariableSpecifications boundNames, List<Ordering> orderings, boolean selectsOnlyStaticColumns, boolean allowUseOfSecondaryIndices, boolean allowFiltering, boolean forView) -
Uses of ClientState in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type ClientStateModifier and TypeMethodDescriptionvoidAddIdentityStatement.authorize(ClientState state) voidAlterRoleStatement.authorize(ClientState state) voidBatchStatement.authorize(ClientState state) voidCreateRoleStatement.authorize(ClientState state) final voidDescribeStatement.authorize(ClientState state) voidDropIdentityStatement.authorize(ClientState state) voidDropRoleStatement.authorize(ClientState state) voidListPermissionsStatement.authorize(ClientState state) voidListRolesStatement.authorize(ClientState state) voidModificationStatement.authorize(ClientState state) voidPermissionsManagementStatement.authorize(ClientState state) voidRoleManagementStatement.authorize(ClientState state) voidSelectStatement.authorize(ClientState state) voidTruncateStatement.authorize(ClientState state) voidUseStatement.authorize(ClientState state) ModificationStatement.buildPartitionKeyNames(QueryOptions options, ClientState state) voidAuthenticationStatement.checkPermission(ClientState state, Permission required, RoleResource resource) ModificationStatement.createClustering(QueryOptions options, ClientState state) DescribeStatement.describe(ClientState state, Keyspaces keyspaces) Returns the schema elements that must be part of the output.protected Stream<? extends SchemaElement>DescribeStatement.Element.describe(ClientState state, Keyspaces keyspaces) protected Stream<? extends SchemaElement>DescribeStatement.Listing.describe(ClientState state, Keyspaces keyspaces) AddIdentityStatement.execute(ClientState state) AlterRoleStatement.execute(ClientState state) abstract ResultMessageAuthenticationStatement.execute(ClientState state) abstract ResultMessageAuthorizationStatement.execute(ClientState state) CreateRoleStatement.execute(ClientState state) DropIdentityStatement.execute(ClientState state) DropRoleStatement.execute(ClientState state) GrantPermissionsStatement.execute(ClientState state) GrantRoleStatement.execute(ClientState state) ListPermissionsStatement.execute(ClientState state) ListRolesStatement.execute(ClientState state) RevokePermissionsStatement.execute(ClientState state) RevokeRoleStatement.execute(ClientState state) SelectStatement.executeRawInternal(QueryOptions options, ClientState state, long nowInSec) BatchStatement.getMutations(ClientState state, BatchQueryOptions options, boolean local, long batchTimestamp, long nowInSeconds, Dispatcher.RequestTime requestTime) SelectStatement.getQuery(QueryOptions options, ClientState state, ColumnFilter columnFilter, long nowInSec, int userLimit, int perPartitionLimit, int pageSize, AggregationSpecification aggregationSpec) SelectStatement.getQuery(QueryOptions options, ClientState state, ColumnFilter columnFilter, long nowInSec, DataLimits limit) SelectStatement.getRowFilter(QueryOptions options, ClientState state) May be used by custom QueryHandler implementationsCQL3CasRequest.makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot) static IResourceAuthorizationStatement.maybeCorrectResource(IResource resource, ClientState state) protected List<ColumnSpecification>DescribeStatement.Element.metadata(ClientState state) protected List<ColumnSpecification>DescribeStatement.Listing.metadata(ClientState state) protected abstract List<ColumnSpecification>DescribeStatement.metadata(ClientState state) Returns the columns of theResultMetadataprotected StatementRestrictionsModificationStatement.Parsed.newRestrictions(ClientState state, TableMetadata metadata, VariableSpecifications boundNames, Operations operations, WhereClause where, Conditions conditions, List<Ordering> orderings) Creates the restrictions.AuthenticationStatement.prepare(ClientState state) AuthorizationStatement.prepare(ClientState state) BatchStatement.Parsed.prepare(ClientState state) final CQLStatementDescribeStatement.prepare(ClientState clientState) ModificationStatement.Parsed.prepare(ClientState state) ModificationStatement.Parsed.prepare(ClientState state, VariableSpecifications bindVariables) SelectStatement.RawStatement.prepare(ClientState state) SelectStatement.RawStatement.prepare(ClientState state, boolean forView) TruncateStatement.prepare(ClientState state) UseStatement.prepare(ClientState state) protected ModificationStatementDeleteStatement.Parsed.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected abstract ModificationStatementModificationStatement.Parsed.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected ModificationStatementUpdateStatement.ParsedInsert.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected ModificationStatementUpdateStatement.ParsedInsertJson.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) protected ModificationStatementUpdateStatement.ParsedUpdate.prepareInternal(ClientState state, TableMetadata metadata, VariableSpecifications bindVariables, Conditions conditions, Attributes attrs) SelectStatement.process(PartitionIterator partitions, long nowInSec, boolean unmask, ClientState state) voidBatchStatement.Parsed.setKeyspace(ClientState state) voidQualifiedStatement.setKeyspace(ClientState state) UpdatesCollector.toMutations(ClientState state) voidAddIdentityStatement.validate(ClientState state) voidAlterRoleStatement.validate(ClientState state) voidBatchStatement.validate(ClientState state) voidCreateRoleStatement.validate(ClientState state) final voidDescribeStatement.validate(ClientState state) voidDropIdentityStatement.validate(ClientState state) voidDropRoleStatement.validate(ClientState state) voidGrantPermissionsStatement.validate(ClientState state) voidListPermissionsStatement.validate(ClientState state) voidListRolesStatement.validate(ClientState state) voidModificationStatement.validate(ClientState state) voidPermissionsManagementStatement.validate(ClientState state) voidRoleManagementStatement.validate(ClientState state) voidSelectStatement.validate(ClientState state) voidTruncateStatement.validate(ClientState state) voidUseStatement.validate(ClientState state) voidModificationStatement.validateDiskUsage(QueryOptions options, ClientState state) -
Uses of ClientState in org.apache.cassandra.cql3.statements.schema
Fields in org.apache.cassandra.cql3.statements.schema declared as ClientStateModifier and TypeFieldDescriptionprotected ClientStateAlterSchemaStatement.stateprotected ClientStateAlterTableStatement.stateMethods in org.apache.cassandra.cql3.statements.schema with parameters of type ClientStateModifier and TypeMethodDescriptionvoidAlterKeyspaceStatement.authorize(ClientState client) voidAlterTableStatement.authorize(ClientState client) voidAlterTypeStatement.authorize(ClientState client) voidAlterViewStatement.authorize(ClientState client) voidCreateAggregateStatement.authorize(ClientState client) voidCreateFunctionStatement.authorize(ClientState client) voidCreateIndexStatement.authorize(ClientState client) voidCreateKeyspaceStatement.authorize(ClientState client) voidCreateTableStatement.authorize(ClientState client) voidCreateTriggerStatement.authorize(ClientState client) voidCreateTypeStatement.authorize(ClientState client) voidCreateViewStatement.authorize(ClientState client) voidDropAggregateStatement.authorize(ClientState client) voidDropFunctionStatement.authorize(ClientState client) voidDropIndexStatement.authorize(ClientState client) voidDropKeyspaceStatement.authorize(ClientState client) voidDropTableStatement.authorize(ClientState client) voidDropTriggerStatement.authorize(ClientState client) voidDropTypeStatement.authorize(ClientState client) voidDropViewStatement.authorize(ClientState client) AlterKeyspaceStatement.Raw.prepare(ClientState state) AlterTableStatement.Raw.prepare(ClientState state) AlterTypeStatement.Raw.prepare(ClientState state) AlterViewStatement.Raw.prepare(ClientState state) CreateAggregateStatement.Raw.prepare(ClientState state) CreateFunctionStatement.Raw.prepare(ClientState state) CreateIndexStatement.Raw.prepare(ClientState state) CreateKeyspaceStatement.Raw.prepare(ClientState state) CreateTableStatement.Raw.prepare(ClientState state) CreateTriggerStatement.Raw.prepare(ClientState state) CreateTypeStatement.Raw.prepare(ClientState state) CreateViewStatement.Raw.prepare(ClientState state) DropAggregateStatement.Raw.prepare(ClientState state) DropFunctionStatement.Raw.prepare(ClientState state) DropIndexStatement.Raw.prepare(ClientState state) DropKeyspaceStatement.Raw.prepare(ClientState state) DropTableStatement.Raw.prepare(ClientState state) DropTriggerStatement.Raw.prepare(ClientState state) DropTypeStatement.Raw.prepare(ClientState state) DropViewStatement.Raw.prepare(ClientState state) voidAlterSchemaStatement.validate(ClientState state) voidAlterTableStatement.MaskColumn.validate(ClientState state) voidAlterTableStatement.validate(ClientState state) voidAlterViewStatement.validate(ClientState state) voidCreateIndexStatement.validate(ClientState state) voidCreateKeyspaceStatement.validate(ClientState state) voidCreateTableStatement.validate(ClientState state) voidCreateTypeStatement.validate(ClientState state) voidCreateViewStatement.validate(ClientState state) -
Uses of ClientState in org.apache.cassandra.db
Methods in org.apache.cassandra.db with parameters of type ClientStateModifier 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) default voidIMutation.validateIndexedColumns(ClientState state) -
Uses of ClientState in org.apache.cassandra.db.guardrails
Fields in org.apache.cassandra.db.guardrails with type parameters of type ClientStateModifier and TypeFieldDescriptionprotected ToLongFunction<ClientState>Threshold.failThresholdprotected ToLongFunction<ClientState>Threshold.warnThresholdMethods in org.apache.cassandra.db.guardrails with parameters of type ClientStateModifier and TypeMethodDescriptionbooleanGuardrail.enabled(ClientState state) Checks whether this guardrail is enabled or not.booleanThreshold.enabled(ClientState state) voidEnableFlag.ensureEnabled(String featureName, ClientState state) Aborts the operation if this guardrail is not enabled.voidEnableFlag.ensureEnabled(ClientState state) Aborts the operation if this guardrail is not enabled.protected voidGuardrail.fail(String message, String redactedMessage, ClientState state) protected voidGuardrail.fail(String message, ClientState state) booleanThreshold.failsOn(long value, ClientState state) protected longMaxThreshold.failValue(ClientState state) protected longMinThreshold.failValue(ClientState state) protected abstract longThreshold.failValue(ClientState state) GuardrailsConfigProvider.Default.getOrCreate(ClientState state) GuardrailsConfigProvider.getOrCreate(ClientState state) Returns theGuardrailsConfigto be used for the specifiedClientState.voidPredicates.guard(T value, ClientState state) Apply the guardrail to the provided value, triggering a warning or failure if appropriate.voidThreshold.guard(long value, String what, boolean containsUserData, ClientState state) Apply the guardrail to the provided value, warning or failing if appropriate.voidTriggers a warning for each of the provided values that is discouraged by this guardrail.voidValues.guard(Set<T> values, ClientState state) Triggers a warning for each of the provided values that is discouraged by this guardrail.booleanEnableFlag.isEnabled(ClientState state) Returns whether the guarded feature is enabled or not.booleanThreshold.triggersOn(long value, ClientState state) Checks whether the provided value would trigger a warning or failure if passed toThreshold.guard(long, java.lang.String, boolean, org.apache.cassandra.service.ClientState).booleanThreshold.warnsOn(long value, ClientState state) protected longMaxThreshold.warnValue(ClientState state) protected longMinThreshold.warnValue(ClientState state) protected abstract longThreshold.warnValue(ClientState state) Constructor parameters in org.apache.cassandra.db.guardrails with type arguments of type ClientStateModifierConstructorDescriptionEnableFlag(String name, String reason, Predicate<ClientState> enabled, String featureName) Creates a newEnableFlagguardrail.EnableFlag(String name, String reason, Predicate<ClientState> warned, Predicate<ClientState> enabled, String featureName) Creates a newEnableFlagguardrail.MaxThreshold(String name, String reason, ToLongFunction<ClientState> warnThreshold, ToLongFunction<ClientState> failThreshold, org.apache.cassandra.db.guardrails.Threshold.ErrorMessageProvider messageProvider) Creates a new threshold guardrail.MinThreshold(String name, String reason, ToLongFunction<ClientState> warnThreshold, ToLongFunction<ClientState> failThreshold, org.apache.cassandra.db.guardrails.Threshold.ErrorMessageProvider messageProvider) Creates a new minimum threshold guardrail.PercentageThreshold(String name, String reason, ToLongFunction<ClientState> warnThreshold, ToLongFunction<ClientState> failThreshold, org.apache.cassandra.db.guardrails.Threshold.ErrorMessageProvider messageProvider) Creates a new threshold guardrail.Threshold(String name, String reason, ToLongFunction<ClientState> warnThreshold, ToLongFunction<ClientState> failThreshold, org.apache.cassandra.db.guardrails.Threshold.ErrorMessageProvider messageProvider) Creates a new threshold guardrail.Values(String name, String reason, Function<ClientState, Set<T>> warnedValues, Function<ClientState, Set<T>> ignoredValues, Function<ClientState, Set<T>> disallowedValues, String what) Creates a new values guardrail. -
Uses of ClientState in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions with parameters of type ClientState -
Uses of ClientState in org.apache.cassandra.db.virtual
Methods in org.apache.cassandra.db.virtual with parameters of type ClientState -
Uses of ClientState in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type ClientStateModifier and TypeMethodDescriptionvoidIndex.validate(PartitionUpdate update, ClientState state) Called at write time to ensure that values present in the update are valid according to the rules of all registered indexes which will process it.voidIndexRegistry.validate(PartitionUpdate update, ClientState state) Called at write time to ensure that values present in the update are valid according to the rules of all registered indexes which will process it.voidSecondaryIndexManager.validate(PartitionUpdate update, ClientState state) Called at write time to ensure that values present in the update are valid according to the rules of all registered indexes which will process it. -
Uses of ClientState in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal with parameters of type ClientStateModifier and TypeMethodDescriptionvoidCassandraIndex.validate(PartitionUpdate update, ClientState state) -
Uses of ClientState in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai with parameters of type ClientStateModifier and TypeMethodDescriptionvoidStorageAttachedIndex.validate(PartitionUpdate update, ClientState state) booleanStorageAttachedIndex.validateTermSize(DecoratedKey key, ByteBuffer term, boolean isClientMutation, ClientState state) voidStorageAttachedIndex.validateTermSizeForRow(DecoratedKey key, Row row, boolean isClientMutation, ClientState state) Validate maximum term size for given row -
Uses of ClientState in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type ClientStateModifier and TypeMethodDescriptionvoidSASIIndex.validate(PartitionUpdate update, ClientState state) -
Uses of ClientState in org.apache.cassandra.locator
Methods in org.apache.cassandra.locator with parameters of type ClientStateModifier and TypeMethodDescriptionvoidAbstractReplicationStrategy.maybeWarnOnOptions(ClientState state) voidNetworkTopologyStrategy.maybeWarnOnOptions(ClientState state) voidSimpleStrategy.maybeWarnOnOptions(ClientState state) static voidAbstractReplicationStrategy.validateReplicationStrategy(String keyspaceName, Class<? extends AbstractReplicationStrategy> strategyClass, TokenMetadata tokenMetadata, IEndpointSnitch snitch, Map<String, String> strategyOptions, ClientState state) -
Uses of ClientState in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema with parameters of type ClientStateModifier and TypeMethodDescriptionvoidKeyspaceParams.validate(String name, ClientState state) voidReplicationParams.validate(String name, ClientState state) -
Uses of ClientState in org.apache.cassandra.service
Methods in org.apache.cassandra.service that return ClientStateModifier and TypeMethodDescriptionClientState.cloneWithKeyspaceIfSet(String keyspace) Clone this ClientState object, but use the provided keyspace instead of the keyspace in this ClientState object.static ClientStateClientState.forExternalCalls(SocketAddress remoteAddress) static ClientStateClientState.forInternalCalls()static ClientStateClientState.forInternalCalls(String keyspace) QueryState.getClientState()Methods in org.apache.cassandra.service with parameters of type ClientStateModifier 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 RowIteratorStorageProxy.legacyCas(String keyspaceName, String cfName, DecoratedKey key, CASRequest request, ConsistencyLevel consistencyForPaxos, ConsistencyLevel consistencyForCommit, ClientState clientState, long nowInSeconds, Dispatcher.RequestTime requestTime) CASRequest.makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot) The updates to perform of a CAS success.Constructors in org.apache.cassandra.service with parameters of type ClientStateModifierConstructorDescriptionprotectedClientState(ClientState source) QueryState(ClientState clientState) QueryState(ClientState clientState, long timestamp, long nowInSeconds) -
Uses of ClientState in org.apache.cassandra.service.pager
Methods in org.apache.cassandra.service.pager with parameters of type ClientStateModifier 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 ClientStateModifierConstructorDescriptionAggregationPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) GroupByPartitionIterator(int pageSize, ConsistencyLevel consistency, ClientState clientState, Dispatcher.RequestTime requestTime) -
Uses of ClientState in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos with parameters of type ClientStateModifier and TypeMethodDescriptionstatic 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) -
Uses of ClientState in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type ClientStateModifier and TypeMethodDescriptionvoidPaxosUncommittedIndex.validate(PartitionUpdate update, ClientState state) -
Uses of ClientState in org.apache.cassandra.transport
Methods in org.apache.cassandra.transport that return ClientState