在用java编写的pig udf中输入多个元组

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

pig脚本的输出示例:

(1, 10)
(2, 100)
(3,44)
(4,99)

我最终想在javaudf中创建一个直方图。如何在自定义项中一次输入所有这些内容?

x6yk4ghg

x6yk4ghg1#

只有将多个元组放入一个包中,然后将其用作输入时,多个元组作为udf的输入才有效。最简单的方法是分组,然后使用生成的包作为自定义项的输入。

相关问题