Function _dropTable

be/src/catalog/workload-management-init.cc:96–128

Equivalent to: DROP TABLE {{db}}.{{tbl_name}} IF NOT EXISTS PURGE.

/// Equivalent to: DROP TABLE {{db}}.{{tbl_name}} IF NOT EXISTS PURGE.
static Status _dropTable(CatalogServiceIf* svc, const string& ip_addr, const string& db,
    const string& tbl_name) {
  TDdlExecResponse resp;
  TDdlExecRequest req;
  Status stat;
  TDropTableOrViewParams drop_tbl;
  TTableName t_tbl_name;
  TDdlQueryOptions t_query_opts;

  t_query_opts.__set_sync_ddl(true);

  t_tbl_name.__set_db_name(db);
  t_tbl_name.__set_table_name(tbl_name);

  drop_tbl.__set_if_exists(true);
  drop_tbl.__set_is_table(true);
  drop_tbl.__set_purge(true);
  drop_tbl.__set_table_name(t_tbl_name);

  req.__set_header(_getHeader(ip_addr));
  req.__set_ddl_type(TDdlType::type::DROP_TABLE);
  req.__set_query_options(t_query_opts);
  req.__set_drop_table_or_view_params(drop_tbl);

  svc->ExecDdl(resp, req);

  stat = StatusFromThrift(resp.result.status);
  if (!stat.ok()) {
    stat.AddDetail(StrCat("could not drop table '", _fullTableName(db, tbl_name), "'"));
  }

  return stat;
} // function _dropTable

/// Equivalent to: CREATE DATABASE IF NOT EXISTS {{db}}.
static Status _setupDb(CatalogServiceIf* svc, const string& ip_addr, const string& db) {