flink git commit: [docs][streaming] fix code examples which use 'implements'

[mx...@apache.org]

Repository: flink
Updated Branches:
  refs/heads/master 6216acf30 -> 8fddbf06c


[docs][streaming] fix code examples which use 'implements'

- replace "implements" with "extends" where applicable


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

Branch: refs/heads/master
Commit: 8fddbf06c14965ba06cd8135a09ca4aa0a65aea5
Parents: 6216acf
Author: Maximilian Michels <mx...@apache.org>
Authored: Wed Nov 25 17:32:03 2015 +0100
Committer: Maximilian Michels <mx...@apache.org>
Committed: Wed Nov 25 17:32:03 2015 +0100

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


http://git-wip-us.apache.org/repos/asf/flink/blob/8fddbf06/docs/apis/streaming_guide.md
----------------------------------------------------------------------
diff --git a/docs/apis/streaming_guide.md b/docs/apis/streaming_guide.md
index 626df10..d61363f 100644
--- a/docs/apis/streaming_guide.md
+++ b/docs/apis/streaming_guide.md
@@ -3098,7 +3098,7 @@ later checkpoints can subsume missing notifications.
 For example the same counting, reduce function shown for `OperatorState`s by using the `Checkpointed` interface instead:
 
 {% highlight java %}
-public class CounterSum implements ReduceFunction<Long>, Checkpointed<Long> {
+public class CounterSum extends ReduceFunction<Long>, Checkpointed<Long> {
 
     // persistent counter
     private long counter = 0;
@@ -3140,7 +3140,7 @@ of different types), the type of the state (used to create efficient serializers
 as a value for keys that do not yet have a value associated).
 
 {% highlight java %}
-public class CounterSum implements RichReduceFunction<Long> {
+public class CounterSum extends RichReduceFunction<Long> {
 
     /** The state handle */
     private OperatorState<Long> counter;
@@ -3188,7 +3188,7 @@ In order to make the updates to the state and output collection atomic (required
 on failure/recovery), the user is required to get a lock from the source's context.
 
 {% highlight java %}
-public static class CounterSource implements RichParallelSourceFunction<Long>, Checkpointed<Long> {
+public static class CounterSource extends RichParallelSourceFunction<Long>, Checkpointed<Long> {
 
     /**  current offset for exactly once semantics */
     private long offset;