[FLINK-14015] Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Resolved
• Fix Version/s: 1.10.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Dian Fu
• Created: 09/Sep/19 13:22
• Updated: 23/Sep/19 12:13
• Resolved: 23/Sep/19 12:13

Description

PythonScalarFunctionOperator is a standalone StreamOperator and it doesn’t need to how the Python ScalarFunctions are executed which is the responsibility of PythonScalarFunctionRunner:

1. It is a StreamOperator which employs PythonScalarFunctionRunner for Python ScalarFunction execution
2. It sends input elements to PythonScalarFunctionRunner, fetches the execution results, constructs the result rows and sends them to the downstream operator
3. It should handle the checkpoint and watermark properly

Issue Links

• links to: GitHub Pull Request #9707