我来谈一下我个人的看法，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: > 如题，想知道这个分类的标准是啥呢？ >
