Apache Flink - Building flink docs locally

2022-01-15 Thread M Singh
Hi:   I wanted to find out what's the command for building the flink docs locally and the location of the final docs.  Is it apart of the build commands (Building Flink from Source) and can they be built separately ?   Thanks 

Fwd: Example with JSONKeyValueDeserializationSchema?

2022-01-15 Thread HG
اشكرك😀 Thanks! A good Java Flink learning experience On Sat, Jan 15, 2022, 11:47 Mariam Walid wrote: > Hi Hans, > > As Kamil said, you can use Jackson. I would suggest that you read the > input stream to be of type DataStream, then create a map function > that map each string in the stream to Ja

Re: Example with JSONKeyValueDeserializationSchema?

2022-01-15 Thread HG
Thanks Kamil. I'll give it a try. Regards Hans On Fri, Jan 14, 2022, 20:32 Kamil ty wrote: > Hello Hans, > > As far as I know the JSONKeyValueDeserializationSchema returns a Jackson > ObjectNode. Below I have included an example based on Flink stable > documentation. > > KafkaSource source = K