flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From iñaki williams <juanramall...@gmail.com>
Subject Re: Custom Source Function for reading JSON?
Date Sun, 15 May 2016 17:18:59 GMT
Hi!

I have the class, I want to create objects using the values extraced from
the JSON text, my fault haha.

Sorry for that

2016-05-15 19:10 GMT+02:00 Gábor Horváth <xazax.hun@gmail.com>:

> Hi!
>
> On 14 May 2016 at 23:47, iñaki williams <juanramallo80@gmail.com> wrote:
>
>> Hi Flink Community!
>>
>> I am new using Apache Flink and I have a problem reading a JSON.
>>
>> I am using a JSON from a webpage, this JSON is changing continuosly so I
>> decided to use my own Source Function in order to grab the JSON using a URL
>> that is always the same: http://www.example/blabla/this.json
>>
>> I have been looking the other Source Functions from Github, but I am not
>> able to read it. I want to take the JSON, parse it and transform it into a
>> java class with some of the attributes and values that I need.
>>
>
> Sorry, but this part is not clear to me. Do you plan to create new classes
> at runtime and instantiate objects, or you do have the class at compile
> time and you want to create objects using the values extraced from the JSON
> text?
>
>
>>
>> When I compare other examples, they use SourceContext with String, but I
>> dont really want to send an String. I got stuck in that part and I am
>> looking for the best way of doing this.
>>
>> Thanks for your attention!
>>
>> Iñaki
>>
>>
> Regards,
> Gábor
>
>

Mime
View raw message