flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dawidwys <...@git.apache.org>
Subject [GitHub] flink pull request #6104: [FLINK-9476]Emit late elements in CEP as sideOutPu...
Date Fri, 01 Jun 2018 12:11:18 GMT
Github user dawidwys commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6104#discussion_r192340339
  
    --- Diff: docs/dev/libs/cep.md ---
    @@ -1524,7 +1524,52 @@ In `CEP` the order in which elements are processed matters. To
guarantee that el
     
     To guarantee that elements across watermarks are processed in event-time order, Flink's
CEP library assumes
     *correctness of the watermark*, and considers as *late* elements whose timestamp is smaller
than that of the last
    -seen watermark. Late elements are not further processed.
    +seen watermark. Late elements are not further processed. Also, you can specify a sideOutput
tag to collect the late elements come after the last seen watermark, you can use it like this.
    +
    +<div class="codetabs" markdown="1">
    +<div data-lang="java" markdown="1">
    +
    +{% highlight java %}
    +PatternStream<Event> patternStream = CEP.pattern(input, pattern);
    +
    +OutputTag<String> lateDataOutputTag = new OutputTag<String>("late-data""){};
    +
    +OutputTag<String> outputTag = new OutputTag<String>("side-output""){};
    --- End diff --
    
    I would use version without timed out results to simplify the example.


---

Mime
View raw message