flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Son Mai <hongson1...@gmail.com>
Subject How is Collector<T> out element processed?
Date Thu, 04 Apr 2019 02:14:39 GMT
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?


View raw message