使用Java UDF

Question

我有我的数据在猪转换的包包多的元组的元组为：

{(2000),(1800),(2700)} 
{(2014),(1500),(1900)} etc. 

我创建一个Java UDF：

DataBag bag = (DataBag) top3.get(0); 
Tuple categoryCode = null; 
if(bag.size() == 0) 
    return null; 
for(Iterator<Tuple> code=bag.iterator(); code.hasNext();) 
    categoryCode=code.next(); 
return categoryCode.get(0).toString(); 

我希望我的输出要像：

2000,1800,2700 
2014,1500,1900 etc 

我UDF给我的输出：

2000 
2014 etc 

请帮助是否有其他解决方案。请帮助你的投入。

Answer 1

这其实很容易，看看那：

public class YourClass extends EvalFunc<String>{ 

    @Override 
    public String exec(Tuple input) throws IOException { 

     DataBag bag = (DataBag)input.get(0); 

     Tuple categoryCode = null; 

     //Keep the count of every cell in the 
     Tuple auxiliary = TupleFactory.getInstance().newTuple(3); 

     int i = 0; 
     for(Iterator<Tuple> code=bag.iterator(); code.hasNext();) { 
      categoryCode=code.next(); 
      //You can use append if don't know from the very beginning 
      //the size of tuple 
      auxiliary.set(i, categoryCode.get(0).toString()); 
      i+=1; 
     } 

     return auxiliary.toDelimitedString(","); 
    } 
} 

您可以使用辅助的元组做的事情变得简单，然后只用实例方法toDelimitedString()，很简单的更好。