多个元组作为用 Java 编写的 pig UDF 中的输入

Posted

技术标签:

【中文标题】多个元组作为用 Java 编写的 pig UDF 中的输入【英文标题】:Multiple tuples as input in a pig UDF written in Java 【发布时间】:2015-04-23 11:57:04 【问题描述】:

pig 脚本的示例输出:

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

我最终想在我的 java UDF 中创建一个直方图。如何在我的 UDF 中一次输入所有这些内容?

【问题讨论】:

【参考方案1】:

多个元组作为 UDF 的输入仅在您将元组放入包中然后将其用作输入时才有效。最简单的方法是创建一个组,然后使用生成的包作为 UDF 的输入。

【讨论】:

以上是关于多个元组作为用 Java 编写的 pig UDF 中的输入的主要内容,如果未能解决你的问题,请参考以下文章

用 Python 为 Pig 编写 UDF

Pig UDF - 将动态模式作为一组字段(不是元组)返回

Pig 将关系作为参数传递给 UDF

Pig UDF 似乎总是在单个减速器中运行 - PARALLEL 不起作用

Pig用户自定义函数(UDF)转

登录 Pig UDF