[
https://issues.apache.org/jira/browse/FLINK-4641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15820896#comment-15820896
]
ASF GitHub Bot commented on FLINK-4641:
---------------------------------------
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.
----
> Support branching CEP patterns
> -------------------------------
>
> Key: FLINK-4641
> URL: https://issues.apache.org/jira/browse/FLINK-4641
> Project: Flink
> Issue Type: Improvement
> Components: CEP
> Reporter: Till Rohrmann
> Assignee: Alexander Chermenin
>
> We should add support for branching CEP patterns to the Pattern API.
> {code}
> |--> B --|
> | |
> A -- --> D
> | |
> |--> C --|
> {code}
> This feature will require changes to the {{Pattern}} class and the
> {{NFACompiler}}.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
