Uses of Class
org.apache.cassandra.cql3.QueryOptions
Packages that use QueryOptions
Package
Description
-
Uses of QueryOptions in org.apache.cassandra.audit
Methods in org.apache.cassandra.audit that return QueryOptionsMethods in org.apache.cassandra.audit with parameters of type QueryOptionsModifier and TypeMethodDescriptionvoidAuditLogManager.batchFailure(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause) voidAuditLogManager.batchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidAuditLogManager.executeFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) voidAuditLogManager.executeSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidAuditLogManager.queryFailure(CQLStatement stmt, String query, QueryOptions options, QueryState state, Exception cause) voidAuditLogManager.querySuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) AuditLogEntry.Builder.setOptions(QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.cql3
Fields in org.apache.cassandra.cql3 declared as QueryOptionsModifier and TypeFieldDescriptionstatic final QueryOptionsQueryOptions.DEFAULTfinal QueryOptionsUpdateParameters.optionsprotected final QueryOptionsBatchQueryOptions.wrappedFields in org.apache.cassandra.cql3 with type parameters of type QueryOptionsMethods in org.apache.cassandra.cql3 that return QueryOptionsModifier and TypeMethodDescriptionstatic QueryOptionsQueryOptions.addColumnSpecifications(QueryOptions options, List<ColumnSpecification> columnSpecs) static 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 QueryOptionsQueryOptions.forInternalCalls(List<ByteBuffer> values) static QueryOptionsQueryOptions.forInternalCalls(ConsistencyLevel consistency, List<ByteBuffer> values) static QueryOptionsQueryOptions.forInternalCallsWithNowInSec(long nowInSec, ConsistencyLevel consistency, List<ByteBuffer> values) static QueryOptionsQueryOptions.forProtocolVersion(ProtocolVersion protocolVersion) abstract QueryOptionsBatchQueryOptions.forStatement(int i) static QueryOptionsQueryProcessor.makeInternalOptions(CQLStatement prepared, Object[] values) static QueryOptionsQueryProcessor.makeInternalOptionsWithNowInSec(CQLStatement prepared, long nowInSec, Object[] values) QueryOptions.prepare(List<ColumnSpecification> specs) static QueryOptionsQueryOptions.withConsistencyLevel(QueryOptions options, ConsistencyLevel consistencyLevel) static QueryOptionsQueryOptions.withPageSize(QueryOptions options, int pageSize) Methods in org.apache.cassandra.cql3 with parameters of type QueryOptionsModifier and TypeMethodDescriptionstatic QueryOptionsQueryOptions.addColumnSpecifications(QueryOptions options, List<ColumnSpecification> columnSpecs) default voidQueryEvents.Listener.batchFailure(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause) default voidQueryEvents.Listener.batchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response) Constants.Marker.bind(QueryOptions options) Lists.DelayedValue.bind(QueryOptions options) Lists.Marker.bind(QueryOptions options) Maps.DelayedValue.bind(QueryOptions options) Maps.Marker.bind(QueryOptions options) Sets.DelayedValue.bind(QueryOptions options) Sets.Marker.bind(QueryOptions options) Term.bind(QueryOptions options) Bind the values in this term to the values contained invalues.Term.Terminal.bind(QueryOptions options) Terms.bind(QueryOptions options) Bind the values in these terms to the values contained inoptions.Tuples.DelayedValue.bind(QueryOptions options) Tuples.InMarker.bind(QueryOptions options) Tuples.Marker.bind(QueryOptions options) UserTypes.DelayedValue.bind(QueryOptions options) UserTypes.Marker.bind(QueryOptions options) Vectors.DelayedValue.bind(QueryOptions options) Constants.Marker.bindAndGet(QueryOptions options) Constants.Value.bindAndGet(QueryOptions options) Term.bindAndGet(QueryOptions options) A shorter for bind(values).get().Term.NonTerminal.bindAndGet(QueryOptions options) Term.Terminal.bindAndGet(QueryOptions options) Terms.bindAndGet(QueryOptions options) Tuples.DelayedValue.bindAndGet(QueryOptions options) UserTypes.DelayedValue.bindAndGet(QueryOptions options) CQLStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) Execute the statement and return the resulting result or null if there is no result.default voidQueryEvents.Listener.executeFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) CQLStatement.executeLocally(QueryState state, QueryOptions options) Variant of execute used for internal query against the system tables, and thus only query the local node.default voidQueryEvents.Listener.executeSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) longAttributes.getTimestamp(long now, QueryOptions options) intAttributes.getTimeToLive(QueryOptions options, TableMetadata metadata) voidQueryEvents.notifyBatchFailure(List<QueryHandler.Prepared> prepared, BatchStatement.Type batchType, List<Object> queryOrIdList, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, Exception cause) voidQueryEvents.notifyBatchSuccess(BatchStatement.Type batchType, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidQueryEvents.notifyExecuteFailure(QueryHandler.Prepared prepared, QueryOptions options, QueryState state, Exception cause) voidQueryEvents.notifyExecuteSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidQueryEvents.notifyQueryFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) voidQueryEvents.notifyQuerySuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) CustomPayloadMirroringQueryHandler.parse(String query, QueryState state, QueryOptions options) QueryHandler.parse(String queryString, QueryState queryState, QueryOptions options) QueryProcessor.parse(String queryString, QueryState queryState, QueryOptions options) CustomPayloadMirroringQueryHandler.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryHandler.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.process(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.process(CQLStatement prepared, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) CustomPayloadMirroringQueryHandler.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryHandler.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.processPrepared(CQLStatement statement, QueryState state, QueryOptions options, Map<String, ByteBuffer> customPayload, Dispatcher.RequestTime requestTime) QueryProcessor.processPrepared(CQLStatement statement, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) QueryProcessor.processStatement(CQLStatement statement, QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) default voidQueryEvents.Listener.queryFailure(CQLStatement statement, String query, QueryOptions options, QueryState state, Exception cause) default voidQueryEvents.Listener.querySuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) static QueryOptionsQueryOptions.withConsistencyLevel(QueryOptions options, ConsistencyLevel consistencyLevel) static BatchQueryOptionsBatchQueryOptions.withoutPerStatementVariables(QueryOptions options) static QueryOptionsQueryOptions.withPageSize(QueryOptions options, int pageSize) static BatchQueryOptionsBatchQueryOptions.withPerStatementVariables(QueryOptions options, List<List<ByteBuffer>> variables, List<Object> queryOrIdList) Constructors in org.apache.cassandra.cql3 with parameters of type QueryOptionsModifierConstructorDescriptionprotectedBatchQueryOptions(QueryOptions wrapped, List<Object> queryOrIdList) UpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, long nowInSec, int ttl, Map<DecoratedKey, Partition> prefetchedRows) -
Uses of QueryOptions in org.apache.cassandra.cql3.conditions
Methods in org.apache.cassandra.cql3.conditions with parameters of type QueryOptionsModifier and TypeMethodDescriptionvoidColumnConditions.addConditionsTo(CQL3CasRequest request, Clustering<?> clustering, QueryOptions options) Adds the conditions to the specified CAS request.voidConditions.addConditionsTo(CQL3CasRequest request, Clustering<?> clustering, QueryOptions options) Adds the conditions to the specified CAS request.abstract ColumnCondition.BoundColumnCondition.bind(QueryOptions options) protected final List<ByteBuffer>ColumnCondition.bindAndGetTerms(QueryOptions options) protected final List<Term.Terminal>ColumnCondition.bindTerms(QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.cql3.functions
Methods in org.apache.cassandra.cql3.functions with parameters of type QueryOptionsModifier and TypeMethodDescriptionFunctionCall.bind(QueryOptions options) FunctionCall.bindAndGet(QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions with parameters of type QueryOptionsModifier and TypeMethodDescriptionvoidCustomIndexExpression.addToRowFilter(RowFilter filter, TableMetadata table, QueryOptions options) final voidMultiColumnRestriction.EQRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) final voidMultiColumnRestriction.INRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) final voidMultiColumnRestriction.NotNullRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) final voidMultiColumnRestriction.SliceRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) Adds to the specified row filter the expressions corresponding to thisRestriction.voidSingleColumnRestriction.AnnRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidSingleColumnRestriction.ContainsRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidSingleColumnRestriction.EQRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidSingleColumnRestriction.INRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidSingleColumnRestriction.IsNotNullRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidSingleColumnRestriction.LikeRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidSingleColumnRestriction.SliceRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) voidTokenRestriction.addToRowFilter(RowFilter filter, IndexRegistry indexRegistry, QueryOptions options) MultiColumnRestriction.SliceRestriction.appendBoundTo(MultiCBuilder builder, Bound bound, QueryOptions options) SingleColumnRestriction.ContainsRestriction.appendBoundTo(MultiCBuilder builder, Bound bound, QueryOptions options) SingleColumnRestriction.SliceRestriction.appendBoundTo(MultiCBuilder builder, Bound bound, QueryOptions options) default MultiCBuilderSingleRestriction.appendBoundTo(MultiCBuilder builder, Bound bound, QueryOptions options) Appends the values of theSingleRestrictionfor the specified bound to the specified builder.MultiColumnRestriction.EQRestriction.appendTo(MultiCBuilder builder, QueryOptions options) MultiColumnRestriction.INRestriction.appendTo(MultiCBuilder builder, QueryOptions options) Appends the values of thisSingleRestrictionto the specified builder.MultiColumnRestriction.NotNullRestriction.appendTo(MultiCBuilder builder, QueryOptions options) MultiColumnRestriction.SliceRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.AnnRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.ContainsRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.EQRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.INRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.IsNotNullRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.LikeRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleColumnRestriction.SliceRestriction.appendTo(MultiCBuilder builder, QueryOptions options) SingleRestriction.appendTo(MultiCBuilder builder, QueryOptions options) Appends the values of thisSingleRestrictionto the specified builder.TokenRestriction.EQRestriction.bounds(Bound b, QueryOptions options) TokenRestriction.SliceRestriction.bounds(Bound b, QueryOptions options) StatementRestrictions.getClusteringColumns(QueryOptions options, ClientState state) Returns the requested clustering columns.StatementRestrictions.getClusteringColumnsBounds(Bound b, QueryOptions options) Returns the bounds (start or end) of the clustering columns.StatementRestrictions.getPartitionKeyBounds(QueryOptions options) Returns the partition key bounds.StatementRestrictions.getPartitionKeys(QueryOptions options, ClientState state) Returns the partition keys for which the data is requested.StatementRestrictions.getRowFilter(IndexRegistry indexRegistry, QueryOptions options) protected abstract List<ByteBuffer>SingleColumnRestriction.INRestriction.getValues(QueryOptions options) protected List<ByteBuffer>SingleColumnRestriction.InRestrictionWithMarker.getValues(QueryOptions options) protected List<ByteBuffer>SingleColumnRestriction.InRestrictionWithValues.getValues(QueryOptions options) protected abstract List<List<ByteBuffer>>MultiColumnRestriction.INRestriction.splitValues(QueryOptions options) protected List<List<ByteBuffer>>MultiColumnRestriction.InRestrictionWithMarker.splitValues(QueryOptions options) protected List<List<ByteBuffer>>MultiColumnRestriction.InRestrictionWithValues.splitValues(QueryOptions options) SingleColumnRestriction.AnnRestriction.value(QueryOptions options) TokenRestriction.EQRestriction.values(QueryOptions options, ClientState state) TokenRestriction.SliceRestriction.values(QueryOptions options, ClientState state) -
Uses of QueryOptions in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection with parameters of type QueryOptionsModifier and TypeMethodDescriptionabstract SelectorSelector.Factory.newInstance(QueryOptions options) Creates a newSelectorinstance.SimpleSelector.SimpleSelectorFactory.newInstance(QueryOptions options) abstract Selection.SelectorsSelection.newSelectors(QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements with parameters of type QueryOptionsModifier and TypeMethodDescriptionvoidCQL3CasRequest.addConditions(Clustering<?> clustering, Collection<ColumnCondition> conds, QueryOptions options) voidModificationStatement.addConditions(Clustering<?> clustering, CQL3CasRequest request, QueryOptions options) ModificationStatement.buildPartitionKeyNames(QueryOptions options, ClientState state) ModificationStatement.createClustering(QueryOptions options, ClientState state) ModificationStatement.createSlices(QueryOptions options) AuthenticationStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) AuthorizationStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) BatchStatement.execute(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) final ResultMessageDescribeStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) ModificationStatement.execute(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) SelectStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) TruncateStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) UseStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) SelectStatement.executeInternal(QueryState state, QueryOptions options, long nowInSec, Dispatcher.RequestTime requestTime) ModificationStatement.executeInternalWithCondition(QueryState state, QueryOptions options) ModificationStatement.executeInternalWithoutCondition(QueryState queryState, QueryOptions options, Dispatcher.RequestTime requestTime) AuthenticationStatement.executeLocally(QueryState state, QueryOptions options) AuthorizationStatement.executeLocally(QueryState state, QueryOptions options) BatchStatement.executeLocally(QueryState queryState, QueryOptions options) DescribeStatement.executeLocally(QueryState state, QueryOptions options) ModificationStatement.executeLocally(QueryState queryState, QueryOptions options) SelectStatement.executeLocally(QueryState state, QueryOptions options) TruncateStatement.executeLocally(QueryState state, QueryOptions options) UseStatement.executeLocally(QueryState state, QueryOptions options) SelectStatement.executeRawInternal(QueryOptions options, ClientState state, long nowInSec) SelectStatement.getAggregationSpec(QueryOptions options) intSelectStatement.getLimit(QueryOptions options) Returns the limit specified by the user.intSelectStatement.getPerPartitionLimit(QueryOptions options) Returns the per partition limit specified by the user.SelectStatement.getQuery(QueryOptions options, long nowInSec) 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 implementationslongModificationStatement.getTimestamp(long now, QueryOptions options) intModificationStatement.getTimeToLive(QueryOptions options) SelectStatement.makeSlices(QueryOptions options) voidSelectStatement.processPartition(RowIterator partition, QueryOptions options, ResultSetBuilder result, long nowInSec) voidModificationStatement.validateDiskUsage(QueryOptions options, ClientState state) voidModificationStatement.validateTimestamp(QueryState queryState, QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.cql3.statements.schema
Methods in org.apache.cassandra.cql3.statements.schema with parameters of type QueryOptionsModifier and TypeMethodDescriptionAlterSchemaStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) AlterSchemaStatement.executeLocally(QueryState state, QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.db.aggregation
Methods in org.apache.cassandra.db.aggregation with parameters of type QueryOptionsModifier and TypeMethodDescriptionAggregationSpecification.Factory.newInstance(QueryOptions options) Creates a newAggregationSpecificationinstance after having binded the parameters. -
Uses of QueryOptions in org.apache.cassandra.fql
Methods in org.apache.cassandra.fql with parameters of type QueryOptionsModifier and TypeMethodDescriptionvoidFullQueryLogger.batchSuccess(BatchStatement.Type type, List<? extends CQLStatement> statements, List<String> queries, List<List<ByteBuffer>> values, QueryOptions queryOptions, QueryState queryState, long batchTimeMillis, Message.Response response) Log an invocation of a batch of queriesvoidFullQueryLogger.executeSuccess(CQLStatement statement, String query, QueryOptions options, QueryState state, long queryTime, Message.Response response) voidFullQueryLogger.querySuccess(CQLStatement statement, String query, QueryOptions queryOptions, QueryState queryState, long queryTimeMillis, Message.Response response) Log a single CQL queryConstructors in org.apache.cassandra.fql with parameters of type QueryOptionsModifierConstructorDescriptionBatch(BatchStatement.Type batchType, List<String> queries, List<List<ByteBuffer>> values, QueryOptions queryOptions, QueryState queryState, long batchTimeMillis) Query(String query, QueryOptions queryOptions, QueryState queryState, long queryStartTime) -
Uses of QueryOptions in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type QueryOptionsModifier and TypeMethodDescriptiondefault Comparator<ByteBuffer>Index.getPostQueryOrdering(Restriction restriction, QueryOptions options) Return a comparator that reorders query result before sending to client -
Uses of QueryOptions in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai with parameters of type QueryOptionsModifier and TypeMethodDescriptionStorageAttachedIndex.getPostQueryOrdering(Restriction restriction, QueryOptions options) -
Uses of QueryOptions in org.apache.cassandra.transport.messages
Fields in org.apache.cassandra.transport.messages declared as QueryOptionsModifier and TypeFieldDescriptionfinal QueryOptionsBatchMessage.optionsfinal QueryOptionsExecuteMessage.optionsfinal QueryOptionsQueryMessage.optionsConstructors in org.apache.cassandra.transport.messages with parameters of type QueryOptionsModifierConstructorDescriptionBatchMessage(BatchStatement.Type type, List<Object> queryOrIdList, List<List<ByteBuffer>> values, QueryOptions options) ExecuteMessage(MD5Digest statementId, MD5Digest resultMetadataId, QueryOptions options) QueryMessage(String query, QueryOptions options)