public class

MutationBatchExecutorWithQueue

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

Summary

Public Constructors
MutationBatchExecutorWithQueue(AckingQueue queue, int nThreads)
Public Methods
void execute(MutationBatch m)
long getFailureCount()
long getSuccessCount()
void shutdown()
MutationBatchExecutorWithQueue startConsumers()
MutationBatchExecutorWithQueue usingRetryablePredicate( predicate)
[Expand]
Inherited Methods
From class java.lang.Object

Public Constructors

public MutationBatchExecutorWithQueue (AckingQueue queue, int nThreads)

Public Methods

public void execute (MutationBatch m)

Throws
Exception

public long getFailureCount ()

public long getSuccessCount ()

public void shutdown ()

public MutationBatchExecutorWithQueue startConsumers ()

public MutationBatchExecutorWithQueue usingRetryablePredicate ( predicate)