[streaming] Added groupBy operator to DataStream + name refactor