[streaming] Implemented sliding window and batchReduce
[streaming] Added groupBy operator to DataStream + name refactor
[streaming] Updated operator test to avoid environment execution