Я работаю над реализацией варианта использования, в котором разные физические устройства отправляют события, и из-за проблем с сетью / питанием может возникнуть задержка в получении событий в источнике мигания. Одним из операторов в задании flink является оператор Pattern, и есть определенные шаблоны, которые чувствительны ко времени, поэтому я использую характеристику времени события. Но проблема возникает, когда возникают непредсказуемые задержки событий с определенного устройства (устройств), что приводит к отбрасыванию этих событий (поскольку я не могу определить статическую привязку, чтобы учесть задержку).
Поскольку я использую KeyedStream, привязанный к идентификатору исходного устройства, есть ли способ разрешить каждому экземпляру оператора CEP (по одному на ключ) продвигать свое время на основе времени события в соответствующем разделе потока. Или, другими словами, есть ли способ сгенерировать водяные знаки для каждого раздела в KeyedStream?
