[FLINK-24547] A function named row_kind() can get row_kind

• Type: New Feature
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Fix Version/s: 1.20.0
• Component/s: Table SQL / Planner
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: jocean.shi
• Created: 14/Oct/21 12:09
• Updated: 11/Mar/24 12:44

Description

Add a function can get row_kind. In many case we need cdc data rowKind, such as agg rowKind or filter some rowKind data, the function return "+I","-U","+U","-D",

you can use this function as "select row_kind() as op from xxx".

Issue Links

• links to: GitHub Pull Request #17483