Skip to content

Commit

Permalink
[hotfix] Fix typo in WindowedStream.
Browse files Browse the repository at this point in the history
This closes apache#6825.
  • Loading branch information
link3280 authored and StefanRRichter committed Oct 11, 2018
1 parent 86f88f7 commit feb01b5
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -1011,7 +1011,7 @@ public <ACC, V, R> SingleOutputStreamOperator<R> aggregate(
* evaluation of the window for each key individually. The output of the window function is
* interpreted as a regular non-windowed stream.
*
* <p>Not that this function requires that all data in the windows is buffered until the window
* <p>Note 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.
Expand Down Expand Up @@ -1045,7 +1045,7 @@ public <R> SingleOutputStreamOperator<R> apply(WindowFunction<T, R, K, W> functi
* evaluation of the window for each key individually. The output of the window function is
* interpreted as a regular non-windowed stream.
*
* <p>Not that this function requires that all data in the windows is buffered until the window
* <p>Note 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.
Expand All @@ -1063,7 +1063,7 @@ public <R> SingleOutputStreamOperator<R> process(ProcessWindowFunction<T, R, K,
* evaluation of the window for each key individually. The output of the window function is
* interpreted as a regular non-windowed stream.
*
* <p>Not that this function requires that all data in the windows is buffered until the window
* <p>Note 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.
Expand Down

0 comments on commit feb01b5

Please sign in to comment.