You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Gustavo de Morais (Jira)" <ji...@apache.org> on 2026/04/08 09:54:00 UTC
[jira] [Updated] (FLINK-39349) Support TO_CHANGELOG retract/upsert stream to upsert stream with deletion flag (4.2.2.1)
[ https://issues.apache.org/jira/browse/FLINK-39349?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Gustavo de Morais updated FLINK-39349:
--------------------------------------
Parent: FLINK-39258
Issue Type: Sub-task (was: New Feature)
> 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: Sub-task
> Components: Table SQL / API
> Reporter: Gustavo de Morais
> Assignee: Gustavo de Morais
> Priority: Major
> Labels: pull-request-available
> Fix For: 2.3.0
>
>
> 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)