GitHub user StefanRRichter opened a pull request:
https://github.com/apache/flink/pull/1905
[FLINK-3708] Scala API for CEP (initial).
This module flink-cep-scala adds a Scala pendant for the Java CEP API to
Flink.
I created Scala classes for Pattern and PatternStream, helper classes, as
well as corresponding tests.
PatternStream in flink-cep is extended to obtain explicit TypeInformation
from Scala code.
Pattern in flink-cep is slightly modified in the type parameters for member
previous.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/StefanRRichter/flink dev-cep-scala
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/1905.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 #1905
----
commit 306210da82c94f6770e22690799a3f1af9a877e7
Author: Stefan Richter <[email protected]>
Date: 2016-04-18T11:10:09Z
Preparations in Pattern and PatternStream of flink-cep to support
flink-cep-scala functionality.
commit 731d96ae78c4dc1b7125966900886225374a3eb5
Author: Stefan Richter <[email protected]>
Date: 2016-04-18T11:10:35Z
Initial commit for flink-cep-scala API.
commit 7da7c14787226d9aa5914a138f632b8b6d5f1335
Author: Stefan Richter <[email protected]>
Date: 2016-04-18T13:48:51Z
[FLINK-3708] Added missing test dependency to pom.
commit 1468bd91aea7d2a757ddeea8b8506b5ad9f3d289
Author: Stefan Richter <[email protected]>
Date: 2016-04-18T14:50:53Z
[FLINK-3708] Pattern in Scala API now uses Option to shield users against
null values from the Java API
commit 9ad8719c5b8767ec2fb0425f55cc7df105e36bcb
Author: Stefan Richter <[email protected]>
Date: 2016-04-18T16:04:35Z
[FLINK-3708] Added test-jar for build phase to pom.
----
---
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.
---
