storm.trident.operation.builtin

Class FirstN

java.lang.Object

storm.trident.operation.builtin.FirstN

All Implemented Interfaces:

Assembly

public class FirstN
extends Object
implements Assembly

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FirstN.FirstNAgg
static class	FirstN.FirstNSortedAgg

Constructor Summary

Constructors

Constructor and Description
FirstN(int n, String sortField)
FirstN(int n, String sortField, boolean reverse)

Method Summary

Modifier and Type	Method and Description
Stream	apply(Stream input)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FirstN

public FirstN(int n,
              String sortField)

FirstN

public FirstN(int n,
              String sortField,
              boolean reverse)

Method Detail

apply

public Stream apply(Stream input)

Specified by:

apply in interface Assembly