java - 为什么我不能导入 org.apache.spark.sql.DataFrame

标签 java apache-spark

我有 Maven 依赖项 spark-sql_2.1.0spark-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.Datasetorg.apache.spark.sql.Row

关于java - 为什么我不能导入 org.apache.spark.sql.DataFrame,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45188113/

相关文章:

java - struts属性标签检索对象

java - Android 应用程序单击按钮调用不正确的 OnClick 监听器

java - 在 LibGdx 中画一条经过某个点的线

Azure Databricks 情绪分析不起作用

apache-spark - 使用 Spark.SQL 编码的 Apache Spark 进行结构化流处理

apache-spark - 使用ES-Spark连接器创建嵌套对象数组

java - 当 RHS == Integer.MAX_VALUE 时对 int 进行 boolean 比较,为什么这个循环会终止?

java - 如何更改计时器格式

java - 为每个 Spark 执行器设置自定义 java.rmi.server.hostname

apache-spark - 按窗口/滞后的 PySpark 数据帧条件