| 2644 | } |
| 2645 | |
| 2646 | std::shared_ptr<MergeJoinSource> Task::getMergeJoinSource( |
| 2647 | uint32_t splitGroupId, |
| 2648 | const core::PlanNodeId& planNodeId) { |
| 2649 | auto& splitGroupState = splitGroupStates_[splitGroupId]; |
| 2650 | |
| 2651 | auto it = splitGroupState.mergeJoinSources.find(planNodeId); |
| 2652 | BOLT_CHECK( |
| 2653 | it != splitGroupState.mergeJoinSources.end(), |
| 2654 | "Merge join source for specified plan node doesn't exist: {}", |
| 2655 | planNodeId); |
| 2656 | return it->second; |
| 2657 | } |
| 2658 | |
| 2659 | void Task::createLocalExchangeQueuesLocked( |
| 2660 | uint32_t splitGroupId, |
no test coverage detected