flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [35/51] [abbrv] [streaming] Updated API to use RichFunctions
Date Mon, 18 Aug 2014 17:26:12 GMT
http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/776bd3f6/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 f3e9310..6295d02 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,10 +19,10 @@
 
 package org.apache.flink.streaming.examples.wordcount;
 
-import org.apache.flink.api.java.functions.FlatMapFunction;
+import org.apache.flink.api.java.functions.RichFlatMapFunction;
 import org.apache.flink.util.Collector;
 
-public class WordCountSplitter extends FlatMapFunction<String, String> {
+public class WordCountSplitter extends RichFlatMapFunction<String, String> {
 	private static final long serialVersionUID = 1L;
 
 	// Splits the lines according on spaces


Mime
View raw message