[
https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16032942#comment-16032942
]
ASF GitHub Bot commented on FLINK-6198:
---------------------------------------
Github user tzulitai commented on a diff in the pull request:
https://github.com/apache/flink/pull/4041#discussion_r119602446
--- Diff: docs/dev/libs/cep.md ---
@@ -65,21 +67,49 @@ Next, you have to add the FlinkCEP dependency to the
`pom.xml` of your project.
Note that FlinkCEP is currently not part of the binary distribution.
See linking with it for cluster execution
[here]({{site.baseurl}}/dev/linking.html).
-Now you can start writing your first CEP program using the pattern API.
+Now you can start writing your first CEP program using the Pattern API.
+
+<span class="label label-danger">Attention</span> The events in the
`DataStream` to which
+you want to apply pattern matching have to implement proper `equals()` and
`hashCode()` methods
+because these are used for comparing and matching events.
<div class="codetabs" markdown="1">
<div data-lang="java" markdown="1">
{% highlight java %}
DataStream<Event> input = ...
-Pattern<Event, ?> pattern = Pattern.begin("start").where(evt ->
evt.getId() == 42)
- .next("middle").subtype(SubEvent.class).where(subEvt ->
subEvt.getVolume() >= 10.0)
- .followedBy("end").where(evt -> evt.getName().equals("end"));
+Pattern<Event, ?> pattern = Pattern.begin("start").where(
+ new SimpleCondition<Event>() {
+ @Override
+ public boolean filter(Event event) {
+ return evt.getId() == 42;
--- End diff --
`evt` --> `event`
> Update the documentation of the CEP library to include all the new features.
> ----------------------------------------------------------------------------
>
> Key: FLINK-6198
> URL: https://issues.apache.org/jira/browse/FLINK-6198
> Project: Flink
> Issue Type: Sub-task
> Components: CEP
> Affects Versions: 1.3.0
> Reporter: Kostas Kloudas
> Assignee: Kostas Kloudas
> Priority: Critical
> Fix For: 1.3.0
>
>
> New features to include:
> * Iterative Functions
> * Quantifiers
> * Time handling
> * Migration from FilterFunction to IterativeCondition
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
