撤回流RetractStream应该是Flink 1.5+已经支持了,参考实现RetractStreamTableSink即可。
> On Jul 4, 2019, at 2:09 PM, liu_mingzhang <[email protected]> wrote: > > 在阿里云上看到了关于Blink 撤回流的场景介绍, 请问如何用Flink实现啊? > <TIM图片20190704140806.png>
撤回流RetractStream应该是Flink 1.5+已经支持了,参考实现RetractStreamTableSink即可。
> On Jul 4, 2019, at 2:09 PM, liu_mingzhang <[email protected]> wrote: > > 在阿里云上看到了关于Blink 撤回流的场景介绍, 请问如何用Flink实现啊? > <TIM图片20190704140806.png>