流数据作为猪中的json对象

【问题标题】：Stream data as json object in pig流数据作为猪中的json对象
【发布时间】：2013-11-08 22:01:10
【问题描述】：

我有一个脚本，它在输入中采用复杂的 json 对象（每行一个）并以 hadoc 格式输出。我想使用 pig 使用 STREAM 通过此脚本流式传输一些数据。如何强制 pig 以 json 格式将数据发送到流式传输？我正在寻找类似的东西

C = stream A through `stream.py` USING JsonStorage()

【问题讨论】：

【解决方案1】：

pig 中似乎还没有这样的实现。最好的选择可能是使用输出 json 字符串的ToJson UDF，然后在流函数中将字符串加载为 json 对象，例如，使用 python 的 json.loads(inputstring)。

【讨论】：