store_sales.sql 1.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. create database if not exists ${DB};
  2. use ${DB};
  3. drop table if exists store_sales;
  4. create table store_sales
  5. (
  6. ss_sold_time_sk bigint,
  7. ss_item_sk bigint,
  8. ss_customer_sk bigint,
  9. ss_cdemo_sk bigint,
  10. ss_hdemo_sk bigint,
  11. ss_addr_sk bigint,
  12. ss_store_sk bigint,
  13. ss_promo_sk bigint,
  14. ss_ticket_number bigint,
  15. ss_quantity int,
  16. ss_wholesale_cost double,
  17. ss_list_price double,
  18. ss_sales_price double,
  19. ss_ext_discount_amt double,
  20. ss_ext_sales_price double,
  21. ss_ext_wholesale_cost double,
  22. ss_ext_list_price double,
  23. ss_ext_tax double,
  24. ss_coupon_amt double,
  25. ss_net_paid double,
  26. ss_net_paid_inc_tax double,
  27. ss_net_profit double
  28. )
  29. partitioned by (ss_sold_date_sk bigint)
  30. stored as ${FILE};
  31. insert overwrite table store_sales partition (ss_sold_date_sk)
  32. select
  33. ss.ss_sold_time_sk,
  34. ss.ss_item_sk,
  35. ss.ss_customer_sk,
  36. ss.ss_cdemo_sk,
  37. ss.ss_hdemo_sk,
  38. ss.ss_addr_sk,
  39. ss.ss_store_sk,
  40. ss.ss_promo_sk,
  41. ss.ss_ticket_number,
  42. ss.ss_quantity,
  43. ss.ss_wholesale_cost,
  44. ss.ss_list_price,
  45. ss.ss_sales_price,
  46. ss.ss_ext_discount_amt,
  47. ss.ss_ext_sales_price,
  48. ss.ss_ext_wholesale_cost,
  49. ss.ss_ext_list_price,
  50. ss.ss_ext_tax,
  51. ss.ss_coupon_amt,
  52. ss.ss_net_paid,
  53. ss.ss_net_paid_inc_tax,
  54. ss.ss_net_profit,
  55. ss.ss_sold_date_sk
  56. from ${SOURCE}.store_sales ss;