StreamingLinearAlgorithm¶
-
类
pyspark.mllib.regression。StreamingLinearAlgorithm( 模型:可选(pyspark.mllib.regression.LinearModel] ) ¶ -
基类必须继承了任何StreamingLinearAlgorithm。
防止predictOn和predictOnValues重新实现方法。
方法
返回最新的模型。
predictOn(dstream)使用该模型来预测从DStream批次的数据。
predictOnValues(dstream)利用该模型预测的值DStream和携带的钥匙。
方法的文档
-
latestModel( )→可选( pyspark.mllib.regression.LinearModel ] ¶ -
返回最新的模型。
-
predictOn( dstream:DStream(VectorLike] )→DStream(浮动] ¶ -
使用该模型来预测从DStream批次的数据。
- 返回
-
-
pyspark.streaming.DStream -
DStream包含预测。
-
-
predictOnValues( dstream:DStream(元组(K,VectorLike]] )→DStream(元组(K,浮动] ] ¶ -
利用该模型预测的值DStream和携带的钥匙。
- 返回
-
-
pyspark.streaming.DStream -
DStream包含预测。
-
-