pyspark.SparkContext.setCheckpointDir

SparkContext。 setCheckpointDir ( 目录名:str )→没有

设置的目录抽样将检查点。目录必须是一个HDFS路径,如果在一个集群上运行。