Operators in Flink

[Felipe Gutierrez]

Hi,

I have a doubt about Flink operators implementation and I am trying to search some link on the internet about this

Do the operators in Flink are compiled and fused at runtime? Do you guys have a link that can explain to me how it is implemented in Flink?

Kind Regards,

Felipe

[rmetzger0]

Hi Felipe,

Operators are fused by the system, yes. We call it operator chaining, read more about it here: https://ci.apache.org/projects/flink/flink-docs-master/concepts/runtime.html

On Fri, Apr 20, 2018 at 11:58 AM, Felipe Gutierrez <[hidden email]> wrote:

Hi,

I have a doubt about Flink operators implementation and I am trying to search some link on the internet about this

Do the operators in Flink are compiled and fused at runtime? Do you guys have a link that can explain to me how it is implemented in Flink?

Kind Regards,

Felipe

[Felipe Gutierrez]

thanks Robert, I will definitely have a look at it.

On Wed, Apr 25, 2018 at 9:45 AM, Robert Metzger <[hidden email]> wrote:

Hi Felipe,

Operators are fused by the system, yes. We call it operator chaining, read more about it here: https://ci.apache.org/projects/flink/flink-docs-master/concepts/runtime.html

On Fri, Apr 20, 2018 at 11:58 AM, Felipe Gutierrez <[hidden email]> wrote:

Hi,

I have a doubt about Flink operators implementation and I am trying to search some link on the internet about this

Do the operators in Flink are compiled and fused at runtime? Do you guys have a link that can explain to me how it is implemented in Flink?

Kind Regards,

Felipe