Repository: flink Updated Branches: refs/heads/release-1.5 ed04f9c48 -> 9b1b7f385
[hotfix][docs][py] Fix class name in example This closes #5692. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/74e64417 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/74e64417 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/74e64417 Branch: refs/heads/release-1.5 Commit: 74e6441719d77c1c9bab49a6c63711dc57e8c1fc Parents: 3ad2489 Author: Florian Schmidt <[email protected]> Authored: Tue Mar 13 16:54:06 2018 +0100 Committer: zentol <[email protected]> Committed: Wed Mar 14 20:47:27 2018 +0100 ---------------------------------------------------------------------- docs/dev/stream/python.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/74e64417/docs/dev/stream/python.md ---------------------------------------------------------------------- diff --git a/docs/dev/stream/python.md b/docs/dev/stream/python.md index a533819..887d983 100644 --- a/docs/dev/stream/python.md +++ b/docs/dev/stream/python.md @@ -464,7 +464,7 @@ Rich functions (.e.g `RichFilterFunction`) enable to define (override) the optio The user may use these functions for initialization and cleanups. {% highlight python %} -class Tockenizer(RichMapFunction): +class Tokenizer(RichMapFunction): def open(self, config): pass def close(self): @@ -472,7 +472,7 @@ class Tockenizer(RichMapFunction): def map(self, value): pass -data_stream.map(Tockenizer()) +data_stream.map(Tokenizer()) {% endhighlight %} The `open` function is called by the worker before starting the streaming pipeline.
