flink-streaming

0熱

1答えて

セッションウィンドウを使用してキー/オペレータの状態を使用してフリンクで状態を管理し、次にトリガーで削減することの利点/欠点について説明できますか？ありがとう

0熱

1答えて

Flinkでカウンタを追加しようとしていますが、上記のhereのようにカウンタを追加しようとしていますが、counter.inc（）はIntegerではなくvoidを返しています。私のメトリックのコードは、あなたのカウンタに値を割り当てる場合、それはより良い動作するはず private static class myMetric extends RichMapFunction<String,Int

0熱

1答えて

flink hbaseコネクタの依存関係を追加する

flinkからHbaseとDruidに接続しようとしています。私はintellijに以下の依存関係を追加しました。 <dependency> <groupId>org.apache.flink</groupId> <artifactId>flink-hbase_2.10</artifactId> <version>1.3.2</version> </dependen

0熱

2答えて

Flinkでカウンタを使用してnumOfRecordsInを取得する

オペレータのnumRecordsInをFlinkに表示したいのですが、これはデータ職人のpptにhereで従っています。カウンターのためのコードは、問題はどのように私はnumber_of_Records_In示ししたいオペレータを指定しないことです public static class mapper extends RichMapFunction<String,String>{ p

0熱

1答えて

Flink：RichFlatMapFunktionのValueStateは常にnullを返します

指定された転落ウィンドウで見つかったハッシュタグの最大量を計算しようとします。このため、私はハッシュタグのための「単語カウント」を行い、それらを合計します。これは正常に動作します。この後、私は指定されたウィンドウ内で最高位のハッシュタグを見つけようとします。私はこれとValueStateのためにRichFlatMapFunctionを使用して、現在のハッシュタグの外観の最大値を保存しますが、これ

0熱

1答えて

Flinkでタイムウィンドウストリーム内のユニークワードを数えるには？

Flink Streamingを使用してタイムウィンドウストリーム内のユニークワードの数を数える方法はありますか？私はthis質問を参照してくださいが、私は時間ウィンドウを実装する方法を知らない。

0熱

3答えて

Flink実行計画UIに表示される演算子、ソース、シンク、パターンの名前付け

オペレータとソースに名前を付けたいだけです。のは、たとえばこれは私がフォームFLINKダッシュボードをとっていることを、実行計画のスクリーンショットであるを見てみましょう。ここで私は2つのDataStreamのソースを持っており、それらに加わっています。私の質問は、これらのソースをEcgStreamとSp02 Streamなどの名前にして、Join1とすることができますか？理由この質問は、視覚

0熱

1答えて

Flink Scala ClassNotFoundException：org.apache.flink.api.common.typeinfo.TypeInformation

私はFlinkを初めて使用していて、私はSocketWindowWordCountの例に従っていました。私はスカラ座2.11.8とFLINK 1.3.2を使用して、私は次のコードを実行すると、EMR上でそれを実行しようとしています、それはエラーを投げた： Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.commo