Hi Igal,
I have use cases such as "when a translator translates 10 words within 30
seconds". Typically, it is beautiful to express these with CEP.
Yet, these are exploration questions where I try to replicate our Flink
application in Statefun. Rephrasing problems better might be what's needed
to fit our problems within Statefun (e.g., from a CEP-like expression to
the ridesharing example you shared)
Oytun
--
[image: MotaWord]
Oytun Tez
M O T A W O R D | CTO & Co-Founder
oy...@motaword.com
<https://www.motaword.com/blog>
On Tue, Apr 14, 2020 at 5:41 AM Igal Shilman <i...@ververica.com> wrote:
> Hi,
>
> I'm not familiar with the other library that you have mentioned, and
> indeed using Flink CEP from within a stateful function is not possible
> within a single Flink job, as Gordon mentioned.
>
> I'm wondering what aspects of CEP are you interested in?
> Because essentially a stateful function can be considered as a state
> machine with auxiliary state.
> You can take a look at the ride sharing example [1] for instance, where
> the drivers, and the rides are cooperative state machines.
>
> [1] -
> https://github.com/apache/flink-statefun/tree/master/statefun-examples/statefun-ridesharing-example/statefun-ridesharing-example-functions/src/main/java/org/apache/flink/statefun/examples/ridesharing
>
> Good luck!
> Igal.
>
>
> On Tue, Apr 14, 2020 at 5:07 AM 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/
>>
>
