docs: public <K> DataStream<T> partitionCustom(Partitioner<K> partitioner, KeySelector<T, K> keySelector) {
  		return setConnectionType(new CustomPartitionerWrapper<>(clean(partitioner),
  				clean(keySelector)));
  	}