Apache Apexの演算子間のネットワーク遅延を計算する方法

Question

Apache Apexの2つの異なる演算子間のN/W遅延を予測する方法がありますか？

オペレータで使用される予定のデータは、別のマシン上に存在します。これはオペレータの待ち時間に追加されます。

これはどのようにして計算できますか？

Answer 1

あなたはブログの記事のカップルを見てみたいことがあります。あなたのタプルは文字列であり、あなたのクラスタノード 上のクロックが同期していることを、あなたはにタイムスタンプを付加することができますと仮定

https://www.datatorrent.com/blog/latency-calculation-in-apache-apex/ https://www.datatorrent.com/blog/blog-apex-performance-benchmark/

Answer 2

それぞれのタプルは送信側 オペレータにあります。受信側のオペレータでは、タイムスタンプ を取り除いて、現在の時刻と比較することができます。もちろん、この のアプローチを他のタイプに適切に適合させることができます。適切に多数のタプルを平均した場合、ネットワーク遅延の良い近似が得られるはずです。