You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Xiqian Yu (Jira)" <ji...@apache.org> on 2026/08/18 09:03:00 UTC

[jira] [Created] (FLINK-40409) Introduce inline Python UDF definition in YAML pipeline

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)