Also would like to know how to do this if it is possible. On Fri, May 4, 2018 at 9:31 AM, Peter Zende <peter.ze...@gmail.com> wrote:
> Hi, > > We use RocksDB with FsStateBackend (HDFS) to store state used by the > mapWithState operator. Is it possible to initialize / populate this state > during the streaming application startup? > > Our intention is to reprocess the historical data from HDFS in a batch job > and save the latest state of the records onto HDFS. Thus when we restart > the streaming job we can just build up or load the most recent view of this > store. > > Many thanks, > Peter >
