Real-time Machine Learning with Spark Streaming - Machine Learning with Spark - page 380

Tip
Calling print on a DStream is similar to calling take on an RDD. It displays only the
first few elements.
We can run this program using SBT. Open a second terminal window, leaving the produ-
cer program running, and run sbt :
>sbt
[info] ...
>run
....
Again, you should see a few options to select:
Multiple main classes detected, select one to run:
[1] StreamingProducer
[2] SimpleStreamingApp
[3] StreamingAnalyticsApp
[4] StreamingStateApp
[5] StreamingModelProducer
[6] SimpleStreamingModel
[7] MonitoringStreamingModel
Run the SimpleStreamingApp main class. You should see the streaming program
start up, displaying output similar to the one shown here:
...
14/11/15 21:02:23 INFO scheduler.ReceiverTracker:
ReceiverTracker started
14/11/15 21:02:23 INFO dstream.ForEachDStream:
metadataCleanupDelay = -1
14/11/15 21:02:23 INFO dstream.SocketInputDStream:
metadataCleanupDelay = -1
14/11/15 21:02:23 INFO dstream.SocketInputDStream: Slide
time = 10000 ms
14/11/15 21:02:23 INFO dstream.SocketInputDStream: Storage
level = StorageLevel(false, false, false, false, 1)