输入-pig.json

{"food":"Tacos", "person":"Alice", "amount":3}

脚本

A = LOAD '/home/kishore/Data/Pig/pig.json' USING JsonLoader('food:chararray,person:chararray,amount:int');
B = foreach A generate food,person,amount;
Dump B;

输出

(Tacos,Alice,3)

我从twitter上找到了使用外部jar的答案。

register 'hdfs:/udf/elephant-bird-pig-4.10.jar';
register 'hdfs:/udf/elephant-bird-core-4.10.jar';
register 'hdfs:/udf/elephant-bird-hadoop-compat-4.10.jar';
register 'hdfs:/udf/json-simple-1.1.1.jar';

测试.json

{"food":"Tacos", "person":"Alice", "amount":3}

脚本：

A = LOAD 'hdfs:/test.json' USING com.twitter.elephantbird.pig.load.JsonLoader('-nestedLoad') AS (json:map[]); 
DUMP A;

我想要的结果是：

([amount#3,food#Tacos,person#Alice])

谢谢！