org.apache.spark.streaming.examples
A simple publisher for demonstration purposes, repeatedly publishes random Messages every one second.
A simple publisher for demonstration purposes, repeatedly publishes random Messages every one second.