Description Usage Arguments Details See Also Examples
View source: R/spark-structured-streaming-utilities.R
Connect to a Spark session
1 |
... |
Arguments to sparkR.session |
Loads the SparkR package and intializes a Spark session from R
Other Spark utilities: castKafkaStreamAsString
,
convertKafkaValueFromJson
1 2 3 4 5 6 7 8 | ## Not run:
sparkHome <- "/Users/naren/softwares/spark-2.3.1-bin-hadoop2.7/"
sparkMaster <- "local[1]"
sparkPackages <- c("org.apache.spark:spark-sql-kafka-0-10_2.11:2.3.1")
sparkRSessionCreateIfNotPresent(master = sparkMaster,
sparkPackages = sparkPackages)
## End(Not run)
|
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.