flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Keep bootstrapped config updated with stream from Kafka
Date Thu, 19 Jan 2017 10:45:27 GMT
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 <nhosgur@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

View raw message