Hey there, Until side input is fully supported, you can use GBK with a fixed key to get all elements in a single bundle (assuming global windowing). That is how textio.Write works internally to produce a single file currently:
https://github.com/apache/beam/blob/90ba47114997e75a3a7daa1e8db92768d05e5432/sdks/go/pkg/beam/io/textio/textio.go#L144 Thanks, Henning On Fri, May 4, 2018 at 11:41 AM 8 Gianfortoni <8...@tokentransit.com> wrote: > Hi dev team, > > I would like to be able to read the entire results of a PCollection > serially after running beam. In other frameworks this is fairly > straightforward, but I don't understand how one might do this with the Beam > Go SDK. > > I guess I can read in a file that I write, but I want to be able to read > the elements in struct format. I looked through a bunch of examples but > don't see any that do this. > > Thanks, > 8 >
