BatchUpdater Class
- java.
lang. Object - com.
microsoft. azure. documentdb. bulkexecutor. internal. BatchOperator - com.
microsoft. azure. documentdb. bulkexecutor. internal. BatchUpdater
- com.
- com.
public class BatchUpdater
extends com.microsoft.azure.documentdb.bulkexecutor.internal.BatchOperator
Field Summary
Modifier and Type | Field and Description |
---|---|
java.util.concurrent.atomic.AtomicInteger |
numberOfDocumentsUpdated
The count of documents bulk updated by this batch updater. |
com.google.common.util.concurrent.AtomicDouble |
totalRequestUnitsConsumed
The total request units consumed by this batch updater. |
Constructor Summary
Constructor | Description | |
---|---|---|
BatchUpdater(String partitionKeyRangeId, List<List<UpdateItem>> batchesToUpdate, DocumentClient client, String bulkUpdateSprocLink, String partitionKeyProperty) |
Method Summary
Modifier and Type | Method and Description |
---|---|
java.util.List<Bulk |
getBulkUpdateFailures() |
java.util.List<Update |
getDocumentsFailedToUpdateDueToSplits() |
int | getNumberOfDocumentsUpdated() |
double | getTotalRequestUnitsConsumed() |
java.util.Iterator<java.util.concurrent.Callable<com.microsoft.azure.documentdb.bulkexecutor.internal.OperationMetrics>> |
miniBatchExecutionCallableIterator()
Gets a stream of tasks that return Insert |
Methods inherited from com.microsoft.azure.documentdb.bulkexecutor.internal.BatchOperator
Methods inherited from java.lang.Object
Field Details
numberOfDocumentsUpdated
public AtomicInteger numberOfDocumentsUpdated
The count of documents bulk updated by this batch updater.
totalRequestUnitsConsumed
public AtomicDouble totalRequestUnitsConsumed
The total request units consumed by this batch updater.
Constructor Details
BatchUpdater
public BatchUpdater(String partitionKeyRangeId, List<>
Parameters:
Method Details
getBulkUpdateFailures
public List
getDocumentsFailedToUpdateDueToSplits
public List
getNumberOfDocumentsUpdated
public int getNumberOfDocumentsUpdated()
getTotalRequestUnitsConsumed
public double getTotalRequestUnitsConsumed()
miniBatchExecutionCallableIterator
public Iterator<>
Gets a stream of tasks that return InsertMetrics that when awaited on operate on the next mini-batch to the document collection.
Overrides:
BatchUpdater.miniBatchExecutionCallableIterator()Applies to
Azure SDK for Java
Comentarios
https://aka.ms/ContentUserFeedback.
Próximamente: A lo largo de 2024 iremos eliminando gradualmente las Cuestiones de GitHub como mecanismo de retroalimentación para el contenido y lo sustituiremos por un nuevo sistema de retroalimentación. Para más información, consulta:Enviar y ver comentarios de