メインコンテンツまでスキップ

永続化を解除する

DataFrame非永続データとしてマークし、メモリとディスクからそのデータフレームに関連するすべてのブロックを削除します。

構文​

unpersist(blocking: bool = False)

パラメーター​

パラメーター

Type

説明

blocking

bool

すべてのブロックが削除されるまでブロックするかどうか。

パラメーター

Type

説明

blocking

bool

すべてのブロックが削除されるまでブロックするかどうか。

戻り値​

DataFrame: 非永続化DataFrame 。

注意​

blocking デフォルト値がScala 2.0に合わせてFalseに変更されました。

キャッシュされたデータはクラスター上のすべてのSparkセッションで共有されるため、キャッシュを無効にするとすべてのセッションに影響します。

例​

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