result=InMemoryBatchIterator.empty(SentinelRow.SENTINEL); | result=CompletableFutures.allAsList(iterators).thenApply(its -> CompositeBatchIterator.seqComposite(its.toArray(new BatchIterator[0]))); | InMemoryBatchIterator.empty(SentinelRow.SENTINEL) | CompletableFutures.allAsList(iterators).thenApply(its -> CompositeBatchIterator.seqComposite(its.toArray(new BatchIterator[0]))) | crate | 6f9c1c65c7403c465d4c181b79babf8459a5182e | io.crate.execution.engine.collect.sources.ShardCollectSource | | | xyz | InMemoryBatchIterator.empty(SentinelRow.SENTINEL) |
---|
| - io.crate.data.InMemoryBatchIterator
- io.crate.data.CompositeBatchIterator
- io.crate.concurrent.CompletableFutures
| xyz | CompletableFutures.allAsList(iterators).thenApply(its -> CompositeBatchIterator.seqComposite(its.toArray(new BatchIterator[0]))) |
---|
| AssignedTo | False |