[FLINK-19185] Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139)

• Type: New Feature
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: API / Python
• Assignee: Wei Zhong
• Reporter: Wei Zhong
• Created: 10/Sep/20 07:47
• Updated: 08/Apr/21 11:26
• Resolved: 08/Apr/21 11:26

Issue Links

• mentioned in: Page Loading...
• mentioned in: Page Loading...

Sub-Tasks

• Introduce the PythonStreamGroupAggregateOperator for Python UDAF: Closed
• Support ListState and ListView for Python UDAF: Closed
• Support MapState and MapView for Python UDAF: Closed
• Support DISTINCT KeyWord for Python UDAF: Closed
• Support FILTER KeyWord for Python UDAF: Closed
• Support mixed use with built-in aggs for Python UDAF: Closed
• Optimize the performance of Python UDAF: Closed
• Support Python UDAF in streaming mode: Closed
• Add documentation for Python UDAF: Closed
• Introduce PythonStreamGroupWindowAggregateOperator: Resolved
• Add support for general python group window aggregate function in Physical Rule and Node: Resolved
• Introduce TimeWindow and CountWindow in PyFlink: Resolved
• Support Python UDAF in Tumbling Window: Resolved
• Support Python UDAF in Sliding Window: Resolved
• Support Python UDAF in Session Window: Resolved
• Add CountTrigger for Python group window aggregation: Closed