public class Submitter
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
LOG |
Constructor and Description |
---|
Submitter() |
Submitter(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
getExecutable(JobConf conf)
Get the URI of the application's executable.
|
static boolean |
getIsJavaMapper(JobConf conf)
Check whether the job is using a Java Mapper.
|
static boolean |
getIsJavaRecordReader(JobConf conf)
Check whether the job is using a Java RecordReader
|
static boolean |
getIsJavaRecordWriter(JobConf conf)
Will the reduce use a Java RecordWriter?
|
static boolean |
getIsJavaReducer(JobConf conf)
Check whether the job is using a Java Reducer.
|
static boolean |
getKeepCommandFile(JobConf conf)
Does the user want to keep the command file for debugging? If this is
true, pipes will write a copy of the command data to a file in the
task directory named "downlink.data", which may be used to run the C++
program under the debugger.
|
static RunningJob |
jobSubmit(JobConf conf)
Submit a job to the Map-Reduce framework.
|
static void |
main(java.lang.String[] args)
Submit a pipes job based on the command line arguments.
|
int |
run(java.lang.String[] args) |
static RunningJob |
runJob(JobConf conf)
Submit a job to the map/reduce cluster.
|
static void |
setExecutable(JobConf conf,
java.lang.String executable)
Set the URI for the application's executable.
|
static void |
setIsJavaMapper(JobConf conf,
boolean value)
Set whether the Mapper is written in Java.
|
static void |
setIsJavaRecordReader(JobConf conf,
boolean value)
Set whether the job is using a Java RecordReader.
|
static void |
setIsJavaRecordWriter(JobConf conf,
boolean value)
Set whether the job will use a Java RecordWriter.
|
static void |
setIsJavaReducer(JobConf conf,
boolean value)
Set whether the Reducer is written in Java.
|
static void |
setKeepCommandFile(JobConf conf,
boolean keep)
Set whether to keep the command file for debugging
|
static RunningJob |
submitJob(JobConf conf)
Deprecated.
Use
runJob(JobConf) |
public Submitter()
public Submitter(org.apache.hadoop.conf.Configuration conf)
public static java.lang.String getExecutable(JobConf conf)
conf
- public static void setExecutable(JobConf conf, java.lang.String executable)
conf
- executable
- The URI of the application's executable.public static void setIsJavaRecordReader(JobConf conf, boolean value)
conf
- the configuration to modifyvalue
- the new valuepublic static boolean getIsJavaRecordReader(JobConf conf)
conf
- the configuration to checkpublic static void setIsJavaMapper(JobConf conf, boolean value)
conf
- the configuration to modifyvalue
- the new valuepublic static boolean getIsJavaMapper(JobConf conf)
conf
- the configuration to checkpublic static void setIsJavaReducer(JobConf conf, boolean value)
conf
- the configuration to modifyvalue
- the new valuepublic static boolean getIsJavaReducer(JobConf conf)
conf
- the configuration to checkpublic static void setIsJavaRecordWriter(JobConf conf, boolean value)
conf
- the configuration to modifyvalue
- the new value to setpublic static boolean getIsJavaRecordWriter(JobConf conf)
conf
- the configuration to checkpublic static boolean getKeepCommandFile(JobConf conf)
conf
- the configuration to checkpublic static void setKeepCommandFile(JobConf conf, boolean keep)
conf
- the configuration to modifykeep
- the new value@Deprecated public static RunningJob submitJob(JobConf conf) throws java.io.IOException
runJob(JobConf)
conf
- the job to submit to the cluster (MODIFIED)java.io.IOException
public static RunningJob runJob(JobConf conf) throws java.io.IOException
conf
- the job to submit to the cluster (MODIFIED)java.io.IOException
public static RunningJob jobSubmit(JobConf conf) throws java.io.IOException
RunningJob
which can be used to track
the running-job.conf
- the job configuration.RunningJob
which can be used to track the
running-job.java.io.IOException
public int run(java.lang.String[] args) throws java.lang.Exception
run
in interface org.apache.hadoop.util.Tool
java.lang.Exception
public static void main(java.lang.String[] args) throws java.lang.Exception
args
- java.lang.Exception
Copyright © 2009 The Apache Software Foundation