在pig中的包上使用枚举时出现错误1070

wooyq4lh  于 2021-05-29  发布在  Hadoop
关注(0)|答案(1)|浏览(403)

我正在尝试使用以下代码枚举一个包:

DEFINE Enumerate datafu.pig.bags.Enumerate('1');

  group = GROUP data1
            By (query_text);

  ranked = FOREACH group {
        ordered = ORDER data1 BY score DESC;
        ordered = Enumerate(ordered);
        generate ordered_suggestions;
    };

获取以下错误:

220255 [main] ERROR org.apache.pig.tools.grunt.Grunt  - ERROR 1070: Could not resolve datafu.pig.bags.Enumerate using imports: [, java.lang., org.apache.pig.builtin., org.apache.pig.impl.builtin.]
17/08/01 17:54:30 ERROR grunt.Grunt: ERROR 1070: Could not resolve datafu.pig.bags.Enumerate using imports: [, java.lang., org.apache.pig.builtin., org.apache.pig.impl.builtin.]
Details at logfile: /mnt/var/log/pig/pig_1501609850542.log
1tuwyuhd

1tuwyuhd1#

我没有注册jar。

REGISTER 's3:/<<s3-bucket-name>>/lib/datafu-1.2.0.jar';

这很好:

REGISTER 's3:/<<s3-bucket-name>>/lib/datafu-1.2.0.jar
 DEFINE Enumerate datafu.pig.bags.Enumerate('1');

  group = GROUP data1
            By (query_text);

  ranked = FOREACH group {
        ordered = ORDER data1 BY score DESC;
        ordered = Enumerate(ordered);
        generate ordered_suggestions;
    };

相关问题