text: drop table if exists catalog_sales_text;
  create table catalog_sales_text
  (
      cs_sold_date_sk           int,
      cs_sold_time_sk           int,
      cs_ship_date_sk           int,
      cs_bill_customer_sk       int,
      cs_bill_cdemo_sk          int,
      cs_bill_hdemo_sk          int,
      cs_bill_addr_sk           int,
      cs_ship_customer_sk       int,
      cs_ship_cdemo_sk          int,
      cs_ship_hdemo_sk          int,
      cs_ship_addr_sk           int,
      cs_call_center_sk         int,
      cs_catalog_page_sk        int,
      cs_ship_mode_sk           int,
      cs_warehouse_sk           int,
      cs_item_sk                int,
      cs_promo_sk               int,
      cs_order_number           int,
      cs_quantity               int,
      cs_wholesale_cost         double,
      cs_list_price             double,
      cs_sales_price            double,
      cs_ext_discount_amt       double,
      cs_ext_sales_price        double,
      cs_ext_wholesale_cost     double,
      cs_ext_list_price         double,
      cs_ext_tax                double,
      cs_coupon_amt             double,
      cs_ext_ship_cost          double,
      cs_net_paid               double,
      cs_net_paid_inc_tax       double,
      cs_net_paid_inc_ship      double,
      cs_net_paid_inc_ship_tax  double,
      cs_net_profit             double
  )
  USING csv
  OPTIONS(header "false", delimiter "|", path "${TPCDS_GENDATA_DIR}/catalog_sales")
  ;
  drop table if exists catalog_sales;
  create table catalog_sales
  using parquet
  as (select * from catalog_sales_text)
  ;
  drop table if exists catalog_sales_text;
  