hive udf保留上一行的值

46qrfjad  于 2021-06-04  发布在  Hadoop
关注(0)|答案(0)|浏览(252)

我有一个自定义项,它应该返回上一行的内容。我用以下代码实现了它。不幸的是,它总是返回参数second的当前行的值。有人知道我做错了什么吗?

@UDFType(stateful = true)   

public class Strip extends UDF {    

private Text result = new Text();
private static ArrayList<Text> lst;
int count=0;

public Strip(){
    result.set("");
}
public Text evaluate(Text first, Text second) {

    if (str == null | stripChars == null) {
return null;
}
if (lst == null)
{
    lst = new ArrayList<Text>();
    lst.add(second);        
    return first;
}

result=lst.get(lst.size()-1);
lst.add(second);    
return result;

}

提前谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题