Class AggregatorUtil.ToIngestElementKey

  • All Implemented Interfaces:
    Function<Element,​Element>
    Enclosing class:
    AggregatorUtil

    public static class AggregatorUtil.ToIngestElementKey
    extends AggregatorUtil.ToElementKey
    A Function that takes and element as input and outputs an element key that consists of the Group-by values in the Schema, the Identifiers and the Group. These act as a key and can be used in a Collector to do ingest aggregation.
    • Constructor Detail

      • ToIngestElementKey

        public ToIngestElementKey​(Schema schema)