使用select命令在配置单元中创建分区表

lf3rwulv  于 2021-06-27  发布在  Hive
关注(0)|答案(2)|浏览(290)

我希望你能帮忙
我试图创建下表,用dt分区-但是每次都会出错&我找不到正确的方法。
我在用Hive
任何帮助都是惊人的:)
谢谢

CREATE TABLE keenek1.ipfr_cf2
AS
SELECT
CASE 
WHEN catreputation = 1 THEN 'Clean Site'
WHEN catreputation = 2 THEN 'Unknown Site'
WHEN catreputation = 3 THEN 'Potentially Dangerous or Affiliated to a dangerous site'
WHEN catreputation = 4 THEN 'Malicious Site'
ELSE 'other'
END as urlcatrating,
dt, hh, count(distinct(emsisdn)) as emsisdncount, sum(bytesdl) as download, sum(bytesul) as upload, count(*) as transactions,
catid, catreputation, catgrpid, serverport, urlsetmatched, urlsetprivate, responderaction, shield_status
FROM udsapp.ipfr
left join keenek1.shield_lookupx on ipfr.emsisdn =  shield_lookupx.emsisdn2
WHERE ipfr.dt = 20181105
GROUP BY dt, hh, catid, catreputation, catgrpid, serverport, urlsetmatched, urlsetprivate, responderaction, shield_status
PARTITIONED BY (dt, string)

错误是: nmismatched input 'PARTITIONED' expecting <EOF>(line 18, pos 0)\n\n== SQL ==\n\nCREATE TABLE keenek1.ipfr_cf2\nAS\nSELECT\nCASE \nWHEN catreputation = 1 THEN 'Clean Site'\nWHEN catreputation = 2 THEN 'Unknown Site'\nWHEN catreputation = 3 THEN 'Potentially Dangerous or Affiliated to a dangerous site'\nWHEN catreputation = 4 THEN 'Malicious Site'\nELSE 'other'\nEND as urlcatrating,\ndt, hh, count(distinct(emsisdn)) as emsisdncount, sum(bytesdl) as download, sum(bytesul) as upload, count(*) as transactions,\ncatid, catreputation, catgrpid, serverport, urlsetmatched, urlsetprivate, responderaction, shield_status\nFROM udsapp.ipfr\nleft join keenek1.shield_lookupx on ipfr.emsisdn = shield_lookupx.emsisdn2\nWHERE ipfr.dt = 20181105\nGROUP BY dt, hh, catid, catreputation, catgrpid, serverport, urlsetmatched, urlsetprivate, responderaction, shield_status\nPARTITIONED BY (dt)\n^^^\n "

i34xakig

i34xakig1#

替换 (dt, string)(dt string)

zysjyyx4

zysjyyx42#

在进行上述更改之后
您可以进行以下设置

SET hive.exec.dynamic.partition = true; 
SET hive.exec.dynamic.partition.mode = nonstrict;

相关问题