[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/4c46af1b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4c46af1b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4c46af1b Branch: refs/heads/master Commit: 4c46af1b4be4c973e383091ae5ba191a0d52a30d Parents: f190f5b Author: Florian Schmidt <[email protected]> Authored: Tue Mar 13 16:54:06 2018 +0100 Committer: zentol <[email protected]> Committed: Wed Mar 14 20:46:23 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/4c46af1b/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.
