Gustavo de Morais created FLINK-39574:
-----------------------------------------
Summary: Support TO_CHANGELOG retract stream to retract stream
with set semantics
Key: FLINK-39574
URL: https://issues.apache.org/jira/browse/FLINK-39574
Project: Flink
Issue Type: Improvement
Components: Table SQL / API
Reporter: Gustavo de Morais
Assignee: Gustavo de Morais
Adds PARTITION BY support for TO_CHANGELOG (set semantics).
Introduces PassThroughMode \{ KEY, ALL, NONE } as a per-argument enum on
StaticArgument, derived from traits (new NO_PASS_THROUGH → NONE,
PASS_COLUMNS_THROUGH → ALL, default → KEY). Type inference and the runtime now
dispatch per-arg on the same enum; the rowtime suffix remains a function-wide
decision (suppressed when any arg uses NONE)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
