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