是否可以在给定的时间内运行apache flink作业（流处理），比如上午11点到晚上11点之间的一天。事先谢谢你的帮助。
tzxcd3kk1#
我有一个问题：-你想积累一天的数据，然后再处理吗？像批处理一样如果没有，只需做一个翻滚窗口：
DataStream<T> input = ...; input .keyBy(<key selector>) .window(TumblingEventTimeWindows.of(Time.hours(12))) .<windowed transformation>(<window function>);
1条答案
按热度按时间tzxcd3kk1#
我有一个问题：-你想积累一天的数据，然后再处理吗？像批处理一样
如果没有，只需做一个翻滚窗口：