Hi,
I am brand new to Apache Flink so please excuse any silly questions. I
have an Iterator function defined as below and adding it as a source to a
Flink stream. But when I try to pass configuration information to it (via
a Spring env), what I notice is that one of the threads calls hasNext() and
it is not the same object and the passed information is null. Something is
constructing it, but what is strange is that if I add a default constructor
I do not see this being called by this thread with the null data so I am
wondering what is going on. Any ideas? How do we pass configuration
information to these functions? Any help would be appreciated.
Thanks,
Rick
@Public
public class NodeSource extends
FromIteratorFunction<LinkedList<BaseDocument>> {
private static final long serialVersionUID = 1L;
public NodeSource(ArangoDBSource iterator) {
super(iterator);
}
}
