Re: Flink nested complex json parsing with multiple schema file

2022-07-21 Thread Soumen Choudhury
Hi Yaroslav, Thanks for your reply. How is performance , Can I have a sample code for the same. On Thu, Jul 21, 2022, 9:31 PM Yaroslav Tkachenko wrote: > Hi Soumen, > > I'd try parsing the input using the DataStream API (with a fast JSON > library) and then converting it to a Table. > > On Thu

Re: Flink nested complex json parsing with multiple schema file

2022-07-21 Thread Yaroslav Tkachenko
Hi Soumen, I'd try parsing the input using the DataStream API (with a fast JSON library) and then converting it to a Table. On Thu, Jul 21, 2022 at 6:22 AM Soumen Choudhury wrote: > We have a requirement of parsing a very complex json (size around 25 kb > per event) event with a predefined sche

Flink nested complex json parsing with multiple schema file

2022-07-21 Thread Soumen Choudhury
We have a requirement of parsing a very complex json (size around 25 kb per event) event with a predefined schema (nested schema, with multiple schema files ) and create a temporary table and from temp table we have to apply some case statement based some fields( eg. to find out success, failure co