basic-lib/src/main/java/com/streamsets/pipeline/stage/processor/aggregation/aggregator/GroupByAggregator.java
public void process(String group, T value) {
    getData().process(ImmutableMap.of(group, value));
  }
public void process(String group, T value) {
    getData().process(ImmutableMap.of(group, value));
  }
Processes the given value into the corresponding group-by element of the aggregator.

@param group the group-by element.
@param value the value to process.