[streaming] Updated logging to utilize SLF4J
[streaming] Added CoBatchGroupReduceInvokable, CoWindowGroupReduceInvokable and grouped variants