Database Reference
In-Depth Information
Created 83 events...
Created 75 events...
...
After about 10 seconds, you should start seeing the model predictions being printed to the
streaming application console, similar to those shown here:
14/11/16 14:54:00 INFO StreamingLinearRegressionWithSGD:
Model updated at time 1416142440000 ms
14/11/16 14:54:00 INFO StreamingLinearRegressionWithSGD:
Current model: weights,
[0.05160959387864821,0.05122747155689144,-0.17224086785756998,0.05822993392274008,0.07848094246845688,-0.1298315806501979,0.006059323642394124,
...
...
14/11/16 14:54:00 INFO JobScheduler: Finished job streaming
job 1416142440000 ms.0 from job set of time 1416142440000 ms
14/11/16 14:54:00 INFO JobScheduler: Starting job streaming
job 1416142440000 ms.1 from job set of time 1416142440000 ms
14/11/16 14:54:00 INFO SparkContext: Starting job: take at
DStream.scala:608
14/11/16 14:54:00 INFO DAGScheduler: Got job 3 (take at
DStream.scala:608) with 1 output partitions
(allowLocal=true)
14/11/16 14:54:00 INFO DAGScheduler: Final stage: Stage
3(take at DStream.scala:608)
14/11/16 14:54:00 INFO DAGScheduler: Parents of final
stage: List()
14/11/16 14:54:00 INFO DAGScheduler: Missing parents: List()
14/11/16 14:54:00 INFO DAGScheduler: Computing the
requested partition locally
14/11/16 14:54:00 INFO SparkContext: Job finished: take at
DStream.scala:608, took 0.014064 s
-------------------------------------------
Time: 1416142440000 ms
-------------------------------------------
-2.0851430248312526
4.609405228401022
2.817934589675725
3.3526557917118813
