Hi together,

I have a question regarding Apache Beam in Python:

When I create a window with timestamps and then make a groupby, then the 
information for the windows remains in the elements. Afterwards, I want to make 
another groupby (something like a cumsum) by certain keys, but that does not 
work as the windows are still there and so it takes the keys + windows to split 
my data in the combineFn. Question now: How can I “delete” the windows and 
timestamps so that I would combine records just by the defined keys in the last 
combineFn.

Hope this is clear.

Best,
Patrizio

________________________________
This e-mail and any attachments may be confidential or legally privileged. If 
you received this message in error or are not the intended recipient, you 
should destroy the e-mail message and any attachments or copies, and you are 
prohibited from retaining, distributing, disclosing or using any information 
contained herein. Please inform us of the erroneous delivery by return e-mail. 
Thank you for your cooperation. For more information on how we use your 
personal data please see our Privacy 
Notice<https://www.oliverwyman.com/policies/privacy-notice.html>.

Reply via email to