|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.hadoop.conf.Configured
net.sf.eos.hadoop.mapred.AbstractEosDriver
public abstract class AbstractEosDriver
Support for some generic configuration data. The run(String[])
analyze the parameter "-s" or "--source" for the source
(input-Path) parameter and "-d" or "--dest" for
the destination (output-Path).
| Field Summary | |
|---|---|
static String |
DESTINATION_LONG_CMD_ARG
Long commandline parameter name for the destination or output path. |
static String |
DESTINATION_SHORT_CMD_ARG
Short commandline parameter name for the destination or output path. |
static String |
SOURCE_LONG_CMD_ARG
Long commandline parameter name for the source or input path. |
static String |
SOURCE_SHORT_CMD_ARG
Short commandline parameter name for the source or input path. |
| Constructor Summary | |
|---|---|
AbstractEosDriver()
|
|
| Method Summary | |
|---|---|
protected org.apache.commons.cli.Options |
createOptions()
|
protected int |
doJob(JobConf conf)
Runs the job for the given configuration. |
protected JobConf |
getJobConf()
Returns the job configuration. |
int |
run(String[] args)
Implementations of AbstractEosDriver must call
super.run(String[]). |
| 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 |
| Field Detail |
|---|
public static final String SOURCE_SHORT_CMD_ARG
public static final String SOURCE_LONG_CMD_ARG
public static final String DESTINATION_SHORT_CMD_ARG
public static final String DESTINATION_LONG_CMD_ARG
| Constructor Detail |
|---|
public AbstractEosDriver()
| Method Detail |
|---|
public int run(String[] args)
throws Exception
AbstractEosDriver must call
super.run(String[]). After the call getJobConf()
returns a value != null.
Never starts a job. This is part of the implementing driver.
run in interface ToolExceptionprotected final JobConf getJobConf()
run(String[]).
IllegalStateException - if called before run(String[])protected org.apache.commons.cli.Options createOptions()
protected int doJob(JobConf conf)
throws Exception
conf - the job configuration
Exception - if an error occurs
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||