flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject [10/23] flink git commit: [FLINK-6107] Enable Javadoc checks in streaming checkstyle
Date Wed, 26 Apr 2017 10:07:32 GMT
http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
index fc7f793..ba18df4 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SourceFunction.java
@@ -69,7 +69,6 @@ import java.io.Serializable;
  *
  *
  * <h3>Timestamps and watermarks:</h3>
- * 
  * Sources may assign timestamps to elements and may manually emit watermarks.
  * However, these are only interpreted if the streaming program runs on 
  * {@link TimeCharacteristic#EventTime}. On other time characteristics 
@@ -77,7 +76,6 @@ import java.io.Serializable;
  * the watermarks from the source function are ignored.
  *
  * <h3>Gracefully Stopping Functions</h3>
- * 
  * Functions may additionally implement the {@link org.apache.flink.api.common.functions.StoppableFunction}
  * interface. "Stopping" a function, in contrast to "canceling" means a graceful exit that leaves the
  * state and the emitted elements in a consistent state.

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
index 2a0be98..07eb1d9 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/TimestampedFileInputSplit.java
@@ -66,13 +66,12 @@ public class TimestampedFileInputSplit extends FileInputSplit implements Compara
 	}
 
 	/**
-	 * Sets the state of the split. This information is used when
-	 * restoring from a checkpoint and allows to resume reading the
-	 * underlying file from the point we left off.
-	 * <p>
-	 * This is applicable to {@link org.apache.flink.api.common.io.FileInputFormat FileInputFormats}
-	 * that implement the {@link org.apache.flink.api.common.io.CheckpointableInputFormat
-	 * CheckpointableInputFormat} interface.
+	 * Sets the state of the split. This information is used when restoring from a checkpoint and
+	 * allows to resume reading the underlying file from the point we left off.
+	 *
+	 * <p>* This is applicable to
+	 * {@link org.apache.flink.api.common.io.FileInputFormat FileInputFormats} that implement the
+	 * {@link org.apache.flink.api.common.io.CheckpointableInputFormat} interface.
 	 * */
 	public void setSplitState(Serializable state) {
 		this.splitState = state;

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
index 0a138f2..253608f 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/timestamps/AscendingTimestampExtractor.java
@@ -42,7 +42,7 @@ public abstract class AscendingTimestampExtractor<T> implements AssignerWithPeri
 	/** The current timestamp. */
 	private long currentTimestamp = Long.MIN_VALUE;
 
-	/** Handler that is called when timestamp monotony is violated */
+	/** Handler that is called when timestamp monotony is violated. */
 	private MonotonyViolationHandler violationHandler = new LoggingHandler();
 	
 	

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
index 929e336..e20b878 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
index 73e1f0f..912a5c0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/AggregateApplyWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
index 0efffb9..2514355 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -35,6 +35,10 @@ import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.util.Collections;
 
+/**
+ * Internal {@link AllWindowFunction} that is used for implementing a fold on a window configuration
+ * that only allows {@link AllWindowFunction} and cannot directly execute a {@link FoldFunction}.
+ */
 @Internal
 public class FoldApplyAllWindowFunction<W extends Window, T, ACC, R>
 	extends WrappingFunction<AllWindowFunction<ACC, R, W>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java
index 8e8e52c..125da03 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -36,6 +36,11 @@ import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.util.Collections;
 
+/**
+ * Internal {@link ProcessAllWindowFunction} that is used for implementing a fold on a window
+ * configuration that only allows {@link ProcessAllWindowFunction} and cannot directly execute a
+ * {@link FoldFunction}.
+ */
 @Internal
 public class FoldApplyProcessAllWindowFunction<W extends Window, T, ACC, R>
 	extends RichProcessAllWindowFunction<T, R, W>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java
index 073a2f3..9a72cab 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyProcessWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -36,6 +36,11 @@ import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.util.Collections;
 
+/**
+ * Internal {@link ProcessWindowFunction} that is used for implementing a fold on a window
+ * configuration that only allows {@link ProcessWindowFunction} and cannot directly execute a
+ * {@link FoldFunction}.
+ */
 @Internal
 public class FoldApplyProcessWindowFunction<K, W extends Window, T, ACC, R>
 	extends RichProcessWindowFunction<T, R, K, W>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java
index 9e916f1..21b9c3b 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/FoldApplyWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -35,6 +35,10 @@ import java.io.ByteArrayOutputStream;
 import java.io.IOException;
 import java.util.Collections;
 
+/**
+ * Internal {@link WindowFunction} that is used for implementing a fold on a window configuration
+ * that only allows {@link WindowFunction} and cannot directly execute a {@link FoldFunction}.
+ */
 @Internal
 public class FoldApplyWindowFunction<K, W extends Window, T, ACC, R>
 	extends WrappingFunction<WindowFunction<ACC, R, K, W>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java
index 4435644..fb1ff81 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -21,6 +21,9 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.streaming.api.windowing.windows.Window;
 import org.apache.flink.util.Collector;
 
+/**
+ * A {@link AllWindowFunction} that just emits each input element.
+ */
 @Internal
 public class PassThroughAllWindowFunction<W extends Window, T> implements AllWindowFunction<T, T, W> {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java
index 319acb6..edc495c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/PassThroughWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -21,6 +21,9 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.streaming.api.windowing.windows.Window;
 import org.apache.flink.util.Collector;
 
+/**
+ * A {@link WindowFunction} that just emits each input element.
+ */
 @Internal
 public class PassThroughWindowFunction<K, W extends Window, T> implements WindowFunction<T, T, K, W> {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java
index f49aa27..4d247a7 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessAllWindowFunction.java
@@ -57,7 +57,7 @@ public abstract class ProcessAllWindowFunction<IN, OUT, W extends Window> implem
 	public void clear(Context context) throws Exception {}
 
 	/**
-	 * The context holding window metadata
+	 * The context holding window metadata.
 	 */
 	public abstract class Context {
 		/**

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java
index bcefaf7..980a94a 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ProcessWindowFunction.java
@@ -59,7 +59,7 @@ public abstract class ProcessWindowFunction<IN, OUT, KEY, W extends Window> impl
 	public void clear(Context context) throws Exception {}
 
 	/**
-	 * The context holding window metadata
+	 * The context holding window metadata.
 	 */
 	public abstract class Context implements java.io.Serializable {
 		/**

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java
index 46a6456..5a635b7 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -25,6 +25,10 @@ import org.apache.flink.util.Collector;
 
 import java.util.Collections;
 
+/**
+ * Internal {@link AllWindowFunction} that is used for implementing a fold on a window configuration
+ * that only allows {@link AllWindowFunction} and cannot directly execute a {@link ReduceFunction}.
+ */
 @Internal
 public class ReduceApplyAllWindowFunction<W extends Window, T, R>
 	extends WrappingFunction<AllWindowFunction<T, R, W>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java
index 4c54c94..847a793 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -27,6 +27,11 @@ import org.apache.flink.util.Collector;
 
 import java.util.Collections;
 
+/**
+ * Internal {@link ProcessAllWindowFunction} that is used for implementing a fold on a window
+ * configuration that only allows {@link AllWindowFunction} and cannot directly execute a
+ * {@link ReduceFunction}.
+ */
 @Internal
 public class ReduceApplyProcessAllWindowFunction<W extends Window, T, R>
 	extends RichProcessAllWindowFunction<T, R, W> {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java
index 1af783a..0fdce83 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyProcessWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -27,6 +27,11 @@ import org.apache.flink.util.Collector;
 
 import java.util.Collections;
 
+/**
+ * Internal {@link ProcessWindowFunction} that is used for implementing a fold on a window
+ * configuration that only allows {@link AllWindowFunction} and cannot directly execute a
+ * {@link ReduceFunction}.
+ */
 @Internal
 public class ReduceApplyProcessWindowFunction<K, W extends Window, T, R>
 	extends RichProcessWindowFunction<T, R, K, W> {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java
index 6e1ba27..c817464 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceApplyWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -25,6 +25,10 @@ import org.apache.flink.util.Collector;
 
 import java.util.Collections;
 
+/**
+ * Internal {@link WindowFunction} that is used for implementing a fold on a window configuration
+ * that only allows {@link WindowFunction} and cannot directly execute a {@link ReduceFunction}.
+ */
 @Internal
 public class ReduceApplyWindowFunction<K, W extends Window, T, R>
 	extends WrappingFunction<WindowFunction<T, R, K, W>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableAllWindowFunction.java
deleted file mode 100644
index 8ec5809..0000000
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableAllWindowFunction.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.flink.streaming.api.functions.windowing;
-
-import org.apache.flink.annotation.Internal;
-import org.apache.flink.api.common.functions.ReduceFunction;
-import org.apache.flink.streaming.api.windowing.windows.Window;
-import org.apache.flink.util.Collector;
-
-@Internal
-public class ReduceIterableAllWindowFunction<W extends Window, T> implements AllWindowFunction<T, T, W> {
-	private static final long serialVersionUID = 1L;
-
-	private final ReduceFunction<T> reduceFunction;
-
-	public ReduceIterableAllWindowFunction(ReduceFunction<T> reduceFunction) {
-		this.reduceFunction = reduceFunction;
-	}
-
-	@Override
-	public void apply(W window, Iterable<T> input, Collector<T> out) throws Exception {
-
-		T curr = null;
-		for (T val: input) {
-			if (curr == null) {
-				curr = val;
-			} else {
-				curr = reduceFunction.reduce(curr, val);
-			}
-		}
-		out.collect(curr);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableWindowFunction.java
deleted file mode 100644
index afb0219..0000000
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/ReduceIterableWindowFunction.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.flink.streaming.api.functions.windowing;
-
-import org.apache.flink.annotation.Internal;
-import org.apache.flink.api.common.functions.ReduceFunction;
-import org.apache.flink.streaming.api.windowing.windows.Window;
-import org.apache.flink.util.Collector;
-
-@Internal
-public class ReduceIterableWindowFunction<K, W extends Window, T> implements WindowFunction<T, T, K, W> {
-	private static final long serialVersionUID = 1L;
-
-	private final ReduceFunction<T> reduceFunction;
-
-	public ReduceIterableWindowFunction(ReduceFunction<T> reduceFunction) {
-		this.reduceFunction = reduceFunction;
-	}
-
-	@Override
-	public void apply(K k, W window, Iterable<T> input, Collector<T> out) throws Exception {
-
-		T curr = null;
-		for (T val: input) {
-			if (curr == null) {
-				curr = val;
-			} else {
-				curr = reduceFunction.reduce(curr, val);
-			}
-		}
-		out.collect(curr);
-	}
-}

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java
index 643680f..b0df6d8 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/RichAllWindowFunction.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -21,6 +21,10 @@ import org.apache.flink.annotation.Public;
 import org.apache.flink.api.common.functions.AbstractRichFunction;
 import org.apache.flink.streaming.api.windowing.windows.Window;
 
+/**
+ * A {@link org.apache.flink.api.common.functions.RichFunction} version of
+ * {@link AllWindowFunction}.
+ */
 @Public
 public abstract class RichAllWindowFunction<IN, OUT, W extends Window> extends AbstractRichFunction implements AllWindowFunction<IN, OUT, W> {
 	private static final long serialVersionUID = 1L;

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java
index 5b1e806..a8fc600 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/CosineDistance.java
@@ -24,7 +24,7 @@ import org.apache.flink.streaming.api.functions.windowing.delta.extractor.Extrac
  * This delta function calculates the cosine distance between two given vectors.
  * The cosine distance is defined as: cosineDistance=1-cosineSimilarity
  * 
- * Cosine similarity: http://en.wikipedia.org/wiki/Cosine_similarity
+ * <p>Cosine similarity: http://en.wikipedia.org/wiki/Cosine_similarity
  * 
  * @param <DATA>
  *            The input data type. This delta function works with a double[],
@@ -35,9 +35,6 @@ import org.apache.flink.streaming.api.functions.windowing.delta.extractor.Extrac
 @PublicEvolving
 public class CosineDistance<DATA> extends ExtractionAwareDeltaFunction<DATA, double[]> {
 
-	/**
-	 * auto-generated id
-	 */
 	private static final long serialVersionUID = -1217813582965151599L;
 
 	public CosineDistance() {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java
index 91020b8..c4b416c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/EuclideanDistance.java
@@ -24,7 +24,7 @@ import org.apache.flink.streaming.api.functions.windowing.delta.extractor.Extrac
  * This delta function calculates the euclidean distance between two given
  * points.
  * 
- * Euclidean distance: http://en.wikipedia.org/wiki/Euclidean_distance
+ * <p>Euclidean distance: http://en.wikipedia.org/wiki/Euclidean_distance
  * 
  * @param <DATA>
  *            The input data type. This delta function works with a double[],
@@ -43,9 +43,6 @@ public class EuclideanDistance<DATA> extends ExtractionAwareDeltaFunction<DATA,
 		super(converter);
 	}
 
-	/**
-	 * auto-generated version id
-	 */
 	private static final long serialVersionUID = 3119432599634512359L;
 
 	@Override

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java
index 6ec150c..535d513 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/ExtractionAwareDeltaFunction.java
@@ -37,10 +37,8 @@ import org.apache.flink.streaming.api.functions.windowing.delta.extractor.Extrac
 @PublicEvolving
 public abstract class ExtractionAwareDeltaFunction<DATA, TO> implements DeltaFunction<DATA> {
 
-	/**
-	 * Generated Version ID
-	 */
 	private static final long serialVersionUID = 6927486219702689554L;
+	
 	private Extractor<DATA, TO> converter;
 
 	public ExtractionAwareDeltaFunction(Extractor<DATA, TO> converter) {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java
index aa48aa5..16d0935 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ArrayFromTuple.java
@@ -27,9 +27,6 @@ import org.apache.flink.api.java.tuple.Tuple;
 @Internal
 public class ArrayFromTuple implements Extractor<Tuple, Object[]> {
 
-	/**
-	 * Auto generated version id
-	 */
 	private static final long serialVersionUID = -6076121226427616818L;
 	int[] order = null;
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java
index b1f8f75..6fd9a67 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/ConcatenatedExtract.java
@@ -34,9 +34,6 @@ import org.apache.flink.annotation.Internal;
 @Internal
 public class ConcatenatedExtract<FROM, OVER, TO> implements Extractor<FROM, TO> {
 
-	/**
-	 * auto-generated id
-	 */
 	private static final long serialVersionUID = -7807197760725651752L;
 
 	private Extractor<FROM, OVER> e1;

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java
index 0b7e4da..76d95b9 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/Extractor.java
@@ -35,7 +35,7 @@ import java.io.Serializable;
 public interface Extractor<FROM, TO> extends Serializable {
 
 	/**
-	 * Extracts/Converts the given input to an object of the output type
+	 * Extracts/Converts the given input to an object of the output type.
 	 * 
 	 * @param in
 	 *            the input data

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java
index 11afaba..c44f32b 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromArray.java
@@ -30,14 +30,12 @@ import java.lang.reflect.Array;
 @Internal
 public class FieldFromArray<OUT> implements Extractor<Object, OUT> {
 
-	/**
-	 * Auto-gernated version id
-	 */
 	private static final long serialVersionUID = -5161386546695574359L;
+	
 	private int fieldId = 0;
 
 	/**
-	 * Extracts the first field (id 0) from the array
+	 * Extracts the first field (id 0) from the array.
 	 */
 	public FieldFromArray() {
 		// noting to do => will use default 0

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java
index c6cf1e1..468b878 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldFromTuple.java
@@ -29,18 +29,9 @@ import org.apache.flink.api.java.tuple.Tuple;
 @Internal
 public class FieldFromTuple<OUT> implements Extractor<Tuple, OUT> {
 
-	/**
-	 * Auto-gernated version id
-	 */
 	private static final long serialVersionUID = -5161386546695574359L;
-	private int fieldId = 0;
 
-	/**
-	 * Extracts the first field (id 0) from the tuple
-	 */
-	public FieldFromTuple() {
-		// noting to do => will use default 0
-	}
+	private int fieldId = 0;
 
 	/**
 	 * Extracts the field with the given id from the tuple.

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java
index 9ac96e1..afc2b4d 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromArray.java
@@ -33,10 +33,8 @@ import java.lang.reflect.Array;
 @Internal
 public class FieldsFromArray<OUT> implements Extractor<Object, OUT[]> {
 
-	/**
-	 * Auto-generated version id
-	 */
 	private static final long serialVersionUID = 8075055384516397670L;
+	
 	private int[] order;
 	private Class<OUT> clazz;
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java
index 21a2641..2321878 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/windowing/delta/extractor/FieldsFromTuple.java
@@ -21,16 +21,13 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.java.tuple.Tuple;
 
 /**
- * Extracts one or more fields of the type Double from a tuple and puts them
- * into a new double[]
+ * Extracts one or more fields of the type Double from a tuple and puts them into a new double[].
  */
 @Internal
 public class FieldsFromTuple implements Extractor<Tuple, double[]> {
 
-	/**
-	 * auto generated version id
-	 */
 	private static final long serialVersionUID = -2554079091050273761L;
+
 	int[] indexes;
 
 	/**

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java
index c9c27d0..d4e4873 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/JSONGenerator.java
@@ -30,6 +30,9 @@ import org.apache.sling.commons.json.JSONArray;
 import org.apache.sling.commons.json.JSONException;
 import org.apache.sling.commons.json.JSONObject;
 
+/**
+ * Helper class for generating a JSON representation from a {@link StreamGraph}.
+ */
 @Internal
 public class JSONGenerator {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
index 93a6387..be591f7 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamConfig.java
@@ -41,6 +41,10 @@ import org.apache.flink.util.InstantiationUtil;
 import org.apache.flink.util.OutputTag;
 import org.apache.flink.util.Preconditions;
 
+/**
+ * Internal configuration for a {@link StreamOperator}. This is created and populated by the
+ * {@link StreamingJobGraphGenerator}.
+ */
 @Internal
 public class StreamConfig implements Serializable {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
index 1acfc5b..157023e 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
@@ -277,7 +277,7 @@ public class StreamGraph extends StreamingPlan {
 	 * Adds a new virtual node that is used to connect a downstream vertex to only the outputs
 	 * with the selected names.
 	 *
-	 * When adding an edge from the virtual node to a downstream node the connection will be made
+	 * <p>When adding an edge from the virtual node to a downstream node the connection will be made
 	 * to the original node, only with the selected names given here.
 	 *
 	 * @param originalId ID of the node that should be connected to.
@@ -329,10 +329,10 @@ public class StreamGraph extends StreamingPlan {
 	}
 
 	/**
-	 * Adds a new virtual node that is used to connect a downstream vertex to an input with a certain
-	 * partitioning.
+	 * Adds a new virtual node that is used to connect a downstream vertex to an input with a
+	 * certain partitioning.
 	 *
-	 * When adding an edge from the virtual node to a downstream node the connection will be made
+	 * <p>When adding an edge from the virtual node to a downstream node the connection will be made
 	 * to the original node, but with the partitioning given here.
 	 *
 	 * @param originalId ID of the node that should be connected to.

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
index 3b9a506..be80371 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphGenerator.java
@@ -49,15 +49,13 @@ import java.util.Map;
  * A generator that generates a {@link StreamGraph} from a graph of
  * {@link StreamTransformation StreamTransformations}.
  *
- * <p>
- * This traverses the tree of {@code StreamTransformations} starting from the sinks. At each
+ * <p>This traverses the tree of {@code StreamTransformations} starting from the sinks. At each
  * transformation we recursively transform the inputs, then create a node in the {@code StreamGraph}
  * and add edges from the input Nodes to our newly created node. The transformation methods
  * return the IDs of the nodes in the StreamGraph that represent the input transformation. Several
  * IDs can be returned to be able to deal with feedback transformations and unions.
  *
- * <p>
- * Partitioning, split/select and union don't create actual nodes in the {@code StreamGraph}. For
+ * <p>Partitioning, split/select and union don't create actual nodes in the {@code StreamGraph}. For
  * these, we create a virtual node in the {@code StreamGraph} that holds the specific property, i.e.
  * partitioning, selector and so on. When an edge is created from a virtual node to a downstream
  * node the {@code StreamGraph} resolved the id of the original node and creates an edge
@@ -67,7 +65,7 @@ import java.util.Map;
  *     Map-1 -&gt; HashPartition-2 -&gt; Map-3
  * </pre>
  *
- * where the numbers represent transformation IDs. We first recurse all the way down. {@code Map-1}
+ * <p>where the numbers represent transformation IDs. We first recurse all the way down. {@code Map-1}
  * is transformed, i.e. we create a {@code StreamNode} with ID 1. Then we transform the
  * {@code HashPartition}, for this, we create virtual node of ID 4 that holds the property
  * {@code HashPartition}. This transformation returns the ID 4. Then we transform the {@code Map-3}.
@@ -137,8 +135,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms one {@code StreamTransformation}.
 	 *
-	 * <p>
-	 * This checks whether we already transformed it and exits early in that case. If not it
+	 * <p>This checks whether we already transformed it and exits early in that case. If not it
 	 * delegates to one of the transformation specific methods.
 	 */
 	private Collection<Integer> transform(StreamTransformation<?> transform) {
@@ -215,8 +212,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code UnionTransformation}.
 	 *
-	 * <p>
-	 * This is easy, we only have to transform the inputs and return all the IDs in a list so
+	 * <p>This is easy, we only have to transform the inputs and return all the IDs in a list so
 	 * that downstream operations can connect to all upstream nodes.
 	 */
 	private <T> Collection<Integer> transformUnion(UnionTransformation<T> union) {
@@ -233,8 +229,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code PartitionTransformation}.
 	 *
-	 * <p>
-	 * For this we create a virtual node in the {@code StreamGraph} that holds the partition
+	 * <p>For this we create a virtual node in the {@code StreamGraph} that holds the partition
 	 * property. @see StreamGraphGenerator
 	 */
 	private <T> Collection<Integer> transformPartition(PartitionTransformation<T> partition) {
@@ -254,8 +249,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code SplitTransformation}.
 	 *
-	 * <p>
-	 * We add the output selector to previously transformed nodes.
+	 * <p>We add the output selector to previously transformed nodes.
 	 */
 	private <T> Collection<Integer> transformSplit(SplitTransformation<T> split) {
 
@@ -278,8 +272,8 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code SelectTransformation}.
 	 *
-	 * <p>
-	 * For this we create a virtual node in the {@code StreamGraph} holds the selected names.
+	 * <p>For this we create a virtual node in the {@code StreamGraph} holds the selected names.
+	 * 
 	 * @see org.apache.flink.streaming.api.graph.StreamGraphGenerator
 	 */
 	private <T> Collection<Integer> transformSelect(SelectTransformation<T> select) {
@@ -305,8 +299,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code SideOutputTransformation}.
 	 *
-	 * <p>
-	 * For this we create a virtual node in the {@code StreamGraph} that holds the side-output
+	 * <p>For this we create a virtual node in the {@code StreamGraph} that holds the side-output
 	 * {@link org.apache.flink.util.OutputTag}.
 	 *
 	 * @see org.apache.flink.streaming.api.graph.StreamGraphGenerator
@@ -334,13 +327,12 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code FeedbackTransformation}.
 	 *
-	 * <p>
-	 * This will recursively transform the input and the feedback edges. We return the concatenation
-	 * of the input IDs and the feedback IDs so that downstream operations can be wired to both.
+	 * <p>This will recursively transform the input and the feedback edges. We return the
+	 * concatenation of the input IDs and the feedback IDs so that downstream operations can be
+	 * wired to both.
 	 *
-	 * <p>
-	 * This is responsible for creating the IterationSource and IterationSink which
-	 * are used to feed back the elements.
+	 * <p>This is responsible for creating the IterationSource and IterationSink which are used to
+	 * feed back the elements.
 	 */
 	private <T> Collection<Integer> transformFeedback(FeedbackTransformation<T> iterate) {
 
@@ -411,13 +403,11 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code CoFeedbackTransformation}.
 	 *
-	 * <p>
-	 * This will only transform feedback edges, the result of this transform will be wired
+	 * <p>This will only transform feedback edges, the result of this transform will be wired
 	 * to the second input of a Co-Transform. The original input is wired directly to the first
 	 * input of the downstream Co-Transform.
 	 *
-	 * <p>
-	 * This is responsible for creating the IterationSource and IterationSink which
+	 * <p>This is responsible for creating the IterationSource and IterationSink which
 	 * are used to feed back the elements.
 	 */
 	private <F> Collection<Integer> transformCoFeedback(CoFeedbackTransformation<F> coIterate) {
@@ -531,8 +521,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code OneInputTransformation}.
 	 *
-	 * <p>
-	 * This recursively transforms the inputs, creates a new {@code StreamNode} in the graph and
+	 * <p>This recursively transforms the inputs, creates a new {@code StreamNode} in the graph and
 	 * wired the inputs to this new node.
 	 */
 	private <IN, OUT> Collection<Integer> transformOneInputTransform(OneInputTransformation<IN, OUT> transform) {
@@ -571,8 +560,7 @@ public class StreamGraphGenerator {
 	/**
 	 * Transforms a {@code TwoInputTransformation}.
 	 *
-	 * <p>
-	 * This recusively transforms the inputs, creates a new {@code StreamNode} in the graph and
+	 * <p>This recusively transforms the inputs, creates a new {@code StreamNode} in the graph and
 	 * wired the inputs to this new node.
 	 */
 	private <IN1, IN2, OUT> Collection<Integer> transformTwoInputTransform(TwoInputTransformation<IN1, IN2, OUT> transform) {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java
index d5084ed..c778b20 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraphHasherV2.java
@@ -59,17 +59,15 @@ public class StreamGraphHasherV2 implements StreamGraphHasher {
 	 * StreamGraph}. The hash is used as the {@link JobVertexID} in order to
 	 * identify nodes across job submissions if they didn't change.
 	 *
-	 * <p>
 	 * <p>The complete {@link StreamGraph} is traversed. The hash is either
 	 * computed from the transformation's user-specified id (see
 	 * {@link StreamTransformation#getUid()}) or generated in a deterministic way.
 	 *
-	 * <p>
 	 * <p>The generated hash is deterministic with respect to:
 	 * <ul>
-	 * <li>node-local properties (like parallelism, UDF, node ID),
-	 * <li>chained output nodes, and
-	 * <li>input nodes hashes
+	 *   <li>node-local properties (like parallelism, UDF, node ID),
+	 *   <li>chained output nodes, and
+	 *   <li>input nodes hashes
 	 * </ul>
 	 *
 	 * @return A map from {@link StreamNode#id} to hash as 16-byte array.
@@ -282,7 +280,6 @@ public class StreamGraphHasherV2 implements StreamGraphHasher {
 	 * attributes are taken into account). The hasher encapsulates the current
 	 * state of the hash.
 	 *
-	 * <p>
 	 * <p>The specified ID is local to this node. We cannot use the
 	 * {@link StreamNode#id}, because it is incremented in a static counter.
 	 * Therefore, the IDs for identical jobs will otherwise be different.

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
index 99c3f4e..e5e5dfc 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
@@ -98,7 +98,7 @@ public abstract class AbstractStreamOperator<OUT>
 
 	private static final long serialVersionUID = 1L;
 	
-	/** The logger used by the operator class and its subclasses */
+	/** The logger used by the operator class and its subclasses. */
 	protected static final Logger LOG = LoggerFactory.getLogger(AbstractStreamOperator.class);
 
 	// ----------- configuration properties -------------
@@ -108,41 +108,53 @@ public abstract class AbstractStreamOperator<OUT>
 
 	// ---------------- runtime fields ------------------
 
-	/** The task that contains this operator (and other operators in the same chain) */
+	/** The task that contains this operator (and other operators in the same chain). */
 	private transient StreamTask<?, ?> container;
 	
 	protected transient StreamConfig config;
 
 	protected transient Output<StreamRecord<OUT>> output;
 
-	/** The runtime context for UDFs */
+	/** The runtime context for UDFs. */
 	private transient StreamingRuntimeContext runtimeContext;
 
 	// ----------------- general state -------------------
 
-	/** The factory that give this operator access to checkpoint storage */
+	/** The factory that give this operator access to checkpoint storage. */
 	private transient CheckpointStreamFactory checkpointStreamFactory;
 
 	// ---------------- key/value state ------------------
 
-	/** key selector used to get the key for the state. Non-null only is the operator uses key/value state */
+	/**
+	 * {@code KeySelector} for extracting a key from an element being processed. This is used to
+	 * scope keyed state to a key. This is null if the operator is not a keyed operator.
+	 *
+	 * <p>This is for elements from the first input.
+	 */
 	private transient KeySelector<?, ?> stateKeySelector1;
+
+	/**
+	 * {@code KeySelector} for extracting a key from an element being processed. This is used to
+	 * scope keyed state to a key. This is null if the operator is not a keyed operator.
+	 *
+	 * <p>This is for elements from the second input.
+	 */
 	private transient KeySelector<?, ?> stateKeySelector2;
 
 	/** Backend for keyed state. This might be empty if we're not on a keyed stream. */
 	private transient AbstractKeyedStateBackend<?> keyedStateBackend;
 
-	/** Keyed state store view on the keyed backend */
+	/** Keyed state store view on the keyed backend. */
 	private transient DefaultKeyedStateStore keyedStateStore;
 
 	// ---------------- operator state ------------------
 
-	/** Operator state backend / store */
+	/** Operator state backend / store. */
 	private transient OperatorStateBackend operatorStateBackend;
 
 	// --------------- Metrics ---------------------------
 
-	/** Metric group for the operator */
+	/** Metric group for the operator. */
 	protected transient MetricGroup metrics;
 
 	protected transient LatencyGauge latencyGauge;
@@ -326,7 +338,7 @@ public abstract class AbstractStreamOperator<OUT>
 	 * {@link OneInputStreamOperator#processElement(StreamRecord)}, or
 	 * {@link TwoInputStreamOperator#processElement1(StreamRecord)} and
 	 * {@link TwoInputStreamOperator#processElement2(StreamRecord)}.
-
+	 *
 	 * <p>The method is expected to flush all remaining buffered data. Exceptions during this flushing
 	 * of buffered should be propagated, in order to cause the operation to be recognized asa failed,
 	 * because the last data items are not processed properly.
@@ -340,7 +352,7 @@ public abstract class AbstractStreamOperator<OUT>
 	 * This method is called at the very end of the operator's life, both in the case of a successful
 	 * completion of the operation, and in the case of a failure and canceling.
 	 *
-	 * This method is expected to make a thorough effort to release all resources
+	 * <p>This method is expected to make a thorough effort to release all resources
 	 * that the operator has acquired.
 	 */
 	@Override
@@ -614,10 +626,6 @@ public abstract class AbstractStreamOperator<OUT>
 
 	/**
 	 * Creates a partitioned state handle, using the state backend configured for this task.
-	 * 
-	 * TODO: NOTE: This method does a lot of work caching / retrieving states just to update the namespace.
-	 *       This method should be removed for the sake of namespaces being lazily fetched from the keyed
-	 *       state backend, or being set on the state directly.
 	 *
 	 * @throws IllegalStateException Thrown, if the key/value state was already initialized.
 	 * @throws Exception Thrown, if the state backend cannot create the key/value state.
@@ -627,6 +635,13 @@ public abstract class AbstractStreamOperator<OUT>
 			TypeSerializer<N> namespaceSerializer,
 			StateDescriptor<S, ?> stateDescriptor) throws Exception {
 
+
+		/*
+	    TODO: NOTE: This method does a lot of work caching / retrieving states just to update the namespace.
+	    This method should be removed for the sake of namespaces being lazily fetched from the keyed
+	    state backend, or being set on the state directly.
+	    */
+		
 		if (keyedStateStore != null) {
 			return keyedStateBackend.getPartitionedState(namespace, namespaceSerializer, stateDescriptor);
 		} else {
@@ -780,23 +795,25 @@ public abstract class AbstractStreamOperator<OUT>
 	}
 
 	/**
-	 * Identifier for a latency source
+	 * Identifier for a latency source.
 	 */
 	private static class LatencySourceDescriptor {
 		/**
-		 * A unique ID identifying a logical source in Flink
+		 * A unique ID identifying a logical source in Flink.
 		 */
 		private final int vertexID;
 
 		/**
-		 * Identifier for parallel subtasks of a logical source
+		 * Identifier for parallel subtasks of a logical source.
 		 */
 		private final int subtaskIndex;
 
 		/**
+		 * Creates a {@code LatencySourceDescriptor} from a given {@code LatencyMarker}.
 		 *
 		 * @param marker The latency marker to extract the LatencySourceDescriptor from.
-		 * @param ignoreSubtaskIndex Set to true to ignore the subtask index, to treat the latencies from all the parallel instances of a source as the same.
+		 * @param ignoreSubtaskIndex Set to true to ignore the subtask index, to treat the latencies
+		 *      from all the parallel instances of a source as the same.
 		 * @return A LatencySourceDescriptor for the given marker.
 		 */
 		public static LatencySourceDescriptor of(LatencyMarker marker, boolean ignoreSubtaskIndex) {
@@ -846,6 +863,9 @@ public abstract class AbstractStreamOperator<OUT>
 		}
 	}
 
+	/**
+	 * Wrapping {@link Output} that updates metrics on the number of emitted elements.
+	 */
 	public class CountingOutput implements Output<StreamRecord<OUT>> {
 		private final Output<StreamRecord<OUT>> output;
 		private final Counter numRecordsOut;
@@ -891,8 +911,8 @@ public abstract class AbstractStreamOperator<OUT>
 	 * Returns an {@link InternalWatermarkCallbackService} which  allows to register a
 	 * {@link OnWatermarkCallback} and multiple keys, for which
 	 * the callback will be invoked every time a new {@link Watermark} is received.
-	 * <p>
-	 * <b>NOTE: </b> This service is only available to <b>keyed</b> operators.
+	 *
+	 * <p><b>NOTE: </b> This service is only available to <b>keyed</b> operators.
 	 */
 	public <K> InternalWatermarkCallbackService<K> getInternalWatermarkCallbackService() {
 		checkTimerServiceInitialization();

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
index 19559e1..550add1 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractUdfStreamOperator.java
@@ -63,10 +63,10 @@ public abstract class AbstractUdfStreamOperator<OUT, F extends Function>
 	private static final long serialVersionUID = 1L;
 	
 	
-	/** the user function */
+	/** The user function. */
 	protected final F userFunction;
 	
-	/** Flag to prevent duplicate function.close() calls in close() and dispose() */
+	/** Flag to prevent duplicate function.close() calls in close() and dispose(). */
 	private transient boolean functionsClosed = false;
 	
 	public AbstractUdfStreamOperator(F userFunction) {
@@ -205,7 +205,6 @@ public abstract class AbstractUdfStreamOperator<OUT, F extends Function>
 	// ------------------------------------------------------------------------
 
 	/**
-	 * 
 	 * Since the streaming API does not implement any parametrization of functions via a
 	 * configuration, the config returned here is actually empty.
 	 * 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
index 742e119..a6d66e8 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/HeapInternalTimerService.java
@@ -59,7 +59,7 @@ public class HeapInternalTimerService<K, N> implements InternalTimerService<N>,
 	private final PriorityQueue<InternalTimer<K, N>> eventTimeTimersQueue;
 
 	/**
-	 * Information concerning the local key-group range
+	 * Information concerning the local key-group range.
 	 */
 	private final KeyGroupsList localKeyGroupRange;
 	private final int totalKeyGroups;

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
index 97bc8ce..a46897c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/KeyedProcessOperator.java
@@ -30,6 +30,10 @@ import org.apache.flink.util.OutputTag;
 import static org.apache.flink.util.Preconditions.checkNotNull;
 import static org.apache.flink.util.Preconditions.checkState;
 
+/**
+ * A {@link org.apache.flink.streaming.api.operators.StreamOperator} for executing keyed
+ * {@link ProcessFunction ProcessFunctions}.
+ */
 @Internal
 public class KeyedProcessOperator<K, IN, OUT>
 		extends AbstractUdfStreamOperator<OUT, ProcessFunction<IN, OUT>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java
index f73b610..f08c1ee 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/ProcessOperator.java
@@ -27,6 +27,10 @@ import org.apache.flink.util.OutputTag;
 
 import static org.apache.flink.util.Preconditions.checkState;
 
+/**
+ * A {@link org.apache.flink.streaming.api.operators.StreamOperator} for executing
+ * {@link ProcessFunction ProcessFunctions}.
+ */
 @Internal
 public class ProcessOperator<IN, OUT>
 		extends AbstractUdfStreamOperator<OUT, ProcessFunction<IN, OUT>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java
index 2df95ca..22f9d9d 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFilter.java
@@ -21,6 +21,9 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.functions.FilterFunction;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing {@link FilterFunction FilterFunctions}.
+ */
 @Internal
 public class StreamFilter<IN> extends AbstractUdfStreamOperator<IN, FilterFunction<IN>> implements OneInputStreamOperator<IN, IN> {
 

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java
index c3ad260..563325b 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamFlatMap.java
@@ -21,6 +21,9 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.functions.FlatMapFunction;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing {@link FlatMapFunction FlatMapFunctions}.
+ */
 @Internal
 public class StreamFlatMap<IN, OUT>
 		extends AbstractUdfStreamOperator<OUT, FlatMapFunction<IN, OUT>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java
index 76a18d8..f984a33 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedFold.java
@@ -32,6 +32,10 @@ import org.apache.flink.core.memory.DataInputViewStreamWrapper;
 import org.apache.flink.core.memory.DataOutputViewStreamWrapper;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing a {@link FoldFunction} on a
+ * {@link org.apache.flink.streaming.api.datastream.KeyedStream}.
+ */
 @Internal
 public class StreamGroupedFold<IN, OUT, KEY>
 		extends AbstractUdfStreamOperator<OUT, FoldFunction<IN, OUT>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java
index 156f336..2fd3f54 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamGroupedReduce.java
@@ -24,6 +24,11 @@ import org.apache.flink.api.common.state.ValueStateDescriptor;
 import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing a {@link ReduceFunction} on a
+ * {@link org.apache.flink.streaming.api.datastream.KeyedStream}.
+ */
+
 @Internal
 public class StreamGroupedReduce<IN> extends AbstractUdfStreamOperator<IN, ReduceFunction<IN>>
 		implements OneInputStreamOperator<IN, IN> {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java
index 6755bc0..5286d2c 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamMap.java
@@ -21,6 +21,9 @@ import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.functions.MapFunction;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing {@link MapFunction MapFunctions}.
+ */
 @Internal
 public class StreamMap<IN, OUT>
 		extends AbstractUdfStreamOperator<OUT, MapFunction<IN, OUT>>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java
index 006e910..b0b7703 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamOperator.java
@@ -34,10 +34,10 @@ import java.io.Serializable;
  * {@link org.apache.flink.streaming.api.operators.TwoInputStreamOperator} to create operators
  * that process elements.
  * 
- * <p> The class {@link org.apache.flink.streaming.api.operators.AbstractStreamOperator}
+ * <p>The class {@link org.apache.flink.streaming.api.operators.AbstractStreamOperator}
  * offers default implementation for the lifecycle and properties methods.
  *
- * <p> Methods of {@code StreamOperator} are guaranteed not to be called concurrently. Also, if using
+ * <p>Methods of {@code StreamOperator} are guaranteed not to be called concurrently. Also, if using
  * the timer service, timer callbacks are also guaranteed not to be called concurrently with
  * methods on {@code StreamOperator}.
  * 
@@ -68,11 +68,10 @@ public interface StreamOperator<OUT> extends Serializable {
 	 * {@link org.apache.flink.streaming.api.operators.OneInputStreamOperator#processElement(StreamRecord)}, or
 	 * {@link org.apache.flink.streaming.api.operators.TwoInputStreamOperator#processElement1(StreamRecord)} and
 	 * {@link org.apache.flink.streaming.api.operators.TwoInputStreamOperator#processElement2(StreamRecord)}.
-
-	 * <p>
-	 * The method is expected to flush all remaining buffered data. Exceptions during this flushing
-	 * of buffered should be propagated, in order to cause the operation to be recognized as failed,
-	 * because the last data items are not processed properly.
+	 *
+	 * <p>The method is expected to flush all remaining buffered data. Exceptions during this
+	 * flushing of buffered should be propagated, in order to cause the operation to be recognized
+	 * as failed, because the last data items are not processed properly.
 	 * 
 	 * @throws java.lang.Exception An exception in this method causes the operator to fail.
 	 */
@@ -82,7 +81,7 @@ public interface StreamOperator<OUT> extends Serializable {
 	 * This method is called at the very end of the operator's life, both in the case of a successful
 	 * completion of the operation, and in the case of a failure and canceling.
 	 * 
-	 * This method is expected to make a thorough effort to release all resources
+	 * <p>This method is expected to make a thorough effort to release all resources
 	 * that the operator has acquired.
 	 */
 	void dispose() throws Exception;

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java
index ef51d8e..acc84d0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamProject.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one or more
  * contributor license agreements.  See the NOTICE file distributed with
  * this work for additional information regarding copyright ownership.
@@ -22,6 +22,9 @@ import org.apache.flink.api.common.typeutils.TypeSerializer;
 import org.apache.flink.api.java.tuple.Tuple;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing projections on streams.
+ */
 @Internal
 public class StreamProject<IN, OUT extends Tuple>
 		extends AbstractStreamOperator<OUT>

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java
index e238566..d92d789 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSink.java
@@ -22,6 +22,9 @@ import org.apache.flink.streaming.api.functions.sink.SinkFunction;
 import org.apache.flink.streaming.runtime.streamrecord.LatencyMarker;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
 
+/**
+ * A {@link StreamOperator} for executing {@link SinkFunction SinkFunctions}.
+ */
 @Internal
 public class StreamSink<IN> extends AbstractUdfStreamOperator<Object, SinkFunction<IN>>
 		implements OneInputStreamOperator<IN, Object> {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
index 36d10d3..25537fa 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamSourceContexts.java
@@ -200,7 +200,7 @@ public class StreamSourceContexts {
 			return mark.getTimestamp() == Long.MAX_VALUE && nextWatermarkTime != Long.MAX_VALUE;
 		}
 
-		/** This will only be called if allowWatermark returned {@code true} */
+		/** This will only be called if allowWatermark returned {@code true}. */
 		@Override
 		protected void processAndEmitWatermark(Watermark mark) {
 			nextWatermarkTime = Long.MAX_VALUE;
@@ -279,7 +279,7 @@ public class StreamSourceContexts {
 	 * watermarks, but if records are emitted without timestamps, no timestamps are automatically
 	 * generated and attached. The records will simply have no timestamp in that case.
 	 *
-	 * Streaming topologies can use timestamp assigner functions to override the timestamps
+	 * <p>Streaming topologies can use timestamp assigner functions to override the timestamps
 	 * assigned here.
 	 */
 	private static class ManualWatermarkContext<T> extends WatermarkContext<T> {
@@ -325,12 +325,12 @@ public class StreamSourceContexts {
 	 * An abstract {@link SourceFunction.SourceContext} that should be used as the base for
 	 * stream source contexts that are relevant with {@link Watermark}s.
 	 *
-	 * Stream source contexts that are relevant with watermarks are responsible of manipulating
+	 * <p>Stream source contexts that are relevant with watermarks are responsible of manipulating
 	 * the current {@link StreamStatus}, so that stream status can be correctly propagated
 	 * downstream. Please refer to the class-level documentation of {@link StreamStatus} for
 	 * information on how stream status affects watermark advancement at downstream tasks.
 	 *
-	 * This class implements the logic of idleness detection. It fires idleness detection
+	 * <p>This class implements the logic of idleness detection. It fires idleness detection
 	 * tasks at a given interval; if no records or watermarks were collected by the source context
 	 * between 2 consecutive checks, it determines the source to be IDLE and correspondingly
 	 * toggles the status. ACTIVE status resumes as soon as some record or watermark is collected
@@ -349,8 +349,8 @@ public class StreamSourceContexts {
 		 * This flag will be reset to {@code true} every time the next check is scheduled.
 		 * Whenever a record or watermark is collected, the flag will be set to {@code false}.
 		 *
-		 * When the scheduled check is fired, if the flag remains to be {@code true}, the check will fail,
-		 * and our current status will determined to be IDLE.
+		 * <p>When the scheduled check is fired, if the flag remains to be {@code true}, the check
+		 * will fail, and our current status will determined to be IDLE.
 		 */
 		private volatile boolean failOnNextCheck;
 
@@ -491,10 +491,13 @@ public class StreamSourceContexts {
 		/** Process and collect record with timestamp. */
 		protected abstract void processAndCollectWithTimestamp(T element, long timestamp);
 
-		/** Whether or not a watermark should be allowed */
+		/** Whether or not a watermark should be allowed. */
 		protected abstract boolean allowWatermark(Watermark mark);
 
-		/** Process and emit watermark. Only called if {@link WatermarkContext#allowWatermark(Watermark)} returns {@code true} */
+		/**
+		 * Process and emit watermark. Only called if
+		 * {@link WatermarkContext#allowWatermark(Watermark)} returns {@code true}.
+		 */
 		protected abstract void processAndEmitWatermark(Watermark mark);
 
 	}

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
index b666a2b..a7f69ac 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/StreamingRuntimeContext.java
@@ -51,10 +51,10 @@ import java.util.Map;
 @PublicEvolving
 public class StreamingRuntimeContext extends AbstractRuntimeUDFContext {
 
-	/** The operator to which this function belongs */
+	/** The operator to which this function belongs. */
 	private final AbstractStreamOperator<?> operator;
 
-	/** The task environment running the operator */
+	/** The task environment running the operator. */
 	private final Environment taskEnvironment;
 
 	private final StreamConfig streamConfig;
@@ -157,6 +157,7 @@ public class StreamingRuntimeContext extends AbstractRuntimeUDFContext {
 
 	/**
 	 * Returns true if checkpointing is enabled for the running job.
+	 *
 	 * @return true if checkpointing is enabled.
 	 */
 	public boolean isCheckpointingEnabled() {
@@ -164,7 +165,8 @@ public class StreamingRuntimeContext extends AbstractRuntimeUDFContext {
 	}
 
 	/**
-	 * Returns the checkpointing mode
+	 * Returns the checkpointing mode.
+	 *
 	 * @return checkpointing mode
 	 */
 	public CheckpointingMode getCheckpointMode() {
@@ -172,7 +174,8 @@ public class StreamingRuntimeContext extends AbstractRuntimeUDFContext {
 	}
 
 	/**
-	 * Returns the buffer timeout of the job
+	 * Returns the buffer timeout of the job.
+	 *
 	 * @return buffer timeout (in milliseconds)
 	 */
 	public long getBufferTimeout() {

http://git-wip-us.apache.org/repos/asf/flink/blob/2581a7b8/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
index ff507e3..7925be8 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
@@ -83,13 +83,13 @@ public class AsyncWaitOperator<IN, OUT>
 
 	private static final String STATE_NAME = "_async_wait_operator_state_";
 
-	/** Capacity of the stream element queue */
+	/** Capacity of the stream element queue. */
 	private final int capacity;
 
-	/** Output mode for this operator */
+	/** Output mode for this operator. */
 	private final AsyncDataStream.OutputMode outputMode;
 
-	/** Timeout for the async collectors */
+	/** Timeout for the async collectors. */
 	private final long timeout;
 
 	protected transient Object checkpointingLock;
@@ -97,21 +97,21 @@ public class AsyncWaitOperator<IN, OUT>
 	/** {@link TypeSerializer} for inputs while making snapshots. */
 	private transient StreamElementSerializer<IN> inStreamElementSerializer;
 
-	/** Recovered input stream elements */
+	/** Recovered input stream elements. */
 	private transient ListState<StreamElement> recoveredStreamElements;
 
-	/** Queue to store the currently in-flight stream elements into */
+	/** Queue to store the currently in-flight stream elements into. */
 	private transient StreamElementQueue queue;
 
-	/** Pending stream element which could not yet added to the queue */
+	/** Pending stream element which could not yet added to the queue. */
 	private transient StreamElementQueueEntry<?> pendingStreamElementQueueEntry;
 
 	private transient ExecutorService executor;
 
-	/** Emitter for the completed stream element queue entries */
+	/** Emitter for the completed stream element queue entries. */
 	private transient Emitter<OUT> emitter;
 
-	/** Thread running the emitter */
+	/** Thread running the emitter. */
 	private transient Thread emitterThread;
 
 
@@ -368,7 +368,7 @@ public class AsyncWaitOperator<IN, OUT>
 				Thread.currentThread().interrupt();
 			}
 
-			/**
+			/*
 			 * FLINK-5638: If we have the checkpoint lock we might have to free it for a while so
 			 * that the emitter thread can complete/react to the interrupt signal.
 			 */
@@ -387,8 +387,8 @@ public class AsyncWaitOperator<IN, OUT>
 	/**
 	 * Add the given stream element queue entry to the operator's stream element queue. This
 	 * operation blocks until the element has been added.
-	 * <p>
-	 * For that it tries to put the element into the queue and if not successful then it waits on
+	 *
+	 * <p>For that it tries to put the element into the queue and if not successful then it waits on
 	 * the checkpointing lock. The checkpointing lock is also used by the {@link Emitter} to output
 	 * elements. The emitter is also responsible for notifying this method if the queue has capacity
 	 * left again, by calling notifyAll on the checkpointing lock.


Mime
View raw message