Hi everyone,

I would like to use a CoGroupByKey statement on unevenly windowed streams
(one of size 15 minutes, one of size 1 minute). As I understand it,
CoGroupByKey groups first by key, then by window. But of course since the
windows are not the same, my CoGroupByKey does not successfully join the
streams.

One idea I had is to extend CoGroupByKey to make some
"CoGroupByKeyWindowEnd", that groups first by key, then by window.end. I
just wanted to check first- is there a better way to do this? Or something
natively supported by Beam?

Thanks,
Akshay
-- 
Akshay Balwally
Software Engineer
9372716469 |

<https://www.lyft.com/>

Reply via email to