unpersist {SparkR} | R Documentation |
Mark this SparkDataFrame as non-persistent, and remove all blocks for it from memory and disk.
unpersist(x, ...) ## S4 method for signature 'SparkDataFrame' unpersist(x, blocking = TRUE)
x |
the SparkDataFrame to unpersist. |
... |
further arguments to be passed to or from other methods. |
blocking |
whether to block until all blocks are deleted. |
unpersist since 1.4.0
Other SparkDataFrame functions: SparkDataFrame-class
,
agg
, arrange
,
as.data.frame
,
attach,SparkDataFrame-method
,
cache
, checkpoint
,
coalesce
, collect
,
colnames
, coltypes
,
createOrReplaceTempView
,
crossJoin
, dapplyCollect
,
dapply
, describe
,
dim
, distinct
,
dropDuplicates
, dropna
,
drop
, dtypes
,
except
, explain
,
filter
, first
,
gapplyCollect
, gapply
,
getNumPartitions
, group_by
,
head
, hint
,
histogram
, insertInto
,
intersect
, isLocal
,
isStreaming
, join
,
limit
, merge
,
mutate
, ncol
,
nrow
, persist
,
printSchema
, randomSplit
,
rbind
, registerTempTable
,
rename
, repartition
,
sample
, saveAsTable
,
schema
, selectExpr
,
select
, showDF
,
show
, storageLevel
,
str
, subset
,
take
, toJSON
,
union
, withColumn
,
with
, write.df
,
write.jdbc
, write.json
,
write.orc
, write.parquet
,
write.stream
, write.text
## Not run:
##D sparkR.session()
##D path <- "path/to/file.json"
##D df <- read.json(path)
##D persist(df, "MEMORY_AND_DISK")
##D unpersist(df)
## End(Not run)