com.asakusafw.runtime.stage.inprocess

Class InProcessStageConfigurator

java.lang.Object

com.asakusafw.runtime.stage.StageConfigurator

com.asakusafw.runtime.stage.inprocess.InProcessStageConfigurator

public class InProcessStageConfigurator
extends StageConfigurator

Configures SimpleJobRunner.

Since:

0.7.1

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEY_FORCE Always enables in-process execution even.
static String	KEY_LIMIT Hadoop property key of the max input data size for in-process job execution.

Constructor Summary

Constructors

Constructor and Description
InProcessStageConfigurator()

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapreduce.Job job) Configures the target job.

Methods inherited from class java.lang.Object

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

Field Detail

KEY_LIMIT

public static final String KEY_LIMIT

Hadoop property key of the max input data size for in-process job execution.

See Also:

Constant Field Values

KEY_FORCE

public static final String KEY_FORCE

Always enables in-process execution even.

See Also:

Constant Field Values

Constructor Detail

InProcessStageConfigurator

public InProcessStageConfigurator()

Method Detail

configure

public void configure(org.apache.hadoop.mapreduce.Job job)
               throws IOException,
                      InterruptedException

Description copied from class: StageConfigurator

Configures the target job.

Specified by:

configure in class StageConfigurator

Parameters:

job - the target Job object

Throws:

IOException - if failed to configure the job

InterruptedException - if interrupted while configuring Job object