Hi Dev, After offline discussions with Gus, I'd like propose we include a Batcher function into contrib/. This would be a DoFn that behaves like this:
[1,2,3,4,5] -> Batcher(max_size=2) -> [[1,2],[3,4],[5]] Its simple code, but it also shows off that values can still be yielded from finish_bundle(), and lots of people found it useful for the internal Google version too. LMK what you think. Thanks! Josh -- joshgc :wq