com.netflix.astyanax.util
Class WriteAheadMutationBatchExecutor

java.lang.Object
  extended by com.netflix.astyanax.util.WriteAheadMutationBatchExecutor

public class WriteAheadMutationBatchExecutor
extends Object


Constructor Summary
WriteAheadMutationBatchExecutor(Keyspace keyspace, ExecutorService executor)
           
WriteAheadMutationBatchExecutor(Keyspace keyspace, int nThreads)
           
 
Method Summary
 com.google.common.util.concurrent.ListenableFuture<OperationResult<Void>> execute(MutationBatch m)
          Write a mutation to the wal and execute it
 List<com.google.common.util.concurrent.ListenableFuture<OperationResult<Void>>> replayWal(int count)
          Replay records from the WAL
 void shutdown()
           
 WriteAheadMutationBatchExecutor usingRetryablePredicate(com.google.common.base.Predicate<Exception> predicate)
           
 WriteAheadMutationBatchExecutor usingWriteAheadLog(WriteAheadLog wal)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

WriteAheadMutationBatchExecutor

public WriteAheadMutationBatchExecutor(Keyspace keyspace,
                                       int nThreads)

WriteAheadMutationBatchExecutor

public WriteAheadMutationBatchExecutor(Keyspace keyspace,
                                       ExecutorService executor)
Method Detail

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.