@InterfaceAudience.Public @InterfaceStability.Stable public class Submitter extends Configured implements Tool
Modifier and Type | Field and Description |
---|---|
static String |
EXECUTABLE |
static String |
INPUT_FORMAT |
static String |
INTERPRETOR |
static String |
IS_JAVA_MAP |
static String |
IS_JAVA_REDUCE |
static String |
IS_JAVA_RR |
static String |
IS_JAVA_RW |
protected static org.apache.commons.logging.Log |
LOG |
static String |
PARTITIONER |
static String |
PORT |
static String |
PRESERVE_COMMANDFILE |
Constructor and Description |
---|
Submitter() |
Submitter(Configuration conf) |
Modifier and Type | Method and Description |
---|---|
static 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(String[] args)
Submit a pipes job based on the command line arguments.
|
int |
run(String[] args)
Execute the command with the given arguments.
|
static RunningJob |
runJob(JobConf conf)
Submit a job to the map/reduce cluster.
|
static void |
setExecutable(JobConf conf,
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) |
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConf, setConf
protected static final org.apache.commons.logging.Log LOG
public static final String PRESERVE_COMMANDFILE
public static final String EXECUTABLE
public static final String INTERPRETOR
public static final String IS_JAVA_MAP
public static final String IS_JAVA_RR
public static final String IS_JAVA_RW
public static final String IS_JAVA_REDUCE
public static final String PARTITIONER
public static final String INPUT_FORMAT
public static final String PORT
public Submitter()
public Submitter(Configuration conf)
public static String getExecutable(JobConf conf)
conf
- public static void setExecutable(JobConf conf, 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 IOException
runJob(JobConf)
conf
- the job to submit to the cluster (MODIFIED)IOException
public static RunningJob runJob(JobConf conf) throws IOException
conf
- the job to submit to the cluster (MODIFIED)IOException
public static RunningJob jobSubmit(JobConf conf) throws 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.IOException
public int run(String[] args) throws Exception
Tool
Copyright © 2015 Apache Software Foundation. All rights reserved.