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()

previous

pyspark.RDD.fullOuterJoin

next

pyspark.RDD.getNumPartitions