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