[jira] [Created] (FLINK-39538) Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG

["Ramin Gharib (Jira)" <ji...@apache.org>]

Ramin Gharib created FLINK-39538:
------------------------------------

             Summary: Apply conditional SET_SEMANTIC_TABLE trait to FROM_CHANGELOG
                 Key: FLINK-39538
                 URL: https://issues.apache.org/jira/browse/FLINK-39538
             Project: Flink
          Issue Type: Sub-task
          Components: Table SQL / Planner
            Reporter: Ramin Gharib


FROM_CHANGELOG used to be locked to row semantics. With the conditional trait API introduced for TO_CHANGELOG, the input argument now switches to set semantics when the call provides PARTITION BY:                                                               
{code:java}
SELECT * FROM FROM_CHANGELOG(
 input => TABLE cdc_stream PARTITION BY id         
){code}
The planner inserts an Exchange(hash[id]) so rows with the same key are co-located in the same parallel operator instance. Without PARTITION BY, behavior is unchanged: each row is processed independently with row semantics.                                                                                                                        
The runtime function is unaffected — only the trait declaration and the resulting parallel execution layout change. 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)