Talked to Daniel offline and it looks like the Python SDK is missing PCollection Tuples like the one Java has: https://github.com/rohdesamuel/beam/blob/master/sdks/java/core/src/main/java/org/apache/beam/sdk/values/PCollectionTuple.java .
I'll go ahead and implement that for the Python SDK. On Thu, Oct 24, 2019 at 5:20 PM Sam Rohde <[email protected]> wrote: > Hey All, > > I'm trying to implement an expand override with multiple output > PCollections. The kicker is that I want to insert a new transform for each > output PCollection. How can I do this? > > Regards, > Sam >
