flink MultipleLinearRegression 拟合采用 3 个参数
flink MultipleLinearRegression fit take 3 params
我效仿
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html
但在示例中 fit 函数只需要一个参数,但在我的代码中,fit 需要三个参数,
mlr.fit(训练、拟合参数、拟合操作);
我认为 fitParameters 可以替代 setIterations(),setStepsize()
但什么是 fitOperation?
fitOperation
参数实际上是一个隐式参数,由Scala编译器自动填充。它封装了MLR逻辑。
因为你的 fit
函数有 3 个参数,我怀疑你正在使用 FlinkML 和 Flink 的 Java API。我强烈建议您使用 Scala API,否则您将不得不手动构建 ML 管道。如果你还想这样做,那么看看 MultipleLinearRegression
伴生对象中定义的 FitOperations
。
我效仿 https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html 但在示例中 fit 函数只需要一个参数,但在我的代码中,fit 需要三个参数,
mlr.fit(训练、拟合参数、拟合操作);
我认为 fitParameters 可以替代 setIterations(),setStepsize() 但什么是 fitOperation?
fitOperation
参数实际上是一个隐式参数,由Scala编译器自动填充。它封装了MLR逻辑。
因为你的 fit
函数有 3 个参数,我怀疑你正在使用 FlinkML 和 Flink 的 Java API。我强烈建议您使用 Scala API,否则您将不得不手动构建 ML 管道。如果你还想这样做,那么看看 MultipleLinearRegression
伴生对象中定义的 FitOperations
。