永続化を解除する

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

構文

unpersist(blocking: bool = False)

パラメーター

パラメーター	Type	説明
blocking	bool	すべてのブロックが削除されるまでブロックするかどうか。

パラメーター	Type	説明
blocking	bool	すべてのブロックが削除されるまでブロックするかどうか。

戻り値

DataFrame: 非永続化DataFrame 。

注意

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

クラシックコンピュートでは、キャッシュされたデータはクラスター上のすべてのSparkセッション間で共有されるため、永続化を解除するとすべてのセッションに影響します。

Serverlessコンピュートでは、unpersist()はキャッシュされた結果を再利用可能としてマークし、blockingを無視します。その後、DataFrameおよびDataFrameから派生したDataFramesは使用できなくなります。Serverless コンピュートでのDataFramesのキャッシュを参照してください。

例

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]