[streaming] Reduce and GroupReduce invokable refactor and performance tweak