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]))) | crate | 6f9c1c65c7403c465d4c181b79babf8459a5182e | io.crate.execution.engine.collect.sources.ShardCollectSource | | | v0 | availableThreads |
---|
v1 | executor |
---|
| - io.crate.data.CompositeBatchIterator
| v0 | availableThreads |
---|
v1 | executor |
---|
| AssignedTo | False |