Function TEST_F

be/src/service/impala-http-handler-test.cc:730–761

} // namespace impala

TEST_F(ImpalaHttpHandlerTest, SelectStatement) {
  const vector<string> SELECT_LABELS = {"01:EXCHANGE", "00:SCAN HDFS"};
  const vector<string> SELECT_LABEL_DETAILS = {"UNPARTITIONED", "default.table"};
  vector<TPlanFragment> fragments;
  TExecSummary summary;

  prepareSelectStatement(SELECT_LABELS, SELECT_LABEL_DETAILS, &fragments, &summary);

  Document document;
  Value value(kObjectType);

  PlanToJson(fragments, summary, &document, &value);
  document.CopyFrom(value, document.GetAllocator());

  validatePlanSchema(document);

  // Check the two nodes in the plan
  auto array = document["plan_nodes"].GetArray();
  ASSERT_EQ(array.Size(), 2);
  for (size_t i = 0; i < array.Size(); ++i) {
    EXPECT_EQ(array[i]["label"].GetString(), SELECT_LABELS.at(i));
    EXPECT_EQ(array[i]["label_detail"].GetString(), SELECT_LABEL_DETAILS.at(i));

    checkPlanNodeStats(array[i], i);

    EXPECT_EQ(array[i]["children"].Size(), 0);
  }

  // The data_stream_target of 00:SCAN HDFS should point to the 01:EXCHANGE node
  ASSERT_TRUE(array[1].HasMember("data_stream_target"));
  EXPECT_EQ(array[1]["data_stream_target"].GetString(), SELECT_LABELS[0]);
}

TEST_F(ImpalaHttpHandlerTest, CreateTableAsSelectStatement) {
  const vector<string> CTAS_LABELS = {"01:EXCHANGE", "00:SCAN HDFS"};