如何在分组之后从pig中展平并获得如下所示的预期输出

zfciruhq 于 2021-07-15 发布在 Hadoop

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

样品日期：
身份证日期
12345 12 20210204
12345 13 20210204
12345 2 20210204
输入：
(12345,{(12345,12,20210204),(12345,13,20210204),(12345,2,20210204)})
所需输出：
(12345,27,20210204)
第二个元素是聚合值。
感谢您的帮助

hadoop etl bigdata apache-pig Flatten

来源：https://stackoverflow.com/questions/66160881/how-to-flatten-and-get-expected-output-shown-below-from-pig-after-group-by

1条答案

按热度按时间

wb1gzix01#

output = FOREACH input GENERATE
    group AS ID,
    SUM(sample.marks) AS mark_sum,
    MIN(sample.date) AS first_date;

您可能需要根据关系和字段名进行调整。如果这些字段都相同，您也可能希望按日期字段分组。

赞(0）回复(0）举报 2021-07-15

我来回答

如何在分组之后从pig中展平并获得如下所示的预期输出

1条答案

相关问题

热门标签

最新问答