我来谈一下我个人的看法,streaming.api.operators是提供给用户使用的stream api, 用户可以使用和扩展该接口。而streaming.runtime.operators是用户侧不感知,在执行时由flink自动调用的。比如: Sink用户可以自己设置,如kafkaSink。但是输出时的state处理和事务commit(CommitterOperator)是Flink根据不同类型的Sink自动生成的统一逻辑,用户无需自己设置和实现。
Best Hongshun On Sat, May 6, 2023 at 11:57 AM yidan zhao <hinobl...@gmail.com> wrote: > 如题,想知道这个分类的标准是啥呢? >