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包含預測。
-
-