[FLINK-34060] Migrate UserDefinedTableAggFunctions to JavaUserDefinedTableAggFunctions

• Type: Technical Debt
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.19.0
• Component/s: Table SQL / Runtime
• Labels: pull-request-available
• Assignee: xuyang
• Reporter: Jane Chan
• Created: 11/Jan/24 09:30
• Updated: 08/Feb/24 03:47

Description

The issue is discovered when testing FLINK-31788.

The Top3 function emits a tuple of (entry.getKey, entry.getKey) see UserDefinedTableAggFunctions.scala#L127, which is peculiar.

Meanwhile, consider getting the scala-free goal; it's time to migrate this class to the `JavaUserDefinedTableAggFunctions`, and revisit the implementation.

Issue Links

• is related to: FLINK-31788 Add back Support emitValueWithRetract for TableAggregateFunction
• links to: GitHub Pull Request #24289