unipg.gila.aggregators

Class ComponentAggregatorAbstract.ComponentFloatXYMaxAggregator

java.lang.Object

unipg.gila.aggregators.ComponentAggregatorAbstract

unipg.gila.aggregators.ComponentAggregatorAbstract.ComponentFloatXYMaxAggregator

All Implemented Interfaces:

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

Direct Known Subclasses:

ComponentAggregatorAbstract.ComponentFloatXYMinAggregator

Enclosing class:

ComponentAggregatorAbstract

public static class ComponentAggregatorAbstract.ComponentFloatXYMaxAggregator
extends ComponentAggregatorAbstract

This aggregator keeps the maximum float coordinates (float[]{x,y}) for each 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.ComponentFloatXYMaxAggregator()

Method Summary

Methods

Modifier and Type	Method and Description
protected float[]	checkEligibility(float[] mycoords, float[] newest)
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.ComponentFloatXYMaxAggregator

public ComponentAggregatorAbstract.ComponentFloatXYMaxAggregator()

Method Detail

checkEligibility

protected float[] checkEligibility(float[] mycoords,
                       float[] newest)

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.