[streaming] Invokables and tests added for fast batch/window reduce operations and aggregations