--
-- partsupp
--
\! ./s3bin/s3 delete @obsbucket@/obscheck/tpch_partsupp_out/ address=@obshostname@ ak=@ak@ sk=@sk@
DROP FOREIGN TABLE if exists EXTPARTSUPP;
CREATE FOREIGN TABLE EXTPARTSUPP (
PS_PARTKEY INTEGER NOT NULL, -- references P_PARTKEY
PS_SUPPKEY INTEGER NOT NULL, -- references S_SUPPKEY
PS_AVAILQTY INTEGER,
PS_SUPPLYCOST DECIMAL,
PS_COMMENT VARCHAR(199)
)SERVER obs_server OPTIONS (
location 'obs://@obsbucket@/obscheck/tpch_partsupp/',
format 'text',
DELIMITER '|',
encoding 'utf8',
chunksize '32') distribute by roundrobin;
DROP TABLE if exists PARTSUPP;
CREATE TABLE PARTSUPP (
PS_PARTKEY INTEGER NOT NULL, -- references P_PARTKEY
PS_SUPPKEY INTEGER NOT NULL, -- references S_SUPPKEY
PS_AVAILQTY INTEGER,
PS_SUPPLYCOST DECIMAL,
PS_COMMENT VARCHAR(199)
);
insert into PARTSUPP select * from EXTPARTSUPP;
drop table PARTSUPP;
drop foreign table EXTPARTSUPP;
\! ./s3bin/s3 delete @obsbucket@/obscheck/tpch_partsupp_out/ address=@obshostname@ ak=@ak@ sk=@sk@