| lambda$executePartitionedGroup$10(AtomicLong, PartitionScopeThresholds, AtomicLong, AtomicInteger, Tuple2) |  | 0% | | 0% | 6 | 6 | 36 | 36 | 1 | 1 |
| BulkExecutor(CosmosAsyncContainer, Flux, CosmosBulkExecutionOptions) | | 0% | | 0% | 3 | 3 | 37 | 37 | 1 | 1 |
| lambda$handleTransactionalBatchOperationResult$18(PartitionScopeThresholds, CosmosBatchResponse, CosmosBatchOperationResult, CosmosItemOperation, FluxSink, CosmosBulkItemResponse, Object, ShouldRetryResult) | | 0% | | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
| handleTransactionalBatchOperationResult(CosmosBatchResponse, CosmosBatchOperationResult, FluxSink, PartitionScopeThresholds) | | 0% | | 0% | 3 | 3 | 17 | 17 | 1 | 1 |
| lambda$handleTransactionalBatchExecutionException$19(PartitionScopeThresholds, Exception, CosmosItemOperation, FluxSink, CosmosException, ItemBulkOperation, Boolean) | | 0% | | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
| lambda$execute$7(CosmosBulkOperationResponse) | | 0% | | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
| handleTransactionalBatchExecutionException(CosmosItemOperation, Exception, FluxSink, PartitionScopeThresholds) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| executeBatchRequest(PartitionKeyRangeServerBatchRequest) | | 0% | | 0% | 9 | 9 | 16 | 16 | 1 | 1 |
| lambda$execute$3() | | 0% | | 0% | 3 | 3 | 18 | 18 | 1 | 1 |
| lambda$executePartitionedGroup$11(PartitionScopeThresholds, FluxSink, List) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| executePartitionedGroup(GroupedFlux) | | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
| lambda$execute$9(Integer) | | 0% | | n/a | 1 | 1 | 15 | 15 | 1 | 1 |
| lambda$execute$8() | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| completeAllSinks() | | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
| lambda$execute$2(CosmosItemOperation) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| getThreadInfo() | | 0% | | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
| executeOperations(List, PartitionScopeThresholds, FluxSink) | | 0% | | 0% | 3 | 3 | 11 | 11 | 1 | 1 |
| getItemOperationDiagnostics(CosmosItemOperation) | | 0% | | 0% | 3 | 3 | 12 | 12 | 1 | 1 |
| lambda$execute$5(CosmosItemOperation, String) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$execute$6(CosmosItemOperation) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| execute() | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| getActualContext(CosmosItemOperation) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| lambda$executePartitionKeyRangeServerBatchRequest$17(PartitionKeyRangeServerBatchRequest, FluxSink, PartitionScopeThresholds, Throwable) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| enqueueForRetry(Duration, FluxSink, CosmosItemOperation, PartitionScopeThresholds) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| lambda$execute$1(Throwable, Object) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| retryOtherExceptions(CosmosItemOperation, Exception, FluxSink, CosmosException, ItemBulkOperation, PartitionScopeThresholds) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| executePartitionKeyRangeServerBatchRequest(PartitionKeyRangeServerBatchRequest, FluxSink, PartitionScopeThresholds) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| lambda$retryOtherExceptions$21(FluxSink, ItemBulkOperation, PartitionScopeThresholds, CosmosItemOperation, Exception, Object, ShouldRetryResult) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
| calculateTotalSerializedLength(AtomicInteger, CosmosItemOperation) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$executePartitionKeyRangeServerBatchRequest$15(FluxSink, PartitionScopeThresholds, CosmosBatchResponse) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
| onFlush() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
| static {...} | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$execute$0(List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$executePartitionKeyRangeServerBatchRequest$16(Exception, FluxSink, PartitionScopeThresholds, CosmosItemOperation) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$executePartitionKeyRangeServerBatchRequest$14(CosmosBatchResponse, FluxSink, PartitionScopeThresholds, CosmosBatchOperationResult) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$execute$4(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$enqueueForRetry$20(FluxSink, CosmosItemOperation, Long) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$executeOperations$13(FluxSink, PartitionScopeThresholds, PartitionKeyRangeServerBatchRequest) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$onFlush$22(FluxSink) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$calculateTotalSerializedLength$12(int, int) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |