public interface LimitAgg

Specifies a limit aggregator for use with limitAgg

Method Summary

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