class QueryablePipeline {

  public PTransformNode getProducer(PCollectionNode pcollection) {
    return (PTransformNode) Iterables.getOnlyElement(pipelineNetwork.predecessors(pcollection));
  }

  private  QueryablePipeline(Collection<String> transformIds, Components components);

}