有没有什么方法可以在java代码中使用scala类型,以便将复杂对象转换为dataframe?

tf7tbtn2  于 2021-05-27  发布在  Spark
关注(0)|答案(0)|浏览(350)

现在,我的java代码中有一个复杂对象的列表。当我试图用它来创建一个Dataframe时,我得到了一个匹配错误。代码如下:

List<MyComplexPojo> myPojoList = new ArrayList<>();
for (....) {
    myPojoList.addAll( getAllValidPojos(...) );
}
DataFrame df = sqlContext.createDataFrame(myPojoList, MyComplexPojo.class); // throw MatchError

我在google上搜索了一下,似乎在java程序中,我不能简单地将一个复杂的javapojo转换成一个Dataframe。但是,我也发现了在创建Dataframe时如何解决scala.matcherror的问题。根据它,如果我使用scala类型而不是java类型,我应该能够从中创建dateframe。例如,我可以使用scala集合而不是java.util.list。
我没有办法将复杂类型java对象列表转换为Dataframe,这是真的吗?
如果是,那么我是否正确理解上面的url?更具体地说,如果我使用scala类型而不是java类型,我能在那里创建一个Dataframe吗?
有没有关于如何在java中使用scala类型的例子?
如果我可以在java中使用scala类型,那么如何在java代码中设置object字段的值呢?再说一次,任何例子都是好的。如何在java中向scala集合添加元素?

暂无答案!

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

相关问题