如果我在pig中有以下数据结构（一个关系），并且我想把它传递给一个javaudf，我想知道输入参数的相关java数据类型应该是什么？（学生关系是一个包，模式是id为int，元组包含一个兴趣包和一个类包）。
student: {id: int,(interest: {(value: chararray)},classes: {(value: chararray)})}
提前谢谢你，林
30byixjq1#
我认为可以如下所示。
public class BagUdf extends EvalFunc<DataBag> { public <returnType> exec(Tuple input) throws IOException { //iterate over the bag elements for (Tuple t : (DataBag)input.get(0)) { // process tuple t } return returnVal; }
请参考此链接
1条答案
按热度按时间30byixjq1#
我认为可以如下所示。
请参考此链接