pos pemeriksaan

Mengembalikan versi checkpoint dari DataFrame ini. Titik pemeriksaan dapat digunakan untuk memotong rencana logis DataFrame ini, yang sangat berguna dalam algoritma berulang di mana rencana dapat tumbuh secara eksponensial. Ini akan disimpan ke file di dalam direktori titik pemeriksaan yang diatur dengan SparkContext.setCheckpointDir, atau spark.checkpoint.dir konfigurasi.

Sintaksis

checkpoint(eager: bool = True)

Parameter-parameternya

Parameter	Tipe	Deskripsi
eager	bool, opsional, default True	Apakah akan segera memeriksa DataFrame ini.

Pengembalian Barang

DataFrame: Checkpointed DataFrame.

Catatan

API ini bersifat eksperimental.

Examples

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