-
public interface AggregatorFactoryClass responsible for creating aggregators.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description booleanequals(Object o)StringgetKey()Returns the key for the aggregator used by the output flow.inthashCode()AggregatornewAggregator(List<String> inputNames, ScalarTokenType[] inputs)Create a new aggregator for the given inputs.
-
-
-
Method Detail
-
getKey
String getKey()
Returns the key for the aggregator used by the output flow. This determines the prefix to use for output names.- Returns:
- the key for the aggregator used by the output flow.
-
newAggregator
Aggregator newAggregator(List<String> inputNames, ScalarTokenType[] inputs)
Create a new aggregator for the given inputs. Factory should return the implementation appropriate for the input types.- Parameters:
inputNames- The input names; used for error reportinginputs- The inputs to the aggregator- Returns:
- a new aggregator for the given inputs
-
-