Sdílet prostřednictvím

CongestionController Class

  • Reference
Package:
com.microsoft.azure.documentdb.bulkexecutor.internal
Maven Artifact:
com.microsoft.azure:documentdb-bulkexecutor:2.9.3
  • java.lang.Object
    • com.microsoft.azure.documentdb.bulkexecutor.internal.CongestionController

public class CongestionController

Constructor Summary

Constructor Description
CongestionController(ListeningExecutorService executor, int partitionThroughput, String partitionKeyRangeId, BatchOperator batchOperator)
CongestionController(ListeningExecutorService executor, int partitionThroughput, String partitionKeyRangeId, BatchOperator batchOperator, Integer startingDegreeOfConcurrency, Integer maxDegreeOfConcurrency)

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 executeAll()

executeAllAsync

public ListenableFuture executeAllAsync()

failed

public boolean failed()

getDegreeOfConcurrency

public int getDegreeOfConcurrency()

getFailures

public List getFailures()

isRunning

public boolean isRunning()

setState

public void setState(CongestionController.State state)

Parameters:

state

Applies to