Package com.rpl.rama.ops

Interface LimitAgg

public interface LimitAgg
Specifies a limit aggregator for use with limitAgg
See Also:

  • Method Details

    • create

      static LimitAgg create(int amt, String... vars)
      Creates a limit aggregator specification
      Parameters:
      amt - Maximum number of emits into post-agg phase
      vars - Vars in pre-agg phase to keep
      Returns:
      Builder-style object to set options

    • sort

      LimitAgg sort(String... vars)
      Sort input for aggregation on values of given vars
      Parameters:
      vars - Vars

    • reverse

      LimitAgg reverse()
      Used in conjunction with sort(java.lang.String...) to reverse the input

    • indexVar

      LimitAgg indexVar(String var)
      If set also emits the index of each emit to the specified var
      Parameters:
      var - Output var to bind to index