com.asakusafw.runtime.mapreduce.simple

Class SimpleJobRunner

java.lang.Object

com.asakusafw.runtime.mapreduce.simple.SimpleJobRunner

All Implemented Interfaces:

JobRunner

public class SimpleJobRunner
extends Object
implements JobRunner

An implementation of JobRunner using simplified map-reduce engine.

Since:

0.7.1

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEY_BUFFER_SIZE Hadoop property key of shuffle buffer size.
static String	KEY_COMPRESS_BLOCK Hadoop property key of whether block file compression is enabled or not.
static String	KEY_TEMPORARY_LOCATION Hadoop property key of shuffle temporary directory.

Constructor Summary

Constructors

Constructor and Description
SimpleJobRunner()

Method Summary

Modifier and Type	Method and Description
boolean	run(org.apache.hadoop.mapreduce.Job job) Runs the target job.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

KEY_BUFFER_SIZE

public static final String KEY_BUFFER_SIZE

Hadoop property key of shuffle buffer size.

See Also:

Constant Field Values

KEY_TEMPORARY_LOCATION

public static final String KEY_TEMPORARY_LOCATION

Hadoop property key of shuffle temporary directory.

See Also:

Constant Field Values

KEY_COMPRESS_BLOCK

public static final String KEY_COMPRESS_BLOCK

Hadoop property key of whether block file compression is enabled or not.

See Also:

Constant Field Values

Constructor Detail

SimpleJobRunner

public SimpleJobRunner()

Method Detail

run

public boolean run(org.apache.hadoop.mapreduce.Job job)
            throws InterruptedException

Description copied from interface: JobRunner

Runs the target job.

Specified by:

run in interface JobRunner

Parameters:

job - the configured job object

Returns:

true if the job was successfully completed, or false otherwise

Throws:

InterruptedException - if interrupted while executing the job

toString

public String toString()

Overrides:

toString in class Object