DataFrame を非永続的としてマークし、メモリとディスクからすべてのブロックを削除します。
構文
unpersist(blocking: bool = False)
パラメーター
| パラメーター | タイプ | 説明 |
|---|---|---|
blocking |
ブール (bool) | すべてのブロックが削除されるまでブロックするかどうかを指定します。 |
返品
DataFrame: 非パーシストed DataFrame。
メモ
blocking 2.0 で Scala と一致するように、既定値が False に変更されました。
キャッシュされたデータはクラスター上のすべての Spark セッションで共有されるため、永続性がないため、すべてのセッションに影響します。
例示
df = spark.range(1)
df.persist()
# DataFrame[id: bigint]
df.unpersist()
# DataFrame[id: bigint]
df = spark.range(1)
df.unpersist(True)
# DataFrame[id: bigint]