Hi Fabian, Thank you for the pointer. Thank, Nihat On Thu, Jan 19, 2017 at 2:46 AM Fabian Hueske <fhue...@gmail.com> wrote:
> Hi Nihat, > > you could implement the stateful function as a RichFunction and load the > data in the open() method. > > Best, Fabian > > 2017-01-19 2:53 GMT+01:00 Nihat Hosgur <nhos...@gmail.com>: > > Hi all, > > We bootstrap data from some DB and then like to keep it updated with > updates coming through Kafka. At spark it was kind of easy by utilizing > through UpdateStateByKey yet I'm kind of stuck to figure out how to do it > with Flink. I've taken a look into iterate yet I don't think it's meant to > do that. > > Any input would be appreciated, > Nihat > -- > Thanks, > Nihat > > > -- Thanks, Nihat
