THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
In RichFunction, user can getRuntimeContext().getCollector(), it returns a RichCollector
...
- Add <S> void collect(OutputTag<S> tag, S value) method to Collector interface
In this way, all of existing function will have side output support without compatbility issue. The drawbacks are there will be large number classes implementing Collector interface with empty implementation
Add getOutput(OutputTag) to SingleOutputStreamOperator
...