[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

CEP: use of values of previously accepted event



I have tried to read [1] and understand how to get values of previously accepted event to use in current event (or pattern).


Iterative conditions (with context.getEventsForPatterns) do something like that, but it gets all previously accepter events..

How to get only last one (by Scala) ? Are there exist examples about that ?


For example, if i have consecutive patterns:

1.       Search event A and read its value: B (that can also be different, like C)

2.       Search the next event based on value of A, that is B, so event B is searched


This is little bit like searching links of list. It is also possible that an event can include many next events, so that means it is like tree- or DAG- pattern structure.


The pattern structure of list, tree or DAG is not known before processing, but during (and after) the processing.. Is that problem ?


[1] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/libs/cep.html


Best, Esa