Re: broadcasting a stream from a collection that is populated from an web service call

2017-02-02 Thread Sathi Chowdhury
between the actual event data to be processed and metadata coming in second stream Sathi From: Till Rohrmann Reply-To: "user@flink.apache.org" Date: Thursday, February 2, 2017 at 2:10 PM To: "user@flink.apache.org" Subject: Re: broadcasting a stream from a collection that

Re: broadcasting a stream from a collection that is populated from an web service call

2017-02-02 Thread Till Rohrmann
Hi Sathi, I would ingest the meta data also into a kinesis queue and read the data from there. Then you don't have to fiddle around with the rest API from within your Flink job. If that is not feasible for you, then you can also write your own custom source function which queries the REST endpoin