Skip to content

Commit 27162f8

Browse files
committed
per suggestion
1 parent 1a991b8 commit 27162f8

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

docs/content/docs/dev/python/table/udfs/python_udfs.md

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,10 +30,6 @@ User-defined functions are important features, because they significantly extend
3030

3131
**NOTE:** Python UDF execution requires Python version (3.6, 3.7 or 3.8) with PyFlink installed. It's required on both the client side and the cluster side.
3232

33-
## Bundling UDFs
34-
35-
To run Python UDFs (as well as Pandas UDFs) in any non-local mode, it is strongly recommended to bundle your Python UDF definitions using the config option [`python-files`]({{< ref "docs/dev/python/python_config" >}}#python-files), if your Python UDFs live outside of the file where the `main()` function is defined. Otherwise, you may run into `ModuleNotFoundError: No module named 'my_udf'` if you define Python UDFs in a file called `my_udf.py`.
36-
3733
## Scalar Functions
3834

3935
It supports to use Python scalar functions in Python Table API programs. In order to define a Python scalar function,
@@ -557,3 +553,7 @@ class ListViewConcatTableAggregateFunction(TableAggregateFunction):
557553
def get_result_type(self):
558554
return DataTypes.ROW([DataTypes.FIELD("a", DataTypes.STRING())])
559555
```
556+
557+
## Bundling UDFs
558+
559+
To run Python UDFs (as well as Pandas UDFs) in any non-local mode, it is strongly recommended to bundle your Python UDF definitions using the config option [`python-files`]({{< ref "docs/dev/python/python_config" >}}#python-files), if your Python UDFs live outside of the file where the `main()` function is defined. Otherwise, you may run into `ModuleNotFoundError: No module named 'my_udf'` if you define Python UDFs in a file called `my_udf.py`.

0 commit comments

Comments
 (0)