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