Hi Dongwon,
AFAIK, Flink doesn't support the usage like "myscalar(col1, col2, col3) as
(col4, col5)". Am I missing something?
If you want to split Tuple2 into two different columns, you can use UDTF.
Best,
Kurt
On Wed, Mar 20, 2019 at 9:59 AM Dongwon Kim <eastcirc...@gmail.com> wrote:
> Hi,
>
> I want to split Tuple2 returned by AggregateFunction.getValue into two
> different columns in a resultant table.
>
> Let's consider the following example where myudaf returns Tuple2<Boolean,
> Boolean>:
>
> Table table2 = table1
> .window(Slide.over("3.rows").every("1.rows").on("time").as("w"))
> .groupBy("w, name")
> .select("name, myudaf(col1, col2, col3) as (col4, col5)")
>
> Then table2.printSchema() returns (w/ Flink 1.7.2)
>
> root
> |-- name: String
> |-- col4: Java Tuple2<Boolean, Boolean>
>
> whereas my expectation is
>
> root
> |-- name: String
> |-- col4: Boolean
> |-- col5: Boolean
>
> When I define a scalar function which returns Tuple2 and use like
> "myscalar(col1, col2, col3) as (col4, col5)", it works as expected.
>
> Is there a possible way of splitting the tuple into two different columns
> in Flink-1.7.2?
> If not, do I have to define an additional UDF in order to flatten the
> tuple? or there's already one I can make use of?
>
> - Dongwon
