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;
	}
protected GenericDataSinkBase < T > translateToDataFlow ( Operator < T > input ) { 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 ) ; sink . setInput ( input ) ; if ( this . dop > 0 ) { sink . setDegreeOfParallelism ( this . dop ) ; } else { sink . setDegreeOfParallelism ( input . getDegreeOfParallelism ( ) ) ; } return sink ; }
--------------------------------------------------------------------------------------------