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
