public void runInjectorPipeline(Pipeline injectorPipeline){
  PipelineResult result=injectorPipeline.run();
  if (result instanceof DataflowPipelineJob) {
    jobsToCancel.add(((DataflowPipelineJob)result));
  }
}

public void runInjectorPipeline ( Pipeline injectorPipeline ) { PipelineResult result = injectorPipeline . run ( ) ; if ( result instanceof DataflowPipelineJob ) { jobsToCancel . add ( ( ( DataflowPipelineJob ) result ) ) ; } }
runs the provided pipeline to inject data into the pubsubio input topic .
