@InterfaceAudience.Private public class LaunchMapper extends org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text> implements JobSubmissionConstants
org.apache.hadoop.mapreduce.Mapper.Context
JobSubmissionConstants.PigConstants, JobSubmissionConstants.Sqoop
COPY_NAME, ENABLE_JOB_RECONNECT, ENABLE_LOG, EXIT_FNAME, HADOOP_CLASSPATH, HADOOP_CLASSPATH_EXTRAS, HIVE_QUERY_TAG, HIVE_QUERY_TAG_ARG_PLACEHOLDER, JAR_ARGS_NAME, JOB_TYPE, KEEP_ALIVE_MSEC, MAPREDUCE_JOB_TAGS, MAPREDUCE_JOB_TAGS_ARG_PLACEHOLDER, OVERRIDE_CLASSPATH, POLL_JOBPROGRESS_MSEC, STATUSDIR_NAME, STDERR_FNAME, STDOUT_FNAME, TEMPLETON_JOB_LAUNCH_TIME_NAME, TOKEN_FILE_ARG_PLACEHOLDER, TOKEN_FILE_ARG_PLACEHOLDER_TEZ, WATCHER_TIMEOUT_SECS
Constructor and Description |
---|
LaunchMapper() |
Modifier and Type | Method and Description |
---|---|
void |
run(org.apache.hadoop.mapreduce.Mapper.Context context) |
protected Process |
startJob(org.apache.hadoop.mapreduce.Mapper.Context context,
String jobId,
String user,
String overrideClasspath,
LauncherDelegator.JobType jobType) |
protected Process startJob(org.apache.hadoop.mapreduce.Mapper.Context context, String jobId, String user, String overrideClasspath, LauncherDelegator.JobType jobType) throws IOException, InterruptedException
IOException
InterruptedException
public void run(org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException, InterruptedException
run
in class org.apache.hadoop.mapreduce.Mapper<org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.NullWritable,org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>
IOException
InterruptedException
Copyright © 2022 The Apache Software Foundation. All rights reserved.