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

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