[
https://issues.apache.org/jira/browse/FLINK-8400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Hequn Cheng updated FLINK-8400:
-------------------------------
Description:
{{UniqueKeyExtractor}} will return a tuple, the first element is the name of a
key field, the second is a group name that is shared by all equivalent key
fields. The group names are used to identify same keys, for example: select('pk
as pk1, 'pk as pk2), both pk1 and pk2 belong to the same group, i.e., pk1. Here
we use the lexicographic smallest attribute as the common group id.
Currently, DataStreamCalc
was:{{UniqueKeyExtractor}} will return a tuple, the first element is the name
of a key field, the second is a group name that is shared by all equivalent key
fields. The group names are used to identify same keys, for example: select('pk
as pk1, 'pk as pk2), both pk1 and pk2 belong to the same group, i.e., pk1. Here
we use the lexicographic smallest attribute as the common group id.
> Use the lexicographic smallest attribute as the common group id when extract
> unique key
> ---------------------------------------------------------------------------------------
>
> Key: FLINK-8400
> URL: https://issues.apache.org/jira/browse/FLINK-8400
> Project: Flink
> Issue Type: Bug
> Components: Table API & SQL
> Reporter: Hequn Cheng
>
> {{UniqueKeyExtractor}} will return a tuple, the first element is the name of
> a key field, the second is a group name that is shared by all equivalent key
> fields. The group names are used to identify same keys, for example:
> select('pk as pk1, 'pk as pk2), both pk1 and pk2 belong to the same group,
> i.e., pk1. Here we use the lexicographic smallest attribute as the common
> group id.
> Currently, DataStreamCalc
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
