加載數據時apache pig錯誤

Question

我使用下面的命令將數據加載到pig上，但遇到錯誤。 請糾正錯誤並告訴我解決方案。

swa = load '/home/user/data/emp.txt' using PigStorage(',') as ($0,$1,$2); 

無錯誤2017年8月25日09：15：12656 [主要] ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1200： 不匹配的輸入 '$ 0' 期待RIGHT_PAREN

Answer 1

加載語句語法不正確。您必須按以下格式指定字段名稱和數據類型。

swa = load '/home/user/data/emp.txt' using PigStorage(',') as (fieldname1:datatype,fieldname2:datatype,fieldname3:datatype); 

例如，假設你在你的文件用逗號分隔的3場

123,London,21.3 
234,Paris,18.6 
345,New York,22.7 

那麼你會加載這個數據作爲

swa = load '/home/user/data/emp.txt' using PigStorage(',') as (id:int,city:chararray,temperature:double);