Spark Streaming - Add a column with date and time in the stream


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?

asked by anonymous 14.06.2018 / 03:13

0 answers