Class LongSum
java.lang.Object
org.apache.storm.streams.operations.aggregators.LongSum
- All Implemented Interfaces:
- Serializable,- CombinerAggregator<Number,,- Long, - Long> - Operation
Computes the long sum of the input values.
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionUpdates the accumulator by applying the current accumulator with the value.init()The initial value of the accumulator to start with.Merges two accumulators and returns the merged accumulator.Produces a result value out of the accumulator.
- 
Constructor Details- 
LongSumpublic LongSum()
 
- 
- 
Method Details- 
initDescription copied from interface:CombinerAggregatorThe initial value of the accumulator to start with.- Specified by:
- initin interface- CombinerAggregator<Number,- Long, - Long> 
- Returns:
- the initial value of the accumulator
 
- 
applyDescription copied from interface:CombinerAggregatorUpdates the accumulator by applying the current accumulator with the value.- Specified by:
- applyin interface- CombinerAggregator<Number,- Long, - Long> 
- Parameters:
- aggregate- the current accumulator
- value- the value
- Returns:
- the updated accumulator
 
- 
mergeDescription copied from interface:CombinerAggregatorMerges two accumulators and returns the merged accumulator.- Specified by:
- mergein interface- CombinerAggregator<Number,- Long, - Long> 
- Parameters:
- accum1- the first accumulator
- accum2- the second accumulator
- Returns:
- the merged accumulator
 
- 
resultDescription copied from interface:CombinerAggregatorProduces a result value out of the accumulator.- Specified by:
- resultin interface- CombinerAggregator<Number,- Long, - Long> 
- Parameters:
- accum- the accumulator
- Returns:
- the result
 
 
-