Может ли кто-нибудь указать на некоторые примеры, относящиеся к потоку данных String Cloud (не Stream XD), о том, как писать сплиттеры и агрегаторы?
В частности нетривиальное разделение и объединение сообщений. Любой нетривиальный пример сложных потоков. Как вы определяете поток, который агрегирует сообщения после разделения, как насчет того, что при наличии маршрутизаторов и другой обработки для созданных сообщений, как все это будет агрегироваться позже?
PS: Извините за длинный вопрос, уточню по мере необходимости. Благодарность!
