GitHub user tillrohrmann opened a pull request:
https://github.com/apache/flink/pull/2041
[FLINK-3317] [cep] Introduce timeout handler to CEP operator
This PR adds timeout handling functionality to the CEP library. Whenever an
event pattern is discarded because it exceeds the window length, a user
specified timeout function can be called. The timeout function receives the all
matched events of the partial pattern as well as the timestamp when the timeout
has occurred. This allows to create timeout events to which down stream
operators can react.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/tillrohrmann/flink cepTimeout
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2041.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 #2041
----
commit d8ccf9bc734ceeaf7a3f897e3c3a5ebda427ccd0
Author: Till Rohrmann <[email protected]>
Date: 2016-05-26T09:34:16Z
[FLINK-3317] [cep] Introduce timeout handler to CEP operator
Introduce timeout handling flag for the NFACompiler
Expose timeout handling via Java API
Update documentation of PatternStream and CEP
Introduce timeout select function to CEP Scala API
Add select and flatSelect with timeout support to CEP Scala API
Add test cases for timeout handling
Update documentation
commit 2d57d8016cedc997ca18b34406dd9a98e93de496
Author: Till Rohrmann <[email protected]>
Date: 2016-05-27T10:13:09Z
Fix CEP Scala API completeness test
----
---
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 [email protected] or file a JIRA ticket
with INFRA.
---
