kontrol noktası

Bu DataFrame'in denetim noktası uygulanmış bir sürümünü döndürür. Denetim noktası oluşturma, bu DataFrame'in mantıksal planının kesilmesi için kullanılabilir. Bu, özellikle planın katlanarak büyüyebileceği yinelemeli algoritmalarda yararlıdır. denetim noktası dizin kümesi içindeki dosyalara veya SparkContext.setCheckpointDir yapılandırmasıyla spark.checkpoint.dirkaydedilir.

Sözdizimi

checkpoint(eager: bool = True)

Parametreler

Parametre Türü Açıklama
eager bool, isteğe bağlı, varsayılan True Bu DataFrame'in hemen denetlenip denetlenmeyeceği.

İadeler

DataFrame: Denetim noktası oluşturulan DataFrame.

Notlar

Bu API deneyseldir.

Örnekler

:::note Sunucusuz uyumluluk

Databricks, Databricks sunucusuz bilgi işlem mimarisiyle uyumlu olmadığı için DataFrame.checkpoint() kullanımından vazgeçilmesini önerir. Bunun yerine DataFrame'i bir Delta tablosuna yazın.

:::

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