DataFrame을 비영구로 표시하고 메모리 및 디스크에서 모든 블록을 제거합니다.
문법
unpersist(blocking: bool = False)
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
blocking |
bool | 모든 블록이 삭제될 때까지 차단할지 여부입니다. |
Returns
DataFrame: 존재하지 않는 DataFrame입니다.
Notes
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]