pig中的条件和

hts6caw3 于 2021-06-04 发布在 Hadoop

关注(0)|答案(1)|浏览(308)

我使用三元运算符来包含 SUM() 有条件地操作。我就是这样做的。

GROUPED = GROUP ALL_MERGED BY (fld1, fld2, fld3);

REPORT_DATA = FOREACH GROUPED
              {     GENERATE group,
                    SUM(GROUPED.fld4 == 'S' ? GROUPED.fld5 : 0) AS sum1,
                    SUM(GROUPED.fld4 == 'S' ? GROUPED.fld5 : (GROUPED.fld5 * -1)) AS sum2;
               }

的架构 ALL_MERGED 是

{ALL_MERGED: {fld1:chararray, fld2:chararray, fld3:chararray, fld4:chararray: fld5:int}}

当我执行此操作时，会出现以下错误：

ERROR org.apache.pig.tools.grunt.Grunt - ERROR 1000: Error during parsing. Invalid alias: SUM in {group: (fld1:chararray, fld2:chararray, fld3:chararray), ALL_MERGED: {fld1:chararray, fld2:chararray, fld3:chararray, fld4:chararray: fld5:int}}

我做错什么了？

hadoop apache-pig

来源：https://stackoverflow.com/questions/14279519/conditional-sum-in-pig

1条答案

按热度按时间

xdnvmnnf1#

SUM 是一个以包作为输入的自定义项。你所做的有很多问题，我想这会帮助你复习一本关于pig的好参考书。我推荐编程Pig，可免费上网。首先， GROUPED 有两个字段：一个称为 group 还有一个叫 ALL_MERGED ，这就是错误消息试图告诉您的内容(我之所以说“尝试”，是因为pig的错误消息通常都很神秘。）
此外，不能像您希望的那样将表达式传递给UDF。相反，你必须 GENERATE 然后经过这些田地。试试这个：

ALL_MERGED_2 =
    FOREACH ALL_MERGED
    GENERATE
        fld1 .. fld5,
        ((fld4 == 'S') ? fld5 : 0) AS sum_me1,
        ((fld4 == 'S') ? fld5 : fld5*-1) AS sum_me2;

GROUPED = GROUP ALL_MERGED_2 BY (fld1, fld2, fld3);
DATA =
    FOREACH GROUPED
    GENERATE
        group,
        SUM(ALL_MERGED_2.sum_me1) AS sum1,
        SUM(ALL_MERGED_2.sum_me2) AS sum2;

赞(0）回复(0）举报 2021-06-04

我来回答

pig中的条件和

1条答案

相关问题

热门标签

最新问答