public PythonDataStream from_collection ( Iterator < Object > iter ) throws Exception { return new PythonDataStream <> ( env . addSource ( new PythonIteratorFunction ( iter ) , TypeExtractor . getForClass ( Object . class ) ) . map ( new AdapterMap <> ( ) ) ) ; }
Creates a python data stream from the given iterator .