Interface AggregatorFactory


public interface AggregatorFactory
Class responsible for creating aggregators.
  • Method Details

    • 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 reporting
      inputs - The inputs to the aggregator
      Returns:
      a new aggregator for the given inputs
    • equals

      boolean equals(Object o)
      Overrides:
      equals in class Object
    • hashCode

      int hashCode()
      Overrides:
      hashCode in class Object