Ну и надо точно знать что вам это нужно, средний слой который наполняется стримом, т.к. реконсиляция батча и стрима это long term очень неприятно, проще выкидывать потоковые агрегаты и замещать их нагоняющими батчевыми (суть паттерна лямбда архитектуры)