[FLINK-20479] Support Row-based Operations in Python Table API

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Implemented
• Fix Version/s: 1.13.0
• Component/s: API / Python
• Assignee: Huang Xingbo
• Reporter: Huang Xingbo
• Created: 04/Dec/20 07:17
• Updated: 15/Apr/21 12:40
• Resolved: 15/Apr/21 12:40

Description

We have support for Row-based Operations in Java, and the aim of this JIRA is to provide this feature in Python.

Issue Links

• mentioned in: Page Loading...

Sub-Tasks

• Support General Python UDF for Map Operation in Python Table API: Closed
• Support Pandas UDF for Map Operation in Python Table API: Closed
• Support FlatMap Operation in Python Table API: Closed
• Support aggregate operation in Python Table API: Closed
• Introduce PythonStreamGroupTableAggregateOperator: Closed
• Introduce StreamExecPythonGroupTableAggregateRule and StreamExecPythonGroupTableAggregate: Closed
• Add Python building blocks to make sure the basic functionality of Stream Group Table Aggregation could work: Closed
• Support row-based operation to accept user-defined function directly: Closed
• Support map operation chained together in Python Table API: Closed
• Support join_lateral/left_outer_join_lateral to accept table function directly in Python Table API: Closed
• Add documentation for row-based operation in Python Table API: Closed