[
https://issues.apache.org/jira/browse/FLINK-40260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40260:
-----------------------------------
Labels: pull-request-available (was: )
> Support Python PTF definition API and the stateless runtime path
> ----------------------------------------------------------------
>
> Key: FLINK-40260
> URL: https://issues.apache.org/jira/browse/FLINK-40260
> Project: Flink
> Issue Type: Sub-task
> Reporter: Chengyu Wang
> Priority: Major
> Labels: pull-request-available
>
> Introduce the Python-side ProcessTableFunction so users can define a PTF and
> run
> it end-to-end for the stateless case, aligned with the Java PTF (FLINK-36703 /
> FLIP-440).
> Scope:
> * Python API: ProcessTableFunction base class, udptf(),
> ProcessTableFunctionArgument
> (table/scalar) and result_type declaration.
> * Java placeholder function and TypeInference wiring so the existing Java PTF
> planner can be reused.
> * Allow PyFlink to call already-registered Java PTFs (including multi-table
> ones).
> * Stateless vertical runtime path: PTF proto, Beam runner, Python worker,
> operator, and 0..N ROW output.
> Depends on: umbrella FLINK-40251.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
