My Flink program is to aggregate the data of a whole day, assume we start this program on 6:00 am, the default state in the window should be the aggregated result of 0:00 am to 6:00 am.
I’m going to run a new Flink program with some initialized window states.
I can’t see there is an official way to do this, right? I’ve tried the bravo project, but it doesn’t support FsStateBackend and it costs too much work if we add a new StateBackend in it.
Any good ideas about this?