Hi Yun, Thanks for the response, I have checked official document, and I have referred this example to write the broadcast state to a savepoint.
My question is: I can use state processor api to read back the savepoint into a dataSet, but how can I use the dataSet as the initial value for the broadcast state in the BroadcastProcessFunction. Thanks a lot! Eleanore On Sun, Jan 26, 2020 at 8:53 AM Yun Tang <myas...@live.com> wrote: > Hi Yi > > Can the official doc of writing broad cast state [1] satisfies your > request? > > [1] > https://ci.apache.org/projects/flink/flink-docs-stable/dev/libs/state_processor_api.html#broadcast-state-1 > > Best > Yun Tang > ------------------------------ > *From:* Jin Yi <eleanore....@gmail.com> > *Sent:* Thursday, January 23, 2020 8:12 > *To:* user <user@flink.apache.org>; user...@flink.apache.org < > user...@flink.apache.org> > *Subject:* [State Processor API] how to convert savepoint back to > broadcast state > > Hi there, > > I would like to read the savepoints (for broadcast state) back into the > broadcast state, how should I do it? > > // load the existingSavepoint; > ExistingSavepoint existingSavepoint = Savepoint.load(environment, > "file:///tmp/new_savepoints", new MemoryStateBackend()); > > // read state from existing savepoint > dataSet = existingSavepoint.readBroadcastState(OPERATOR_UID, > "largeKeySetStateDescription", BasicTypeInfo.STRING_TYPE_INFO, > BasicTypeInfo.STRING_TYPE_INFO); > > // TODO in BoradcastProcessFunction, how can I put the savepoint dataset back > into BroadcastState? > > Thanks! > > Eleanore > >
