Hadoop上的Java UDF輸入參數 - 從Pig上調用Hadoop

Question

如果我在Pig中有以下數據結構（關係），並且我想將它傳遞給Java UDF，那麼想知道應該將相關的Java數據類型輸入參數？

（學生關係是一個包，模式是ID爲int，一個元組包含一個興趣包和一個類包）。

student: {id: int,(interest: {(value: chararray)},classes: {(value: chararray)})} 

在此先感謝， 林

Answer 1

，我認爲這是可以做到如下圖所示。

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

請參閱本link