Package org.apache.cassandra.cql3

Class Operation

java.lang.Object

org.apache.cassandra.cql3.Operation

Direct Known Subclasses:

Constants.Adder, Constants.Deleter, Constants.Setter, Constants.Substracter, Lists.Appender, Lists.Discarder, Lists.DiscarderByIndex, Lists.Prepender, Lists.Setter, Lists.SetterByIndex, Maps.DiscarderByKey, Maps.Putter, Maps.Setter, Maps.SetterByKey, Sets.Adder, Sets.Discarder, Sets.ElementDiscarder, Sets.Setter, UserTypes.DeleterByField, UserTypes.Setter, UserTypes.SetterByField

public abstract class Operation
extends Object

An UPDATE or DELETE operation. For UPDATE this includes: - setting a constant - counter operations - collections operations and for DELETE: - deleting a column - deleting an element of collection column Fine grained operation are obtained from their raw counterpart (Operation.Raw, which correspond to a parsed, non-checked operation) by provided the receiver for the operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Operation.Addition
static class	Operation.ColumnDeletion
static class	Operation.ElementDeletion
static class	Operation.FieldDeletion
static class	Operation.Prepend
static interface	Operation.RawDeletion	A parsed raw DELETE operation.
static interface	Operation.RawUpdate	A parsed raw UPDATE operation.
static class	Operation.SetElement
static class	Operation.SetField
static class	Operation.SetValue
static class	Operation.Substraction

Field Summary

Fields

Modifier and Type	Field	Description
final ColumnMetadata	column
protected final Term	t

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	Operation(ColumnMetadata column, Term t)

Method Summary

Modifier and Type	Method	Description
void	addFunctionsTo(List<Function> functions)
void	collectMarkerSpecification(VariableSpecifications boundNames)	Collects the column specification for the bind variables of this operation.
abstract void	execute(DecoratedKey partitionKey, UpdateParameters params)	Execute the operation.
boolean	requiresRead()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

column

public final ColumnMetadata column

t

protected final Term t

Constructor Details

Operation

protected Operation(ColumnMetadata column,
 Term t)

Method Details

addFunctionsTo

public void addFunctionsTo(List<Function> functions)

requiresRead

public boolean requiresRead()

Returns:

whether the operation requires a read of the previous value to be executed (only lists setterByIdx, discard and discardByIdx requires that).

collectMarkerSpecification

public void collectMarkerSpecification(VariableSpecifications boundNames)

Collects the column specification for the bind variables of this operation.

Parameters:

boundNames - the list of column specification where to collect the bind variables of this term in.

execute

public abstract void execute(DecoratedKey partitionKey,
 UpdateParameters params)
                      throws InvalidRequestException

Execute the operation.

Parameters:

partitionKey - partition key for the update.

params - parameters of the update.

Throws:

InvalidRequestException