org.apache.storm.trident.operation.builtin

Class FirstN

java.lang.Object

org.apache.storm.trident.operation.builtin.FirstN

All Implemented Interfaces:

Assembly

public class FirstN
extends Object
implements Assembly

An Assembly implementation

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) Applies the Assembly to a given Stream

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)

Description copied from interface: Assembly

Applies the Assembly to a given Stream

Specified by:

apply in interface Assembly

Returns: