[streaming] Tests added for Reduce, GroupReduce and BatchGroupReduce invokables