Xiqian Yu created FLINK-40409:
---------------------------------
Summary: Introduce inline Python UDF definition in YAML pipeline
Key: FLINK-40409
URL: https://issues.apache.org/jira/browse/FLINK-40409
Project: Flink
Issue Type: New Feature
Components: Flink CDC
Reporter: Xiqian Yu
Assignee: Xiqian Yu
Fix For: cdc-3.7.0
It is suggested to introduce inline Python UDF definitions in YAML pipeline
jobs:
transform:
- source-table: db.usersprojection: ID, py_normalize(EMAIL) AS EMAIL_NORM,
py_double(AGE) AS DOUBLEDpipeline: user-defined-function:
- name: py_normalizepython-code: | def eval(value: str) -> str:
return value.strip().lower()python-executable: /usr/bin/python3 -
name: py_doublepython-code: | def eval(value: int) -> int:
return value * 2
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
