localCheckpoint

Mengembalikan versi DataFrame yang dicentang secara lokal. Titik pemeriksaan dapat digunakan untuk memotong rencana logis DataFrame ini, yang sangat berguna dalam algoritma berulang di mana rencana dapat tumbuh secara eksponensial. Titik pemeriksaan lokal disimpan di pelaksana menggunakan subsistem penembolokan dan karenanya tidak dapat diandalkan.

Sintaksis

localCheckpoint(eager: bool = True, storageLevel: Optional[StorageLevel] = None)

Parameter-parameternya

Parameter	Tipe	Deskripsi
eager	bool, opsional, default True	Apakah akan segera memeriksa DataFrame ini.
storageLevel	StorageLevel, opsional, default Tidak Ada	StorageLevel tempat titik pemeriksaan akan disimpan. Jika tidak ditentukan, default untuk titik pemeriksaan lokal RDD.

Pengembalian Barang

DataFrame: Checkpointed DataFrame.

Catatan

API ini bersifat eksperimental.

Examples

df = spark.createDataFrame([
    (14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
df.localCheckpoint(False)
# DataFrame[age: bigint, name: string]