Spark2.X 的 Java API 移除了DataFrame类,换为使用DataSet<ROW>
代替。
对应的包为:
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
版权声明:本文为EnterPine原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。
Spark2.X 的 Java API 移除了DataFrame类,换为使用DataSet<ROW>
代替。
对应的包为:
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;