pyspark.mllib.regression.
StreamingLinearAlgorithm
Base class that has to be inherited by any StreamingLinearAlgorithm.
Prevents reimplementation of methods predictOn and predictOnValues.
New in version 1.5.0.
Methods
latestModel()
latestModel
Returns the latest model.
predictOn(dstream)
predictOn
Use the model to make predictions on batches of data from a DStream.
predictOnValues(dstream)
predictOnValues
Use the model to make predictions on the values of a DStream and carry over its keys.
Methods Documentation
pyspark.streaming.DStream
DStream containing predictions.