我以https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html但在这个例子中,fit函数只需要一个参数,但在我的代码中,fit需要三个参数,
mlr.fit(training,fitParameters,fitOperation);
我认为fitParameters可能是setIterations()、setStepsize()的替代方案但是fitOperation是什么?
fitOperation
参数实际上是一个隐式参数,由Scala编译器自动填充。它封装了MLR逻辑。
由于fit
函数有3个参数,我怀疑您正在将FlinkML与Flink的Java API一起使用。我强烈建议您使用Scala API,因为否则您将不得不手动构建ML管道。如果您仍然想这样做,请查看MultipleLinearRegression
伴随对象中定义的FitOperations
。