edu.yale.cs.hadoopdb.exec
Class HDFSJobBase

java.lang.Object
  extended by org.apache.hadoop.conf.Configured
      extended by edu.yale.cs.hadoopdb.exec.HDFSJobBase
All Implemented Interfaces:
org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool
Direct Known Subclasses:
AggTaskLargeHDFS, AggTaskSmallHDFS, GlobalHasher, GrepTaskHDFS, JoinTaskHDFS, SelectionTaskHDFS, UDFAggTaskHDFS

public abstract class HDFSJobBase
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

HDFSJobBase is an abstract class for MapReduce jobs that read data from HDFS. Extensions need to configure jobs by implementing configure and implementing necessary Map/Reduce functions.


Constructor Summary
HDFSJobBase()
           
 
Method Summary
protected abstract  org.apache.hadoop.mapred.JobConf configureJob(java.lang.String... args)
          Override this method to set job-specific options
 int printHDFSUsage()
           
protected abstract  int printUsage()
          Provide job-specific command-line help
 int run(java.lang.String[] args)
           
 
Methods inherited from class org.apache.hadoop.conf.Configured
getConf, setConf
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.hadoop.conf.Configurable
getConf, setConf
 

Constructor Detail

HDFSJobBase

public HDFSJobBase()
Method Detail

configureJob

protected abstract org.apache.hadoop.mapred.JobConf configureJob(java.lang.String... args)
                                                          throws java.lang.Exception
Override this method to set job-specific options

Throws:
java.lang.Exception

printHDFSUsage

public int printHDFSUsage()

printUsage

protected abstract int printUsage()
Provide job-specific command-line help


run

public int run(java.lang.String[] args)
        throws java.lang.Exception
Specified by:
run in interface org.apache.hadoop.util.Tool
Throws:
java.lang.Exception