[
https://issues.apache.org/jira/browse/FLINK-6198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16032879#comment-16032879
]
ASF GitHub Bot commented on FLINK-6198:
---------------------------------------
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/4041#discussion_r119596846
--- Diff: docs/dev/libs/cep.md ---
@@ -874,3 +1141,19 @@ val alerts = patternStream.select(createAlert(_)))
{% endhighlight %}
</div>
</div>
+
+## Migrating from an older Flink version
+
+The CEP library in Flink-1.3 ships with a number of new features which
have led to some changes in the API. Here we
+describe the changes that you need to make to your old CEP jobs, in order
to be able to run them with Flink-1.3. After
+making these changes and recompiling your job, you will be able to resume
its execution from a savepoint taken with the
+old version of your job, *i.e.* without having to re-process your past
data.
+
+The changes required are:
+
+1. Change your conditions (the ones in the `where(...)` clause) to extend
the `SimpleCondition` class instead of
+implementing the `FilterFunction` interface.
+
+2. Change your functions provided as arguments to the `select(...)` and
`flatSelect(...)` methods to expect a list of
+events associated with each state (`List` in `Java`, `Iterable` in
`Scala`). This is because with the addition of
+the looping states, multiple input events can much a single (looping)
state.
--- End diff --
hehe good "cats" (catch) :P
> 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)
