[FLINK-29189] Pass KeyValue to MergeFunction

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: table-store-0.3.0
• Component/s: Table Store
• Labels: pull-request-available
• Assignee: Jingsong Lee
• Reporter: Jingsong Lee
• Created: 05/Sep/22 09:04
• Updated: 06/Sep/22 05:24
• Resolved: 06/Sep/22 05:24

Description

We should pass KeyValue to MergeFunction, give MergeFunction more capabilities, such as throwing an exception when it sees an unreasonable RowKind.

Issue Links

• is related to: FLINK-27626 Introduce pre-aggregated merge to table store
• links to: GitHub Pull Request #286