问题描述
如果我检查点如下所示的DataFrame。我怎样才能读回它？
df1 = spark.createDataFrame([('Abraham','Lincoln')],['first_name','last_name'])
df1.checkpoint()
类似....
reload = spark.read.something('checkpoints/87b411a8-19e3-402a-86a7-cfac0a4a6d14/rdd-40/*')
我看到写入checkpoints文件夹的checkpoint文件已分区，但无法确定文件类型是什么。
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）