flinkml

3熱度

1回答

弗林克版本弗林克流預測：1.2.0 斯卡拉版本：2.11.8 我想用數據流中弗林克使用模型使用Scala的預測。我有一個使用scala的flink中的DataStream [String]，它包含來自kafka source的json格式的數據。我想用這個數據流來預測已經訓練過的Flink-ml模型。問題是所有的flink-ml示例都使用DataSet API來預測。我對flink和scal

0熱度

1回答

弗林克MultipleLinearRegression適合需要3個PARAMS

我遵循的 https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html 的例子，但在本例中的擬合函數只需要一個PARAM，但在我的代碼，適合需要三個參數，可以 mlr.fit（培訓，fitParameters ，fitOperation）;

0熱度

2回答

誤差弗林克0.10.1

隨着當地弗林克0.10.1我不能因以下錯誤jobmanager連接： Association with remote system [akka.tcp://[email protected]:49789] has failed, address is now gated for [5000] ms. Reason is: [scala.Option; local class incompatibl

4熱度

1回答

OutOfBoundsException與ALS - 弗林克MLlib

我做的電影recommandation系統，利用現有的MovieLens數據集在這裏： http://grouplens.org/datasets/movielens/ 要計算該recommandation系統，我用弗林克的ML庫Scala和particulalrly ALS算法（org.apache.flink.ml.recommendation.ALS）。我第一次在電影的收視率映射到Data

1熱度

1回答

使用Flink窗口和摺疊功能，元素缺失？

當我嘗試使用窗口和摺疊功能聚合元素時，元素的某些從獲取聚合中錯過。使用來自卡夫卡(value:0, value:1, value:2, value:3)的元素，並將它們合併爲奇數和偶數值。輸出爲：10-13之間 {even=[0, 2, 4], odd=[1, 3]} {even=[6, 8], odd=[5, 7, 9]} {even=[14, 16, 18], odd=[15, 1

0熱度

1回答

Flink多元線性迴歸：它有預測嗎？

我有一個多元迴歸模型的訓練，現在我想用它來預測。讀documents據我所知，輸入是標記的矢量和輸出是與元組數據集[inputValue的，PredictValue]，是嗎？創建我的標記矢量： val mapped = data.map {x => new org.apache.flink.ml.common.LabeledVector (x._4, org.apache.flink.ml.m

0熱度

1回答

Flink：ERROR解析數值格式

我試圖在Flink（Scala）中使用Zeppelin開發K均值模型。這是我簡單的代碼部分： //Reading data val mapped : DataSet[Vector] = data.map {x => DenseVector (x._1,x._2) } //Create algorithm val knn = KNN() .setK(3) .setBlo