Description Usage Arguments Details Value See Also
View source: R/spark-structured-streaming-utilities.R
Connect to a Spark session
1 | convertKafkaValueFromJson(streamObj, schema)
|
streamObj |
Spark Structured Streaming DataFrame which is returned by the |
schema |
A structType object created from SparkR specifying the schema of the json data present in the |
Takes in a Structured Stream from Kafka created from read.stream(source = 'kafka', ...)
and returns
a Structured Streaming DataFrame where the key
and value
from the Kafka stream are cast to string
Spark Structured Streaming DataFrame with the json data in the value
attribute of the Kafka stream parsed
into a DataFrame format
Other Spark utilities: castKafkaStreamAsString
,
sparkRSessionCreateIfNotPresent
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.