kontrolní bod

Vrátí kontrolní bodovou verzi tohoto datového rámce. Kontrolní body lze použít ke zkrácení logického plánu tohoto datového rámce, což je zvlášť užitečné v iterativních algoritmech, kde se plán může exponenciálně zvětšit. Uloží se do souborů v adresáři kontrolního bodu nastaveném pomocí SparkContext.setCheckpointDirparametru nebo spark.checkpoint.dir konfigurace.

Syntaxe

checkpoint(eager: bool = True)

Parametry

Parameter	Typ	Description
eager	bool, optional, default True	Zda se má kontrolní bod tohoto datového rámce provést okamžitě.

Návraty

DataFrame: Kontrolní datový rámec.

Poznámky

Toto rozhraní API je experimentální.

Příklady

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