@InterfaceAudience.Public @InterfaceStability.Stable public class Submitter extends Configured implements Tool
| 修飾子とタイプ | フィールドと説明 | 
|---|---|
| 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 | 
| コンストラクタと説明 | 
|---|
| Submitter() | 
| Submitter(Configuration conf) | 
| 修飾子とタイプ | メソッドと説明 | 
|---|---|
| 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? | 
| 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)非推奨です。 
 Use  runJob(JobConf) | 
getConf, setConfclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetConf, setConfprotected 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 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)IOExceptionpublic static RunningJob runJob(JobConf conf) throws IOException
conf - the job to submit to the cluster (MODIFIED)IOExceptionpublic 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.IOExceptionpublic int run(String[] args) throws Exception
ToolCopyright © 2016 Apache Software Foundation. All rights reserved.