| saveAsTable {SparkR} | R Documentation |
Save the contents of the SparkDataFrame to a data source as a table
saveAsTable(df, tableName, source = NULL, mode = "error", ...) ## S4 method for signature 'SparkDataFrame,character' saveAsTable(df, tableName, source = NULL, mode = "error", ...)
df |
A SparkDataFrame |
tableName |
A name for the table |
source |
A name for external data source |
mode |
One of 'append', 'overwrite', 'error', 'ignore' save mode (it is 'error' by default) |
The data source is specified by the 'source' and a set of options (...). If 'source' is not specified, the default data source configured by spark.sql.sources.default will be used.
Additionally, mode is used to specify the behavior of the save operation when
data already exists in the data source. There are four modes:
append: Contents of this SparkDataFrame are expected to be appended to existing data.
overwrite: Existing data is expected to be overwritten by the contents of this
SparkDataFrame.
error: An exception is expected to be thrown.
ignore: The save operation is expected to not save the contents of the SparkDataFrame
and to not change the existing data.
Other SparkDataFrame functions: SparkDataFrame-class,
[[, agg,
arrange, as.data.frame,
attach, cache,
collect, colnames,
coltypes, columns,
count, dapply,
describe, dim,
distinct, dropDuplicates,
dropna, drop,
dtypes, except,
explain, filter,
first, group_by,
head, histogram,
insertInto, intersect,
isLocal, join,
limit, merge,
mutate, ncol,
persist, printSchema,
registerTempTable, rename,
repartition, sample,
selectExpr, select,
showDF, show,
str, take,
unionAll, unpersist,
withColumn, write.df,
write.jdbc, write.json,
write.parquet, write.text
## Not run:
##D sc <- sparkR.init()
##D sqlContext <- sparkRSQL.init(sc)
##D path <- "path/to/file.json"
##D df <- read.json(sqlContext, path)
##D saveAsTable(df, "myfile")
## End(Not run)