Запуск задания Apache Flink в течение определенного промежутка времени

Question

Возможно ли запустить задание Apache Flink (потоковая обработка) в течение некоторого заданного промежутка времени, например, в течение одного дня с 11 до 23 часов.Заранее спасибо за помощь.

Answer 1

У меня вопрос: --- Хотите накапливать данные за 1 день и затем обрабатывать?Как пакетная обработка

Если нет, просто сделайте окно Tumbling:

   DataStream<T> input = ...;

input
    .keyBy(<key selector>)
    .window(TumblingEventTimeWindows.of(Time.hours(12)))
    .<windowed transformation>(<window function>);