Dian Fu created FLINK-14015:
-------------------------------
Summary: Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution
Key: FLINK-14015
URL:
https://issues.apache.org/jira/browse/FLINK-14015 Project: Flink
Issue Type: Sub-task
Components: API / Python
Reporter: Dian Fu
Fix For: 1.10.0
PythonScalarFunctionOperator is a standalone StreamOperator and it doesn’t need to how the Python ScalarFunctions are executed which is the responsibility of PythonScalarFunctionRunner:
# It is a StreamOperator which employs PythonScalarFunctionRunner for Python ScalarFunction execution
# It sends input elements to PythonScalarFunctionRunner, fetches the execution results, constructs the result rows and sends them to the downstream operator
# It should handle the checkpoint and watermark properly
--
This message was sent by Atlassian Jira
(v8.3.2#803003)