selectExpr {SparkR} | R Documentation |
Select from a SparkDataFrame using a set of SQL expressions.
selectExpr(x, expr, ...) ## S4 method for signature 'SparkDataFrame,character' selectExpr(x, expr, ...)
x |
A SparkDataFrame to be selected from. |
expr |
A string containing a SQL expression |
... |
Additional expressions |
A SparkDataFrame
selectExpr 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
, select
,
showDF
, show
,
storageLevel
, str
,
subset
, take
,
toJSON
, union
,
unpersist
, 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 selectExpr(df, "col1", "(col2 * 5) as newCol")
## End(Not run)