1

PatternTimeoutFunction定義された時間枠から外れると、イベント シーケンスを破棄するために使用しています。

次のように透かしを設定しています

public Watermark checkAndGetNextWatermark(Event lastElement, long extractedTimestamp) {
    return new Watermark(extractedTimestamp);
}

パターンのタイムアウトが発生した場合、timeoutTimestamp最初のイベントのタイムスタンプ + タイムウィンドウの値に等しい必要があります

ただし、次のウォーターマークを受信した後にタイムアウトがトリガーされます。タイムアウトは、次のウォーターマークを受信した後、または有効期限に基づいてトリガーされtimeWindowますか?

4

1 に答える 1

1

イベント時間を使用する場合、タイムアウトはウォーターマークの受信によってトリガーされます。このタイムスタンプの透かしを受け取った場合にのみ、特定のポイントまでのすべての要素を確実に確認できるためです。

これは、次のウォーターマークの値によっては、タイムアウトのタイムスタンプが最初のイベントのタイムスタンプ + ウィンドウの長さよりも大きくなる可能性があることを意味します。したがって、タイムアウトのタイムスタンプは、実際には、パターンがタイムアウトになったことを認識するイベント時間です。

于 2016-07-18T13:51:51.577 に答える