FLINKは3つのparams

Question

私は https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/batch/libs/ml/multiple_linear_regression.html の例に従うが、例にフィット機能は一つだけのparamが必要ですが、私のコードでは、フィットが3つのparamsを必要とし、

mlr.fit（トレーニング、fitParametersを取るフィットMultipleLinearRegression 、fitOperation）;

私はfitParametersがsetIterations（）、setStepsize（）の代わりになる可能性があると考えていましたが、fitOperationとは何ですか？

Answer 1

パラメータfitOperationは実際にはScalaコンパイラによって自動的に埋め込まれる暗黙のパラメータです。これは、MLRロジックをカプセル化します。

fit関数に3つのパラメータがあるため、FlinkのJava APIでFlinkMLを使用していると思われます。 Scala APIを使用することをお勧めします。そうしないと、手動でMLパイプラインを構築する必要があるからです。それでもやりたい場合は、MultipleLinearRegressionコンパニオンオブジェクトで定義されているFitOperationsを見てください。