Catatan
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba masuk atau mengubah direktori.
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba mengubah direktori.
Menandai DataFrame sebagai tidak persisten, dan menghapus semua blok untuknya dari memori dan disk.
Sintaksis
unpersist(blocking: bool = False)
Parameter-parameternya
| Parameter | Tipe | Deskripsi |
|---|---|---|
blocking |
bool | Apakah akan memblokir hingga semua blok dihapus. |
Pengembalian Barang
DataFrame: DataFrame yang tidak diopersi.
Catatan
blocking default telah berubah menjadi False cocok dengan Scala di 2.0.
Data yang di-cache dibagikan di semua sesi Spark pada kluster, sehingga batal berdampak pada semua sesi.
Examples
df = spark.range(1)
df.persist()
# DataFrame[id: bigint]
df.unpersist()
# DataFrame[id: bigint]
df = spark.range(1)
df.unpersist(True)
# DataFrame[id: bigint]