Spark LogicalPlan序列化/反序列化

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)

能做到吗 怎么样?