apache pig加载数据时出错

t3psigkw 于 2021-05-29 发布在 Hadoop

关注(0)|答案(1)|浏览(428)

我使用下面的命令在pig上加载了数据，但是遇到了一个错误。请纠正错误并告诉我解决方法。

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

错误-2017-08-25 09:15:12656[main]error org.apache.pig.tools.grunt.grunt-错误1200:不匹配的输入“$0”需要正确的参数

1条答案

load语句语法不正确。必须按以下格式指定字段名和数据类型。

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);