collectFinish() deleted from MulticastCollector
there is no need for further casting of Collector<T> in the user flatmap program
current error: MulticastCollector is not invoked in all cases (only print the mapped messages)
collectFinish() deleted from MulticastCollector
ChainedMapDriver multicast error
because of ChainedMapDriver the multicast collect() is never invoked
if the second MapFunction outputs MulticastMessage as well then everything works fine! This id odd...
ChainedMapDriver multicast error
MultiCastTest ChainedMapDriver test examples