inventory.sql 772 B

12345678910111213141516171819202122232425262728293031
  1. set hive.enforce.bucketing=true;
  2. set hive.exec.dynamic.partition.mode=nonstrict;
  3. set hive.exec.max.dynamic.partitions=4096;
  4. set hive.exec.max.dynamic.partitions.pernode=4096;
  5. set mapred.job.reduce.input.buffer.percent=0.0;
  6. create database if not exists ${DB};
  7. use ${DB};
  8. drop table if exists inventory;
  9. create table inventory
  10. (
  11. inv_date_sk int,
  12. inv_item_sk int,
  13. inv_warehouse_sk int,
  14. inv_quantity_on_hand int
  15. )
  16. partitioned by (inv_date string)
  17. stored as ${FILE};
  18. insert overwrite table inventory partition (inv_date)
  19. from (select
  20. i.inv_date_sk,
  21. i.inv_item_sk,
  22. i.inv_warehouse_sk,
  23. i.inv_quantity_on_hand,
  24. d.d_date as inv_date
  25. from ${SOURCE}.inventory i
  26. left outer join ${SOURCE}.date_dim d
  27. on (d.d_date_sk = i.inv_date_sk);