You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2019/08/26 08:24:11 UTC
[flink] 01/10: [hotfix][docs] Correct method name in
KeyedStateReaderFunction example
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 <da...@alpinegizmo.com>
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 {