docs: protected DataStream<T> setConnectionType(StreamPartitioner<T> partitioner) {
  		return new DataStream<>(this.getExecutionEnvironment(), new PartitionTransformation<>(this.getTransformation(), partitioner));
  	}