I'm consuming the Kafka data and persisting in the BD cassandra. I need to add a column in the stream to measure latency. Anyone know how to add? Do I need to treat this stream as an RDD?
Spark Streaming - Add a column with date and time in the stream
0
asked by anonymous 14.06.2018 / 03:13