flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hsapu...@apache.org
Subject git commit: Fix the Javadoc link in DataStream class
Date Fri, 17 Oct 2014 23:37:42 GMT
Repository: incubator-flink
Updated Branches:
  refs/heads/master f5d383908 -> ba44459f6


Fix the Javadoc link in DataStream class

Fix the Javadoc link for org.apache.flink.api.common.functions.RichFunction and missing method
reference in DataStream class.

Author: Henry Saputra <henry.saputra@gmail.com>

Closes #154 from hsaputra/fix_comments_streaming and squashes the following commits:

127e47a [Henry Saputra] Fix the Javadoc link for org.apache.flink.api.common.functions.RichFunction
and missing method reference.


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

Branch: refs/heads/master
Commit: ba44459f66f3a73b831da5ae807775faf4843b06
Parents: f5d3839
Author: Henry Saputra <henry.saputra@gmail.com>
Authored: Fri Oct 17 16:37:36 2014 -0700
Committer: Henry Saputra <henry.saputra@gmail.com>
Committed: Fri Oct 17 16:37:36 2014 -0700

----------------------------------------------------------------------
 .../apache/flink/streaming/api/datastream/DataStream.java | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-flink/blob/ba44459f/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
----------------------------------------------------------------------
diff --git a/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
index 7abde6b..000f6db 100644
--- a/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
+++ b/flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
@@ -75,7 +75,7 @@ import org.apache.flink.streaming.util.serialization.TypeWrapper;
  * <ul>
  * <li>{@link DataStream#map},</li>
  * <li>{@link DataStream#filter}, or</li>
- * <li>{@link DataStream#batchReduce}.</li>
+ * <li>{@link DataStream#aggregate}.</li>
  * </ul>
  * 
  * @param <OUT>
@@ -325,7 +325,7 @@ public class DataStream<OUT> {
 	 * calls a {@link MapFunction} for each element of the DataStream. Each
 	 * MapFunction call returns exactly one element. The user can also extend
 	 * {@link RichMapFunction} to gain access to other features provided by the
-	 * {@link RichFuntion} interface.
+	 * {@link org.apache.flink.api.common.functions.RichFunction} interface.
 	 * 
 	 * @param mapper
 	 *            The MapFunction that is called for each element of the
@@ -349,7 +349,7 @@ public class DataStream<OUT> {
 	 * transformation calls a {@link FlatMapFunction} for each element of the
 	 * DataStream. Each FlatMapFunction call can return any number of elements
 	 * including none. The user can also extend {@link RichFlatMapFunction} to
-	 * gain access to other features provided by the {@link RichFuntion}
+	 * gain access to other features provided by the {@link org.apache.flink.api.common.functions.RichFunction}
 	 * interface.
 	 * 
 	 * @param flatMapper
@@ -373,7 +373,7 @@ public class DataStream<OUT> {
 	/**
 	 * Applies a reduce transformation on the data stream. The user can also
 	 * extend the {@link RichReduceFunction} to gain access to other features
-	 * provided by the {@link RichFuntion} interface.
+	 * provided by the {@link org.apache.flink.api.common.functions.RichFunction} interface.
 	 * 
 	 * @param reducer
 	 *            The {@link ReduceFunction} that will be called for every
@@ -678,7 +678,7 @@ public class DataStream<OUT> {
 	 * DataStream and retains only those element for which the function returns
 	 * true. Elements for which the function returns false are filtered. The
 	 * user can also extend {@link RichFilterFunction} to gain access to other
-	 * features provided by the {@link RichFuntion} interface.
+	 * features provided by the {@link org.apache.flink.api.common.functions.RichFunction} interface.
 	 * 
 	 * @param filter
 	 *            The FilterFunction that is called for each element of the


Mime
View raw message