hadoop - 将 json 文件加载到 PIG

Question

如何使用 PIG 加载以下 json 文件？

{"age":100,"name":"mkyong.com","messages":["msg 1","msg 2","msg 3"]}

我试过这样的事情，但它给了我异常(exception)。

jsoncust_table = LOAD 'customers.json' USING JsonLoader('age:int, name:string, messages:chararray');

Answer 1

Pig 没有字符串数据类型。改用字符数组

Pig Datatypes

jsoncust_table = LOAD 'customers.json' USING JsonLoader('age:int, name:chararray, messages:chararray');

要加载消息，请使用 elephant-bird jar.