[
https://issues.apache.org/jira/browse/FLINK-41343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ramin Gharib reassigned FLINK-41343:
------------------------------------
Assignee: Ramin Gharib
> Add Variant#normalize() and VARIANT_NORMALIZE
> ---------------------------------------------
>
> Key: FLINK-41343
> URL: https://issues.apache.org/jira/browse/FLINK-41343
> Project: Flink
> Issue Type: Sub-task
> Components: API / Core, Table SQL / API
> Reporter: Ramin Gharib
> Assignee: Ramin Gharib
> Priority: Major
>
> {code:sql}
> VARIANT_NORMALIZE(variant) -- VARIANT
> VARIANT_NORMALIZE(VARIANT_DELETE(v, '$.user.email'))
> --
> {"coupon":null,"items":[{"qty":2,"sku":"A1"}],"order_id":17,"user":{"name":"ada"}},
> with email gone from the metadata too
> {code}
> Scope:
> * Rewrites the value in one standard layout: the keys of each object in
> order, and only the field names in use, in a sorted list.
> * Values and their stored types stay the same, so VARIANT_TYPE gives the same
> answer.
> * If an object has a key twice, the first one is kept.
> * A value already in that layout comes back unchanged. The check reads only
> the object headers.
> * SQL NULL gives NULL.
> * The Java method Variant#normalize() and unit tests for it.
> VARIANT_NORMALIZE calls it.
> * Table API and PyFlink expressions, SQL and Table API tests, docs.
> Depends on FLINK-41338
--
This message was sent by Atlassian Jira
(v10.3.26#10030026)
