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)
