basic-lib/src/main/java/com/streamsets/pipeline/stage/processor/aggregation/aggregator/AggregatorDataProvider.java
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;
  }
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;
  }
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.
Stops the AggregatorDataProvider instance .