MutationBatch

Class Overview

Batch mutator which operates at the row level assuming the hierarchy: RowKey -> ColumnFamily -> Mutation. This hierarchy serves two purposes. First, it makes it possible to perform multiple operations on the same row without having to repeat specifying the row key. Second, it mirrors the underlying Thrift data structure which averts unnecessary operations to convert from one data structure to another. The mutator is not thread safe If successful, all the mutations are cleared and new mutations may be created. Any previously acquired ColumnFamilyMutations are no longer valid and should be discarded. No data is actually returned after a mutation is executed, hence the Void return value type. Example:

 {
     @code
     ColumnFamily<String, String> cf = AFactory.makeColumnFamily("COLUMN_FAMILY_NAME", // Name
                                                                                       // of
                                                                                       // CF
                                                                                       // in
                                                                                       // Cassandra
             StringSerializer.get(), // Row key serializer (implies string type)
             StringSerializer.get(), // Column name serializer (implies string
                                     // type)
             ColumnType.STANDARD); // This is a standard row
 
     // Create a batch mutation
     RowMutationBatch m = keyspace.prepareMutationBatch();
 
     // Start mutate a column family for a specific row key
     ColumnFamilyMutation<String> cfm = m.row(cfSuper, "UserId").putColumn("Address", "976 Elm St.")
             .putColumn("Age", 50).putColumn("Gender", "Male");
 
     // To delete a row
     m.row(cfSuper, "UserId").delete();
 
     // Finally, execute the query
     m.execute();
 
 }
 

Summary

[Expand] Inherited Methods
From interface com.netflix.astyanax.Execution abstract OperationResult<R> execute() Block while executing the operations@return abstract Future<OperationResult<R>> executeAsync() Return a future to the operation.