Hi,

Is there any more detailed explanation on how Beam chooses the window size
(bundle size) in streaming mode? It seems there is no clear answer in the
[Beam Programming Guide](
https://beam.apache.org/documentation/programming-guide/) and I can't find
how PubsubIO implements this windowing strategy as well. :(

Could someone kindly provide some pointers? Thanks!
-- 
Derek Hao Hu

Software Engineer | Snapchat
Snap Inc.

Reply via email to