Hi all,
here's what I want to do: Consider a query such as *(A and B) followed_by
(C or D)*. (Pseudo code, obviously.) I want to create a graph of
independent processing nodes, each running an independent instance of
FlinkCEP. I want each of them to represent an operator of the query above,
like so:
* followed_by <-- Processing node 1*
* / \*
* and or <-- Processing nodes 2 and 3*
*/ \ / \A B C D*
The three nodes would have to process the following (sub-)queries,
respectively. (Pseudo code, again.)
*Node1: {{node2ResultStream}} followed_by {{node3ResultStream}}*
*Node2: A and B*
*Node3: C or D*
Long story short: I want to execute the query in a distributed fashion. Is
that currently possible using FlinkCEP?
Thank you very much in advance!
Best
Lucas
