public Map < Aggregator , AggregatorData > roll ( long newDataWindowEndTimeMillis ) { Utils . checkState ( started , "Not started" ) ; Utils . checkState ( ! stopped , "Already stopped" ) ; return dataProvider . roll ( newDataWindowEndTimeMillis ) ; }
Atomically rolls the DataWindow of all aggregators associated with the Aggregators instance .