I am not sure that this does what we want. We rather want something like `{1:
pc, 2: pc} | beam.CoGBK() | ConsumeJoinedCollections()` (sic). Otherwise we're
just 'grouping' a single PCollection no?In that case `ConsumeJoinedCollections` is perhaps simply a map / ParDo that ensures the collections are readfrom GBK [ Full content available at: https://github.com/apache/beam/pull/6239 ] This message was relayed via gitbox.apache.org for [email protected]
