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

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

Methods inherited from class java.lang.Object

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

Constructor Details

One

public One()

Method Details

init

public Integer init(TridentTuple tuple)

Specified by:

init in interface CombinerAggregator<Integer>

combine

public Integer combine(Integer val1,
 Integer val2)

Specified by:

combine in interface CombinerAggregator<Integer>

zero

public Integer zero()

Specified by:

zero in interface CombinerAggregator<Integer>