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 Job |
job |
static String |
JOB_NAME_PREFIX |
protected JobStory |
jobdesc |
static org.apache.commons.logging.Log |
LOG |
protected Path |
outdir |
protected int |
seq |
static String |
SLEEPJOB_MAPTASK_ONLY |
protected long |
submissionTimeNanos |
protected UserGroupInformation |
ugi |
Constructor and Description |
---|
SleepJob(Configuration conf,
long submissionMillis,
JobStory jobdesc,
Path outRoot,
UserGroupInformation ugi,
int seq,
int numLocations,
String[] hosts) |
Modifier and Type | Method and Description |
---|---|
Job |
call() |
protected boolean |
canEmulateCompression()
Indicates whether this
GridmixJob supports compression emulation. |
int |
compareTo(Delayed other) |
protected static void |
configureTaskJVMOptions(Configuration originalJobConf,
Configuration simulatedJobConf) |
boolean |
equals(Object other) |
long |
getDelay(TimeUnit unit) |
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 Path outdir
protected final Job job
protected final JobStory jobdesc
protected final 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(Configuration conf, long submissionMillis, JobStory jobdesc, Path outRoot, UserGroupInformation ugi, int seq, int numLocations, String[] hosts) throws IOException
IOException
protected boolean canEmulateCompression()
GridmixJob
supports compression emulation.public Job call() throws IOException, InterruptedException, ClassNotFoundException
protected static void configureTaskJVMOptions(Configuration originalJobConf, Configuration simulatedJobConf)
public UserGroupInformation getUgi()
public int compareTo(Delayed other)
compareTo
in interface Comparable<Delayed>
Copyright © 2013 Apache Software Foundation. All rights reserved.