Package org.apache.storm.trident.operation.builtin

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

Modifier and Type	Method	Description
Long	combine(Long val1, Long val2)
Long	init(TridentTuple tuple)
Long	zero()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Count

public Count()

Method Details

init

public Long init(TridentTuple tuple)

Specified by:

init in interface CombinerAggregator<Long>

combine

public Long combine(Long val1,
 Long val2)

Specified by:

combine in interface CombinerAggregator<Long>

zero

public Long zero()

Specified by:

zero in interface CombinerAggregator<Long>