Logically it would make sense to be able to initialize BroadcastState in the open method of a BroadcastProcessFunction, but in practice I don't believe it can be done -- because the necessary Context isn't made available.
Perhaps you could use the State Processor API to bootstrap some state into the broadcast state. David On Mon, Sep 26, 2022 at 6:07 PM alfredo.vasquez.spglobal.com via user < user@flink.apache.org> wrote: > Hello community. > > > > Currently we have a BroadcastProcessFunction implementation that is > storing the broadcast state using a MapStateDescriptor<String, Rule>. > > I have a use case that needs to load the BroadcastState to perform some > operation before receiving any processElement or processBroadcastElement > message. > > > > Is there a way to load the BroadcastState on BroadcastProcessFunction > instantiation, overriding open(Configuration parameters) method or by > overriding some other callback function? > > > > Kind regards, > > ------------------------------ > > The information contained in this message is intended only for the > recipient, and may be a confidential attorney-client communication or may > otherwise be privileged and confidential and protected from disclosure. If > the reader of this message is not the intended recipient, or an employee or > agent responsible for delivering this message to the intended recipient, > please be aware that any dissemination or copying of this communication is > strictly prohibited. If you have received this communication in error, > please immediately notify us by replying to the message and deleting it > from your computer. S&P Global Inc. reserves the right, subject to > applicable local law, to monitor, review and process the content of any > electronic message or information sent to or from S&P Global Inc. e-mail > addresses without informing the sender or recipient of the message. By > sending electronic message or information to S&P Global Inc. e-mail > addresses you, as the sender, are consenting to S&P Global Inc. processing > any of your personal data therein. >
