帶元組的豬編程

Question

如何從UDF返回元組？

我知道如何從UDF返回一個字符串。

有人可以向我解釋如何用一個簡單的例子從UDF返回一個Tuple？

Answer 1

使用Python UDF，它是定義您的@outputSchema，它是一個元組或字符串。爲例：

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

Answer 2

只是元組替換字符串像下面..

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; 
    }  

}