org.apache.hadoop.contrib.utils.join
Class DataJoinJob

java.lang.Object
  extended by org.apache.hadoop.contrib.utils.join.DataJoinJob

public class DataJoinJob
extends java.lang.Object

This class implements the main function for creating a map/reduce job to join data of different sources. To create sucn a job, the user must implement a mapper class that extends DataJoinMapperBase class, and a reducer class that extends DataJoinReducerBase.


Constructor Summary
DataJoinJob()
           
 
Method Summary
static JobConf createDataJoinJob(java.lang.String[] args)
           
static java.lang.Class getClassByName(java.lang.String className)
           
static void main(java.lang.String[] args)
           
static boolean runJob(JobConf job)
          Submit/run a map/reduce job.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DataJoinJob

public DataJoinJob()
Method Detail

getClassByName

public static java.lang.Class getClassByName(java.lang.String className)

createDataJoinJob

public static JobConf createDataJoinJob(java.lang.String[] args)
                                 throws java.io.IOException
Throws:
java.io.IOException

runJob

public static boolean runJob(JobConf job)
                      throws java.io.IOException
Submit/run a map/reduce job.

Parameters:
job -
Returns:
true for success
Throws:
java.io.IOException

main

public static void main(java.lang.String[] args)
Parameters:
args -


Copyright © 2009 The Apache Software Foundation