将pig输出存储到csv文件中

jljoyd4f  于 2021-06-25  发布在  Pig
关注(0)|答案(1)|浏览(347)

我有一个csv文件,我用它作为pig脚本的输入。csv有如下数据
1045 966 320189 1048 555 714067 1035 199 975050 1026 748 814808 1018 656 103141 1004 186 686093 1016 292 553100 1043 864 750624 1050 839 785765 1002 454 452221 1041 807 330616 1019 538 680915 1002 950 583977 1036 638 111509 1031 687 876615
我的剧本---

REGISTER /home/user/myudfs.jar;
A = LOAS 'new.csv' using PigStorage(',');
STORE A INTO '/home/user/result.csv'
USING CSVExcelStorage(',', 'NO_MULTILINE', 'WINDOWS');

我有一个内置类的myudfs jar CSVExcelStorage . 我正在我的脚本中注册它。
在执行脚本时,我得到一个错误

"ERROR 1070: Could not resolve myudfs.CSVExcelStorage using imports: [,org.apache.pig.builtin., org.apache.pig.impl.builtin.]"

请帮忙。

q35jwt9p

q35jwt9p1#

如果已经在包下创建了udf类,那么在pig脚本中应该给出udf类的完全限定名,即

STORE A INTO '/home/user/result.csv'
USING HereGoesThePackageName.CSVExcelStorage(',', 'NO_MULTILINE', 'WINDOWS');

相关问题