在处理输入数据之后，我得到了一个java对象。我已经创建了avro模式，用于将对象存储在avro文件中。我一直在使用模式将对象写入hdfs。有人能告诉我使用pig脚本和相应的udf编写对象的过程吗？
plupiseo1#
如果您使用java，我想您正在使用一个udf。所以您只需将udf的结果作为pig元组返回。然后，您就可以得到一个与数据的关系，以便存储。最后，您可以使用avrostorage使用store命令。
1条答案
按热度按时间plupiseo1#
如果您使用java，我想您正在使用一个udf。
所以您只需将udf的结果作为pig元组返回。
然后，您就可以得到一个与数据的关系，以便存储。
最后，您可以使用avrostorage使用store命令。