Repository: flink
Updated Branches:
  refs/heads/release-1.5 4e69adfbe -> 2787a1b81


[FLINK-8426][docs] fix java examples for "Generating Timestamp/Watermakr" 
documentation.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a43e785b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a43e785b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a43e785b

Branch: refs/heads/release-1.5
Commit: a43e785bd5bded2037c533ac3525040d3aff5059
Parents: 4e69adf
Author: Dmitrii_Kniazev <dmitrii_knia...@epam.com>
Authored: Wed Apr 11 12:46:22 2018 +0300
Committer: zentol <ches...@apache.org>
Committed: Wed Apr 11 12:14:58 2018 +0200

----------------------------------------------------------------------
 docs/dev/event_timestamps_watermarks.md | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/a43e785b/docs/dev/event_timestamps_watermarks.md
----------------------------------------------------------------------
diff --git a/docs/dev/event_timestamps_watermarks.md 
b/docs/dev/event_timestamps_watermarks.md
index acde9e4..44ecf54 100644
--- a/docs/dev/event_timestamps_watermarks.md
+++ b/docs/dev/event_timestamps_watermarks.md
@@ -190,7 +190,7 @@ Two simple examples of timestamp assigners with periodic 
watermark generation ar
  * but only to a certain degree. The latest elements for a certain timestamp t 
will arrive
  * at most n milliseconds after the earliest elements for timestamp t.
  */
-public class BoundedOutOfOrdernessGenerator extends 
AssignerWithPeriodicWatermarks<MyEvent> {
+public class BoundedOutOfOrdernessGenerator implements 
AssignerWithPeriodicWatermarks<MyEvent> {
 
     private final long maxOutOfOrderness = 3500; // 3.5 seconds
 
@@ -214,7 +214,7 @@ public class BoundedOutOfOrdernessGenerator extends 
AssignerWithPeriodicWatermar
  * This generator generates watermarks that are lagging behind processing time 
by a fixed amount.
  * It assumes that elements arrive in Flink after a bounded delay.
  */
-public class TimeLagWatermarkGenerator extends 
AssignerWithPeriodicWatermarks<MyEvent> {
+public class TimeLagWatermarkGenerator implements 
AssignerWithPeriodicWatermarks<MyEvent> {
 
        private final long maxTimeLag = 5000; // 5 seconds
 
@@ -292,7 +292,7 @@ new watermark will be emitted.
 <div class="codetabs" markdown="1">
 <div data-lang="java" markdown="1">
 {% highlight java %}
-public class PunctuatedAssigner extends 
AssignerWithPunctuatedWatermarks<MyEvent> {
+public class PunctuatedAssigner implements 
AssignerWithPunctuatedWatermarks<MyEvent> {
 
        @Override
        public long extractTimestamp(MyEvent element, long 
previousElementTimestamp) {

Reply via email to