igr*_*eld 5 apache-spark apache-spark-sql
我想将DataFrame.queryExecution.optimizedPlan保存为一些持久性,然后重用它在其他spark应用程序中创建新的DataSet:使用此API:
org.apache.spark.sql.Dataset.ofRows(sparkSession, logicalPlan)
Run Code Online (Sandbox Code Playgroud)
能做到吗 怎么样?
| 归档时间: |
|
| 查看次数: |
105 次 |
| 最近记录: |