code: private void initOutputs(ClassLoader cl) throws Exception {
  		this.chainedTasks = new ArrayList<ChainedDriver<?, ?>>();
  		this.eventualOutputs = new ArrayList<RecordWriter<?>>();
  
  		this.output = BatchTask.initOutputs(this, cl, this.config, this.chainedTasks, this.eventualOutputs,
  				getExecutionConfig(), getEnvironment().getAccumulatorRegistry().getUserMap());
  	}
docs: Creates a writer for each output. Creates an OutputCollector which forwards its input to all writers.
  The output collector applies the configured shipping strategy.