袋子里的 Pig Sum 字段不起作用

Question

已更新

输入是 json 行文本文件。

{"store":"079","items":[{"name":"早晨全餐","unit_price":18,"quantity":1,"total":18},{"name":"麦趣鸡盒","unit_price":78,"quantity":5,"total":390},{"name":"巨无霸","unit_price":17,"quantity":5,"total":85},{"name":"香骨鸡腿","unit_price":12,"quantity":2,"total":24},{"name":"小薯条","unit_price":7,"quantity":5,"total":35}],"date":"\/Date(1483256820000)\/","oId":"27841ef9-f88e-478f-8f20-17c3ad090ebc"}
{"store":"041","items":[{"name":"小薯条","unit_price":7,"quantity":2,"total":14},{"name":"巨无霸","unit_price":17,"quantity":4,"total":68}],"date":"\/Date(1483221780000)\/","oId":"afee2e6d-0f81-4780-82e9-2169bf3c43f3"}
{"store":"008","items":[{"name":"奶昔香草","unit_price":9,"quantity":5,"total":45},{"name":"小薯条","unit_price":7,"quantity":2,"total":14}],"date":"\/Date(1483248600000)\/","oId":"802ea077-1eef-4cc9-af89-af7398e56792"}

期望按所有店铺分组，计算每项总和，例如：

store_name  total_amount
_________________________
001 2212.26
002 3245.46
003 888888

我的 Pig 脚本：

store_table = LOAD '/example/store-data/2017-store-sales-data.json'
    USING JsonLoader('
        store_name:chararray,
         items: {(
                name:chararray,
                unit_price:Bigdecimal,
                quantity:int,
                total:Bigdecimal)
                },
      date:Datetime,
      oId:chararray'
       );

platten_table = foreach store_table generate flatten(items), store_name;
store_group =  group platten_table by store_name;

result = foreach store_group {
total_sum = sum(platten_table.items::total);
Generate group,total_sum;
}

猪的错误是： 2017-11-28 08:53:54,357 [main] 错误 org.apache.pig.tools.grunt.Grunt - 错误 1200：不匹配的输入 'Generate' 期望 SEMI_COLON

Answer 1

Eval 函数区分大小写，您需要使用大写的 eval 函数 SUM。

代码片段-

result = foreach store_group {
    total_sum = SUM(platten_table.items::total);
    Generate group,total_sum;
}

Refer : https://pig.apache.org/docs/r0.10.0/basic.html

袋子里的 Pig Sum 字段不起作用

Pig Sum field from bag not works

apache-pig