StreamingLinearAlgorithm¶

class pyspark.mllib.regression.StreamingLinearAlgorithm(model)[source]¶

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`()	Returns the latest model.
`predictOn`(dstream)	Use the model to make predictions on batches of data from a DStream.
`predictOnValues`(dstream)	Use the model to make predictions on the values of a DStream and carry over its keys.

Methods Documentation

predictOn(dstream)[source]¶

Use the model to make predictions on batches of data from a DStream.

New in version 1.5.0.

Returns

predictOnValues(dstream)[source]¶

Use the model to make predictions on the values of a DStream and carry over its keys.

New in version 1.5.0.

Returns

IsotonicRegression

StreamingLinearRegressionWithSGD