OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
result=CompositeBatchIterator.asyncComposite(executor,availableThreads,iterators.toArray(new BatchIterator[0]));result=CompletableFutures.allAsList(iterators).thenApply(its -> CompositeBatchIterator.asyncComposite(executor,availableThreads,its.toArray(new BatchIterator[0])));CompositeBatchIterator.asyncComposite(executor,availableThreads,iterators.toArray(new BatchIterator[0]))CompletableFutures.allAsList(iterators).thenApply(its -> CompositeBatchIterator.asyncComposite(executor,availableThreads,its.toArray(new BatchIterator[0])))crate6f9c1c65c7403c465d4c181b79babf8459a5182eio.crate.execution.engine.collect.sources.ShardCollectSource
_1299
_2301
_1result
_2result
v0availableThreads
v1executor
  • io.crate.data.CompositeBatchIterator
v0availableThreads
v1executor
AssignedToFalse