| 685 | } |
| 686 | |
| 687 | PlanRootSink* FragmentInstanceState::GetRootSink() const { |
| 688 | return fragment_.output_sink.type == TDataSinkType::PLAN_ROOT_SINK ? |
| 689 | static_cast<PlanRootSink*>(sink_) : |
| 690 | nullptr; |
| 691 | } |
| 692 | |
| 693 | bool FragmentInstanceState::HasJoinBuildSink() const { |
| 694 | return IsJoinBuildSink(fragment_.output_sink.type); |