ParallelDocumentQueryExecutionContext<T> Class

Definition

While this class is public, but it is not part of our published public APIs. This is meant to be internally used only by our sdk.

public class ParallelDocumentQueryExecutionContext<T> extends ParallelDocumentQueryExecutionContextBase<T>

Type Parameters

T
Inheritance
java.lang.Object
ParallelDocumentQueryExecutionContext<T>

Inherited Members

DocumentQueryExecutionContextBase<T>.createCommonHeadersAsync(CosmosQueryRequestOptions cosmosQueryRequestOptions) DocumentQueryExecutionContextBase<T>.createDocumentServiceRequest(Map<String,String> requestHeaders, SqlQuerySpec querySpec, PartitionKeyInternal partitionKey) DocumentQueryExecutionContextBase<T>.createDocumentServiceRequest(Map<String,String> requestHeaders, SqlQuerySpec querySpec, PartitionKeyInternal partitionKeyInternal, PartitionKeyRange targetRange, String collectionRid, String throughputControlGroup) DocumentQueryExecutionContextBase<T>.createDocumentServiceRequestWithFeedRange(Map<String,String> requestHeaders, SqlQuerySpec querySpec, PartitionKeyInternal partitionKeyInternal, FeedRange feedRange, String collectionRid, String throughputControlGroupName) DocumentQueryExecutionContextBase<T>.executeAsync() DocumentQueryExecutionContextBase<T>.executeQueryRequestAsync(RxDocumentServiceRequest request) DocumentQueryExecutionContextBase<T>.executeReadFeedRequestAsync(RxDocumentServiceRequest request) DocumentQueryExecutionContextBase<T>.executeRequestAsync(RxDocumentServiceRequest request) DocumentQueryExecutionContextBase<T>.getFeedOptions(String continuationToken, Integer maxPageSize) DocumentQueryExecutionContextBase<T>.getFeedResponse(Mono<RxDocumentServiceResponse> response) DocumentQueryExecutionContextBase<T>.populatePartitionKeyRangeInfo(RxDocumentServiceRequest request, PartitionKeyRange range, String collectionRid) ParallelDocumentQueryExecutionContextBase<T>.createDocumentProducer(String collectionRid, PartitionKeyRange targetRange, String initialContinuationToken, int initialPageSize, CosmosQueryRequestOptions cosmosQueryRequestOptions, SqlQuerySpec querySpecForInit, Map<String,String> commonRequestHeaders, TriFunction<FeedRangeEpkImpl,String,Integer,RxDocumentServiceRequest> createRequestFunc, Function<RxDocumentServiceRequest,Mono<FeedResponse<T>>> executeFunc, Callable<DocumentClientRetryPolicy> createRetryPolicyFunc, FeedRangeEpkImpl feedRange) ParallelDocumentQueryExecutionContextBase<T>.drainAsync(int maxPageSize) ParallelDocumentQueryExecutionContextBase<T>.initialize(String collectionRid, Map<FeedRangeEpkImpl,String> feedRangeToContinuationTokenMap, int initialPageSize, SqlQuerySpec querySpecForInit) ParallelDocumentQueryExecutionContextBase<T>.initializeReadMany(IDocumentQueryClient queryClient, String collectionResourceId, SqlQuerySpec sqlQuerySpec, Map<PartitionKeyRange,SqlQuerySpec> rangeQueryMap, CosmosQueryRequestOptions cosmosQueryRequestOptions, UUID activityId, String collectionRid) ParallelDocumentQueryExecutionContextBase<T>.setTop(int newTop) java.lang.Object.clone() java.lang.Object.equals(java.lang.Object) java.lang.Object.finalize() java.lang.Object.getClass() java.lang.Object.hashCode() java.lang.Object.notify() java.lang.Object.notifyAll() java.lang.Object.toString() java.lang.Object.wait() java.lang.Object.wait(long) java.lang.Object.wait(long,int)

Methods

<T>createAsync(DiagnosticsClientContext diagnosticsClientContext, IDocumentQueryClient client, PipelinedDocumentQueryParams<T> initParams)
<T>createReadManyQueryAsync(DiagnosticsClientContext diagnosticsClientContext, IDocumentQueryClient queryClient, String collectionResourceId, SqlQuerySpec sqlQuery, Map<PartitionKeyRange,SqlQuerySpec> rangeQueryMap, CosmosQueryRequestOptions cosmosQueryRequestOptions, String collectionRid, String collectionLink, UUID activityId, Class<T> klass, ResourceType resourceTypeEnum)
createDocumentProducer(String collectionRid, PartitionKeyRange targetRange, String initialContinuationToken, int initialPageSize, CosmosQueryRequestOptions cosmosQueryRequestOptions, SqlQuerySpec querySpecForInit, Map<String,String> commonRequestHeaders, TriFunction<FeedRangeEpkImpl,String,Integer,RxDocumentServiceRequest> createRequestFunc, Function<RxDocumentServiceRequest,Mono<FeedResponse<T>>> executeFunc, Callable<DocumentClientRetryPolicy> createRetryPolicyFunc, FeedRangeEpkImpl feedRange)
drainAsync(int maxPageSize)
executeAsync()

Applies to