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

Question

オペレータとソースに名前を付けたいだけです。のは、たとえば

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

理由この質問は、視覚化が容易になるためです。また、私はページの最後に、Opsclarityページかかわらず行っていたとして、彼らは、タスク名以下

注意を述べているとOPERATOR_NAMEは待ち時間があるときに、我々は まだ正しくタスクと演算子を区別することができ、圧縮されています は、タスクとオペレーター間で集約されます。しかし、これらの圧縮された名前は、 がFlink UIに表示されているものと一致しません。これにより、 のフラグメントがオペレータ名として表示されます。 これらの名前がメトリックシステムで意味のある である必要がある場合は、のFlink コードで名前を指定する必要があります。この圧縮された値は、 という非常に長いデフォルトの名前の場合にのみ有効です。それ以外の場合は法的なメトリックではありません 値です。

私はCEPのパターンを作成するときに、実行計画UIをパターンとして表示するだけのもう1つの質問もあります。そのパターンが何であるかを示す方法はありますか？A B + C？ D。また、複数のパターンがある場合は、より名前を付けることができます。パターン{1..n}

Answer 1

、

// getting RR interval stream 
DataStream<RRIntervalStreamEvent> rrIntervalStreamEventDataStream = envrionment.addSource(new RR_interval_Gen()).uid("RR interval stream"); 

// getting QRS interval stream 

DataStream<qrsIntervalStreamEvent> qrsIntervalStreamEventDataStream = envrionment.addSource(new Qrs_interval_Gen()).uid("qrs Interval stream"); 

を次のように私は、ソースストリームにUIDを追加した。しかし、実行グラフは、これらのUIDの

を示してはいけない。またsout以下の結果は3であります

System.out.println("id for stream 1 is " + stream1.getId()); 

Answer 2

オペレータに適切な名前を割り当てるには、the documentationを参照してください。これは、実行計画を読みやすくするだけでなく、アプリケーションが進化するにつれてセーブポイントをより堅牢に復元できるようにするためでもあります（docs）。 @alpinegizmoによって示唆されるように

Answer 3

この問題は

// getting RR interval stream 
DataStream<RRIntervalStreamEvent> rrIntervalStreamEventDataStream = envrionment.addSource(new RR_interval_Gen()).name("RR Interval stream"); 


System.out.println("getting transformation for stream 1 = " + rrIntervalStreamEventDataStream.getTransformation()); 
// getting QRS interval stream 

DataStream<qrsIntervalStreamEvent> qrsIntervalStreamEventDataStream = envrionment.addSource(new Qrs_interval_Gen()).name("qrs Interval stream"); 

を次のように、出力グラフは