Bulk Operation

FLINK-14013 Support to run Python UDF jobs in a YARN cluster

FLINK-14013 Improve the README.md in pyflink to prepare for PyPI release

FLINK-14013 Improve the release script for Python API release package

FLINK-14013 Support all the data types in Python user-defined functions

FLINK-14013 Remove method FunctionDefinition#getLanguage

FLINK-14013 Support Blink planner for Python UDF

FLINK-14013 Support Python UDFs without arguments

FLINK-14013 Optimize Python UDFs with parameters of constant values

FLINK-14013 Optimize the execution plan for Python Calc when there is a condition

FLINK-14013 Add documentation for Python user-defined functions

FLINK-14013 Manage the resource of Python worker properly

FLINK-14013 Add validation check for places where Python ScalarFunction cannot be used

FLINK-14013 Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node

FLINK-14013 Python environment and dependency management

FLINK-14013 Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

FLINK-14013 Support to start up Python worker in process mode

FLINK-14013 Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

FLINK-14013 Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

FLINK-14013 Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution