如何根据 Spark SQL 中的 DBRef 字段列表进行查询

问题描述

我有一个包含 DBRef 对象列表的 mongo 数据库。我正在将此集合转换为 spark 中的数据框。

enter image description here

这给出了以下错误。有谁知道如何解决这个错误??

EDIT:: Conversion to dataframe 给出以下错误 -> org.codehaus.janino.InternalCompilerException:两个非抽象方法“public int scala.collection.TraversableOnce.size()”具有相同的参数类型,声明类型和返回类型

解决方法

将“org.codehaus.janino”的版本升级到3.0.9后,错误得到解决(之前我使用的是3.0.8)。