de.hpi.fgis.voidgen.hadoop.closure
Class ClosureDriver

java.lang.Object
  extended by de.hpi.fgis.voidgen.hadoop.Driver
      extended by de.hpi.fgis.voidgen.hadoop.closure.ClosureDriver
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class ClosureDriver
extends Driver

This class encapsulates the execution of MapReduce jobs for calculation of the transitive closure of the vertices within a graph.

This class is based on the transitive closure algorithm described by Dandy Fenz and Matthias Pohl within a MapReduce Seminar at HPI.

Author:
Johannes Gosda, Hasso Plattner Institute at University of Potsdam, Germany

Field Summary
static java.lang.String INPUT_FORMAT
          The input format of the initial input for the transitive closure job.
static java.lang.String INPUT_MAPPER
          The name of the mapper class for reading graph based data and applying initial cluster identifiers to each vertex of the graph.
static java.lang.String INPUT_PATHS
          The path containing the input.
static java.lang.String OUTPUT_PATH
          The path containing the output of the iterations of the transitive closure job.
 
Constructor Summary
ClosureDriver()
           
 
Method Summary
 org.apache.hadoop.fs.Path getOutputPath()
           
 int run(java.lang.String[] args)
           
 
Methods inherited from class de.hpi.fgis.voidgen.hadoop.Driver
getConf, getPath, getPaths, setConf
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

INPUT_MAPPER

public static final java.lang.String INPUT_MAPPER
The name of the mapper class for reading graph based data and applying initial cluster identifiers to each vertex of the graph.


INPUT_FORMAT

public static final java.lang.String INPUT_FORMAT
The input format of the initial input for the transitive closure job. The input format class must extend Class org.apache.hadoop.mapreduce.InputFormat


INPUT_PATHS

public static final java.lang.String INPUT_PATHS
The path containing the input.


OUTPUT_PATH

public static final java.lang.String OUTPUT_PATH
The path containing the output of the iterations of the transitive closure job.

Constructor Detail

ClosureDriver

public ClosureDriver()
Method Detail

run

public int run(java.lang.String[] args)
        throws java.lang.Exception
Throws:
java.lang.Exception

getOutputPath

public org.apache.hadoop.fs.Path getOutputPath()
Returns:
the path to the directory containing the clusters or null if this directory does not (yet) exist.