code: protected GenericDataSourceBase<OUT, ?> translateToDataFlow() {
  		String name = this.name != null ? this.name : this.inputFormat.toString();
  		if (name.length() > 100) {
  			name = name.substring(0, 100);
  		}
  		
  		@SuppressWarnings({ "unchecked", "rawtypes" })
  		GenericDataSourceBase<OUT, ?> source = new GenericDataSourceBase(this.inputFormat,
  				new OperatorInformation<OUT>(getType()), name);
  		source.setDegreeOfParallelism(dop);
  		
  		return source;
  	}
docs: --------------------------------------------------------------------------------------------