在给定的时间内运行 apache flink 作业

Question

是否可以在给定的时间内运行 apache flink 作业（流处理），例如上午 11 点到晚上 11 点之间的一天。 提前感谢您的帮助。

Answer 1

我有一个问题： --- 你想把数据积累1天然后处理吗？就像批处理一样

如果没有，只需执行翻转窗口：

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