BulkExecutor(CosmosAsyncContainer, Flux, BulkProcessingOptions) |  | 0% | | n/a | 1 | 1 | 18 | 18 | 1 | 1 |
handleTransactionalBatchExecutionException(CosmosItemOperation, Exception, FluxSink) |  | 0% |  | 0% | 5 | 5 | 11 | 11 | 1 | 1 |
handleTransactionalBatchOperationResult(TransactionalBatchResponse, TransactionalBatchOperationResult, FluxSink) |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
executePartitionedGroup(GroupedFlux) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
execute() |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
executeOperations(List, String, FluxSink) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$executePartitionKeyRangeServerBatchRequest$11(PartitionKeyRangeServerBatchRequest, FluxSink, Throwable) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$handleTransactionalBatchExecutionException$13(FluxSink, CosmosItemOperation, Exception, ShouldRetryResult) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$handleTransactionalBatchOperationResult$12(FluxSink, CosmosItemOperation, CosmosBulkItemResponse, ShouldRetryResult) |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
executePartitionKeyRangeServerBatchRequest(PartitionKeyRangeServerBatchRequest, FluxSink) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$execute$1(CosmosItemOperation) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
completeAllSinks() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$execute$5(CosmosBulkOperationResponse) |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
lambda$execute$2() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
executeBatchRequest(PartitionKeyRangeServerBatchRequest) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$execute$4(CosmosItemOperation) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$executePartitionKeyRangeServerBatchRequest$9(FluxSink, TransactionalBatchResponse) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$execute$0(Throwable, Object) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$executePartitionKeyRangeServerBatchRequest$10(Exception, FluxSink, CosmosItemOperation) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$executePartitionKeyRangeServerBatchRequest$8(TransactionalBatchResponse, FluxSink, TransactionalBatchOperationResult) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$executePartitionedGroup$6(String, FluxSink, List) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$executeOperations$7(FluxSink, PartitionKeyRangeServerBatchRequest) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$execute$3(CosmosItemOperation, String) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |