永続化を解除する

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

構文

unpersist(blocking: bool = False)

パラメーター

パラメーター	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]