Method HasResultSink

be/src/runtime/query-exec-params.cc:52–57

  : query_id_(query_id), exec_request_(exec_request), query_schedule_(query_schedule) {}

bool QueryExecParams::HasResultSink(const TPlanFragment* fragment) const {
  return fragment != nullptr &&
      fragment->output_sink.type == TDataSinkType::TABLE_SINK &&
      fragment->output_sink.table_sink.type == TTableSinkType::HDFS &&
      fragment->output_sink.table_sink.hdfs_table_sink.is_result_sink;
}

bool QueryExecParams::HasResultSink() const {
  return HasResultSink(GetCoordFragmentImpl());