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
