Uses of Class
org.apache.cassandra.exceptions.InvalidRequestException
Packages that use InvalidRequestException
Package
Description
-
Uses of InvalidRequestException in org.apache.cassandra.cql3
Methods in org.apache.cassandra.cql3 that throw InvalidRequestExceptionModifier and TypeMethodDescriptionCell<?>UpdateParameters.addCell(ColumnMetadata column, ByteBuffer value) Cell<?>UpdateParameters.addCell(ColumnMetadata column, CellPath path, ByteBuffer value) voidUpdateParameters.addCounter(ColumnMetadata column, long increment) voidUpdateParameters.addTombstone(ColumnMetadata column) voidUpdateParameters.addTombstone(ColumnMetadata column, CellPath path) 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.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) Term.bindAndGet(QueryOptions options) A shorter for bind(values).get().Term.NonTerminal.bindAndGet(QueryOptions options) Term.Terminal.bindAndGet(QueryOptions options) Tuples.DelayedValue.bindAndGet(QueryOptions options) UserTypes.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 <T> Lists.ValueLists.Value.fromSerialized(ByteBuffer value, ListType<T> type) static <K,V> Maps.Value Maps.Value.fromSerialized(ByteBuffer value, MapType<K, V> type) static <T> Sets.ValueSets.Value.fromSerialized(ByteBuffer value, SetType<T> type) static <T> Tuples.InValueTuples.InValue.fromSerialized(ByteBuffer value, ListType<T> type) abstract ByteBufferTerm.Terminal.get(ProtocolVersion version) QueryOptions.getJsonColumnValue(int bindIndex, ColumnIdentifier columnName, Collection<ColumnMetadata> expectedReceivers) Returns the term corresponding to columncolumnNamein the JSON value of bind indexbindIndex.static ResultMessage.PreparedQueryProcessor.getStoredPreparedStatement(String queryString, 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) AbstractMarker.INRaw.prepare(String keyspace, ColumnSpecification receiver) AbstractMarker.MultiColumnRaw.prepare(String keyspace, ColumnSpecification receiver) AbstractMarker.Raw.prepare(String keyspace, ColumnSpecification receiver) ArrayLiteral.prepare(String keyspace, ColumnSpecification receiver) Constants.Literal.prepare(String keyspace, ColumnSpecification receiver) abstract CQL3TypeLists.Literal.prepare(String keyspace, ColumnSpecification receiver) Maps.Literal.prepare(String keyspace, ColumnSpecification receiver) Operation.Addition.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.ColumnDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) Operation.ElementDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) Operation.FieldDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) Operation.Prepend.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.RawDeletion.prepare(String keyspace, ColumnMetadata receiver, TableMetadata metadata) This method validates the operation (i.e.Operation.RawUpdate.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) This method validates the operation (i.e.Operation.SetElement.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.SetField.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.SetValue.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Operation.Substraction.prepare(TableMetadata metadata, ColumnMetadata receiver, boolean canReadExistingState) Sets.Literal.prepare(String keyspace, ColumnSpecification receiver) abstract TermTerm.MultiColumnRaw.prepare(String keyspace, List<? extends ColumnSpecification> receiver) abstract TermTerm.Raw.prepare(String keyspace, ColumnSpecification receiver) This method validates this RawTerm is valid for provided column specification and "prepare" this RawTerm, returning the resulting prepared Term.Tuples.INRaw.prepare(String keyspace, List<? extends ColumnSpecification> receivers) Tuples.Literal.prepare(String keyspace, List<? extends ColumnSpecification> receivers) Tuples.Literal.prepare(String keyspace, ColumnSpecification receiver) Tuples.Raw.prepare(String keyspace, List<? extends ColumnSpecification> receivers) TypeCast.prepare(String keyspace, ColumnSpecification receiver) UserTypes.Literal.prepare(String keyspace, ColumnSpecification receiver) Vectors.Literal.prepare(String keyspace, ColumnSpecification receiver) CQL3Type.Raw.prepareInternal(String keyspace, Types udts) protected List<ColumnMetadata>MultiColumnRelation.receivers(TableMetadata table) static ResultMessage.PreparedQueryProcessor.storePreparedStatement(String queryString, String keyspace, QueryHandler.Prepared prepared) protected TermMultiColumnRelation.toTerm(List<? extends ColumnSpecification> receivers, Term.Raw raw, String keyspace, VariableSpecifications boundNames) protected TermSingleColumnRelation.toTerm(List<? extends ColumnSpecification> receivers, Term.Raw raw, String keyspace, VariableSpecifications boundNames) protected TermTokenRelation.toTerm(List<? extends ColumnSpecification> receivers, Term.Raw raw, String keyspace, VariableSpecifications boundNames) static voidQueryProcessor.validateKey(ByteBuffer key) Constructors in org.apache.cassandra.cql3 that throw InvalidRequestExceptionModifierConstructorDescriptionUpdateParameters(TableMetadata metadata, RegularAndStaticColumns updatedColumns, ClientState clientState, QueryOptions options, long timestamp, long nowInSec, int ttl, Map<DecoratedKey, Partition> prefetchedRows) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.functions
Methods in org.apache.cassandra.cql3.functions that return InvalidRequestExceptionMethods in org.apache.cassandra.cql3.functions with parameters of type InvalidRequestExceptionModifier and TypeMethodDescriptionstatic UDFunctionUDFunction.createBrokenFunction(FunctionName name, List<ColumnIdentifier> argNames, List<AbstractType<?>> argTypes, AbstractType<?> returnType, boolean calledOnNullInput, String language, 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 InvalidRequestExceptionModifier and TypeMethodDescriptionvoidAdds the specified input to this aggregate.FunctionCall.bind(QueryOptions options) FunctionCall.bindAndGet(QueryOptions options) AggregateFunction.Aggregate.compute(ProtocolVersion protocolVersion) Computes and returns the aggregate current value.Applies this function to the specified arguments.static FunctionFunctionResolver.get(String keyspace, FunctionName name, List<? extends AssignmentTestable> providedArgs, String receiverKeyspace, String receiverTable, AbstractType<?> receiverType) static FunctionFunctionResolver.get(String keyspace, FunctionName name, List<? extends AssignmentTestable> providedArgs, String receiverKeyspace, String receiverTable, AbstractType<?> receiverType, UserFunctions functions) static ToJsonFctToJsonFct.getInstance(String name, List<AbstractType<?>> argTypes) AggregateFunction.newAggregate()Creates a newAggregateinstance.UDAggregate.newAggregate()FunctionCall.Raw.prepare(String keyspace, ColumnSpecification receiver) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.functions.masking
Methods in org.apache.cassandra.cql3.functions.masking that throw InvalidRequestExceptionModifier and TypeMethodDescription -
Uses of InvalidRequestException in org.apache.cassandra.cql3.restrictions
Methods in org.apache.cassandra.cql3.restrictions that throw InvalidRequestExceptionModifier and TypeMethodDescriptionTokenRestriction.EQRestriction.bounds(Bound b, QueryOptions options) 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) final org.apache.cassandra.cql3.restrictions.PartitionKeyRestrictionsTokenRestriction.mergeWith(Restriction otherRestriction) TokenRestriction.EQRestriction.values(QueryOptions options, ClientState state) 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 InvalidRequestExceptionModifier and TypeMethodDescriptionvoidSimpleSelector.addInput(Selector.InputRow input) abstract ByteBufferSelector.getOutput(ProtocolVersion protocolVersion) Returns the selector output.VectorSelector.getOutput(ProtocolVersion protocolVersion) Selectable.WithTerm.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) -
Uses of InvalidRequestException in org.apache.cassandra.cql3.statements
Methods in org.apache.cassandra.cql3.statements that return InvalidRequestExceptionModifier and TypeMethodDescriptionstatic InvalidRequestExceptionRequestValidations.invalidRequest(String message) Returns anInvalidRequestExceptionwith the specified message.static InvalidRequestExceptionRequestValidations.invalidRequest(String messageTemplate, Object... messageArgs) Returns anInvalidRequestExceptionwith the specified message.Methods in org.apache.cassandra.cql3.statements that throw InvalidRequestExceptionModifier and TypeMethodDescriptionvoidCQL3CasRequest.addConditions(Clustering<?> clustering, 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) ModificationStatement.buildPartitionKeyNames(QueryOptions options, ClientState state) static voidRequestValidations.checkBindValueSet(ByteBuffer b, String messageTemplate, Object messageArg) Checks that the specified bind marker value is set to a meaningful value.static voidRequestValidations.checkContainsNoDuplicates(List<?> list, String message) Checks that the specified list does not contains duplicates.static <E> voidRequestValidations.checkContainsOnly(List<E> list, List<E> expectedElements, String message) Checks that the specified list contains only the specified elements.static voidRequestValidations.checkFalse(boolean expression, String message) Checks that the specified expression isfalse.static voidRequestValidations.checkFalse(boolean expression, String messageTemplate, Object messageArg) Checks that the specified expression isfalse.static voidRequestValidations.checkFalse(boolean expression, String messageTemplate, Object arg1, Object arg2) Checks that the specified expression isfalse.static voidRequestValidations.checkFalse(boolean expression, String messageTemplate, Object arg1, Object arg2, Object arg3) Checks that the specified expression isfalse.static <T extends Collection<E>,E>
TRequestValidations.checkNotEmpty(T collection, String messageTemplate, Object messageArg) Checks that the specified collections is NOTempty.static <T extends Collection<E>,E>
TRequestValidations.checkNotEmpty(T collection, String messageTemplate, Object arg1, Object arg2) Checks that the specified collections is NOTempty.static <T> TRequestValidations.checkNotNull(T object, String message) Checks that the specified object is NOTnull.static <T> TRequestValidations.checkNotNull(T object, String messageTemplate, Object messageArg) Checks that the specified object is NOTnull.static <T> TRequestValidations.checkNotNull(T object, String messageTemplate, Object arg1, Object arg2) Checks that the specified object is NOTnull.static voidChecks that the specified object isnull.static voidChecks that the specified object isnull.static voidChecks that the specified expression istrue.static voidChecks that the specified expression istrue.static voidChecks that the specified expression istrue.static voidRequestValidations.checkTrue(boolean expression, String messageTemplate, Object arg1, Object arg2, Object arg3) Checks that the specified expression istrue.ModificationStatement.createClustering(QueryOptions options, ClientState state) TruncateStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) UseStatement.execute(QueryState state, QueryOptions options, Dispatcher.RequestTime requestTime) UseStatement.executeLocally(QueryState state, QueryOptions options) 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) CQL3CasRequest.makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot) static IResourceAuthorizationStatement.maybeCorrectResource(IResource resource, ClientState state) SelectStatement.RawStatement.prepare(ClientState state, boolean forView) SelectStatement.process(PartitionIterator partitions, long nowInSec, boolean unmask, ClientState state) voidSelectStatement.processPartition(RowIterator partition, QueryOptions options, ResultSetBuilder result, long 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.dbModifier and TypeClassDescriptionclassclassMethods in org.apache.cassandra.db that throw InvalidRequestExceptionModifier and TypeMethodDescriptionstatic 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 -
Uses of InvalidRequestException in org.apache.cassandra.exceptions
Subclasses of InvalidRequestException in org.apache.cassandra.exceptions -
Uses of InvalidRequestException in org.apache.cassandra.index
Methods in org.apache.cassandra.index that throw InvalidRequestExceptionModifier and TypeMethodDescriptiondefault voidIndex.QueryPlan.validate(ReadCommand command) Used to validate the various parameters of a suppliedReadCommandagainst the indexes in this plan.voidIndex.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.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, 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 InvalidRequestException in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal that throw InvalidRequestExceptionModifier and TypeMethodDescriptionvoidCassandraIndex.validate(PartitionUpdate update, ClientState state) voidCassandraIndex.validate(ReadCommand command) -
Uses of InvalidRequestException in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai that throw InvalidRequestExceptionModifier and TypeMethodDescriptionStorageAttachedIndex.searcherFor(ReadCommand command) voidStorageAttachedIndex.validate(PartitionUpdate update, ClientState state) voidStorageAttachedIndex.validate(ReadCommand command) -
Uses of InvalidRequestException in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi that throw InvalidRequestExceptionModifier and TypeMethodDescriptionSASIIndex.searcherFor(ReadCommand command) voidSASIIndex.validate(PartitionUpdate update, ClientState state) -
Uses of InvalidRequestException in org.apache.cassandra.io.sstable
Methods in org.apache.cassandra.io.sstable that throw InvalidRequestExceptionModifier and TypeMethodDescriptionAdds a new row to the writer.Adds a new row to the writer.Adds a new row to the writer.CQLSSTableWriter.rawAddRow(ByteBuffer... values) Adds a new row to the writer given already serialized values.CQLSSTableWriter.rawAddRow(List<ByteBuffer> values) Adds a new row to the writer given already serialized values.CQLSSTableWriter.rawAddRow(Map<String, 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 InvalidRequestExceptionModifier and TypeMethodDescriptionColumnMetadata.newSelectorFactory(TableMetadata table, AbstractType<?> expectedType, List<ColumnMetadata> defs, VariableSpecifications boundNames) -
Uses of InvalidRequestException in org.apache.cassandra.service
Methods in org.apache.cassandra.service that throw InvalidRequestExceptionModifier and TypeMethodDescriptionbooleanCASRequest.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(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.StorageService.describeLocalRing(String keyspace) The same asdescribeRing(String)but considers only the part of the ring formed by nodes in the local DC.StorageService.describeRing(String keyspace) The TokenRange for a given keyspace.ClientState.getKeyspace()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.static voidStorageProxy.mutateWithTriggers(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 InvalidRequestExceptionModifier 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) 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 InvalidRequestExceptionModifier and TypeMethodDescriptionvoidPaxosUncommittedIndex.validate(PartitionUpdate update, ClientState state) -
Uses of InvalidRequestException in org.apache.cassandra.triggers
Methods in org.apache.cassandra.triggers that throw InvalidRequestExceptionModifier and TypeMethodDescriptionTriggerExecutor.execute(Collection<? extends IMutation> mutations) Takes a collection of mutations and possibly augments it by adding extra mutations generated by configured triggers.TriggerExecutor.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.