[
https://issues.apache.org/jira/browse/FLINK-39349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-39349:
-----------------------------------
Labels: pull-request-available (was: )
> Support TO_CHANGELOG retract/upsert stream to upsert stream with deletion
> flag (4.2.2.1)
> ----------------------------------------------------------------------------------------
>
> Key: FLINK-39349
> URL: https://issues.apache.org/jira/browse/FLINK-39349
> Project: Flink
> Issue Type: New Feature
> Components: Table SQL / API
> Reporter: Gustavo de Morais
> Priority: Major
> Labels: pull-request-available
>
> Support the use case where a deletion flag is used, as described in [4.2.2.1
> Retract/upsert stream to upsert stream (with deletion
> flag)|https://cwiki.apache.org/confluence/display/FLINK/FLIP-564%3A+Support+FROM_CHANGELOG+and+TO_CHANGELOG+built-in+PTFs#4221-retractupsert-stream-to-upsert-stream-with-deletion-flag]
> Allows comma-separated RowKind names as keys in op_mapping, so multiple
> RowKinds can map to the same output code. This enables the Kafka
> Connect-style deletion flag pattern where inserts/updates produce 'false' and
> deletes
> produce 'true':
>
>
>
>
>
>
>
> SELECT * FROM TO_CHANGELOG(
>
>
>
> input => TABLE t PARTITION BY id,
>
>
>
> op => DESCRIPTOR(deleted),
>
>
>
> op_mapping => MAP['INSERT, UPDATE_AFTER', 'false', 'DELETE', 'true']
>
>
>
> )
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
