Package org.apache.cassandra.cql3.statements

Class CQL3CasRequest

java.lang.Object

org.apache.cassandra.cql3.statements.CQL3CasRequest

All Implemented Interfaces:

CASRequest

public class CQL3CasRequest
extends Object
implements CASRequest

Processed CAS conditions and update on potentially multiple rows of the same partition.

Field Summary

Fields

Modifier and Type	Field	Description
final DecoratedKey	key
final TableMetadata	metadata

Constructor Summary

Constructors

Constructor	Description
CQL3CasRequest(TableMetadata metadata, DecoratedKey key, RegularAndStaticColumns conditionColumns, boolean updatesRegularRows, boolean updatesStaticRow)

Method Summary

Modifier and Type	Method	Description
void	addConditions(Clustering<?> clustering, Collection<ColumnCondition> conds, QueryOptions options)
void	addExist(Clustering<?> clustering)
void	addNotExist(Clustering<?> clustering)
boolean	appliesTo(FilteredPartition current)	Checks whether the conditions represented by this object applies provided the current state of the partition on which those conditions are.
PartitionUpdate	makeUpdates(FilteredPartition current, ClientState clientState, Ballot ballot)	The updates to perform of a CAS success.
SinglePartitionReadCommand	readCommand(long nowInSec)	The command to use to fetch the value to compare for the CAS.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

metadata

public final TableMetadata metadata

key

public final DecoratedKey key

Constructor Details

CQL3CasRequest

public CQL3CasRequest(TableMetadata metadata,
 DecoratedKey key,
 RegularAndStaticColumns conditionColumns,
 boolean updatesRegularRows,
 boolean updatesStaticRow)

Method Details

addNotExist

public void addNotExist(Clustering<?> clustering)
                 throws InvalidRequestException

Throws:

InvalidRequestException

addExist

public void addExist(Clustering<?> clustering)
              throws InvalidRequestException

Throws:

InvalidRequestException

addConditions

public void addConditions(Clustering<?> clustering,
 Collection<ColumnCondition> conds,
 QueryOptions options)
                   throws InvalidRequestException

Throws:

InvalidRequestException

readCommand

public SinglePartitionReadCommand readCommand(long nowInSec)

Description copied from interface: CASRequest

The command to use to fetch the value to compare for the CAS.

Specified by:

readCommand in interface CASRequest

appliesTo

public boolean appliesTo(FilteredPartition current)
                  throws InvalidRequestException

Checks whether the conditions represented by this object applies provided the current state of the partition on which those conditions are.

Specified by:

appliesTo in interface CASRequest

Parameters:

current - the partition with current data corresponding to these conditions. More precisely, this must be the result of executing the command returned by readCommand(long). This can be empty but it should not be null.

Returns:

whether the conditions represented by this object applies or not.

Throws:

InvalidRequestException

makeUpdates

public PartitionUpdate makeUpdates(FilteredPartition current,
 ClientState clientState,
 Ballot ballot)
                            throws InvalidRequestException

Description copied from interface: CASRequest

The updates to perform of a CAS success. The values fetched using the readFilter() are passed as argument.

Specified by:

makeUpdates in interface CASRequest

Throws:

InvalidRequestException

toString

public String toString()

Overrides:

toString in class Object