initialize(String, List, int, String) |  | 0% |  | 0% | 5 | 5 | 17 | 17 | 1 | 1 |
createAsync(DiagnosticsClientContext, IDocumentQueryClient, PipelinedDocumentQueryParams) |  | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
drainAsync(int) |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
createReadManyQueryAsync(DiagnosticsClientContext, IDocumentQueryClient, String, SqlQuerySpec, Map, CosmosQueryRequestOptions, String, String, UUID, Class, ResourceType) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
getPartitionKeyRangesForContinuation(CompositeContinuationToken, List) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
fluxSequentialMergePrefetch(CosmosQueryRequestOptions, int, int, int) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
createDocumentProducer(String, PartitionKeyRange, String, int, CosmosQueryRequestOptions, SqlQuerySpec, Map, TriFunction, Function, Callable) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
ParallelDocumentQueryExecutionContext(DiagnosticsClientContext, IDocumentQueryClient, List, ResourceType, Class, SqlQuerySpec, CosmosQueryRequestOptions, String, String, String, boolean, boolean, UUID) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
fluxSequentialMergeConcurrency(CosmosQueryRequestOptions, int) |  | 0% |  | 0% | 3 | 3 | 6 | 6 | 1 | 1 |
executeAsync() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createDocumentProducer$1() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$drainAsync$0(DocumentProducer) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |