You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/02/17 16:24:14 UTC
[4/8] flink git commit: [hotfix] Fix trailing whitespace in
WindowedStream.java
[hotfix] Fix trailing whitespace in WindowedStream.java
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/82db667d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/82db667d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/82db667d
Branch: refs/heads/master
Commit: 82db667d319778f30244e9c4212bf3a2920f604f
Parents: 09fe4b0
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Tue Feb 7 10:54:54 2017 +0100
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Fri Feb 17 17:15:51 2017 +0100
----------------------------------------------------------------------
.../api/datastream/WindowedStream.java | 34 ++++++++++----------
1 file changed, 17 insertions(+), 17 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/82db667d/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
index 3fbdda8..04da04d 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/datastream/WindowedStream.java
@@ -89,7 +89,7 @@ import static org.apache.flink.util.Preconditions.checkNotNull;
* Note that the {@code WindowedStream} is purely and API construct, during runtime
* the {@code WindowedStream} will be collapsed together with the
* {@code KeyedStream} and the operation over the window into one single operation.
- *
+ *
* @param <T> The type of elements in the stream.
* @param <K> The type of the key by which elements are grouped.
* @param <W> The type of {@code Window} that the {@code WindowAssigner} assigns the elements to.
@@ -190,9 +190,9 @@ public class WindowedStream<T, K, W extends Window> {
* so a few elements are stored per key (one per slide interval).
* Custom windows may not be able to incrementally aggregate, or may need to store extra values
* in an aggregation tree.
- *
+ *
* @param function The reduce function.
- * @return The data stream that is the result of applying the reduce function to the window.
+ * @return The data stream that is the result of applying the reduce function to the window.
*/
@SuppressWarnings("unchecked")
public SingleOutputStreamOperator<T> reduce(ReduceFunction<T> function) {
@@ -521,10 +521,10 @@ public class WindowedStream<T, K, W extends Window> {
*
* @param function The aggregation function.
* @return The data stream that is the result of applying the fold function to the window.
- *
+ *
* @param <ACC> The type of the AggregateFunction's accumulator
* @param <R> The type of the elements in the resulting stream, equal to the
- * AggregateFunction's result type
+ * AggregateFunction's result type
*/
public <ACC, R> SingleOutputStreamOperator<R> aggregate(AggregateFunction<T, ACC, R> function) {
checkNotNull(function, "function");
@@ -549,10 +549,10 @@ public class WindowedStream<T, K, W extends Window> {
*
* @param function The aggregation function.
* @return The data stream that is the result of applying the aggregation function to the window.
- *
+ *
* @param <ACC> The type of the AggregateFunction's accumulator
* @param <R> The type of the elements in the resulting stream, equal to the
- * AggregateFunction's result type
+ * AggregateFunction's result type
*/
public <ACC, R> SingleOutputStreamOperator<R> aggregate(
AggregateFunction<T, ACC, R> function,
@@ -581,11 +581,11 @@ public class WindowedStream<T, K, W extends Window> {
*
* @param aggFunction The aggregate function that is used for incremental aggregation.
* @param windowFunction The window function.
- *
+ *
* @return The data stream that is the result of applying the window function to the window.
- *
+ *
* @param <ACC> The type of the AggregateFunction's accumulator
- * @param <V> The type of AggregateFunction's result, and the WindowFunction's input
+ * @param <V> The type of AggregateFunction's result, and the WindowFunction's input
* @param <R> The type of the elements in the resulting stream, equal to the
* WindowFunction's result type
*/
@@ -620,17 +620,17 @@ public class WindowedStream<T, K, W extends Window> {
* @param windowFunction The window function.
* @param accumulatorType Type information for the internal accumulator type of the aggregation function
* @param resultType Type information for the result type of the window function
- *
+ *
* @return The data stream that is the result of applying the window function to the window.
- *
+ *
* @param <ACC> The type of the AggregateFunction's accumulator
- * @param <V> The type of AggregateFunction's result, and the WindowFunction's input
+ * @param <V> The type of AggregateFunction's result, and the WindowFunction's input
* @param <R> The type of the elements in the resulting stream, equal to the
* WindowFunction's result type
*/
public <ACC, V, R> SingleOutputStreamOperator<R> aggregate(
AggregateFunction<T, ACC, V> aggregateFunction,
- WindowFunction<V, R, K, W> windowFunction,
+ WindowFunction<V, R, K, W> windowFunction,
TypeInformation<ACC> accumulatorType,
TypeInformation<V> aggregateResultType,
TypeInformation<R> resultType) {
@@ -699,7 +699,7 @@ public class WindowedStream<T, K, W extends Window> {
// ------------------------------------------------------------------------
// Window Function (apply)
// ------------------------------------------------------------------------
-
+
/**
* Applies the given window function to each window. The window function is called for each
* evaluation of the window for each key individually. The output of the window function is
@@ -708,7 +708,7 @@ public class WindowedStream<T, K, W extends Window> {
* <p>
* Not that this function requires that all data in the windows is buffered until the window
* is evaluated, as the function provides no means of incremental aggregation.
- *
+ *
* @param function The window function.
* @return The data stream that is the result of applying the window function to the window.
*/
@@ -1229,7 +1229,7 @@ public class WindowedStream<T, K, W extends Window> {
@SuppressWarnings("unchecked")
OneInputStreamOperator<T, R> op = (OneInputStreamOperator<T, R>)
new AggregatingProcessingTimeWindowOperator<>(
- reducer, input.getKeySelector(),
+ reducer, input.getKeySelector(),
input.getKeyType().createSerializer(getExecutionEnvironment().getConfig()),
input.getType().createSerializer(getExecutionEnvironment().getConfig()),
windowLength, windowSlide);