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: DataFrame yang diperiksa.

Catatan

API ini bersifat eksperimental.

Examples

Note

Databricks menyarankan untuk beralih dari DataFrame.checkpoint() karena tidak kompatibel dengan arsitektur komputasi serverless Databricks. Tulis DataFrame ke tabel Delta sebagai gantinya.

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