unipg.gila.aggregators

Class ComponentAggregatorAbstract.ComponentIntSumAggregator

java.lang.Object

unipg.gila.aggregators.ComponentAggregatorAbstract

unipg.gila.aggregators.ComponentAggregatorAbstract.ComponentIntSumAggregator

All Implemented Interfaces:

org.apache.giraph.aggregators.Aggregator<org.apache.hadoop.io.MapWritable>

Enclosing class:

ComponentAggregatorAbstract

public static class ComponentAggregatorAbstract.ComponentIntSumAggregator
extends ComponentAggregatorAbstract

This aggregator sums up integer values with the same key.

Author:

Alessio Arleo

Nested Class Summary

Nested classes/interfaces inherited from class unipg.gila.aggregators.ComponentAggregatorAbstract

ComponentAggregatorAbstract.ComponentFloatXYMaxAggregator, ComponentAggregatorAbstract.ComponentFloatXYMinAggregator, ComponentAggregatorAbstract.ComponentIntSumAggregator, ComponentAggregatorAbstract.ComponentMapOverwriteAggregator

Field Summary

Fields inherited from class unipg.gila.aggregators.ComponentAggregatorAbstract

internalState

Constructor Summary

Constructors

Constructor and Description
ComponentAggregatorAbstract.ComponentIntSumAggregator()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	specificAggregate(java.util.Map.Entry<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> current) This method must be overridden in order to subclass ComponentAggregatorAbstract.

Methods inherited from class unipg.gila.aggregators.ComponentAggregatorAbstract

aggregate, createInitialValue, getAggregatedValue, reset, setAggregatedValue

Methods inherited from class java.lang.Object

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

Constructor Detail

ComponentAggregatorAbstract.ComponentIntSumAggregator

public ComponentAggregatorAbstract.ComponentIntSumAggregator()

Method Detail

specificAggregate

protected void specificAggregate(java.util.Map.Entry<org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> current)

Description copied from class: ComponentAggregatorAbstract

This method must be overridden in order to subclass ComponentAggregatorAbstract. The method is used to decide whether to insert the current java.util.map.Entry in the map or not. Note that if the key is already present the entry will be always stored in the map.

Specified by:

specificAggregate in class ComponentAggregatorAbstract

Parameters:

current - A java.util.map.Entry object representing the key-value pair to insert into the map.