查询中的配置单元Sparksql错误:不支持java类型类java。util。ArrayList
现在我们将配置单元转移到spark sql。我们使用ETL创建了一些UDF。使用FUNC(X)时--返回一个ArrayList。在蜂箱中是正确的。但是相同的FUNC使用sparksql抛出:查询中的sparksql错误:不支持的java类型类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.
坦斯克
共 (0) 个答案