# public interface LimitAgg

Specifies a limit aggregator for use with [`limitAgg`](/content/javadoc/com/rpl/rama/Block.html#limitAgg(com.rpl.rama.ops.LimitAgg))

## Method Summary

| Modifier and Type | Method                               | Description                                                    |
|-------------------|--------------------------------------|----------------------------------------------------------------|
| static LimitAgg   | create(int amt, String... vars)     | Creates a limit aggregator specification                        |
| LimitAgg          | indexVar(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...)`](/content/javadoc/com/rpl/rama/ops/LimitAgg.html#sort(java.lang.String.../index.html)) to reverse the input |
| LimitAgg          | sort(String... vars)                | Sort input for aggregation on values of given vars             |

## Method Details

### create

```java
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

```java
LimitAgg sort(String... vars)
```
Sort input for aggregation on values of given vars

**Parameters:**  
`vars` - Vars

### reverse

```java
LimitAgg reverse()
```
Used in conjunction with [`sort(java.lang.String...)`](/content/javadoc/com/rpl/rama/ops/LimitAgg.html#sort(java.lang.String.../index.html)) to reverse the input

### indexVar

```java
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