unpersist

DataFrame'i kalıcı olmayan olarak işaretler ve bellekten ve diskten tüm blokları kaldırır.

Sözdizimi

unpersist(blocking: bool = False)

Parametreler

Parametre	Türü	Açıklama
blocking	bool	Tüm bloklar silinene kadar engellenip engellenmeyeceği.

İadeler

DataFrame: Unpersisted DataFrame.

Notlar

blocking varsayılan değeri 2.0'da Scala ile eşleşecek şekilde False değiştirildi.

Önbelleğe alınan veriler kümedeki tüm Spark oturumlarında paylaşılır, bu nedenle tüm oturumları etkiler.

Örnekler

df = spark.range(1)
df.persist()
# DataFrame[id: bigint]
df.unpersist()
# DataFrame[id: bigint]
df = spark.range(1)
df.unpersist(True)
# DataFrame[id: bigint]