Flink Tumble Window Время запуска

Question

Я использую Flink для агрегирования данных из тем Кафки. Я использую периодическое окно продолжительностью 1 час, для характеристики времени c установлено время события. Я также использую AscendingTimestampExtractor и назначаю водяные знаки для ввода на основе определенного значения поля в json.

env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);

Можно предположить, что поле JSON, используемое для водяных знаков, имеет значение времени, аналогичное значению системных часов.

Если я разверну работу в 15:25, когда я могу ожидать агрегированный выходной сигнал? Будет ли это в 16:00, 17:00 ... или 15:25 - 16:25, 16:25 - 17: 25 ...

Answer 1

Флинк windows выровнен с эпохой (а не с первым событием), поэтому, если задание развернуто в 3:25, первое окно будет примерно с интервалом от 3:00:00 до 3:59: 59.999, и будет вскоре произведен (на основе водяных знаков).

Обратите внимание, что вы можете передать смещение конструктору, поэтому если вы хотите, чтобы windows заканчивался через 10 минут после часа, вы может сделать это, указав

.window(TumblingEventTimeWindows.of(Time.hours(1), Time.minutes(10)))