[FLINK-20467][python][docs] Fix the example in Python DataStream API …

…documentation This closes apache#14297.
derekm · Dec 3, 2020 · a411abf · a411abf
1 parent c1b96de
commit a411abf
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/docs/dev/python/datastream-api-users-guide/operators.md b/docs/dev/python/datastream-api-users-guide/operators.md
@@ -49,7 +49,7 @@ instance:
 # Implementing MapFunction
 class MyMapFunction(MapFunction):
 
- def map(value):
+ def map(self, value):
  return value + 1
 
 data_stream = env.from_collection([1, 2, 3, 4, 5], type_info=Types.INT())

diff --git a/docs/dev/python/datastream-api-users-guide/operators.zh.md b/docs/dev/python/datastream-api-users-guide/operators.zh.md
@@ -46,7 +46,7 @@ Python DataStream API 给各种算子提供了函数接口，用户可以定义
 # Implementing MapFunction
 class MyMapFunction(MapFunction):
 
- def map(value):
+ def map(self, value):
  return value + 1
 
 data_stream = env.from_collection([1, 2, 3, 4, 5], type_info=Types.INT())