1

この Flink CEP の例を理解しようとしています

https://github.com/tillrohrmann/cep-monitoring ..分散モード (1 マスター & 3 コア) で Flink CEP のこの例を実行しました。 3つのコアがあるため、3つのファイル..ファイルの1つに、次のようなレコードが表示されます。

TemperatureAlert(4), For Temperature:110.60808293330018,At Timestamp : 1464259424016
TemperatureAlert(4), For Temperature:102.75469017603604,At Timestamp : 1464259486205
TemperatureAlert(4), For Temperature:110.98650912782037,At Timestamp : 1464259492214
TemperatureAlert(4), For Temperature:115.47245702561352,At Timestamp : 1464259554901
TemperatureAlert(1), For Temperature:113.65291115679136,At Timestamp : 1464259735252
TemperatureAlert(1), For Temperature:110.88374917920495,At Timestamp : 1464259795436
TemperatureAlert(1), For Temperature:116.23995588293668,At Timestamp : 1464259810056
TemperatureAlert(4), For Temperature:103.27459440260448,At Timestamp : 1464259929121
TemperatureAlert(1), For Temperature:114.53029859331343,At Timestamp : 1464259942139
TemperatureAlert(4), For Temperature:109.13921010205338,At Timestamp : 1464260060204
(4,117.14184470661019) ,1464259692594
TemperatureWarning(4,115.08289903597866) ,1464259701806
TemperatureWarning(4,113.9136297471108) ,1464259723436
TemperatureWarning(1,112.15684481878216) ,1464259733249
TemperatureWarning(1,113.65291115679136) ,1464259735252
TemperatureWarning(1,125.07387226846537) ,1464259770401
TemperatureWarning(1,100.829623781131) ,1464259776409
TemperatureWarning(4,105.76155716070109) ,1464259789027
TemperatureWarning(1,110.88374917920495) ,1464259795436
TemperatureWarning(1,110.03271176117211) ,1464259803447
TemperatureWarning(1,108.99904165096143) ,1464259809255
TemperatureWarning(1,116.23995588293668) ,1464259810056
TemperatureWarning(1,113.74475027506949) ,1464259815664
TemperatureWarning(4,118.65623814713382) ,1464259826078
TemperatureWarning(1,125.24779125130385) ,1464259877349
TemperatureWarning(4,110.38935504983476) ,1464259890467
TemperatureWarning(4,101.92222208289115) ,1464259927319
TemperatureWarning(4,103.27459440260448) ,1464259929121
TemperatureWarning(1,113.15048106140453) ,1464259937533
TemperatureWarning(1,114.53029859331343) ,1464259942139
TemperatureWarning(4,112.4172409140119) ,1464259953755
TemperatureWarning(1,107.21833971444117) ,1464259981194
TemperatureWarning(1,105.08408728033956) ,1464259981594
TemperatureWarning(4,108.83063471822507) ,1464259990608
TemperatureWarning(4,127.9723904319025) ,1464260054997
TemperatureWarning(4,106.06561268720989) ,1464260059804
TemperatureWarning(4,109.13921010205338) ,1464260060204

行番号 5 から調べ始めると、行番号 5 から出力されたすべての温度アラート (つまり、温度: 113.65291115679136) を確認でき、TemperatureWarning で (温度: 113.65291115679136 が行 15 に存在する) 以下の温度を識別できます。つまり、どの温度に対してどれを特定できるか、アラートが出力されていることを意味します....しかし、行番号1から4で生成されたアラートはどうですか?? 行番号のレコードでも同じことがわかります。11..アラートが生成された温度警告を特定する方法を教えてください。バッチモード、連続モード、またはマイクロバッチモードでストリーミングを実行していますか??

4

1 に答える 1

1

  1. TemperatureWarning は、同じラック ID から 10 秒のウィンドウで 2 つの連続した TemperatureEvents が発生した場合に生成されます。

  2. 同じラック ID から 20 秒以内に 2 つの連続した TemperatureWarnings が送信され、TemperatureWarnings の温度が上昇しているように見える場合、TemperatureAlert が生成されます。TemperatureAlert には最初の TemperatureWarning のデータがあります

  3. 連続ストリームソースです

于 2016-07-01T01:49:34.490 に答える