使用元组进行 Pig 编程

Posted 2023-04-18

【中文标题】使用元组进行 Pig 编程

【英文标题】：Pig Programming with Tuples

【发布时间】：2014-07-06 12:13:41

【问题描述】：

如何从 UDF 返回元组？

我知道如何从 UDF 返回一个字符串。

谁能通过一个简单的例子向我解释如何从 UDF 返回元组？

【参考方案1】：

只需用下面的元组替换字符串..

public class YourUdf extends EvalFunc<Tuple> 

    public Tuple exec(Tuple input) throws IOException 

             DefaultTuple dt = new DefaultTuple();//creating tuple object

            //using tuple object you can add the values

                              //your code here;

             return dt;
        

【参考方案2】：

使用 Python UDF，您的 @outputSchema 定义了它是一个元组或字符串。示例：

@outputSchema("record: (Id, name, age)")