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;
}