This would need to use `CoGroupByKey` internally to match up input pipelines.
This would need to use
CoGroupByKeyinternally to match up input pipelines.