flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Zili Chen <wander4...@gmail.com>
Subject Re: How is Collector<T> out element processed?
Date Thu, 04 Apr 2019 02:45:28 GMT
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


Son Mai <hongson1104@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

View raw message