Package org.apache.cassandra.db.virtual

Class VirtualMutation

java.lang.Object

org.apache.cassandra.db.virtual.VirtualMutation

All Implemented Interfaces:

IMutation

public final class VirtualMutation
extends Object
implements IMutation

A specialised IMutation implementation for virtual keyspaces. Mainly overrides apply() to go straight to VirtualTable.apply(PartitionUpdate) for every table involved.

Field Summary

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

MAX_MUTATION_SIZE

Constructor Summary

Constructors

Constructor	Description
VirtualMutation(String keyspaceName, DecoratedKey partitionKey, com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications)
VirtualMutation(PartitionUpdate update)

Method Summary

Modifier and Type	Method	Description
void	apply()
String	getKeyspaceName()
Collection<PartitionUpdate>	getPartitionUpdates()
Collection<TableId>	getTableIds()
long	getTimeout(TimeUnit unit)
Supplier<Mutation>	hintOnFailure()
DecoratedKey	key()
String	toString(boolean shallow)
void	validateIndexedColumns(ClientState state)
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, toString, wait, wait, wait

Constructor Details

VirtualMutation

public VirtualMutation(PartitionUpdate update)

VirtualMutation

public VirtualMutation(String keyspaceName,
 DecoratedKey partitionKey,
 com.google.common.collect.ImmutableMap<TableId,PartitionUpdate> modifications)

Method Details

apply

public void apply()

Specified by:

apply in interface IMutation

getKeyspaceName

public String getKeyspaceName()

Specified by:

getKeyspaceName in interface IMutation

getTableIds

public Collection<TableId> getTableIds()

Specified by:

getTableIds in interface IMutation

key

public DecoratedKey key()

Specified by:

key in interface IMutation

getTimeout

public long getTimeout(TimeUnit unit)

Specified by:

getTimeout in interface IMutation

toString

public String toString(boolean shallow)

Specified by:

toString 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

validateIndexedColumns

public void validateIndexedColumns(ClientState state)

Specified by:

validateIndexedColumns 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.