Hi Tison, so are you saying that the output will be iterated on when the next operator that called them? and they are not processed in push but pull mechanism by the next operator like sink?
Thanks, On Thu, Apr 4, 2019 at 9:46 AM Zili Chen <wander4...@gmail.com> wrote: > Hi Son, > > As from Collector's document, it collects a record and forwards it. > The collector is the "push" counterpart of the Iterator which "pulls" data > in. > > Best, > tison. > > > Son Mai <hongson1...@gmail.com> 于2019年4月4日周四 上午10:15写道： > >> Hi all, >> >> when I create new classes extending ProcessFunction or implementing >> WindowFunction, there is a *Collector<T> out* for output. >> >> How is this output processed in the next stage, for example a Sink or >> another WindowAssigner? Is it processed immediately by the next operator by >> push mechanism, or is the collector checked regularly by the next operator >> to see if an element exists? >> >> Thanks, >> Son >> >
