code: private <OUT> DataStreamSource<OUT> fromParallelCollection(SplittableIterator<OUT> iterator, TypeInformation<OUT>
  			typeInfo, String operatorName) {
  		return addSource(new FromSplittableIteratorFunction<>(iterator), operatorName, typeInfo);
  	}
docs: private helper for passing different names