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;
  }
Stops the AggregatorDataProvider instance.