Re: Flink SQL on JSON data without schema

2017-01-19 Thread Fabian Hueske
The first level must be static, but a field can hold a complex object with nested data. So you could have a schema with a single JSON object as field. Best, Fabian 2017-01-19 19:31 GMT+01:00 Nihat Hosgur : > Hi Fabian, > I just want to make sure there is no misunderstanding. So what I've > under

Re: Flink SQL on JSON data without schema

2017-01-19 Thread Nihat Hosgur
Hi Fabian, I just want to make sure there is no misunderstanding. So what I've understood from your response is that regardless table source is KafkaTable or not we need to provide static schema. Best, Nihat On Thu, Jan 19, 2017 at 2:50 AM Fabian Hueske wrote: Hi Nihat, at the current state, F

Re: Flink SQL on JSON data without schema

2017-01-19 Thread Fabian Hueske
Hi Nihat, at the current state, Flink's SQL and Table APIs require a static schema. You could use an JSON object as value and implement scalar functions to extract fields, but that would not be very usable. Best, Fabian 2017-01-19 2:59 GMT+01:00 Nihat Hosgur : > Hi there, > We are evaluating fl