public class

WriteAheadMutationBatchExecutor

extends Object
java.lang.Object
   ↳ com.netflix.astyanax.util.WriteAheadMutationBatchExecutor

Summary

Public Constructors
WriteAheadMutationBatchExecutor(Keyspace keyspace, int nThreads)
WriteAheadMutationBatchExecutor(Keyspace keyspace, ExecutorService executor)
Public Methods
execute(MutationBatch m)
Write a mutation to the wal and execute it
List<> replayWal(int count)
Replay records from the WAL
void shutdown()
WriteAheadMutationBatchExecutor usingRetryablePredicate( predicate)
WriteAheadMutationBatchExecutor usingWriteAheadLog(WriteAheadLog wal)
[Expand]
Inherited Methods
From class java.lang.Object

Public Constructors

public WriteAheadMutationBatchExecutor (Keyspace keyspace, int nThreads)

public WriteAheadMutationBatchExecutor (Keyspace keyspace, ExecutorService executor)

Public Methods

public execute (MutationBatch m)

Write a mutation to the wal and execute it

Throws
WalException

public List<> replayWal (int count)

Replay records from the WAL

public void shutdown ()

public WriteAheadMutationBatchExecutor usingRetryablePredicate ( predicate)

public WriteAheadMutationBatchExecutor usingWriteAheadLog (WriteAheadLog wal)