pig脚本的输出示例:
(1, 10) (2, 100) (3,44) (4,99)
我最终想在javaudf中创建一个直方图。如何在自定义项中一次输入所有这些内容?
x6yk4ghg1#
只有将多个元组放入一个包中,然后将其用作输入时,多个元组作为udf的输入才有效。最简单的方法是分组,然后使用生成的包作为自定义项的输入。
1条答案
按热度按时间x6yk4ghg1#
只有将多个元组放入一个包中,然后将其用作输入时,多个元组作为udf的输入才有效。最简单的方法是分组,然后使用生成的包作为自定义项的输入。