Interface AggregatorFactory


  • public interface AggregatorFactory
    Class responsible for creating aggregators.
    • 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 reporting
        inputs - The inputs to the aggregator
        Returns:
        a new aggregator for the given inputs