现在我们将hive转移到sparksql。我们使用etl创建了一些udf。当使用func(x)--返回一个arraylist。在Hive里是正确的。但是相同的func use spark sql抛出:spark sql error in query:unsupported java type class java.util.arraylist。下面是我的简单代码
import java.util.ArrayList;
public class Array_Test extends UDF{
public static ArrayList<String> evaluate(String jsonArrayStr) {
ArrayList<String> textList = new ArrayList<String>();
textList.add(jsonArrayStr);
return textList;
}
}
有人知道为什么吗?我们使用的spark vesrion是spark2-2.1.0.cloudera2-1.cdh5.7.0.p0.171658.hive版本是1.1.0-cdh5.15.2。
坦斯克
暂无答案!
目前还没有任何答案,快来回答吧!