org.apache.hadoop.tools.dynamometer.workloadgenerator

Class WorkloadDriver

java.lang.Object

org.apache.hadoop.conf.Configured

org.apache.hadoop.tools.dynamometer.workloadgenerator.WorkloadDriver

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.util.Tool

public class WorkloadDriver
extends org.apache.hadoop.conf.Configured
implements org.apache.hadoop.util.Tool

This is the driver for generating generic workloads against a NameNode under test. It launches a map-only job with a mapper class specified by the "mapper_class_name" argument. See the specific mappers (currently AuditReplayMapper and CreateFileMapper) for information on their specific behavior and parameters.

Field Summary

Fields

Modifier and Type	Field and Description
static String	MAPPER_CLASS_NAME
static String	NN_URI
static String	START_TIME_OFFSET
static String	START_TIME_OFFSET_DEFAULT
static String	START_TIMESTAMP_MS

Constructor Summary

Constructors

Constructor and Description
WorkloadDriver()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.mapreduce.Job	getJobForSubmission(org.apache.hadoop.conf.Configuration baseConf, String nnURI, long startTimestampMs, Class<? extends WorkloadMapper<?,?,?,?>> mapperClass)
static void	main(String[] args)
int	run(String[] args)

Methods inherited from class org.apache.hadoop.conf.Configured

getConf, setConf

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.conf.Configurable

getConf, setConf

Field Detail

START_TIMESTAMP_MS

public static final String START_TIMESTAMP_MS

See Also:

Constant Field Values

START_TIME_OFFSET

public static final String START_TIME_OFFSET

See Also:

Constant Field Values

START_TIME_OFFSET_DEFAULT

public static final String START_TIME_OFFSET_DEFAULT

See Also:

Constant Field Values

NN_URI

public static final String NN_URI

See Also:

Constant Field Values

MAPPER_CLASS_NAME

public static final String MAPPER_CLASS_NAME

See Also:

Constant Field Values

Constructor Detail

WorkloadDriver

public WorkloadDriver()

Method Detail

run

public int run(String[] args)
        throws Exception

Specified by:

run in interface org.apache.hadoop.util.Tool

Throws:

Exception

getJobForSubmission

public static org.apache.hadoop.mapreduce.Job getJobForSubmission(org.apache.hadoop.conf.Configuration baseConf,
                                                                  String nnURI,
                                                                  long startTimestampMs,
                                                                  Class<? extends WorkloadMapper<?,?,?,?>> mapperClass)
                                                           throws IOException,
                                                                  InstantiationException,
                                                                  IllegalAccessException

Throws:

IOException

InstantiationException

IllegalAccessException

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception