Ramin Gharib created FLINK-39430:
------------------------------------
Summary: Add `invalid_op_handling` parameter to FROM_CHANGELOG PTF
Key: FLINK-39430
URL: https://issues.apache.org/jira/browse/FLINK-39430
Project: Flink
Issue Type: Sub-task
Components: Table SQL / API
Reporter: Ramin Gharib
Add an `invalid_op_handling` parameter to the `FROM_CHANGELOG` built-in process
table function as specified in FLIP-564.
Currently, when FROM_CHANGELOG encounters an operation code in the input that
is not present in the `op_mapping`, the row is silently dropped. The
`invalid_op_handling` parameter would allow users to control this behavior with
three modes:
- **`FAIL`** — throw an exception when an unmapped operation code is
encountered (strict mode)
- **`LOG`** — log a warning and drop the row
- **`SKIP`** — silently drop the row (current default behavior)
### Example
```sql
SELECT * FROM FROM_CHANGELOG(
input => TABLE cdc_stream,
op => DESCRIPTOR(__op),
op_mapping => MAP['c, r', 'INSERT', 'u', 'UPDATE_AFTER', 'd', 'DELETE'],
invalid_op_handling => 'FAIL'
)
```
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
