Add sf1000 for hive

Author: PingLiuPing

benchmarks/tpch-load/create-schema/sf100.sql

@@ -1,3 +1,3 @@
-CREATE SCHEMA IF NOT EXISTS load_tpch_sf100_parquet WITH (LOCATION = 's3a://presto-workload/hive_java_load_tpch_sf100_parquet/');
+CREATE SCHEMA IF NOT EXISTS load_tpch_sf1000_parquet WITH (LOCATION = 's3a://presto-workload/hive_java_load_tpch_sf1000_parquet/');
 --Do not need to explicitly speficy schema here
-USE load_tpch_sf100_parquet;
+USE load_tpch_sf1000_parquet;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/customer_sf1000.sql

@@ -0,0 +1,12 @@
+-- Inserting into customer
+INSERT INTO customer
+SELECT
+    custkey,
+    CAST(name AS VARCHAR(25)),
+    CAST(address AS VARCHAR(40)),
+    nationkey,
+    CAST(phone AS VARCHAR(15)),
+    CAST(acctbal AS DECIMAL(12,2)),
+    CAST(mktsegment AS VARCHAR(10)),
+    CAST(comment AS VARCHAR(117))
+FROM tpch.sf1000.customer;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/lineitem_sf1000.sql

@@ -0,0 +1,20 @@
+-- Inserting into lineitem
+INSERT INTO lineitem
+SELECT
+    orderkey,
+    partkey,
+    suppkey,
+    linenumber,
+    CAST(quantity AS DECIMAL(12,2)),
+    CAST(extendedprice AS DECIMAL(12,2)),
+    CAST(discount AS DECIMAL(12,2)),
+    CAST(tax AS DECIMAL(12,2)),
+    CAST(returnflag AS VARCHAR(1)),
+    CAST(linestatus AS VARCHAR(1)),
+    shipdate,
+    commitdate,
+    receiptdate,
+    CAST(shipinstruct AS VARCHAR(25)),
+    CAST(shipmode AS VARCHAR(10)),
+    CAST(comment AS VARCHAR(44))
+FROM tpch.sf1000.lineitem;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/nation_sf1000.sql

@@ -0,0 +1,8 @@
+-- Inserting into nation
+INSERT INTO nation
+SELECT
+    nationkey,
+    CAST(name AS VARCHAR(25)),
+    regionkey,
+    CAST(comment AS VARCHAR(152))
+FROM tpch.sf1000.nation;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/orders_sf1000.sql

@@ -0,0 +1,13 @@
+-- Inserting into orders
+INSERT INTO orders
+SELECT
+    orderkey,
+    custkey,
+    CAST(orderstatus AS VARCHAR(1)),
+    CAST(totalprice AS DECIMAL(12,2)),
+    orderdate,
+    CAST(orderpriority AS VARCHAR(15)),
+    CAST(clerk AS VARCHAR(15)),
+    shippriority,
+    CAST(comment AS VARCHAR(79))
+FROM tpch.sf1000.orders;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/part_sf1000.sql

@@ -0,0 +1,13 @@
+-- Inserting into part
+INSERT INTO part
+SELECT
+    partkey,
+    CAST(name AS VARCHAR(55)),
+    CAST(mfgr AS VARCHAR(25)),
+    CAST(brand AS VARCHAR(10)),
+    CAST(type AS VARCHAR(25)),
+    size,
+    CAST(container AS VARCHAR(10)),
+    CAST(retailprice AS DECIMAL(12,2)),
+    CAST(comment AS VARCHAR(23))
+FROM tpch.sf1000.part;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/partsupp_sf1000.sql

@@ -0,0 +1,9 @@
+-- Inserting into partsupp
+INSERT INTO partsupp
+SELECT
+    partkey,
+    suppkey,
+    availqty,
+    CAST(supplycost AS DECIMAL(12,2)),
+    CAST(comment AS VARCHAR(199))
+FROM tpch.sf1000.partsupp;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/region_sf1000.sql

@@ -0,0 +1,7 @@
+-- Inserting into region
+INSERT INTO region
+SELECT
+    regionkey,
+    CAST(name AS VARCHAR(25)),
+    CAST(comment AS VARCHAR(152))
+FROM tpch.sf1000.region;

benchmarks/tpch-load/hive-tpch-parquet-j-1000/supplier_sf1000.sql

@@ -0,0 +1,11 @@
+-- Inserting into supplier
+INSERT INTO supplier
+SELECT
+    suppkey,
+    CAST(name AS VARCHAR(25)),
+    CAST(address AS VARCHAR(40)),
+    nationkey,
+    CAST(phone AS VARCHAR(15)),
+    CAST(acctbal AS DECIMAL(12,2)),
+    CAST(comment AS VARCHAR(101))
+FROM tpch.sf1000.supplier;

benchmarks/tpch-load/hive_sf1000.json

@@ -0,0 +1,5 @@
+{
+  "description": "Specifies the schema for TPCH scale factor 10 GB.",
+  "catalog": "hive",
+  "schema": "load_tpch_sf1000_parquet"
+}