spark sql错误:不支持的java类型类java.util.arraylist

pkbketx9  于 2021-06-25  发布在  Hive
关注(0)|答案(0)|浏览(282)

现在我们将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。
坦斯克

暂无答案!

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

相关问题