storm.trident.operation.builtin
Class Count

java.lang.Object
  storm.trident.operation.builtin.Count

All Implemented Interfaces:

java.io.Serializable, CombinerAggregator<java.lang.Long>

public class Count
extends java.lang.Object
implements CombinerAggregator<java.lang.Long>

See Also:

Serialized Form

Constructor Summary

Count()

Method Summary

java.lang.Long	combine(java.lang.Long val1, java.lang.Long val2)
java.lang.Long	init(TridentTuple tuple)
java.lang.Long	zero()

Methods inherited from class java.lang.Object

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

Constructor Detail

Count

public Count()

Method Detail

init

public java.lang.Long init(TridentTuple tuple)

Specified by:

init in interface CombinerAggregator<java.lang.Long>

combine

public java.lang.Long combine(java.lang.Long val1,
                              java.lang.Long val2)

Specified by:

combine in interface CombinerAggregator<java.lang.Long>

zero

public java.lang.Long zero()

Specified by:

zero in interface CombinerAggregator<java.lang.Long>