com.asakusafw.yaess.jobqueue

Class QueueHadoopScriptHandler

java.lang.Object

com.asakusafw.yaess.core.ExecutionScriptHandlerBase

com.asakusafw.yaess.jobqueue.QueueHadoopScriptHandler

All Implemented Interfaces:

ExecutionScriptHandler<HadoopScript>, HadoopScriptHandler, Service

public class QueueHadoopScriptHandler
extends ExecutionScriptHandlerBase
implements HadoopScriptHandler

An implementation of HadoopScript using Job Queue client.

Since:

0.2.6

Field Summary

Fields inherited from interface com.asakusafw.yaess.core.ExecutionScriptHandler

DEFAULT_RESOURCE_ID, ENV_EXTENSION_PREFIX, KEY_ENV_PREFIX, KEY_PROP_PREFIX, KEY_RESOURCE

Constructor Summary

Constructors

Constructor and Description
QueueHadoopScriptHandler()

Method Summary

Modifier and Type	Method and Description
void	cleanUp(ExecutionMonitor monitor, ExecutionContext context) Cleanup the target environment.
protected void	doConfigure(ServiceProfile<?> profile, Map<String,String> desiredProperties, Map<String,String> desiredEnvironmentVariables) Configures this handler internally (extention point).
void	execute(ExecutionMonitor monitor, ExecutionContext context, HadoopScript script) Executes the specified script.

Methods inherited from class com.asakusafw.yaess.core.ExecutionScriptHandlerBase

configure, getEnvironmentVariables, getHandlerId, getProperties, getResourceId, setUp, voidCleanUp, voidSetUp

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.asakusafw.yaess.core.ExecutionScriptHandler

getEnvironmentVariables, getHandlerId, getProperties, getResourceId, setUp

Methods inherited from interface com.asakusafw.yaess.core.Service

configure

Constructor Detail

QueueHadoopScriptHandler

public QueueHadoopScriptHandler()

Method Detail

doConfigure

protected void doConfigure(ServiceProfile<?> profile,
                           Map<String,String> desiredProperties,
                           Map<String,String> desiredEnvironmentVariables)
                    throws InterruptedException,
                           IOException

Description copied from class: ExecutionScriptHandlerBase

Configures this handler internally (extention point).

Specified by:

doConfigure in class ExecutionScriptHandlerBase

Parameters:

profile - the profile of this service

desiredProperties - the current desired system/hadoop properties (configurable)

desiredEnvironmentVariables - the current desired environment variables (configurable)

Throws:

InterruptedException - if interrupted in configuration

IOException - if failed to configure this service

execute

public void execute(ExecutionMonitor monitor,
                    ExecutionContext context,
                    HadoopScript script)
             throws InterruptedException,
                    IOException

Description copied from interface: ExecutionScriptHandler

Executes the specified script.

Specified by:

execute in interface ExecutionScriptHandler<HadoopScript>

Parameters:

monitor - the progress monitor of the execution

context - current execution context

script - target script

Throws:

InterruptedException - if the execution was interrupted

IOException - if execution was failed

cleanUp

public void cleanUp(ExecutionMonitor monitor,
                    ExecutionContext context)
             throws InterruptedException,
                    IOException

Description copied from class: ExecutionScriptHandlerBase

Cleanup the target environment.

Specified by:

cleanUp in interface ExecutionScriptHandler<HadoopScript>

Overrides:

cleanUp in class ExecutionScriptHandlerBase

Parameters:

monitor - the progress monitor of the operation

context - the current execution context

Throws:

InterruptedException - if this operation is interrupted

IOException - if failed to setup the target environment