Can anybody point to some examples specific to String Cloud Data Flow (not Stream XD) on how to write splitters and aggregators?
In particular non trivial splitting and joining of messages. Any non trivial example of complex streams. How do you define a stream that is aggregating messages after spliting, how about when there are Routers and diferent processing for the produced messages, how is all that aggregated later?
PS: Sorry for the long question, I will clarify as needed. thanks!
There is an out of the box app available for splitter here. The aggregator is yet to be added to the OOTB apps and is being tracked here. You can write an app based on this and your contributions are welcome!