Re: Flink Table SQL and writing nested Avro files

2020-09-22 Thread Dan Hill
Nice! I'll try that. Thanks, Dawid! On Mon, Sep 21, 2020 at 2:37 AM Dawid Wysakowicz wrote: > Hi Dan, > > I think the best what I can suggest is this: > > SELECT > > ROW(left.field0, left.field1, left.field2, ...), > > ROW(right.field0, right.field1, right.field2, ...) > > FROM ... > >

Re: Flink Table SQL and writing nested Avro files

2020-09-21 Thread Dawid Wysakowicz
Hi Dan, I think the best what I can suggest is this: |SELECT || | |    ROW(left.field0, left.field1, left.field2, ...),| |    ROW(right.field0, right.field1, right.field2, ...)| |FROM ...| You will need to list all the fields manually, as SQL does not allow for asterisks in regular function c

Flink Table SQL and writing nested Avro files

2020-09-18 Thread Dan Hill
Hi! I want to join two tables and write the results to Avro where the left and right rows are nested in the avro output. Is it possible to do this with the SQL interface? Thanks! - Dan CREATE TABLE `flat_avro` ( `left` ROW, `right` ROW ) WITH ( 'connector' = 'filesystem', 'path' =