return projectors.wrap(createMultiShardScoreDocCollector(collectPhase,requireMoveToStartSupport,collectTask,localNodeId)); | return createMultiShardScoreDocCollector(collectPhase,requireMoveToStartSupport,collectTask,localNodeId).thenApply(projectors::wrap); | projectors.wrap(createMultiShardScoreDocCollector(collectPhase,requireMoveToStartSupport,collectTask,localNodeId)) | createMultiShardScoreDocCollector(collectPhase,requireMoveToStartSupport,collectTask,localNodeId).thenApply(projectors::wrap) | crate | 6f9c1c65c7403c465d4c181b79babf8459a5182e | io.crate.execution.engine.collect.sources.ShardCollectSource | | _1 | getIterator |
---|
_2 | getIterator |
---|
| v0 | createMultiShardScoreDocCollector(collectPhase,requireMoveToStartSupport,collectTask,localNodeId) |
---|
| | v0 | createMultiShardScoreDocCollector(collectPhase,requireMoveToStartSupport,collectTask,localNodeId) |
---|
| Returns | True |