-
public interface AggregatorFactory
Class responsible for creating aggregators.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description boolean
equals(Object o)
String
getKey()
Returns the key for the aggregator used by the output flow.int
hashCode()
Aggregator
newAggregator(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
-
-