...
Add org.apache.flink.util.RichCollector.
Replace possible userFunciton Collector with it’s extension RichCollector.- offer RichCollector from RichFunction RuntimeContext instance
Proposed Changes
We want to introduce outputTag and support operator collect arbitrary types of records with defined output Tags. In this prototype, it demonstrated how things works in raw/hacky form.
...