使用pig以不同的方式读取json

blpfk2vs  于 2021-06-25  发布在  Pig
关注(0)|答案(0)|浏览(204)

我的json文件

{"messages":[{"food":"Taco1", "person":"Alice1", "amount":1}]}
{"messages":[{"food":"Taco2", "person":"Alice2", "amount":2}]}
{"messages":[{"food":"Taco3", "person":"Alice3", "amount":3}]}

我的代码

STOCK_A = LOAD 'file.json' 
USING JsonLoader('messages:{(food:chararray, person:chararray, amount:int)}');
rowarr = FOREACH STOCK_A GENERATE FLATTEN(messages.(food, person,amount));

结果架构

rowarr: {null::food: chararray,null::person: chararray,null::amount: int}

预期

rowarr: {food: chararray,person: chararray,amount: int}

我要怎么做?有什么想法吗

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题