com.rpl.rama.ops

Interface LimitAgg

public interface LimitAgg

Specifies a limit aggregator for use with limitAgg

See Also:

Detailed limitAgg documentation

Method Summary

Modifier and Type	Method and Description
static LimitAgg	create(int amt, java.lang.String... vars) Creates a limit aggregator specification
LimitAgg	indexVar(java.lang.String var) If set also emits the index of each emit to the specified var
LimitAgg	reverse() Used in conjunction with sort(java.lang.String...) to reverse the input
LimitAgg	sort(java.lang.String... vars) Sort input for aggregation on values of given vars

Method Detail

create

static LimitAgg create(int amt,
                       java.lang.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(java.lang.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(java.lang.String var)

If set also emits the index of each emit to the specified var

Parameters:

var - Output var to bind to index