This is an automated email from the ASF dual-hosted git repository. sewen pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit a55dc42e6762e3e74ed36129a9dd6fc4c51f646f Author: David Anderson <[email protected]> AuthorDate: Fri Aug 23 10:29:23 2019 +0200 [hotfix][docs] Correct method name in KeyedStateReaderFunction example This closes #9520 --- docs/dev/libs/state_processor_api.md | 2 +- docs/dev/libs/state_processor_api.zh.md | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/docs/dev/libs/state_processor_api.md b/docs/dev/libs/state_processor_api.md index 676ac49..75a6f12 100644 --- a/docs/dev/libs/state_processor_api.md +++ b/docs/dev/libs/state_processor_api.md @@ -290,7 +290,7 @@ class ReaderFunction extends KeyedStateReaderFunction<Integer, KeyedState> { } @Override - public void processKey( + public void readKey( Integer key, Context ctx, Collector<KeyedState> out) throws Exception { diff --git a/docs/dev/libs/state_processor_api.zh.md b/docs/dev/libs/state_processor_api.zh.md index 676ac49..75a6f12 100644 --- a/docs/dev/libs/state_processor_api.zh.md +++ b/docs/dev/libs/state_processor_api.zh.md @@ -290,7 +290,7 @@ class ReaderFunction extends KeyedStateReaderFunction<Integer, KeyedState> { } @Override - public void processKey( + public void readKey( Integer key, Context ctx, Collector<KeyedState> out) throws Exception {
