Nota
L-aċċess għal din il-paġna jeħtieġ l-awtorizzazzjoni. Tista’ tipprova tidħol jew tibdel id-direttorji.
L-aċċess għal din il-paġna jeħtieġ l-awtorizzazzjoni. Tista’ tipprova tibdel id-direttorji.
Returns a checkpointed version of this DataFrame. Checkpointing can be used to truncate the logical plan of this DataFrame, which is especially useful in iterative algorithms where the plan may grow exponentially. It will be saved to files inside the checkpoint directory set with SparkContext.setCheckpointDir, or spark.checkpoint.dir configuration.
Syntax
checkpoint(eager: bool = True)
Parameters
| Parameter | Type | Description |
|---|---|---|
eager |
bool, optional, default True | Whether to checkpoint this DataFrame immediately. |
Returns
DataFrame: Checkpointed DataFrame.
Notes
This API is experimental.
Examples
df = spark.createDataFrame([
(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"])
df.checkpoint(False)
# DataFrame[age: bigint, name: string]