flinkml

0熱

1答えて

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

0熱

1答えて

apache-flink UnsortedGroupingでのKMeans操作

私は多くの異なるセンサーからのセンサーの読みを含むflink DataSet（ファイルから読み込み）を持っています。私は、センサーごとにUnsortedGroupingとしてデータを整理するために、flinks groupBy（）メソッドを使用します。次に、分散した方法で、データセット内のすべてのUnsortedGroupingでKMeansアルゴリズムを実行したいと思います。私の質問は、この機

0熱

1答えて

Java Flickのチュートリアルを学ぶApache Flinkマシンはありますか

私は基本的なApacheのflinkマシンの学習をセットアップするチュートリアルを探しています。現在avilable 素材はスカラ言語です。

1熱

1答えて

Flinkウィンドウと折り畳み機能を使用すると、要素がありませんか？

ウィンドウと折り畳み機能を使用して要素を集計しようとすると、一部のの要素が集計されなくなります。消費カフカ(value:0, value:1, value:2, value:3)からの要素を消費し、それらを奇数および偶数値としてに集約します。出力がある：10-13間 {even=[0, 2, 4], odd=[1, 3]} {even=[6, 8], odd=[5, 7, 9]} {e