GitHub user bowenli86 opened a pull request: https://github.com/apache/flink/pull/4899
[FLINK-5967][DataStream API][Doc] Add RuntimeContext#getAggregatingState() and document AggregatingState ## What is the purpose of the change Add `RuntimeContext#getAggregatingState()` and document `AggregatingState` ## Brief change log - Added `RuntimeContext#getAggregatingState()` and its implementations - Added necessary unit tests - Documented `AggregatingState` ## Verifying this change Added new unit tests in `StreamingRuntimeContextTest.java` and `RichAsyncFunctionTest.java` ## Does this pull request potentially affect one of the following parts: - The public API, i.e., is any changed class annotated with `@Public(Evolving)` ## Documentation - Does this pull request introduce a new feature? (yes) - If yes, how is the feature documented? (docs / JavaDocs) You can merge this pull request into a Git repository by running: $ git pull https://github.com/bowenli86/flink FLINK-5967 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/flink/pull/4899.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #4899 ---- commit 50072e39bb7a81c86c51e2e897ee0e0eac606f1d Author: Bowen Li <bowenl...@gmail.com> Date: 2017-10-23T02:43:51Z [FLINK-5967] Document AggregatingState commit 6f59f82802161235e79349b8ebc15aefa9c18d8a Author: Bowen Li <bowenl...@gmail.com> Date: 2017-10-23T07:58:14Z add docs of AggregatingState commit 24a9ccbab04b299bb6b363d3619b3562f3cf2be9 Author: Bowen Li <bowenl...@gmail.com> Date: 2017-10-25T03:33:43Z add tests commit 1094b7f50ac18cab75a84fb25bb4af6202a1cfea Author: Bowen Li <bowenl...@gmail.com> Date: 2017-10-25T04:52:55Z remove unused import ---- ---