You can re-use the broadcasted state (along with its descriptor) that comes into your KeyedBroadcastProcessFunction, in another operator downstream. that's basically duplicating the broadcasted state whichever operator you want to use, every time.
--- Oytun Tez *M O T A W O R D* The World's Fastest Human Translation Platform. oy...@motaword.com — www.motaword.com On Mon, Sep 30, 2019 at 8:29 PM Navneeth Krishnan <reachnavnee...@gmail.com> wrote: > Hi All, > > Is it possible to access a broadcast state across the pipeline? For > example, say I have a KeyedBroadcastProcessFunction which adds the incoming > data to state and I have downstream operator where I need the same state as > well, would I be able to just read the broadcast state with a readonly > view. I know this is possible in kafka streams. > > Thanks >
