Hello, I have a use case where I have a bounded source and I am reading Avro files from Google Cloud Storage. I am also using group by transform.The amount of data is huge and I need to process the data in sequential order.
But as Bounded source reads everything it seemed to be a good idea fixed window on top of the global window. But it does not seem to be working as expected. Can you please tell me how to handle such scenarios where a bounded source with large dataset can be broken down into smaller chunks for processing, using windows such that the window for a key should always be processed in order. Regards, Neha
