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 >
