对于python udf，@outputschema定义了一个元组或字符串。例如：

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

用下面的元组替换字符串。。

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

}