You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Thank you for sharing this library, I've learned from it quite a lot and used the same mechanics to implement a centralized error collection component in a pipeline I'm working on.
I was wondering how do you deal with applying the Flatten.pCollections() to PCollections that might have different windowing associated with them.
In order to overcome this issue in my code I had to re-window each PCollection before adding it to the PCollectionList which is ultimately flattened. I wonder if there is another way to go about that.
Thank you!
Amit.
The text was updated successfully, but these errors were encountered:
Hello!
Thank you for sharing this library, I've learned from it quite a lot and used the same mechanics to implement a centralized error collection component in a pipeline I'm working on.
I was wondering how do you deal with applying the
Flatten.pCollections()
to PCollections that might have different windowing associated with them.In order to overcome this issue in my code I had to re-window each PCollection before adding it to the
PCollectionList
which is ultimately flattened. I wonder if there is another way to go about that.Thank you!
Amit.
The text was updated successfully, but these errors were encountered: