Description Usage Arguments Details Value See Also
View source: R/spark-structured-streaming-utilities.R
Connect to a Spark session
1 | castKafkaStreamAsString(streamObj)
|
streamObj |
Spark Structured Streaming DataFrame returned by |
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
Updated Spark Structured Streaming DataFrame with key, value, topic and timestamp from the Kafka stream
Other Spark utilities: convertKafkaValueFromJson
,
sparkRSessionCreateIfNotPresent
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.