Re: Creating Flink SQL Row with named fields

2022-02-04 Thread Vladislav Keda
Thanks a lot! --- Best Regards, Vladislav Keda чт, 3 февр. 2022 г. в 12:13, Francesco Guardiani : > Hi, > > Unfortunately at the moment, creating a row with named fields is not > possible from the ROW constructor. > > One solution could be to wrap it in a cast, like: CAST((f0 + 12, 'Hello > wo

Re: Creating Flink SQL Row with named fields

2022-02-03 Thread Francesco Guardiani
Hi, Unfortunately at the moment, creating a row with named fields is not possible from the ROW constructor. One solution could be to wrap it in a cast, like: CAST((f0 + 12, 'Hello world') AS ROW) Or you could create a UDF and use the @DataTypeHint to define the row return type, with named fields.

Creating Flink SQL Row with named fields

2022-02-02 Thread Vladislav Keda
Hi, I'm trying to create Row(..) using Flink SQL, but I can't assign names to its fields. *For example:*Input table1 structure:* (id INT, some_name STRING)* Query: *select *, ROW(id, some_name) as row1 from table1* Output result structure: *(id INT , some_name STRING, row1 ROW (EXPR$0 INT, EX