Re: how to add a new runtime operator

2020-08-12 Thread Timo Walther
Hi Vincent, we don't have a step by step guide for adding new operators. Most of the important operations are exposed via DataStream API. Esp. ProcessFunction [1] fits for most complex use cases with access to the primitives such as time and state. What kind of operator is missing for your u

how to add a new runtime operator

2020-08-11 Thread Vincent Cai
Hi All, Flink is an amazing streaming platfrom??meanwhile it is also complicated. Do we have some "step by step" guideline for adding new runtime operators for Flink? I got one page via google but it should be out of date. Thanks.  https://ci.apache.org/projects/flink/flink-docs-release-1.1/int