flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timo Walther (JIRA)" <j...@apache.org>
Subject [jira] [Resolved] (FLINK-4244) Field names for union operator do not have to be equal
Date Mon, 25 Jul 2016 13:50:20 GMT

     [ https://issues.apache.org/jira/browse/FLINK-4244?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Timo Walther resolved FLINK-4244.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 1.1.0

Fixed in 588830aaaa9470bf36a0c9011fe07d1a9c48368f.

> Field names for union operator do not have to be equal
> ------------------------------------------------------
>
>                 Key: FLINK-4244
>                 URL: https://issues.apache.org/jira/browse/FLINK-4244
>             Project: Flink
>          Issue Type: Improvement
>          Components: Table API & SQL
>    Affects Versions: 1.1.0
>            Reporter: Till Rohrmann
>            Assignee: Jark Wu
>            Priority: Trivial
>             Fix For: 1.1.0
>
>
> Flink Table API's documentation says that the schemas of unioned tables have to be identical
(wrt types and names). However, union works also with tables where the types are identical
but not the names:
> {code}
> val input1Seq = 0 until 10 map {x => (x, ('a' + x).toChar.toString, x.toDouble)}
>     val input2Seq = 0 until 10 map {x => (x, ('a' + x).toChar.toString, x.toDouble)}
>     val inputDS1 = env.fromCollection(input1Seq)
>     val inputDS2 = env.fromCollection(input2Seq)
>     val input1 = tblEnv.fromDataSet(inputDS1, 'a, 'b, 'c)
>     tblEnv.registerTable("foobar", input1)
>     val input2 = tblEnv.fromDataSet(inputDS2, 'd, 'e, 'f)
>     tblEnv.registerTable("foobar2", input2)
>     val result = tblEnv.sql("SELECT * FROM foobar UNION ALL SELECT * FROM foobar2")
>     tblEnv.toDataSet[Row](result).print()
> {code}
> We should update the documentation accordingly.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message