Skip to content

Commit

Permalink
[hotfix][docs][py] Fix class name in example
Browse files Browse the repository at this point in the history
This closes apache#5692.
  • Loading branch information
florianschmidt1994 authored and zentol committed Mar 14, 2018
1 parent f190f5b commit 4c46af1
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions docs/dev/stream/python.md
Original file line number Diff line number Diff line change
Expand Up @@ -464,15 +464,15 @@ 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):
pass
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.
Expand Down

0 comments on commit 4c46af1

Please sign in to comment.