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