我以https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html 但是在这个例子中fit函数只需要一个参数,但是在我的代码中,fit需要三个参数,
mlr.fit(培训、fit参数、fit操作);
我认为fitparameters可能是setiterations()、setstepsize()的替代方法,但fitoperation是什么?
1条答案
按热度按时间wixjitnu1#
这个
fitOperation
参数实际上是由scala编译器自动填充的隐式参数。它封装了mlr逻辑。自从你的
fit
函数有3个参数,我怀疑您将flinkml与flink的JavaAPI一起使用。我强烈建议您使用scalaapi,否则您将不得不手动构建ml管道。如果你还想这么做,那就看看FitOperations
定义在MultipleLinearRegression
伴星。