flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gábor Horváth <xazax....@gmail.com>
Subject Re: Custom Source Function for reading JSON?
Date Sun, 15 May 2016 17:10:37 GMT
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