public class SleepJob extends Object
Modifier and Type | Class and Description |
---|---|
static class |
GridmixJob.DraftPartitioner<V> |
static class |
GridmixJob.SpecGroupingComparator |
static class |
SleepJob.SleepInputFormat |
static class |
SleepJob.SleepMapper |
static class |
SleepJob.SleepReducer |
static class |
SleepJob.SleepSplit |
Modifier and Type | Field and Description |
---|---|
protected static String |
GRIDMIX_DEFAULT_QUEUE |
protected static String |
GRIDMIX_JOB_SEQ |
static String |
GRIDMIX_SLEEP_INTERVAL
Interval at which to report progress, in seconds.
|
static String |
GRIDMIX_SLEEP_MAX_MAP_TIME |
static String |
GRIDMIX_SLEEP_MAX_REDUCE_TIME |
protected static String |
GRIDMIX_USE_QUEUE_IN_TRACE |
protected org.apache.hadoop.mapreduce.Job |
job |
static String |
JOB_NAME_PREFIX |
protected org.apache.hadoop.tools.rumen.JobStory |
jobdesc |
static org.apache.commons.logging.Log |
LOG |
protected org.apache.hadoop.fs.Path |
outdir |
protected int |
seq |
static String |
SLEEPJOB_MAPTASK_ONLY |
protected long |
submissionTimeNanos |
protected org.apache.hadoop.security.UserGroupInformation |
ugi |
Constructor and Description |
---|
SleepJob(org.apache.hadoop.conf.Configuration conf,
long submissionMillis,
org.apache.hadoop.tools.rumen.JobStory jobdesc,
org.apache.hadoop.fs.Path outRoot,
org.apache.hadoop.security.UserGroupInformation ugi,
int seq,
int numLocations,
String[] hosts) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.Job |
call() |
protected boolean |
canEmulateCompression()
Indicates whether this
GridmixJob supports compression emulation. |
int |
compareTo(Delayed other) |
protected static void |
configureTaskJVMOptions(org.apache.hadoop.conf.Configuration originalJobConf,
org.apache.hadoop.conf.Configuration simulatedJobConf) |
boolean |
equals(Object other) |
long |
getDelay(TimeUnit unit) |
org.apache.hadoop.security.UserGroupInformation |
getUgi() |
int |
hashCode() |
String |
toString() |
public static final org.apache.commons.logging.Log LOG
public static final String SLEEPJOB_MAPTASK_ONLY
public static final String GRIDMIX_SLEEP_INTERVAL
public static final String GRIDMIX_SLEEP_MAX_MAP_TIME
public static final String GRIDMIX_SLEEP_MAX_REDUCE_TIME
public static final String JOB_NAME_PREFIX
protected final int seq
protected final org.apache.hadoop.fs.Path outdir
protected final org.apache.hadoop.mapreduce.Job job
protected final org.apache.hadoop.tools.rumen.JobStory jobdesc
protected final org.apache.hadoop.security.UserGroupInformation ugi
protected final long submissionTimeNanos
protected static final String GRIDMIX_JOB_SEQ
protected static final String GRIDMIX_USE_QUEUE_IN_TRACE
protected static final String GRIDMIX_DEFAULT_QUEUE
public SleepJob(org.apache.hadoop.conf.Configuration conf, long submissionMillis, org.apache.hadoop.tools.rumen.JobStory jobdesc, org.apache.hadoop.fs.Path outRoot, org.apache.hadoop.security.UserGroupInformation ugi, int seq, int numLocations, String[] hosts) throws IOException
IOException
protected boolean canEmulateCompression()
GridmixJob
supports compression emulation.public org.apache.hadoop.mapreduce.Job call() throws IOException, InterruptedException, ClassNotFoundException
protected static void configureTaskJVMOptions(org.apache.hadoop.conf.Configuration originalJobConf, org.apache.hadoop.conf.Configuration simulatedJobConf)
public org.apache.hadoop.security.UserGroupInformation getUgi()
public int compareTo(Delayed other)
compareTo
in interface Comparable<Delayed>
Copyright © 2015 Apache Software Foundation. All Rights Reserved.