Package 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	Description
static class	FirstN.FirstNAgg
static class	FirstN.FirstNSortedAgg

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

FirstN

public FirstN(int n,
 String sortField)

FirstN

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

Method Details

apply

public Stream apply(Stream input)

Description copied from interface: Assembly

Applies the `Assembly` to a given Stream.

Specified by:

apply in interface Assembly