code: public <OUT> DataStreamSource<OUT> fromParallelCollection(SplittableIterator<OUT> iterator, Class<OUT> type) {
  		return fromParallelCollection(iterator, TypeExtractor.getForClass(type));
  	}
docs: Creates a new data stream that contains elements in the iterator. The iterator is splittable,
  allowing the framework to create a parallel data stream source that returns the elements in
  the iterator.
  
  <p>Because the iterator will remain unmodified until the actual execution happens, the type
  of data returned by the iterator must be given explicitly in the form of the type class
  (this is due to the fact that the Java compiler erases the generic type information).
  
  @param iterator
  The iterator that produces the elements of the data stream
  @param type
  The class of the data produced by the iterator. Must not be a generic class.
  @param <OUT>
  The type of the returned data stream
  @return A data stream representing the elements in the iterator