Re: Using Stateful Functions within a Flink pipeline

Posted by Oytun Tez on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Using-Stateful-Functions-within-a-Flink-pipeline-tp34582p34584.html

Hi Annemarie,

Unfortunately this is not possible at the moment, but DataStream as in/egress is in the plans as much as I know.

On Wed, Apr 22, 2020 at 10:26 AM Annemarie Burger <[hidden email]> wrote:

I was wondering if it is possible to use a Stateful Function within a Flink
pipeline. I know they work with different API's, so I was wondering if it is
possible to have a DataStream as ingress for a Stateful Function.

Some context: I'm working on a streaming graph analytics system, and want to
save the state of the graph within a window. Stateful functions could then
allow me to process these distributed graph states by making use of the SF
messaging.

Thanks!



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/