Re: FromIteratorFunction problems

Thanks, that example is helpful. It seems like to use `fromCollection` with an iterator it must be an iterator that implements serializable, and Java's built in `Iterator`s don't, unfortunately. On Thu, Apr 7, 2016 at 6:11 PM, Chesnay Schepler wrote: > hmm, maybe i was to

Re: FromIteratorFunction problems

hmm, maybe i was to quick with linking to the JIRA. As for an example: you can look at the streaming WindowJoin example. The sample data uses an Iterator. (ThrottledIterator) Note that the iterator implementation used is part of flink and also implements serializable. On 07.04.2016 22:18,

Re: FromIteratorFunction problems

you will find some information regarding this issue in this JIRA: https://issues.apache.org/jira/browse/FLINK-2608 On 07.04.2016 22:18, Andrew Whitaker wrote: Hi, I'm trying to get a simple example of a source backed by an iterator working. Here's the code I've got: ```

FromIteratorFunction problems

Hi, I'm trying to get a simple example of a source backed by an iterator working. Here's the code I've got: ``` StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); List list = Arrays.asList(1, 2); env.fromCollection(list.iterator(), Integer.class).print();