Hi Gordon,
Getting a little closer to Flink API could be helpful here with
integration. DataStreams as ingress/egress would be AMAZING. Deploying
regular Flink API code and statefun together as a single job is also
something I will explore soon.
With CEP, I simply want to keep a Function-specific pattern engine. I could
use a library like Siddhi and try to persist its state via Function's
PersistValue or something.
Also, one thing to consider in Flink API integration is protobuf
enforcement in statefun. We had to use protobuf within the statefun code,
but nowhere else we are using protobuf. Even if we talk via DataStreams,
this would still bring us some level of separation between our Flink API
code and statefun.
--
[image: MotaWord]
Oytun Tez
M O T A W O R D | CTO & Co-Founder
oy...@motaword.com
<https://www.motaword.com/blog>
On Mon, Apr 13, 2020 at 11:07 PM Tzu-Li (Gordon) Tai <tzuli...@apache.org>
wrote:
> Hi!
>
> It isn't possible to use Flink CEP within Stateful Functions.
>
> That could be an interesting primitive, to add CEP-based function
> constructs.
> Could your briefly describe what you are trying to achieve?
>
> On the other hand, there are plans to integrate Stateful Functions more
> closely with the Flink APIs.
> One direction we've been thinking about is to, for example, support Flink
> DataStreams as StateFun ingress / egresses. In this case, you'll be able to
> use Flink CEP to detect patterns, and use the results as an ingress which
> invokes functions within a StateFun app.
>
> Cheers,
> Gordon
>
>
>
> --
> Sent from:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
>
