Я использую PatternTimeoutFunction для отбрасывания последовательности событий, когда она выходит за пределы определенного временного окна.
Я устанавливаю водяной знак следующим образом
public Watermark checkAndGetNextWatermark(Event lastElement, long extractedTimestamp) {
return new Watermark(extractedTimestamp);
}
Когда происходит тайм-аут шаблона, timeoutTimestamp должно быть равно отметке времени первого события + значение временного окна.
Но тайм-аут срабатывает после получения следующего водяного знака. Инициируется ли тайм-аут после получения следующего водяного знака или по истечении срока действия timeWindow?
