0

我遵循 https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html的示例， 但在示例中，拟合函数只需要一个参数，但在我的代码中，fit 需要三个参数，

mlr.fit（训练，fitParameters，fitOperation）；

我认为 fitParameters 可能是 setIterations(),setStepsize() 的替代方法，但 fitOperation 是什么？

4

1 回答 1

0

该fitOperation参数实际上是一个隐式参数，由 Scala 编译器自动填充。它封装了 MLR 逻辑。

由于您的fit函数有 3 个参数，我怀疑您将 FlinkML 与 Flink 的 Java API 一起使用。我强烈建议您使用 Scala API，否则您将不得不手动构建 ML 管道。如果您仍然想这样做，请查看伴随对象中FitOperations定义的内容。MultipleLinearRegression

于 2016-04-06T09:41:24.403 回答