Second version of single-pass analytics over bounded data streams

Summary
Second version of singlepass analytics over bounded data streams