| 752 | } |
| 753 | |
| 754 | BlockingReason LocalMerge::addMergeSources(ContinueFuture* /* future */) { |
| 755 | if (sources_.empty()) { |
| 756 | sources_ = operatorCtx_->task()->getLocalMergeSources( |
| 757 | operatorCtx_->driverCtx()->splitGroupId, planNodeId()); |
| 758 | } |
| 759 | return BlockingReason::kNotBlocked; |
| 760 | } |
| 761 | |
| 762 | MergeExchange::MergeExchange( |
| 763 | int32_t operatorId, |
nothing calls this directly
no test coverage detected