Hi!

I was trying to understand the behavior of StartBundle and FinishBundle
w.r.t. DoFns.
I have an unbounded data source and I am trying to leverage bundling to
achieve batching.
>From the docs of ParDo:

"when a ParDo transform is executed, the elements of the input PCollection
are first divided up into some number of "bundles"

I would like to know if bundling is possible for unbounded data in the
first place. If it is then how do I control the bundle size i.e. number of
elements of a given PCollection in that bundle?

Reply via email to