com.netflix.astyanax.util
Class MutationBatchExecutorWithQueue
java.lang.Object
com.netflix.astyanax.util.MutationBatchExecutorWithQueue
public class MutationBatchExecutorWithQueue
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
MutationBatchExecutorWithQueue
public MutationBatchExecutorWithQueue(AckingQueue queue,
int nThreads)
usingRetryablePredicate
public MutationBatchExecutorWithQueue usingRetryablePredicate(com.google.common.base.Predicate<Exception> predicate)
startConsumers
public MutationBatchExecutorWithQueue startConsumers()
execute
public void execute(MutationBatch m)
throws Exception
- Throws:
Exception
shutdown
public void shutdown()
getFailureCount
public long getFailureCount()
getSuccessCount
public long getSuccessCount()
Copyright © 2012. All Rights Reserved.