code: protected GenericDataSinkBase<T> translateToDataFlow(Operator<T> input) {
  		// select the name (or create a default one)
  		String name = this.name != null ? this.name : this.format.toString();
  		GenericDataSinkBase<T> sink = new GenericDataSinkBase<T>(this.format, new UnaryOperatorInformation<T, Nothing>(this.type, new NothingTypeInfo()), name);
  		// set input
  		sink.setInput(input);
  		// set dop
  		if(this.dop > 0) {
  			// use specified dop
  			sink.setDegreeOfParallelism(this.dop);
  		} else {
  			// if no dop has been specified, use dop of input operator to enable chaining
  			sink.setDegreeOfParallelism(input.getDegreeOfParallelism());
  		}
  		
  		return sink;
  	}
docs: --------------------------------------------------------------------------------------------