HxP2fSgS

1SET hive.exec.dynamic.partition.mode=nonstrict;
2SET hive.exec.max.dynamic.partitions=2000;
3SET hive.exec.max.dynamic.partitions.pernode=500;
4USE kukawkadomi;
5
6CREATE EXTERNAL TABLE IF NOT EXISTS INSPEKCJA(
7  LP INT,
8  serial_number STRING,
9  activity_date STRING,
10  facility_name STRING,
11  score INT,
12  grade STRING,
13  service_code INT,
14  service_description STRING,
15  employee_id STRING,
16  facility_address STRING,
17  facility_city STRING,
18  facility_id STRING,
19  facility_state STRING,
20  facility_zip STRING,
21  owner_id STRING,
22  owner_name STRING,
23  pe_description STRING,
24  program_element_pe INT,
25  program_name STRING,
26  program_status STRING,
27  record_id STRING)
28 ROW FORMAT DELIMITED
29 FIELDS TERMINATED BY ','
30 STORED AS TEXTFILE
31 LOCATION '/user/kukawkadomi/temp2'
32 TBLPROPERTIES ('skip.header.line.count'='1');use kukawkadomi;
33
34load data inpath "/user/kukawkadomi/temp2/LFG.csv" into table kukawkadomi.inspekcja;
35
36CREATE TABLE inspekcja_main (
37  lp INT,
38  facility_name STRING,
39  score INT,
40  )
41  COMMENT 'liczba restauracji z danego ryzyka'
42  PARTITIONED BY(pe_description STRING)
43  CLUSTERED BY(facility_name) INTO 4 BUCKETS
44  STORED AS ORC;