public Map < Aggregator , AggregatorData > stop ( ) { Utils . checkState ( started , "Not started" ) ; Utils . checkState ( ! stopped , "Already stopped" ) ; stopped = true ; long currentTimeMillis = System . currentTimeMillis ( ) ; for ( Map . Entry < Aggregator , AggregatorData > e : data . entrySet ( ) ) { e . getValue ( ) . setTime ( currentTimeMillis ) ; } Map < Aggregator , AggregatorData > result = data ; result = aggregateDataWindows ( result ) ; return result ; }
Stops the AggregatorDataProvider instance .