spark_sql: Spark SQL

Description Usage Arguments Value Examples

View source: R/spark.R

Description

Execute Spark SQL queries directly on the spark session

Usage

1
spark_sql(expr)

Arguments

expr

a string, the SQL query

Value

a spark_tbl

Examples

1
2
3
4
5
6
## Not run: 
spark_tbl(iris) %>% register_temp_view("iris")
iris_preview <- spark_sql("SELECT * FROM iris LIMIT 10")
iris_preview %>% collect

## End(Not run)

danzafar/tidyspark documentation built on Sept. 30, 2020, 12:19 p.m.