storm.trident.operation.builtin
Class FirstN

java.lang.Object
  extended by storm.trident.operation.builtin.FirstN
All Implemented Interfaces:
Assembly

public class FirstN
extends java.lang.Object
implements Assembly


Nested Class Summary
static class FirstN.FirstNAgg
           
static class FirstN.FirstNSortedAgg
           
 
Constructor Summary
FirstN(int n, java.lang.String sortField)
           
FirstN(int n, java.lang.String sortField, boolean reverse)
           
 
Method Summary
 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,
              java.lang.String sortField)

FirstN

public FirstN(int n,
              java.lang.String sortField,
              boolean reverse)
Method Detail

apply

public Stream apply(Stream input)
Specified by:
apply in interface Assembly