You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by yidan zhao <hi...@gmail.com> on 2023/05/06 03:55:53 UTC

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

如题，想知道这个分类的标准是啥呢？

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

Posted by Hongshun Wang <lo...@gmail.com>.

我来谈一下我个人的看法，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 <hi...@gmail.com> wrote:

> 如题，想知道这个分类的标准是啥呢？
>