Class FirstN.FirstNAgg

java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.operation.BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State>
org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg
All Implemented Interfaces:
Serializable, Aggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State>, Operation
Enclosing class:
FirstN

public static class FirstN.FirstNAgg extends BaseAggregator<org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State>
See Also:
  • Constructor Details

    • FirstNAgg

      public FirstNAgg(int n)
  • Method Details

    • init

      public org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State init(Object batchId, TridentCollector collector)
    • aggregate

      public void aggregate(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentTuple tuple, TridentCollector collector)
    • complete

      public void complete(org.apache.storm.trident.operation.builtin.FirstN.FirstNAgg.State val, TridentCollector collector)