[streaming] Added counter aggregation
[streaming] Added checked exception to execution
[streaming] GroupedBatchReduce modified to batch by key, updated WindowReduce + Batch/Window reduce refactor