本文共 4553 字，大约阅读时间需要 15 分钟。

#������������������������-Hive������������

������������������������������

���������������������������������Hive������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������Hive������������������������������������

������������������������������������������������������������test_04_13���test_04_14������������������������������������������������������������������������������������������������������������������������������������Hive���������������������������������������������������������

Hive������������������

���������������������PARTITION BY������������������������������������������������������������������������������������������������������������������������������������������������������������������������

������������������������������������test���������������������day���

CREATE TABLE test (id INT, part STRING, quantity INT) PARTITIONED BY (day INT);
-- ������������������
ALTER TABLE test ADD PARTITION (day=20200413);
ALTER TABLE test ADD PARTITION (day=20200414);
ALTER TABLE test ADD PARTITION (day=20200415);

������������������������������������������������������������

SELECT part, quantity FROM test WHERE day >='20200413' AND day <='20200415' AND quantity <4;

������������������������������������������������������������������������������������

���������������������������

������������������

������������������������������������������������������������������������������������(CLUSTER BY)������������������������������������������������������������������������������

���������������������user_id���������������������

CREATE TABLE weblog (url STRING, source_ip STRING)
PARTITIONED BY (dt STRING)
CLUSTERED BY (user_id) INTO 96 BUCKETS;

���������������������������

������������������������������������������������������������������������������������������������������

������������������������������distinct_ip_in_logs������������������������������

CREATE TABLE distinct_ip_in_logs (hit_date STRING, ip STRING)
PARTITIONED BY (hit_date STRING);

������������ETL���������������������������������������������������������������

���������������������������

Hive���������������������������������������������������������������������������������������������������������������������������������������������array���map���struct���������������������������������������������������������I/O���������

���������������������������������������������������������������������������������������������������

���������������������������

Hive���������������������������������������������������������������������������������������������������������INSERT OVERWRITE������������������������������������������������������������

���������

INSERT OVERWRITE table sales
SELECT * FROM history
WHERE action = 'purchased';
INSERT OVERWRITE table credits
SELECT * FROM history
WHERE action = 'returned';

������������������������������������INSERT���������������������������������������

������������������������

������������������������������������������������������������������������������������������������������������������������������������������������������������Hive���������������������

���������������������

������

���������������������������������������Hive���������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������������