Gustavo de Morais created FLINK-39636:
-----------------------------------------
Summary: Add "produces_full_deletes" parameter in TO_CHANGELOG
Key: FLINK-39636
URL: https://issues.apache.org/jira/browse/FLINK-39636
Project: Flink
Issue Type: Sub-task
Components: Table SQL / API
Reporter: Gustavo de Morais
We currently always require full deletes in TO_CHANGELOG by using the PTF trait
"StaticArgumentTrait.REQUIRE_FULL_DELETE". That means, if we have a source
containing partial deletes (as kafka does) we'll add a ChangelogNormalize to
the pipeline to build full delete events out of partial deletes.
By adding the produces_full_deletes param, we can make this trait conditional
and check and only require full deletes if we have to produce full deletes.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
