pyspark.RDD.getCheckpointFile

RDD.getCheckpointFile() → Optional[str]

Gets the name of the file to which this RDD was checkpointed

Not defined if RDD is checkpointed locally.

New in version 0.7.0.

Returns

str

the name of the file to which this RDD was checkpointed

See also

RDD.checkpoint()

SparkContext.setCheckpointDir()

SparkContext.getCheckpointDir()

pyspark.RDD.fullOuterJoin pyspark.RDD.getNumPartitions