Uses of Class
org.apache.cassandra.exceptions.InvalidRequestException
-
-
Uses of InvalidRequestException in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that throw InvalidRequestException Modifier and Type Method Description Cell<?>UpdateParameters. addCell(ColumnMetadata column, java.nio.ByteBuffer value)Cell<?>UpdateParameters. addCell(ColumnMetadata column, CellPath path, java.nio.ByteBuffer value)voidUpdateParameters. addCounter(ColumnMetadata column, long increment)voidUpdateParameters. addTombstone(ColumnMetadata column)voidUpdateParameters. addTombstone(ColumnMetadata column, CellPath path)Constants.ValueConstants.Marker. bind(QueryOptions options)Term.TerminalLists.DelayedValue. bind(QueryOptions options)Term.TerminalLists.Marker. bind(QueryOptions options)Term.TerminalMaps.DelayedValue. bind(QueryOptions options)Term.TerminalMaps.Marker. bind(QueryOptions options)Term.TerminalSets.DelayedValue. bind(QueryOptions options)Term.TerminalSets.Marker. bind(QueryOptions options)Term.TerminalTerm. bind(QueryOptions options)Bind the values in this term to the values contained invalues.Tuples.ValueTuples.DelayedValue. bind(QueryOptions options)Tuples.InValueTuples.InMarker. bind(QueryOptions options)Tuples.ValueTuples.Marker. bind(QueryOptions options)UserTypes.ValueUserTypes.DelayedValue. bind(QueryOptions options)Term.TerminalUserTypes.Marker. bind(QueryOptions options)java.nio.ByteBufferConstants.Marker. bindAndGet(QueryOptions options)java.nio.ByteBufferTerm. bindAndGet(QueryOptions options)A shorter for bind(values).get().java.nio.ByteBufferTerm.NonTerminal. bindAndGet(QueryOptions options)java.nio.ByteBufferTerm.Terminal. bindAndGet(QueryOptions options)java.nio.ByteBufferTuples.DelayedValue. bindAndGet(QueryOptions options)java.nio.ByteBufferUserTypes.DelayedValue. bindAndGet(QueryOptions options)voidConstants.Adder. execute(DecoratedKey partitionKey, UpdateParameters params)voidConstants.Deleter. execute(DecoratedKey partitionKey, UpdateParameters params)voidConstants.Setter. execute(DecoratedKey partitionKey, UpdateParameters params)voidConstants.Substracter. execute(DecoratedKey partitionKey, UpdateParameters params)voidLists.Appender. execute(DecoratedKey partitionKey, UpdateParameters params)voidLists.Discarder. execute(DecoratedKey partitionKey, UpdateParameters params)voidLists.DiscarderByIndex. execute(DecoratedKey partitionKey, UpdateParameters params)voidLists.Prepender. execute(DecoratedKey partitionKey, UpdateParameters params)voidLists.Setter. execute(DecoratedKey partitionKey, UpdateParameters params)voidLists.SetterByIndex. execute(DecoratedKey partitionKey, UpdateParameters params)voidMaps.DiscarderByKey. execute(DecoratedKey partitionKey, UpdateParameters params)voidMaps.Putter. execute(DecoratedKey partitionKey, UpdateParameters params)voidMaps.Setter. execute(DecoratedKey partitionKey, UpdateParameters params)voidMaps.SetterByKey. execute(DecoratedKey partitionKey, UpdateParameters params)abstract voidOperation. execute(DecoratedKey partitionKey, UpdateParameters params)Execute the operation.voidSets.Adder. execute(DecoratedKey partitionKey, UpdateParameters params)voidSets.Discarder. execute(DecoratedKey partitionKey, UpdateParameters params)voidSets.ElementDiscarder. execute(DecoratedKey partitionKey, UpdateParameters params)voidSets.Setter. execute(DecoratedKey partitionKey, UpdateParameters params)voidUserTypes.DeleterByField. execute(DecoratedKey partitionKey, UpdateParameters params)voidUserTypes.Setter. execute(DecoratedKey partitionKey, UpdateParameters params)voidUserTypes.SetterByField. execute(DecoratedKey partitionKey, UpdateParameters params)static Lists.ValueLists.Value. fromSerialized(java.nio.ByteBuffer value, ListType type, ProtocolVersion version)static Maps.ValueMaps.Value. fromSerialized(java.nio.ByteBuffer value, MapType type, ProtocolVersion version)static Sets.ValueSets.Value. fromSerialized(java.nio.ByteBuffer value, SetType type, ProtocolVersion version)static Tuples.InValueTuples.InValue. fromSerialized(java.nio.ByteBuffer value, ListType type, QueryOptions options)abstract java.nio.ByteBufferTerm.Terminal. get(ProtocolVersion protocolVersion)TermQueryOptions. getJsonColumnValue(int bindIndex, ColumnIdentifier columnName, java.util.Collection<ColumnMetadata> expectedReceivers)Returns the term corresponding to columncolumnNamein the JSON value of bind indexbindIndex.static ResultMessage.PreparedQueryProcessor. getStoredPreparedStatement(java.lang.String queryString, java.lang.String clientKeyspace)longAttributes. getTimestamp(long now, QueryOptions options)intAttributes. getTimeToLive(QueryOptions options, TableMetadata metadata)protected RestrictionSingleColumnRelation. newContainsRestriction(TableMetadata table, VariableSpecifications boundNames, boolean isKey)protected RestrictionSingleColumnRelation. newIsNotRestriction(TableMetadata table, VariableSpecifications boundNames)<V> voidUpdateParameters. newRow(Clustering<V> clustering)Lists.MarkerAbstractMarker.INRaw. prepare(java.lang.String keyspace, ColumnSpecification receiver)Term.NonTerminalAbstractMarker.MultiColumnRaw. prepare(java.lang.String keyspace, ColumnSpecification receiver)Term.NonTerminalAbstractMarker.Raw. prepare(java.lang.String keyspace, ColumnSpecification receiver)AttributesAttributes.Raw. prepare(java.lang.String ksName, java.lang.String cfName)Constants.ValueConstants.Literal. prepare(java.lang.String keyspace, ColumnSpecification receiver)abstract CQL3TypeCQL3Type.Raw. prepare(java.lang.String keyspace, Types udts)TermLists.Literal. prepare(java.lang.String keyspace, ColumnSpecification receiver)TermMaps.Literal. prepare(java.lang.String keyspace, ColumnSpecification receiver)OperationOperation.Addition. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.ColumnDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)OperationOperation.ElementDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)OperationOperation.FieldDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)OperationOperation.Prepend. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.RawDeletion. prepare(java.lang.String keyspace, ColumnMetadata receiver, TableMetadata metadata)This method validates the operation (i.e.OperationOperation.RawUpdate. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)This method validates the operation (i.e.OperationOperation.SetElement. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.SetField. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.SetValue. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)OperationOperation.Substraction. prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState)TermSets.Literal. prepare(java.lang.String keyspace, ColumnSpecification receiver)abstract TermTerm.MultiColumnRaw. prepare(java.lang.String keyspace, java.util.List<? extends ColumnSpecification> receiver)abstract TermTerm.Raw. prepare(java.lang.String keyspace, ColumnSpecification receiver)This method validates this RawTerm is valid for provided column specification and "prepare" this RawTerm, returning the resulting prepared Term.AbstractMarkerTuples.INRaw. prepare(java.lang.String keyspace, java.util.List<? extends ColumnSpecification> receivers)TermTuples.Literal. prepare(java.lang.String keyspace, java.util.List<? extends ColumnSpecification> receivers)TermTuples.Literal. prepare(java.lang.String keyspace, ColumnSpecification receiver)AbstractMarkerTuples.Raw. prepare(java.lang.String keyspace, java.util.List<? extends ColumnSpecification> receivers)TermTypeCast. prepare(java.lang.String keyspace, ColumnSpecification receiver)TermUserTypes.Literal. prepare(java.lang.String keyspace, ColumnSpecification receiver)CQL3TypeCQL3Type.Raw. prepareInternal(java.lang.String keyspace, Types udts)protected java.util.List<ColumnMetadata>MultiColumnRelation. receivers(TableMetadata table)static ResultMessage.PreparedQueryProcessor. storePreparedStatement(java.lang.String queryString, java.lang.String keyspace, QueryHandler.Prepared prepared)protected TermMultiColumnRelation. toTerm(java.util.List<? extends ColumnSpecification> receivers, Term.Raw raw, java.lang.String keyspace, VariableSpecifications boundNames)protected TermSingleColumnRelation. toTerm(java.util.List<? extends ColumnSpecification> receivers, Term.Raw raw, java.lang.String keyspace, VariableSpecifications boundNames)protected TermTokenRelation. toTerm(java.util.List<? extends ColumnSpecification> receivers, Term.Raw raw, java.lang.String keyspace, VariableSpecifications boundNames)static voidQueryProcessor. validateKey(java.nio.ByteBuffer key)Constructors in org.apache.cassandra.cql3 that throw InvalidRequestException Constructor Description UpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, int nowInSec, int ttl, java.util.Map<DecoratedKey,Partition> prefetchedRows) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.functions
Methods in org.apache.cassandra.cql3.functions with parameters of type InvalidRequestException Modifier and Type Method Description static UDFunctionUDFunction. createBrokenFunction(FunctionName name, java.util.List<ColumnIdentifier> argNames, java.util.List<AbstractType<?>> argTypes, AbstractType<?> returnType, boolean calledOnNullInput, java.lang.String language, java.lang.String body, InvalidRequestException reason)It can happen that a function has been declared (is listed in the scheam) but cannot be loaded (maybe only on some nodes).Methods in org.apache.cassandra.cql3.functions that throw InvalidRequestException Modifier and Type Method Description voidAggregateFunction.Aggregate. addInput(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> values)Adds the specified input to this aggregate.Term.TerminalFunctionCall. bind(QueryOptions options)java.nio.ByteBufferFunctionCall. bindAndGet(QueryOptions options)java.nio.ByteBufferAggregateFunction.Aggregate. compute(ProtocolVersion protocolVersion)Computes and returns the aggregate current value.java.nio.ByteBufferScalarFunction. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)Applies this function to the specified parameter.java.nio.ByteBufferToJsonFct. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)java.nio.ByteBufferTokenFct. execute(ProtocolVersion protocolVersion, java.util.List<java.nio.ByteBuffer> parameters)static FunctionFunctionResolver. get(java.lang.String keyspace, FunctionName name, java.util.List<? extends AssignmentTestable> providedArgs, java.lang.String receiverKs, java.lang.String receiverCf, AbstractType<?> receiverType)static ToJsonFctToJsonFct. getInstance(java.util.List<AbstractType<?>> argTypes)AggregateFunction.AggregateAggregateFunction. newAggregate()Creates a newAggregateinstance.AggregateFunction.AggregateUDAggregate. newAggregate()TermFunctionCall.Raw. prepare(java.lang.String keyspace, ColumnSpecification receiver) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions that throw InvalidRequestException Modifier and Type Method Description java.util.List<java.nio.ByteBuffer>TokenRestriction.EQRestriction. bounds(Bound b, QueryOptions options)java.util.List<java.nio.ByteBuffer>TokenRestriction.SliceRestriction. bounds(Bound b, QueryOptions options)protected abstract org.apache.cassandra.cql3.restrictions.PartitionKeyRestrictionsTokenRestriction. doMergeWith(TokenRestriction otherRestriction)Merges this restriction with the specifiedTokenRestriction.protected org.apache.cassandra.cql3.restrictions.PartitionKeyRestrictionsTokenRestriction.EQRestriction. doMergeWith(TokenRestriction otherRestriction)protected org.apache.cassandra.cql3.restrictions.PartitionKeyRestrictionsTokenRestriction.SliceRestriction. doMergeWith(TokenRestriction otherRestriction)org.apache.cassandra.cql3.restrictions.PartitionKeyRestrictionsTokenRestriction. mergeWith(Restriction otherRestriction)java.util.List<java.nio.ByteBuffer>TokenRestriction.EQRestriction. values(QueryOptions options, ClientState state)java.util.List<java.nio.ByteBuffer>TokenRestriction.SliceRestriction. values(QueryOptions options, ClientState state) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.selection
Methods in org.apache.cassandra.cql3.selection that throw InvalidRequestException Modifier and Type Method Description voidSimpleSelector. addInput(ProtocolVersion protocolVersion, Selector.InputRow input)abstract java.nio.ByteBufferSelector. getOutput(ProtocolVersion protocolVersion)Returns the selector output.Selector.FactorySelectable.WithTerm. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return InvalidRequestException Modifier and Type Method Description static InvalidRequestExceptionRequestValidations. invalidRequest(java.lang.String message)Returns anInvalidRequestExceptionwith the specified message.static InvalidRequestExceptionRequestValidations. invalidRequest(java.lang.String messageTemplate, java.lang.Object... messageArgs)Returns anInvalidRequestExceptionwith the specified message.Methods in org.apache.cassandra.cql3.statements that throw InvalidRequestException Modifier and Type Method Description voidCQL3CasRequest. addConditions(Clustering<?> clustering, java.util.Collection<ColumnCondition> conds, QueryOptions options)voidModificationStatement. addConditions(Clustering<?> clustering, CQL3CasRequest request, QueryOptions options)voidCQL3CasRequest. addExist(Clustering<?> clustering)voidCQL3CasRequest. addNotExist(Clustering<?> clustering)voidDeleteStatement. addUpdateForKey(PartitionUpdate.Builder updateBuilder, Clustering<?> clustering, UpdateParameters params)booleanCQL3CasRequest. appliesTo(FilteredPartition current)Checks whether the conditions represented by this object applies provided the current state of the partition on which those conditions are.voidBatchStatement. authorize(ClientState state)voidListRolesStatement. authorize(ClientState state)voidModificationStatement. authorize(ClientState state)voidSelectStatement. authorize(ClientState state)voidTruncateStatement. authorize(ClientState state)java.util.List<java.nio.ByteBuffer>ModificationStatement. buildPartitionKeyNames(QueryOptions options, ClientState state)static voidRequestValidations. checkBindValueSet(java.nio.ByteBuffer b, java.lang.String messageTemplate, java.lang.Object messageArg)Checks that the specified bind marker value is set to a meaningful value.static voidRequestValidations. checkContainsNoDuplicates(java.util.List<?> list, java.lang.String message)Checks that the specified list does not contains duplicates.static <E> voidRequestValidations. checkContainsOnly(java.util.List<E> list, java.util.List<E> expectedElements, java.lang.String message)Checks that the specified list contains only the specified elements.static voidRequestValidations. checkFalse(boolean expression, java.lang.String message)Checks that the specified expression isfalse.static voidRequestValidations. checkFalse(boolean expression, java.lang.String messageTemplate, java.lang.Object messageArg)Checks that the specified expression isfalse.static voidRequestValidations. checkFalse(boolean expression, java.lang.String messageTemplate, java.lang.Object arg1, java.lang.Object arg2)Checks that the specified expression isfalse.static voidRequestValidations. checkFalse(boolean expression, java.lang.String messageTemplate, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3)Checks that the specified expression isfalse.static <T extends java.util.Collection<E>,E>
TRequestValidations. checkNotEmpty(T collection, java.lang.String messageTemplate, java.lang.Object messageArg)Checks that the specified collections is NOTempty.static <T extends java.util.Collection<E>,E>
TRequestValidations. checkNotEmpty(T collection, java.lang.String messageTemplate, java.lang.Object arg1, java.lang.Object arg2)Checks that the specified collections is NOTempty.static <T> TRequestValidations. checkNotNull(T object, java.lang.String message)Checks that the specified object is NOTnull.static <T> TRequestValidations. checkNotNull(T object, java.lang.String messageTemplate, java.lang.Object messageArg)Checks that the specified object is NOTnull.static <T> TRequestValidations. checkNotNull(T object, java.lang.String messageTemplate, java.lang.Object arg1, java.lang.Object arg2)Checks that the specified object is NOTnull.static voidRequestValidations. checkNull(java.lang.Object object, java.lang.String message)Checks that the specified object isnull.static voidRequestValidations. checkNull(java.lang.Object object, java.lang.String messageTemplate, java.lang.Object messageArg)Checks that the specified object isnull.static voidRequestValidations. checkTrue(boolean expression, java.lang.String message)Checks that the specified expression istrue.static voidRequestValidations. checkTrue(boolean expression, java.lang.String messageTemplate, java.lang.Object messageArg)Checks that the specified expression istrue.static voidRequestValidations. checkTrue(boolean expression, java.lang.String messageTemplate, java.lang.Object arg1, java.lang.Object arg2)Checks that the specified expression istrue.static voidRequestValidations. checkTrue(boolean expression, java.lang.String messageTemplate, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3)Checks that the specified expression istrue.java.util.NavigableSet<Clustering<?>>ModificationStatement. createClustering(QueryOptions options, ClientState state)ResultMessageTruncateStatement. execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)ResultMessageUseStatement. execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime)ResultMessageUseStatement. executeLocally(QueryState state, QueryOptions options)RowFilterSelectStatement. getRowFilter(QueryOptions options)May be used by custom QueryHandler implementationslongModificationStatement. getTimestamp(long now, QueryOptions options)intModificationStatement. getTimeToLive(QueryOptions options)SlicesSelectStatement. makeSlices(QueryOptions options)PartitionUpdateCQL3CasRequest. makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot)static IResourceAuthorizationStatement. maybeCorrectResource(IResource resource, ClientState state)SelectStatementSelectStatement.RawStatement. prepare(boolean forView)ResultSetSelectStatement. process(PartitionIterator partitions, int nowInSec)voidSelectStatement. processPartition(RowIterator partition, QueryOptions options, ResultSetBuilder result, int nowInSec)voidBatchStatement.Parsed. setKeyspace(ClientState state)voidBatchStatement. validate()voidBatchStatement. validate(ClientState state)voidListRolesStatement. validate(ClientState state)voidModificationStatement. validate(ClientState state)voidSelectStatement. validate(ClientState state)voidTruncateStatement. validate(ClientState state)voidUseStatement. validate(ClientState state) -
Uses of InvalidRequestException in org.apache.cassandra.db
Subclasses of InvalidRequestException in org.apache.cassandra.db Modifier and Type Class Description classKeyspaceNotDefinedExceptionclassMutationExceededMaxSizeExceptionMethods in org.apache.cassandra.db that throw InvalidRequestException Modifier and Type Method Description static voidExpirationDateOverflowHandling. maybeApplyExpirationDateOverflowPolicy(TableMetadata metadata, int ttl, boolean isDefaultTTL)voidConsistencyLevel. validateCounterForWrite(TableMetadata metadata)voidConsistencyLevel. validateForCas()voidConsistencyLevel. validateForCasCommit(AbstractReplicationStrategy replicationStrategy)voidConsistencyLevel. validateForRead()voidConsistencyLevel. validateForWrite() -
Uses of InvalidRequestException in org.apache.cassandra.db.guardrails
Subclasses of InvalidRequestException in org.apache.cassandra.db.guardrails Modifier and Type Class Description classGuardrailViolatedException -
Uses of InvalidRequestException in org.apache.cassandra.exceptions
Subclasses of InvalidRequestException in org.apache.cassandra.exceptions Modifier and Type Class Description classOversizedCQLMessageException -
Uses of InvalidRequestException in org.apache.cassandra.index
Methods in org.apache.cassandra.index that throw InvalidRequestException Modifier and Type Method Description voidIndex. validate(PartitionUpdate update)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.default voidIndex. validate(ReadCommand command)Used to validate the various parameters of a supplied ReadCommand, this is called prior to execution.voidSecondaryIndexManager. validate(PartitionUpdate update)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 InvalidRequestException in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal that throw InvalidRequestException Modifier and Type Method Description voidCassandraIndex. validate(PartitionUpdate update)voidCassandraIndex. validate(ReadCommand command) -
Uses of InvalidRequestException in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi that throw InvalidRequestException Modifier and Type Method Description Index.SearcherSASIIndex. searcherFor(ReadCommand command)voidSASIIndex. validate(PartitionUpdate update) -
Uses of InvalidRequestException in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that throw InvalidRequestException Modifier and Type Method Description CQLSSTableWriterCQLSSTableWriter. addRow(java.lang.Object... values)Adds a new row to the writer.CQLSSTableWriterCQLSSTableWriter. addRow(java.util.List<java.lang.Object> values)Adds a new row to the writer.CQLSSTableWriterCQLSSTableWriter. addRow(java.util.Map<java.lang.String,java.lang.Object> values)Adds a new row to the writer.CQLSSTableWriterCQLSSTableWriter. rawAddRow(java.nio.ByteBuffer... values)Adds a new row to the writer given already serialized values.CQLSSTableWriterCQLSSTableWriter. rawAddRow(java.util.List<java.nio.ByteBuffer> values)Adds a new row to the writer given already serialized values.CQLSSTableWriterCQLSSTableWriter. rawAddRow(java.util.Map<java.lang.String,java.nio.ByteBuffer> values)Adds a new row to the writer given already serialized values. -
Uses of InvalidRequestException in org.apache.cassandra.schema
Methods in org.apache.cassandra.schema that throw InvalidRequestException Modifier and Type Method Description Selector.FactoryColumnMetadata. newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, java.util.List<ColumnMetadata> defs, VariableSpecifications boundNames) -
Uses of InvalidRequestException in org.apache.cassandra.service
Methods in org.apache.cassandra.service that throw InvalidRequestException Modifier and Type Method Description booleanCASRequest. appliesTo(FilteredPartition current)Returns whether the provided CF, that represents the values fetched using the readFilter(), match the CAS conditions this object stands for.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.java.util.List<TokenRange>StorageService. describeLocalRing(java.lang.String keyspace)The same asdescribeRing(String)but considers only the part of the ring formed by nodes in the local DC.java.util.List<TokenRange>StorageService. describeRing(java.lang.String keyspace)The TokenRange for a given keyspace.java.lang.StringClientState. getKeyspace()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)PartitionUpdateCASRequest. makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot)The updates to perform of a CAS success.static voidStorageProxy. mutateWithTriggers(java.util.List<? extends IMutation> mutations, ConsistencyLevel consistencyLevel, boolean mutateAtomically, Dispatcher.RequestTime requestTime)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) -
Uses of InvalidRequestException in org.apache.cassandra.service.paxos
Methods in org.apache.cassandra.service.paxos that throw InvalidRequestException Modifier and Type Method Description 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 PartitionIteratorPaxos. read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, long deadline)static PartitionIteratorPaxos. read(SinglePartitionReadCommand.Group group, ConsistencyLevel consistencyForConsensus, Dispatcher.RequestTime requestTime) -
Uses of InvalidRequestException in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted that throw InvalidRequestException Modifier and Type Method Description voidPaxosUncommittedIndex. validate(PartitionUpdate update) -
Uses of InvalidRequestException in org.apache.cassandra.triggers
Methods in org.apache.cassandra.triggers that throw InvalidRequestException Modifier and Type Method Description java.util.Collection<Mutation>TriggerExecutor. execute(java.util.Collection<? extends IMutation> mutations)Takes a collection of mutations and possibly augments it by adding extra mutations generated by configured triggers.PartitionUpdateTriggerExecutor. execute(PartitionUpdate updates)Augment a partition update by executing triggers to generate an intermediate set of mutations, then merging the update from each mutation with those supplied.
-