code: public PythonDataStream from_collection(Iterator<Object> iter) throws Exception {
  		return new PythonDataStream<>(env.addSource(new PythonIteratorFunction(iter), TypeExtractor.getForClass(Object.class))
  			.map(new AdapterMap<>()));
  	}
docs: Creates a python data stream from the given iterator.
  
  <p>Note that this operation will result in a non-parallel data stream source, i.e.,
  a data stream source with a parallelism of one.</p>
  
  @param iter The iterator of elements to create the data stream from
  @return The data stream representing the elements in the iterator
  @see StreamExecutionEnvironment#fromCollection(java.util.Iterator, org.apache.flink.api.common.typeinfo.TypeInformation)