用 Window 实现。
2019年10月22日 +0800 13:25 王佩 <[email protected]>,写道:
> 想在Flink DataStream中实现微批,可以做到吗。该如何实现?
>
> 比方说基于处理时间,从Kafka 消费数据,每隔5s产生一个Batch,然后对这个Batch处理。
>
> 感谢!

回复