Re: [State Processor API] how to convert savepoint back to broadcast state

2020-01-27 Thread Jin Yi
/operators/co/CoBroadcastWithKeyedOperator.java#L101 > > > Best > Yun Tang > > -- > *From:* Jin Yi > *Sent:* Monday, January 27, 2020 14:50 > *To:* Yun Tang > *Cc:* user ; user...@flink.apache.org < > user...@flink.apache.org>

Re: [State Processor API] how to convert savepoint back to broadcast state

2020-01-27 Thread Yun Tang
che/flink/streaming/api/operators/co/CoBroadcastWithKeyedOperator.java#L101 Best Yun Tang From: Jin Yi Sent: Monday, January 27, 2020 14:50 To: Yun Tang Cc: user ; user...@flink.apache.org Subject: Re: [State Processor API] how to convert savepoint back to broadcast state

Re: [State Processor API] how to convert savepoint back to broadcast state

2020-01-26 Thread Jin Yi
-docs-stable/dev/libs/state_processor_api.html#broadcast-state-1 >> >> Best >> Yun Tang >> -- >> *From:* Jin Yi >> *Sent:* Thursday, January 23, 2020 8:12 >> *To:* user ; user...@flink.apache.org < >> user...@flink.apache.org> >> *Subject:*

Re: [State Processor API] how to convert savepoint back to broadcast state

2020-01-26 Thread Jin Yi
-docs-stable/dev/libs/state_processor_api.html#broadcast-state-1 > > Best > Yun Tang > -- > *From:* Jin Yi > *Sent:* Thursday, January 23, 2020 8:12 > *To:* user ; user...@flink.apache.org < > user...@flink.apache.org> > *Subject:* [State Processor A

Re: [State Processor API] how to convert savepoint back to broadcast state

2020-01-26 Thread Yun Tang
To: user ; 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

[State Processor API] how to convert savepoint back to broadcast state

2020-01-22 Thread Jin Yi
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 exis