[streaming] Added CoBatchReduceInvokable, CoWindowReduceInvokable and grouped variants