[flink] branch master updated: [FLINK-10980][docs] Fix CEP documentation error.

[ji...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jincheng pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new cbf5f0c  [FLINK-10980][docs] Fix CEP documentation error.
cbf5f0c is described below

commit cbf5f0c937e9181314824789bb43162a2f97716e
Author: DuBin <bd...@cisco.com>
AuthorDate: Thu Nov 22 12:31:52 2018 +0800

    [FLINK-10980][docs] Fix CEP documentation error.
    
    This closes #7158
---
 docs/dev/libs/cep.md | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/docs/dev/libs/cep.md b/docs/dev/libs/cep.md
index c8e8363..ce9a9c3 100644
--- a/docs/dev/libs/cep.md
+++ b/docs/dev/libs/cep.md
@@ -1527,8 +1527,8 @@ The events for a given pattern are ordered by timestamp. The reason for returnin
 
 {% highlight scala %}
 def selectFn(pattern : Map[String, Iterable[IN]]): OUT = {
-    val startEvent = pattern.get("start").get.next
-    val endEvent = pattern.get("end").get.next
+    val startEvent = pattern.get("start").get.head
+    val endEvent = pattern.get("end").get.head
     OUT(startEvent, endEvent)
 }
 {% endhighlight %}
@@ -1539,8 +1539,8 @@ The `flatSelect` method is similar to the `select` method. Their only difference
 
 {% highlight scala %}
 def flatSelectFn(pattern : Map[String, Iterable[IN]], collector : Collector[OUT]) = {
-    val startEvent = pattern.get("start").get.next
-    val endEvent = pattern.get("end").get.next
+    val startEvent = pattern.get("start").get.head
+    val endEvent = pattern.get("end").get.head
     for (i <- 0 to startEvent.getValue) {
         collector.collect(OUT(startEvent, endEvent))
     }