storm.trident.operation.builtin
Class FirstN.FirstNSortedAgg
java.lang.Object
storm.trident.operation.BaseOperation
storm.trident.operation.BaseAggregator<java.util.PriorityQueue>
storm.trident.operation.builtin.FirstN.FirstNSortedAgg
- All Implemented Interfaces:
- java.io.Serializable, Aggregator<java.util.PriorityQueue>, Operation
- Enclosing class:
- FirstN
public static class FirstN.FirstNSortedAgg
- extends BaseAggregator<java.util.PriorityQueue>
- See Also:
- Serialized Form
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FirstN.FirstNSortedAgg
public FirstN.FirstNSortedAgg(int n,
java.lang.String sortField,
boolean reverse)
init
public java.util.PriorityQueue init(java.lang.Object batchId,
TridentCollector collector)
aggregate
public void aggregate(java.util.PriorityQueue state,
TridentTuple tuple,
TridentCollector collector)
complete
public void complete(java.util.PriorityQueue val,
TridentCollector collector)