flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [32/51] [abbrv] [streaming] Updated Streaming function interfaces to match main project
Date Mon, 18 Aug 2014 17:26:09 GMT
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/FlatMapTest.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/FlatMapTest.java
b/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/FlatMapTest.java
index 2a8973c..ca9c1cb 100644
--- a/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/FlatMapTest.java
+++ b/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/FlatMapTest.java
@@ -25,7 +25,7 @@ import static org.junit.Assert.assertTrue;
 import java.util.HashSet;
 import java.util.Set;
 
-import org.apache.flink.api.java.functions.RichFlatMapFunction;
+import org.apache.flink.api.common.functions.FlatMapFunction;
 import org.apache.flink.streaming.api.DataStream;
 import org.apache.flink.streaming.api.LocalStreamEnvironment;
 import org.apache.flink.streaming.api.StreamExecutionEnvironment;
@@ -37,7 +37,7 @@ import org.junit.Test;
 
 public class FlatMapTest {
 
-	public static final class MyFlatMap extends RichFlatMapFunction<Integer, Integer>
{
+	public static final class MyFlatMap implements FlatMapFunction<Integer, Integer> {
 
 		private static final long serialVersionUID = 1L;
 
@@ -49,7 +49,7 @@ public class FlatMapTest {
 
 	}
 
-	public static final class ParallelFlatMap extends RichFlatMapFunction<Integer, Integer>
{
+	public static final class ParallelFlatMap implements FlatMapFunction<Integer, Integer>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -60,7 +60,7 @@ public class FlatMapTest {
 
 	}
 
-	public static final class GenerateSequenceFlatMap extends RichFlatMapFunction<Long, Long>
{
+	public static final class GenerateSequenceFlatMap implements FlatMapFunction<Long, Long>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -71,7 +71,7 @@ public class FlatMapTest {
 
 	}
 
-	public static final class MySink extends SinkFunction<Integer> {
+	public static final class MySink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -81,7 +81,7 @@ public class FlatMapTest {
 
 	}
 
-	public static final class FromElementsSink extends SinkFunction<Integer> {
+	public static final class FromElementsSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -91,7 +91,7 @@ public class FlatMapTest {
 
 	}
 
-	public static final class FromCollectionSink extends SinkFunction<Integer> {
+	public static final class FromCollectionSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -101,7 +101,7 @@ public class FlatMapTest {
 
 	}
 
-	public static final class GenerateSequenceSink extends SinkFunction<Long> {
+	public static final class GenerateSequenceSink implements SinkFunction<Long> {
 		private static final long serialVersionUID = 1L;
 
 		@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/MapTest.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/MapTest.java
b/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/MapTest.java
index 07478fb..73185df 100644
--- a/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/MapTest.java
+++ b/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/invokable/operator/MapTest.java
@@ -27,7 +27,7 @@ import java.util.HashSet;
 import java.util.List;
 import java.util.Set;
 
-import org.apache.flink.api.java.functions.RichMapFunction;
+import org.apache.flink.api.common.functions.MapFunction;
 import org.apache.flink.streaming.api.DataStream;
 import org.apache.flink.streaming.api.LocalStreamEnvironment;
 import org.apache.flink.streaming.api.StreamExecutionEnvironment;
@@ -40,7 +40,7 @@ import org.junit.Test;
 
 public class MapTest {
 
-	public static final class MySource extends SourceFunction<Integer> {
+	public static final class MySource implements SourceFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -51,7 +51,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MySource1 extends SourceFunction<Integer> {
+	public static final class MySource1 implements SourceFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -62,7 +62,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MySource2 extends SourceFunction<Integer> {
+	public static final class MySource2 implements SourceFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -73,7 +73,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MySource3 extends SourceFunction<Integer> {
+	public static final class MySource3 implements SourceFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -84,7 +84,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyMap extends RichMapFunction<Integer, Integer> {
+	public static final class MyMap implements MapFunction<Integer, Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -94,7 +94,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MySingleJoinMap extends RichMapFunction<Integer, Integer>
{
+	public static final class MySingleJoinMap implements MapFunction<Integer, Integer>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -104,7 +104,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyMultipleJoinMap extends RichMapFunction<Integer, Integer>
{
+	public static final class MyMultipleJoinMap implements MapFunction<Integer, Integer>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -114,7 +114,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyFieldsMap extends RichMapFunction<Integer, Integer> {
+	public static final class MyFieldsMap implements MapFunction<Integer, Integer> {
 		private static final long serialVersionUID = 1L;
 
 		private int counter = 0;
@@ -128,7 +128,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyDiffFieldsMap extends RichMapFunction<Integer, Integer>
{
+	public static final class MyDiffFieldsMap implements MapFunction<Integer, Integer>
{
 		private static final long serialVersionUID = 1L;
 
 		private int counter = 0;
@@ -138,11 +138,11 @@ public class MapTest {
 			counter++;
 			if (counter > 3)
 				threeInAll = false;
-			return value*value;
+			return value * value;
 		}
 	}
 
-	public static final class MySink extends SinkFunction<Integer> {
+	public static final class MySink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -151,7 +151,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyBroadcastSink extends SinkFunction<Integer> {
+	public static final class MyBroadcastSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -160,7 +160,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyShufflesSink extends SinkFunction<Integer> {
+	public static final class MyShufflesSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -169,7 +169,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyFieldsSink extends SinkFunction<Integer> {
+	public static final class MyFieldsSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -178,7 +178,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyDiffFieldsSink extends SinkFunction<Integer> {
+	public static final class MyDiffFieldsSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -187,7 +187,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class MyGraphSink extends SinkFunction<Integer> {
+	public static final class MyGraphSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -196,7 +196,7 @@ public class MapTest {
 		}
 	}
 
-	public static final class JoinSink extends SinkFunction<Integer> {
+	public static final class JoinSink implements SinkFunction<Integer> {
 		private static final long serialVersionUID = 1L;
 
 		@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/streamcomponent/StreamComponentTest.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/streamcomponent/StreamComponentTest.java
b/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/streamcomponent/StreamComponentTest.java
index 566acd2..7d78d8f 100644
--- a/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/streamcomponent/StreamComponentTest.java
+++ b/flink-addons/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/streamcomponent/StreamComponentTest.java
@@ -45,7 +45,7 @@ public class StreamComponentTest {
 
 	public static Map<Integer, Integer> data = new HashMap<Integer, Integer>();
 
-	public static class MySource extends SourceFunction<Tuple1<Integer>> {
+	public static class MySource implements SourceFunction<Tuple1<Integer>> {
 		private static final long serialVersionUID = 1L;
 
 		private Tuple1<Integer> tuple = new Tuple1<Integer>(0);
@@ -82,7 +82,7 @@ public class StreamComponentTest {
 	// }
 	// }
 
-	public static class MySink extends SinkFunction<Tuple2<Integer, Integer>> {
+	public static class MySink implements SinkFunction<Tuple2<Integer, Integer>>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/basictopology/BasicTopology.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/basictopology/BasicTopology.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/basictopology/BasicTopology.java
index 04b8ee2..c5b51e6 100755
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/basictopology/BasicTopology.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/basictopology/BasicTopology.java
@@ -19,7 +19,7 @@
 
 package org.apache.flink.streaming.examples.basictopology;
 
-import org.apache.flink.api.java.functions.RichMapFunction;
+import org.apache.flink.api.common.functions.MapFunction;
 import org.apache.flink.api.java.tuple.Tuple1;
 import org.apache.flink.streaming.api.DataStream;
 import org.apache.flink.streaming.api.StreamExecutionEnvironment;
@@ -28,7 +28,7 @@ import org.apache.flink.util.Collector;
 
 public class BasicTopology {
 
-	public static class BasicSource extends SourceFunction<Tuple1<String>> {
+	public static class BasicSource implements SourceFunction<Tuple1<String>> {
 
 		private static final long serialVersionUID = 1L;
 		Tuple1<String> tuple = new Tuple1<String>("streaming");
@@ -42,7 +42,7 @@ public class BasicTopology {
 		}
 	}
 
-	public static class BasicMap extends RichMapFunction<Tuple1<String>, Tuple1<String>>
{
+	public static class BasicMap implements MapFunction<Tuple1<String>, Tuple1<String>>
{
 		private static final long serialVersionUID = 1L;
 
 		// map to the same tuple

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/cellinfo/CellInfoLocal.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/cellinfo/CellInfoLocal.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/cellinfo/CellInfoLocal.java
index 5704723..bb5cc07 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/cellinfo/CellInfoLocal.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/cellinfo/CellInfoLocal.java
@@ -37,7 +37,7 @@ public class CellInfoLocal {
 	private final static int PARALLELISM = 1;
 	private final static int SOURCE_PARALLELISM = 1;
 
-	private final static class QuerySource extends
+	private final static class QuerySource implements
 			SourceFunction<Tuple4<Boolean, Integer, Long, Integer>> {
 		private static final long serialVersionUID = 1L;
 
@@ -56,7 +56,7 @@ public class CellInfoLocal {
 		}
 	}
 
-	public final static class InfoSource extends
+	public final static class InfoSource implements
 			SourceFunction<Tuple4<Boolean, Integer, Long, Integer>> {
 		private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSink.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSink.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSink.java
index 8a76d0a..d2162fa 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSink.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSink.java
@@ -22,7 +22,7 @@ package org.apache.flink.streaming.examples.iterative.collaborativefilter;
 import org.apache.flink.streaming.api.function.sink.SinkFunction;
 import org.apache.flink.api.java.tuple.Tuple4;
 
-public class CollaborativeFilteringSink extends
+public class CollaborativeFilteringSink implements
 		SinkFunction<Tuple4<Integer, Integer, Integer, Long>> {
 	private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSource.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSource.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSource.java
index 4776b20..6e57739 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSource.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringSource.java
@@ -26,7 +26,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple4;
 import org.apache.flink.util.Collector;
 
-public class CollaborativeFilteringSource extends
+public class CollaborativeFilteringSource implements
 		SourceFunction<Tuple4<Integer, Integer, Integer, Long>> {
 	private static final long serialVersionUID = 1L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSink.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSink.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSink.java
index 047e7bf..c549d13 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSink.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSink.java
@@ -22,7 +22,7 @@ package org.apache.flink.streaming.examples.iterative.kmeans;
 import org.apache.flink.streaming.api.function.sink.SinkFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 
-public class KMeansSink extends SinkFunction<Tuple3<Integer, Integer, Long>>
{
+public class KMeansSink implements SinkFunction<Tuple3<Integer, Integer, Long>>
{
 	private static final long serialVersionUID = 1L;
 	
 	@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSource.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSource.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSource.java
index 86720a2..ea50231 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSource.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/kmeans/KMeansSource.java
@@ -25,7 +25,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple2;
 import org.apache.flink.util.Collector;
 
-public class KMeansSource extends SourceFunction<Tuple2<String, Long>> {
+public class KMeansSource implements SourceFunction<Tuple2<String, Long>> {
 	private static final long serialVersionUID = 1L;
 	private final long DEFAULT_SEED = 4650285087650871364L;
 	private Random random = new Random(DEFAULT_SEED);

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSink.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSink.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSink.java
index 9b0e23a..77f5c10 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSink.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSink.java
@@ -22,7 +22,7 @@ package org.apache.flink.streaming.examples.iterative.pagerank;
 import org.apache.flink.streaming.api.function.sink.SinkFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 
-public class PageRankSink extends SinkFunction<Tuple3<Integer, Float, Long>>
{
+public class PageRankSink implements SinkFunction<Tuple3<Integer, Float, Long>>
{
 	private static final long serialVersionUID = 1L;
 
 	@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSource.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSource.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSource.java
index 3269856..6b38f2f 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSource.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/pagerank/PageRankSource.java
@@ -26,7 +26,7 @@ import org.apache.flink.api.java.tuple.Tuple3;
 import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.util.Collector;
 
-public class PageRankSource extends SourceFunction<Tuple3<Integer, Integer, Long>>
{
+public class PageRankSource implements SourceFunction<Tuple3<Integer, Integer, Long>>
{
 	private static final long serialVersionUID = 1L;
 
 	private Tuple3<Integer, Integer, Long> outRecord = new Tuple3<Integer, Integer,
Long>();

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSink.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSink.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSink.java
index 0b10be0..ec84bd1 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSink.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSink.java
@@ -22,7 +22,7 @@ package org.apache.flink.streaming.examples.iterative.sssp;
 import org.apache.flink.streaming.api.function.sink.SinkFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 
-public class SSSPSink extends SinkFunction<Tuple3<Integer, Integer, Long>> {
+public class SSSPSink implements SinkFunction<Tuple3<Integer, Integer, Long>>
{
 	private static final long serialVersionUID = 1L;
 
 	@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSource.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSource.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSource.java
index 15be203..7936efc 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSource.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/iterative/sssp/SSSPSource.java
@@ -26,7 +26,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 import org.apache.flink.util.Collector;
 
-public class SSSPSource extends SourceFunction<Tuple3<Integer, Integer, Long>>
{
+public class SSSPSource implements SourceFunction<Tuple3<Integer, Integer, Long>>
{
 	private static final long serialVersionUID = 1L;
 
 	private Tuple3<Integer, Integer, Long> outRecord = new Tuple3<Integer, Integer,
Long>();

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSink.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSink.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSink.java
index 1d87a20..4cf7ab6 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSink.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSink.java
@@ -22,7 +22,7 @@ package org.apache.flink.streaming.examples.join;
 import org.apache.flink.streaming.api.function.sink.SinkFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 
-public class JoinSink extends SinkFunction<Tuple3<String, Integer, Integer>>
{
+public class JoinSink implements SinkFunction<Tuple3<String, Integer, Integer>>
{
 	private static final long serialVersionUID = 1L;
 
 	@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceOne.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceOne.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceOne.java
index d178033..5d59ee9 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceOne.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceOne.java
@@ -25,7 +25,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 import org.apache.flink.util.Collector;
 
-public class JoinSourceOne extends SourceFunction<Tuple3<String, String, Integer>>
{
+public class JoinSourceOne implements SourceFunction<Tuple3<String, String, Integer>>
{
 
 	private static final long serialVersionUID = 6670933703432267728L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceTwo.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceTwo.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceTwo.java
index 3730534..032db06 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceTwo.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/join/JoinSourceTwo.java
@@ -25,7 +25,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple3;
 import org.apache.flink.util.Collector;
 
-public class JoinSourceTwo extends SourceFunction<Tuple3<String, String, Integer>>
{
+public class JoinSourceTwo implements SourceFunction<Tuple3<String, String, Integer>>
{
 
 	private static final long serialVersionUID = -5897483980082089771L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
index 05a7eb1..6264cb9 100755
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalLearningSkeleton.java
@@ -29,7 +29,7 @@ import org.apache.flink.util.Collector;
 public class IncrementalLearningSkeleton {
 
 	// Source for feeding new data for prediction
-	public static class NewDataSource extends SourceFunction<Tuple1<Integer>> {
+	public static class NewDataSource implements SourceFunction<Tuple1<Integer>>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override
@@ -46,7 +46,7 @@ public class IncrementalLearningSkeleton {
 	}
 
 	// Source for feeding new training data for partial model building
-	public static class TrainingDataSource extends SourceFunction<Tuple1<Integer>>
{
+	public static class TrainingDataSource implements SourceFunction<Tuple1<Integer>>
{
 		private static final long serialVersionUID = 1L;
 
 		@Override

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalOLS.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalOLS.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalOLS.java
index 1b1cfe1..366e7b5 100755
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalOLS.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/ml/IncrementalOLS.java
@@ -34,7 +34,7 @@ import org.apache.flink.util.Collector;
 
 public class IncrementalOLS {
 
-	public static class NewDataSource extends SourceFunction<Tuple2<Boolean, Double[]>>
{
+	public static class NewDataSource implements SourceFunction<Tuple2<Boolean, Double[]>>
{
 
 		private static final long serialVersionUID = 1L;
 		Random rnd = new Random();
@@ -55,7 +55,7 @@ public class IncrementalOLS {
 		}
 	}
 
-	public static class TrainingDataSource extends SourceFunction<Tuple2<Double, Double[]>>
{
+	public static class TrainingDataSource implements SourceFunction<Tuple2<Double, Double[]>>
{
 		private static final long serialVersionUID = 1L;
 
 		Random rnd = new Random();

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceOne.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceOne.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceOne.java
index 9e16ef8..eacd790 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceOne.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceOne.java
@@ -25,7 +25,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple4;
 import org.apache.flink.util.Collector;
 
-public class WindowJoinSourceOne extends SourceFunction<Tuple4<String, String, Integer,
Long>> {
+public class WindowJoinSourceOne implements SourceFunction<Tuple4<String, String, Integer,
Long>> {
 
 	private static final long serialVersionUID = 6670933703432267728L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceTwo.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceTwo.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceTwo.java
index dfac58d..c4441c0 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceTwo.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/window/join/WindowJoinSourceTwo.java
@@ -25,7 +25,7 @@ import org.apache.flink.streaming.api.function.source.SourceFunction;
 import org.apache.flink.api.java.tuple.Tuple4;
 import org.apache.flink.util.Collector;
 
-public class WindowJoinSourceTwo extends SourceFunction<Tuple4<String, String, Integer,
Long>> {
+public class WindowJoinSourceTwo implements SourceFunction<Tuple4<String, String, Integer,
Long>> {
 
 	private static final long serialVersionUID = -5897483980082089771L;
 

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountCounter.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountCounter.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountCounter.java
index 7142b58..f106afe 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountCounter.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountCounter.java
@@ -22,10 +22,10 @@ package org.apache.flink.streaming.examples.wordcount;
 import java.util.HashMap;
 import java.util.Map;
 
-import org.apache.flink.api.java.functions.RichMapFunction;
 import org.apache.flink.api.java.tuple.Tuple2;
+import org.apache.flink.api.common.functions.MapFunction;
 
-public class WordCountCounter extends RichMapFunction<String, Tuple2<String, Integer>>
{
+public class WordCountCounter implements MapFunction<String, Tuple2<String, Integer>>
{
 	private static final long serialVersionUID = 1L;
 
 	private Map<String, Integer> wordCounts = new HashMap<String, Integer>();
@@ -33,7 +33,7 @@ public class WordCountCounter extends RichMapFunction<String, Tuple2<String,
Int
 	private Integer count = 0;
 
 	private Tuple2<String, Integer> outTuple = new Tuple2<String, Integer>();
-	
+
 	// Increments the counter of the occurrence of the input word
 	@Override
 	public Tuple2<String, Integer> map(String inTuple) throws Exception {

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountSplitter.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountSplitter.java
b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountSplitter.java
index 6295d02..eb0dfd3 100644
--- a/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountSplitter.java
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/main/java/org/apache/flink/streaming/examples/wordcount/WordCountSplitter.java
@@ -19,16 +19,16 @@
 
 package org.apache.flink.streaming.examples.wordcount;
 
-import org.apache.flink.api.java.functions.RichFlatMapFunction;
+import org.apache.flink.api.common.functions.FlatMapFunction;
 import org.apache.flink.util.Collector;
 
-public class WordCountSplitter extends RichFlatMapFunction<String, String> {
+public class WordCountSplitter implements FlatMapFunction<String, String> {
 	private static final long serialVersionUID = 1L;
 
 	// Splits the lines according on spaces
 	@Override
 	public void flatMap(String inTuple, Collector<String> out) throws Exception {
-		
+
 		for (String word : inTuple.split(" ")) {
 			out.collect(word);
 		}

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/ASTopology.data.md5
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/ASTopology.data.md5
b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/ASTopology.data.md5
new file mode 100644
index 0000000..2c386b7
--- /dev/null
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/ASTopology.data.md5
@@ -0,0 +1 @@
+f1b947a26b33b32f1de2cdd841f7b4c8

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/MovieLens100k.data.md5
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/MovieLens100k.data.md5
b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/MovieLens100k.data.md5
new file mode 100644
index 0000000..6499b43
--- /dev/null
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/MovieLens100k.data.md5
@@ -0,0 +1 @@
+6e47046882bad158b0efbb84cd5cb987

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/hamlet.txt.md5
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/hamlet.txt.md5
b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/hamlet.txt.md5
new file mode 100644
index 0000000..6526a51
--- /dev/null
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/hamlet.txt.md5
@@ -0,0 +1 @@
+4bb8c10cdde12a4953250423266465cc

http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/e73ea295/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/terainput.txt.md5
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/terainput.txt.md5
b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/terainput.txt.md5
new file mode 100644
index 0000000..365f210
--- /dev/null
+++ b/flink-addons/flink-streaming/flink-streaming-examples/src/test/resources/testdata_checksum/terainput.txt.md5
@@ -0,0 +1 @@
+7002e15fe547614160a0df6f22a5b8d0


Mime
View raw message