Re: streaming.api.operators和streaming.runtime.operators的区别是啥？

2023-05-06 文章 Hongshun Wang
我来谈一下我个人的看法，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 wrote:

streaming.api.operators和streaming.runtime.operators的区别是啥？

2023-05-05 文章 yidan zhao
如题，想知道这个分类的标准是啥呢？