diff options
| author | Felix Cheung <felixcheung_m@hotmail.com> | 2016-07-13 13:33:34 -0700 |
|---|---|---|
| committer | Shivaram Venkataraman <shivaram@cs.berkeley.edu> | 2016-07-13 13:33:34 -0700 |
| commit | b4baf086ca380a46d953f2710184ad9eee3a045e (patch) | |
| tree | cc6f5484fa0c0045b41e1d993536e22a12f4874a /examples/src/main | |
| parent | 51a6706b1339bb761602e33276a469f71be2cd90 (diff) | |
| download | spark-b4baf086ca380a46d953f2710184ad9eee3a045e.tar.gz spark-b4baf086ca380a46d953f2710184ad9eee3a045e.tar.bz2 spark-b4baf086ca380a46d953f2710184ad9eee3a045e.zip | |
[SPARKR][MINOR] R examples and test updates
## What changes were proposed in this pull request?
Minor example updates
## How was this patch tested?
manual
shivaram
Author: Felix Cheung <felixcheung_m@hotmail.com>
Closes #14171 from felixcheung/rexample.
Diffstat (limited to 'examples/src/main')
| -rw-r--r-- | examples/src/main/r/RSparkSQLExample.R | 3 | ||||
| -rw-r--r-- | examples/src/main/r/dataframe.R | 2 |
2 files changed, 4 insertions, 1 deletions
diff --git a/examples/src/main/r/RSparkSQLExample.R b/examples/src/main/r/RSparkSQLExample.R index eba3f1b91e..f20875ca9e 100644 --- a/examples/src/main/r/RSparkSQLExample.R +++ b/examples/src/main/r/RSparkSQLExample.R @@ -195,3 +195,6 @@ results <- collect(sql("FROM src SELECT key, value")) # $example on:jdbc$ df <- read.jdbc("jdbc:postgresql:dbserver", "schema.tablename", user = "username", password = "password") # $example off:jdbc$ + +# Stop the SparkSession now +sparkR.session.stop() diff --git a/examples/src/main/r/dataframe.R b/examples/src/main/r/dataframe.R index 295f9b4276..82b85f2f59 100644 --- a/examples/src/main/r/dataframe.R +++ b/examples/src/main/r/dataframe.R @@ -18,7 +18,7 @@ library(SparkR) # Initialize SparkSession -sc <- sparkR.session(appName = "SparkR-DataFrame-example") +sparkR.session(appName = "SparkR-DataFrame-example") # Create a simple local data.frame localDF <- data.frame(name=c("John", "Smith", "Sarah"), age=c(19, 23, 18)) |