/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>
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
Hi Yun,
After search around in the documentation, I tried extends
BroadcastProcessFunction implements CheckpointedFunction. And I have
initialized broadcast state in public void
initializeState(FunctionInitializationContext
context) method, it seems working fine.
Here is the doc I followed:
https
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
broa
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
Sent: Thursday, January 23, 2020 8:12
To
