GitHub user chermenin opened a pull request:
https://github.com/apache/flink/pull/3105
[FLINK-4641] Support branching CEP patterns
Support for branched CEP patterns was added in this PR.
After merging that we will be able to use follow code to define more
complex patterns:
```
Pattern<T, ?> pattern = EventPattern.<T>event("start")
.next(
Pattern.or(
EventPattern.<T>event("middle_1").subtype(F.class)),
EventPattern.<T>event("middle_2").where(new MyFilterFunction())
))
.followedBy(EventPattern.<T>event("end"));
```
This PR will close https://issues.apache.org/jira/browse/FLINK-4641.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/chermenin/flink flink-4641
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/3105.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #3105
----
commit 026ada648d1277fd57f2fb2361a36bf0c8f5e57b
Author: Aleksandr Chermenin <aleksandr_cherme...@epam.com>
Date: 2017-01-12T09:54:44Z
[FLINK-4641] Base Java implementation.
commit f82fc8386493e84e824110a26d5e059333efaec0
Author: Aleksandr Chermenin <aleksandr_cherme...@epam.com>
Date: 2017-01-12T10:07:53Z
[FLINK-4641] Fixed branching pattern.
commit ad074e2e2c1faf8571b8b8e7ce3144c0fbc5e31d
Author: Aleksandr Chermenin <aleksandr_cherme...@epam.com>
Date: 2017-01-12T10:21:15Z
[FLINK-4641] Fixed Scala API.
commit 38e14a89b001bd443133746216d422ac46176c3f
Author: Aleksandr Chermenin <aleksandr_cherme...@epam.com>
Date: 2017-01-12T10:56:22Z
[FLINK-4641] Fixed tests for Scala API.
commit 9ba130df964ece5b8756e8b46b6ec22dcde69877
Author: Aleksandr Chermenin <aleksandr_cherme...@epam.com>
Date: 2017-01-12T12:15:01Z
[FLINK-4641] Fixed CEP Java 8 lambda test.
commit 8d490aae497e85003a402ca6c1fd687e30c3b55f
Author: Aleksandr Chermenin <aleksandr_cherme...@epam.com>
Date: 2017-01-12T12:24:52Z
[FLINK-4641] Improved code documentation.
----
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
