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