edu.umn.cs.spatialHadoop.operations

Class Aggregate

java.lang.Object

edu.umn.cs.spatialHadoop.operations.Aggregate

public class Aggregate
extends java.lang.Object

Computes the minimum and maximum values for a set of input HDF files. Used to find a tight range to plot heat maps.

Author:

Ahmed Eldawy

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Aggregate.Map
static class	Aggregate.MinMax A structure to hold the minimum and maximum values for aggregation.
static class	Aggregate.Reduce

Constructor Summary

Constructors

Constructor and Description
Aggregate()

Method Summary

Methods

Modifier and Type	Method and Description
static Aggregate.MinMax	aggregate(Path[] inFiles, OperationsParams params) Computes the minimum and maximum values of readings in input.
static Aggregate.MinMax	aggregateMapReduce(Path[] files, OperationsParams params) Counts the exact number of lines in a file by issuing a MapReduce job that does the thing
static void	main(java.lang.String[] args)

Methods inherited from class java.lang.Object

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

Constructor Detail

Aggregate

public Aggregate()

Method Detail

aggregateMapReduce

public static Aggregate.MinMax aggregateMapReduce(Path[] files,
                                  OperationsParams params)
                                           throws java.io.IOException

Counts the exact number of lines in a file by issuing a MapReduce job that does the thing

Parameters:

conf -

fs -

file -

Returns:

Throws:

java.io.IOException

aggregate

public static Aggregate.MinMax aggregate(Path[] inFiles,
                         OperationsParams params)
                                  throws java.io.IOException

Computes the minimum and maximum values of readings in input. Useful as a preparatory step before drawing.

Parameters:

inFiles - - A list of input files.

plotRange - - The spatial range to plot

forceCompute - - Ignore any preset values and force computation of the aggregate functions.

Returns:

Throws:

java.io.IOException

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException

Parameters:

args -

Throws:

java.io.IOException