[
https://issues.apache.org/jira/browse/FLINK-39576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gustavo de Morais closed FLINK-39576.
-------------------------------------
Resolution: Won't Fix
My goal was to make this not impact the metadata that comes out the of PTFs but
this is not easily possible - partition keys, unique keys and upsert keys. We
need these metadata to be preserved and it's better to keep this specific ptf
change out of scope from this init. Thus I'm closing this and we'll move
forward with the schema changes while preserving the partition by columns with
the help of the ptf framework, which pre appends them at the beginning.
> Add new PTF StaticArgumentTrait#NO_PASS_THROUGH
> ------------------------------------------------
>
> Key: FLINK-39576
> URL: https://issues.apache.org/jira/browse/FLINK-39576
> Project: Flink
> Issue Type: Sub-task
> Components: Table SQL / API
> Reporter: Gustavo de Morais
> Assignee: Gustavo de Morais
> Priority: Major
> Labels: pull-request-available
>
> Add ArgumentTrait.NO_PASS_THROUGH so users can declare it on PTF arguments
> alongside PASS_COLUMNS_THROUGH. With this trait the framework adds neither
> the PARTITION BY columns nor the rowtime suffix to the output, leaving the
> schema fully
> under the function's control.
>
> - New ArgumentTrait.NO_PASS_THROUGH constant with full javadoc and warning
> about the user's responsibility to forward partition keys and watermarked
> timestamps.
> - Cross-reference and mutual-exclusion note on PASS_COLUMNS_THROUGH.
> - Documentation in docs/.../ptfs.md (en + zh).
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
