[FLINK-21223] Support to specify the input/output types of Python UDFs via string

• Type: Improvement
• Status: Closed
• Priority: Not a Priority
• Resolution: Done
• Fix Version/s: 1.17.0
• Component/s: API / Python
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned pull-request-available
• Assignee: Huang Xingbo
• Reporter: Dian Fu
• Created: 01/Feb/21 07:20
• Updated: 12/Dec/22 03:26
• Resolved: 12/Dec/22 03:26

Description

Currently, users need to specify the input/output types as following:

{{@udf(result_type=DataTypes.BIGINT())
def add(i, j):
   return i + j
}}

FLIP-65 makes it possible to support syntaxes as following:

{{@udf(result_type="BIGINT")
def add(i, j):
   return i + j
}}

Issue Links

• links to: GitHub Pull Request #21332