Repository: flink Updated Branches: refs/heads/master e856071e1 -> 0a5a64ab7
[FLINK-8426][docs] fix java examples for "Generating Timestamp/Watermakr" documentation. This closes #5828. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0e0ba5d8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0e0ba5d8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0e0ba5d8 Branch: refs/heads/master Commit: 0e0ba5d8ff394ea9be4d1b8e988d157761976666 Parents: e856071 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:15:37 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/0e0ba5d8/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) {
