lineitem.sql 888 B

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. create database if not exists ${DB};
  2. use ${DB};
  3. drop table if exists lineitem;
  4. create table lineitem
  5. (L_ORDERKEY BIGINT,
  6. L_PARTKEY BIGINT,
  7. L_SUPPKEY BIGINT,
  8. L_LINENUMBER INT,
  9. L_QUANTITY DOUBLE,
  10. L_EXTENDEDPRICE DOUBLE,
  11. L_DISCOUNT DOUBLE,
  12. L_TAX DOUBLE,
  13. L_RETURNFLAG STRING,
  14. L_LINESTATUS STRING,
  15. L_COMMITDATE STRING,
  16. L_RECEIPTDATE STRING,
  17. L_SHIPINSTRUCT STRING,
  18. L_SHIPMODE STRING,
  19. L_COMMENT STRING)
  20. partitioned by (L_SHIPDATE STRING)
  21. stored as ${FILE}
  22. ;
  23. ALTER TABLE lineitem SET TBLPROPERTIES('orc.bloom.filter.columns'='*','orc.compress'='ZLIB');
  24. INSERT OVERWRITE TABLE lineitem Partition(L_SHIPDATE)
  25. select
  26. L_ORDERKEY ,
  27. L_PARTKEY ,
  28. L_SUPPKEY ,
  29. L_LINENUMBER ,
  30. L_QUANTITY ,
  31. L_EXTENDEDPRICE ,
  32. L_DISCOUNT ,
  33. L_TAX ,
  34. L_RETURNFLAG ,
  35. L_LINESTATUS ,
  36. L_COMMITDATE ,
  37. L_RECEIPTDATE ,
  38. L_SHIPINSTRUCT ,
  39. L_SHIPMODE ,
  40. L_COMMENT ,
  41. L_SHIPDATE
  42. from ${SOURCE}.lineitem
  43. ;