Pyspark 線性回歸梯度下降交叉驗證知識點詳解
我正在嘗試在 pyspark 中的 SGD 模型上執(zhí)行交叉驗證,我正在使用pyspark.mllib.regression,ParamGridBuilder和CrossValidator都來自pyspark.ml.tuning庫的LinearRegressionWithSGD。
在 Spark 網(wǎng)站上跟蹤文件資料之后,我希望運行此方法可以正常工作
資料參考:https://spark.apache.org/docs/2.1.0/ml-tuning.html
lr = LinearRegressionWithSGD() pipeline=Pipeline(stages=[lr]) paramGrid = ParamGridBuilder()\ .addGrid(lr.stepSize, Array(0.1, 0.01))\ .build() crossval = CrossValidator(estimator=pipeline,estimatorParamMaps= paramGrid, evaluator=RegressionEvaluator(), numFolds=10)
但是LinearRegressionWithSGD()沒有屬性stepSize(也沒有運氣嘗試過其他人)。
我可以將 lr 設(shè)置為LinearRegression,但是我無法在模型中使用 SGD 并進行交叉驗證。
斯卡拉中有kFold方法,但我不確定如何從 pyspark 訪問該方法
解決方案
您可以使用LinearRegressionWithSGD中的step參數(shù)來定義步長,但由于您正在混合不兼容的庫,因此這將使代碼無法正常工作。不幸的是,我不知道如何使用SGD優(yōu)化對ml庫進行交叉驗證,我想知道自己,但是您正在混合使用pyspark.ml和pyspark.mllib庫。具體來說,您不能將LinearRegressionWithSGD與pyspark.ml庫一起使用。您必須使用pyspark.ml.regression.LinearRegression。
好消息是您可以將pyspark.ml.regression.LinearRegression的setsolver屬性設(shè)置為使用'gd'。因此,您可能可以將'gd'優(yōu)化器的參數(shù)設(shè)置為以SGD運行,但是我不確定求解器文檔在哪里或如何設(shè)置求解器屬性(例如批大小)。該api顯示了調(diào)用Param()的LinearRegression對象,但是我不確定它是否使用pyspark.mllib優(yōu)化器。如果有人知道如何設(shè)置求解器屬性,則可以通過允許您將Pipeline,ParamGridBuilder和CrossValidation ml軟件包用于LinearRegression進行模型選擇,并利用SGD優(yōu)化進行參數(shù)調(diào)整來回答您的問題。
到此這篇關(guān)于Pyspark 線性回歸梯度下降交叉驗證知識點詳解的文章就介紹到這了,更多相關(guān)Pyspark 線性回歸梯度下降交叉驗證內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
python 兩個數(shù)據(jù)庫postgresql對比
這篇文章主要介紹了python 兩個數(shù)據(jù)庫postgresql對比,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2019-10-10selenium中g(shù)et_cookies()和add_cookie()的用法詳解
這篇文章主要介紹了selenium中g(shù)et_cookies()和add_cookie()的用法詳解,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-01-01