Package org.apache.cassandra.db
Interface IMutation
- All Known Implementing Classes:
CounterMutation,Mutation,VirtualMutation
public interface IMutation
-
Field Summary
Fields -
Method Summary
Modifier and TypeMethodDescriptionvoidapply()static longdataSize(Collection<? extends IMutation> mutations) Computes the total data size of the specified mutations.longgetTimeout(TimeUnit unit) key()toString(boolean shallow) default voidvoidvalidateSize(int version, int overhead) Validates size of mutation does not exceedDatabaseDescriptor.getMaxMutationSize().
-
Field Details
-
MAX_MUTATION_SIZE
static final long MAX_MUTATION_SIZE
-
-
Method Details
-
apply
void apply() -
getKeyspaceName
String getKeyspaceName() -
getTableIds
Collection<TableId> getTableIds() -
key
DecoratedKey key() -
getTimeout
-
toString
-
getPartitionUpdates
Collection<PartitionUpdate> getPartitionUpdates() -
hintOnFailure
-
validateIndexedColumns
-
validateSize
void validateSize(int version, int overhead) Validates size of mutation does not exceedDatabaseDescriptor.getMaxMutationSize().- Parameters:
version- the MessagingService version the mutation is being serialized for. seeMessagingService.current_versionoverhead- overhadd to add for mutation size to validate. Pass zero if not required but not a negative value.- Throws:
MutationExceededMaxSizeException- ifDatabaseDescriptor.getMaxMutationSize()is exceeded
-
dataSize
Computes the total data size of the specified mutations.- Parameters:
mutations- the mutations- Returns:
- the total data size of the specified mutations
-