First version of single- pass analytics over bounded data streams

Summary
First version of singlepass analytics over bounded data streams