|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectde.hpi.fgis.voidgen.hadoop.Driver
de.hpi.fgis.voidgen.hadoop.closure.ClosureDriver
public class ClosureDriver
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.
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 |
---|
public static final java.lang.String INPUT_MAPPER
public static final java.lang.String INPUT_FORMAT
public static final java.lang.String INPUT_PATHS
public static final java.lang.String OUTPUT_PATH
Constructor Detail |
---|
public ClosureDriver()
Method Detail |
---|
public int run(java.lang.String[] args) throws java.lang.Exception
java.lang.Exception
public org.apache.hadoop.fs.Path getOutputPath()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |