我有 Maven 依赖项 spark-sql_2.1.0
和 spark-hive_2.1.0
。但是,当我尝试 import org.apache.spark.sql.DataFrame
时,出现错误。但是进口
org.apache.spark.sql.SQLContext
没问题,没有错误。为什么?
最佳答案
DataFrame 变成了 type DataFrame = Dataset[Row]
在 Spark 2.x 中。 Java 没有类型别名,因此它在 Java 中不可用。您现在应该使用新类型 Dataset<Row>
, 所以同时导入 org.apache.spark.sql.Dataset
和 org.apache.spark.sql.Row
关于java - 为什么我不能导入 org.apache.spark.sql.DataFrame,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45188113/