Hi, I've a scenario where I use connected streams where one is a low throughput metadata stream and another one is a high throughput data stream. I use CoProcessFunction that operates on a data stream with behavior controlled by a metadata stream.
Is there a way to slow down/pause the high throughput data stream until I've received one entry from the metadata stream? It's possible that by the time I get the first element from the metadata stream, I might get 1000s of items from the data stream. One option is to create a state to buffer the data stream within the operator. Is there any other option which doesn't need this state management? Thanks, Gopi
