Class AggSpecFreeze

All Implemented Interfaces:
AggSpec

@Immutable public abstract class AggSpecFreeze extends AggSpecEmptyBase
Specifies an aggregation that freezes the first value for each group and ignores subsequent changes. When groups are removed, the corresponding output row is removed. When groups are re-added (on a subsequent update cycle), the newly added value is then frozen.
ImplNote:
Only one row per group is allowed in the output, because the operation has no way to determine which row to freeze otherwise. This is a constraint on the input data.
  • Constructor Details

    • AggSpecFreeze

      public AggSpecFreeze()
  • Method Details

    • of

      public static AggSpecFreeze of()
    • description

      public final String description()
      Description copied from interface: AggSpec
      Get a simple description for this AggSpec.
      Returns:
      The description
    • walk

      public final <V extends AggSpec.Visitor> V walk(V visitor)
      Description copied from interface: AggSpec
      Glue method to deliver this AggSpec to a AggSpec.Visitor.
      Parameters:
      visitor - The visitor
      Returns:
      The visitor