相关疑难解决方法(0)

使用loadfunc pig UDF将protobuf格式文件加载到pig脚本中

我对猪的知识很少.我有protobuf格式的数据文件.我需要将此文件加载到pig脚本中.我需要编写一个LoadFunc UDF来加载它.说功能是Protobufloader().

我的PIG脚本会是

A = LOAD 'abc_protobuf.dat' USING Protobufloader() as (name, phonenumber, email);
Run Code Online (Sandbox Code Playgroud)

我想知道的是如何获取文件输入流.一旦我掌握了文件输入流,我就可以将数据从protobuf格式解析为PIG元组格式.

PS:提前谢谢

hadoop protocol-buffers apache-pig hadoop-plugins

4
推荐指数
1
解决办法
3082
查看次数