Package com.rpl.agentorama

Class BuiltIn

java.lang.Object
com.rpl.agentorama.BuiltIn
public class BuiltIn extends Object
Built-in aggregators for use with agent aggregation nodes. This class provides pre-configured aggregators that can be used with AgentTopology.newAgent(String) aggregation nodes. These aggregators are wrappers around Rama's built-in aggregation functions, adapted for use in agent-o-rama.
See Also:

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static com.rpl.agentorama.impl.BuiltInAgg
    AND_AGG
    Logical AND aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    FIRST_AGG
    First value aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    LAST_AGG
    Last value aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    LIST_AGG
    List aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    MAP_AGG
    Map aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    MAX_AGG
    Maximum value aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    MERGE_MAP_AGG
    Merge map aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    MIN_AGG
    Minimum value aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    MULTI_SET_AGG
    Multi-set aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    OR_AGG
    Logical OR aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    SET_AGG
    Set aggregator.
    static com.rpl.agentorama.impl.BuiltInAgg
    SUM_AGG
    Sum aggregator.

  • Constructor Summary

    Constructors
    Constructor
    Description
    BuiltIn()
     

  • Method Summary

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Field Details

    • AND_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg AND_AGG
      Logical AND aggregator. Combines boolean values using logical AND. Returns true only if all aggregated values are true.

    • FIRST_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg FIRST_AGG
      First value aggregator. Returns the first value encountered during aggregation.

    • LAST_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg LAST_AGG
      Last value aggregator. Returns the last value encountered during aggregation.

    • LIST_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg LIST_AGG
      List aggregator. Collects all values into a list in the order they were emitted.

    • MAP_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg MAP_AGG
      Map aggregator. Collects key-value pairs into a map. Keys and values are the first two elements of each emitted value.

    • MAX_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg MAX_AGG
      Maximum value aggregator. Returns the maximum value encountered during aggregation. Values must be comparable.

    • MERGE_MAP_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg MERGE_MAP_AGG
      Merge map aggregator. Merges multiple maps into a single map. Each emitted value should be a map that gets merged into the aggregated result.

    • MIN_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg MIN_AGG
      Minimum value aggregator. Returns the minimum value encountered during aggregation. Values must be comparable.

    • MULTI_SET_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg MULTI_SET_AGG
      Multi-set aggregator. Collects values into a map from element to count.

    • OR_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg OR_AGG
      Logical OR aggregator. Combines boolean values using logical OR. Returns true if any aggregated value is true.

    • SET_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg SET_AGG
      Set aggregator. Collects unique values into a set, automatically deduplicating identical values.

    • SUM_AGG

      public static com.rpl.agentorama.impl.BuiltInAgg SUM_AGG
      Sum aggregator. Sums all numeric values encountered during aggregation. Values must be numeric types (Integer, Long, Double, etc.).

  • Constructor Details

    • BuiltIn

      public BuiltIn()