Package org.apache.storm.starter.trident
Class TridentReach.One
- java.lang.Object
-
- org.apache.storm.starter.trident.TridentReach.One
-
- All Implemented Interfaces:
Serializable
,CombinerAggregator<Integer>
- Enclosing class:
- TridentReach
public static class TridentReach.One extends Object implements CombinerAggregator<Integer>
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description One()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Integer
combine(Integer val1, Integer val2)
Integer
init(TridentTuple tuple)
Integer
zero()
-
-
-
Method Detail
-
init
public Integer init(TridentTuple tuple)
- Specified by:
init
in interfaceCombinerAggregator<Integer>
-
combine
public Integer combine(Integer val1, Integer val2)
- Specified by:
combine
in interfaceCombinerAggregator<Integer>
-
zero
public Integer zero()
- Specified by:
zero
in interfaceCombinerAggregator<Integer>
-
-