Hi, We are looking to use the side input feature for one of our DoFns. The side input has to be a PCollection which is being constructed from a subscription using PubsubIO.read
We want our primary DoFn which operates in a global window KV pair to access this side input. The goal is to have all the messages of this unbounded source (side input) to be available across all the KV pairs in our input DoFn which will use this side input. Is it possible to have an unbounded source (like pubsub) as a side input? Thanks, Sahil
