有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

查询中的配置单元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) 个答案