Package org.apache.cassandra.db

Class CounterMutation

java.lang.Object

org.apache.cassandra.db.CounterMutation

All Implemented Interfaces:

IMutation

public class CounterMutation
extends Object
implements IMutation

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CounterMutation.CounterMutationSerializer

Field Summary

Fields

Modifier and Type	Field	Description
static final CounterMutation.CounterMutationSerializer	serializer

Fields inherited from interface org.apache.cassandra.db.IMutation

MAX_MUTATION_SIZE

Constructor Summary

Constructors

Constructor	Description
CounterMutation(Mutation mutation, ConsistencyLevel consistency)

Method Summary

Modifier and Type	Method	Description
void	apply()
Mutation	applyCounterMutation()	Applies the counter mutation, returns the result Mutation (for replication to other nodes).
ConsistencyLevel	consistency()
String	getKeyspaceName()
Mutation	getMutation()
Collection<PartitionUpdate>	getPartitionUpdates()
Collection<TableId>	getTableIds()
long	getTimeout(TimeUnit unit)
Supplier<Mutation>	hintOnFailure()
DecoratedKey	key()
int	serializedSize(int version)
String	toString()
String	toString(boolean shallow)
void	validateSize(int version, int overhead)	Validates size of mutation does not exceed DatabaseDescriptor.getMaxMutationSize().

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.db.IMutation

validateIndexedColumns

Field Details

serializer

public static final CounterMutation.CounterMutationSerializer serializer

Constructor Details

CounterMutation

public CounterMutation(Mutation mutation,
 ConsistencyLevel consistency)

Method Details

getKeyspaceName

public String getKeyspaceName()

Specified by:

getKeyspaceName in interface IMutation

getTableIds

public Collection<TableId> getTableIds()

Specified by:

getTableIds in interface IMutation

getPartitionUpdates

public Collection<PartitionUpdate> getPartitionUpdates()

Specified by:

getPartitionUpdates in interface IMutation

hintOnFailure

public Supplier<Mutation> hintOnFailure()

Specified by:

hintOnFailure in interface IMutation

validateSize

public void validateSize(int version,
 int overhead)

Description copied from interface: IMutation

Validates size of mutation does not exceed DatabaseDescriptor.getMaxMutationSize().

Specified by:

validateSize in interface IMutation

Parameters:

version - the MessagingService version the mutation is being serialized for. see MessagingService.current_version

overhead - overhadd to add for mutation size to validate. Pass zero if not required but not a negative value.

getMutation

public Mutation getMutation()

key

public DecoratedKey key()

Specified by:

key in interface IMutation

consistency

public ConsistencyLevel consistency()

applyCounterMutation

public Mutation applyCounterMutation()
                              throws WriteTimeoutException

Applies the counter mutation, returns the result Mutation (for replication to other nodes). 1. Grabs the striped cell-level locks in the proper order 2. Gets the current values of the counters-to-be-modified from the counter cache 3. Reads the rest of the current values (cache misses) from the CF 4. Writes the updated counter values 5. Updates the counter cache 6. Releases the lock(s) See CASSANDRA-4775 and CASSANDRA-6504 for further details.

Returns:

the applied resulting Mutation

Throws:

WriteTimeoutException

apply

public void apply()

Specified by:

apply in interface IMutation

getTimeout

public long getTimeout(TimeUnit unit)

Specified by:

getTimeout in interface IMutation

serializedSize

public int serializedSize(int version)

toString

public String toString()

Overrides:

toString in class Object

toString

public String toString(boolean shallow)

Specified by:

toString in interface IMutation