Method create_table

tests/query_test/test_iceberg.py:290–297

(tbl_name, file_format, partition_cols)

      return '%s/%s.db/%s/' % (WAREHOUSE, unique_database, tbl_name)

    def create_table(tbl_name, file_format, partition_cols):
      self.execute_query("""CREATE TABLE IF NOT EXISTS {}.{} (
            id INT,
            name STRING,
            teststeps array<struct<step_number:int,step_description:string>>)
          PARTITIONED BY ({})
          STORED AS {}
          """.format(unique_database, tbl_name, partition_cols, file_format))

    def add_file_to_table_partition(tbl_name, part_dir, local_filename):
      tbl_loc = get_table_loc(tbl_name)