com.netflix.astyanax.util
Class WriteAheadMutationBatchExecutor
java.lang.Object
com.netflix.astyanax.util.WriteAheadMutationBatchExecutor
public class WriteAheadMutationBatchExecutor
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
WriteAheadMutationBatchExecutor
public WriteAheadMutationBatchExecutor(Keyspace keyspace,
int nThreads)
WriteAheadMutationBatchExecutor
public WriteAheadMutationBatchExecutor(Keyspace keyspace,
ExecutorService executor)
usingWriteAheadLog
public WriteAheadMutationBatchExecutor usingWriteAheadLog(WriteAheadLog wal)
usingRetryablePredicate
public WriteAheadMutationBatchExecutor usingRetryablePredicate(com.google.common.base.Predicate<Exception> predicate)
replayWal
public List<com.google.common.util.concurrent.ListenableFuture<OperationResult<Void>>> replayWal(int count)
- Replay records from the WAL
execute
public com.google.common.util.concurrent.ListenableFuture<OperationResult<Void>> execute(MutationBatch m)
throws WalException
- Write a mutation to the wal and execute it
- Throws:
WalException
shutdown
public void shutdown()
Copyright © 2012. All Rights Reserved.