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));
  }
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.
Processes the given value into the corresponding group - by element of the aggregator .