CongestionController Class
- java.
lang. Object - com.
microsoft. azure. documentdb. bulkexecutor. internal. CongestionController
- com.
public class CongestionController
Constructor Summary
Method Summary
| Modifier and Type | Method and Description |
|---|---|
| boolean | completed() |
| com.google.common.util.concurrent.ListenableFuture<java.lang.Void> | executeAll() |
| com.google.common.util.concurrent.ListenableFuture<java.lang.Void> | executeAllAsync() |
| boolean | failed() |
| int | getDegreeOfConcurrency() |
| java.util.List<java.lang.Exception> | getFailures() |
| boolean | isRunning() |
| void | setState(CongestionController.State state) |
Methods inherited from java.lang.Object
java.lang.Object.clone
java.lang.Object.equals
java.lang.Object.finalize
java.lang.Object.getClass
java.lang.Object.hashCode
java.lang.Object.notify
java.lang.Object.notifyAll
java.lang.Object.toString
java.lang.Object.wait
java.lang.Object.wait
java.lang.Object.wait
Constructor Details
CongestionController
public CongestionController(ListeningExecutorService executor, int partitionThroughput, String partitionKeyRangeId, BatchOperator batchOperator)
Parameters:
executor
partitionThroughput
partitionKeyRangeId
batchOperator
CongestionController
public CongestionController(ListeningExecutorService executor, int partitionThroughput, String partitionKeyRangeId, BatchOperator batchOperator, Integer startingDegreeOfConcurrency, Integer maxDegreeOfConcurrency)
Parameters:
executor
partitionThroughput
partitionKeyRangeId
batchOperator
startingDegreeOfConcurrency
maxDegreeOfConcurrency
Method Details
completed
public boolean completed()
executeAll
public ListenableFuture<Void> executeAll()
executeAllAsync
public ListenableFuture<Void> executeAllAsync()
failed
public boolean failed()
getDegreeOfConcurrency
public int getDegreeOfConcurrency()
getFailures
public List<Exception> getFailures()
isRunning
public boolean isRunning()
setState
public void setState(CongestionController.State state)
Parameters:
state
