public SourceRuntimeEnvironment(final String processingNodeId,final String pipelineId,final Source source,final StreamingMessageQueueProducer queueProducer) throws RequiredInputMissingException {
  this(processingNodeId,pipelineId,source,queueProducer,Executors.newCachedThreadPool());
  this.localExecutorService=true;
}

public SourceRuntimeEnvironment ( final String processingNodeId , final String pipelineId , final Source source , final StreamingMessageQueueProducer queueProducer ) throws RequiredInputMissingException { this ( processingNodeId , pipelineId , source , queueProducer , Executors . newCachedThreadPool ( ) ) ; this . localExecutorService = true ; }
initializes the runtime environment using the provided input
