public void startInjectorIfNeeded(String inputFile){
  ExamplePubsubTopicOptions pubsubTopicOptions=options.as(ExamplePubsubTopicOptions.class);
  if (pubsubTopicOptions.isStreaming() && !Strings.isNullOrEmpty(inputFile) && !Strings.isNullOrEmpty(pubsubTopicOptions.getPubsubTopic())) {
    runInjectorPipeline(inputFile,pubsubTopicOptions.getPubsubTopic());
  }
}

public void startInjectorIfNeeded ( String inputFile ) { ExamplePubsubTopicOptions pubsubTopicOptions = options . as ( ExamplePubsubTopicOptions . class ) ; if ( pubsubTopicOptions . isStreaming ( ) && ! Strings . isNullOrEmpty ( inputFile ) && ! Strings . isNullOrEmpty ( pubsubTopicOptions . getPubsubTopic ( ) ) ) { runInjectorPipeline ( inputFile , pubsubTopicOptions . getPubsubTopic ( ) ) ; } }
if this is an unbounded ( streaming ) pipeline , and both inputfile and pubsub topic are defined , start an ' injector ' pipeline that publishes the contents of the file to the given topic , first creating the topic if necessary .
