com.asakusafw.yaess.multidispatch

Class ExecutionScriptHandlerDispatcher<T extends ExecutionScript>

java.lang.Object

com.asakusafw.yaess.multidispatch.ExecutionScriptHandlerDispatcher<T>

Type Parameters:

T - the target script kind

All Implemented Interfaces:

ExecutionScriptHandler<T>, Service

Direct Known Subclasses:

CommandScriptHandlerDispatcher, HadoopScriptHandlerDispatcher

public abstract class ExecutionScriptHandlerDispatcher<T extends ExecutionScript>
extends Object
implements ExecutionScriptHandler<T>

A Dispatcher implementation for ExecutionScriptHandler.

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

Modifier	Constructor and Description
protected	ExecutionScriptHandlerDispatcher(Class<? extends ExecutionScriptHandler<T>> handlerKind) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	cleanUp(ExecutionMonitor monitor, ExecutionContext context) Cleanup the target environment.
void	configure(ServiceProfile<?> profile) Configures this service.
void	execute(ExecutionMonitor monitor, ExecutionContext context, T script) Executes the specified script.
Map<String,String>	getEnvironmentVariables(ExecutionContext context, ExecutionScript script) Returns desired environment variables to execute scripts using this handler.
String	getHandlerId() Returns the ID of this handler.
Map<String,String>	getProperties(ExecutionContext context, ExecutionScript script) Returns desired system/hadoop properties to execute scripts using this handler.
String	getResourceId(ExecutionContext context, ExecutionScript script) Returns the ID of a resource which is used for executing this handler.
void	setUp(ExecutionMonitor monitor, ExecutionContext context) Setup the target environment.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionScriptHandlerDispatcher

protected ExecutionScriptHandlerDispatcher(Class<? extends ExecutionScriptHandler<T>> handlerKind)

Creates a new instance.

Parameters:

handlerKind - the handler kind

Throws:

IllegalArgumentException - if some parameters were null

Method Detail

configure

public void configure(ServiceProfile<?> profile)
               throws IOException,
                      InterruptedException

Description copied from interface: Service

Configures this service. This method will be invoked only once when this instance is created from the profile.

Specified by:

configure in interface Service

Parameters:

profile - the profile of this service

Throws:

IOException - if failed to configure this service

InterruptedException - if interrupted in configuration

getHandlerId

public String getHandlerId()

Description copied from interface: ExecutionScriptHandler

Returns the ID of this handler.

Specified by:

getHandlerId in interface ExecutionScriptHandler<T extends ExecutionScript>

Returns:

the ID

getResourceId

public String getResourceId(ExecutionContext context,
                            ExecutionScript script)
                     throws InterruptedException,
                            IOException

Description copied from interface: ExecutionScriptHandler

Returns the ID of a resource which is used for executing this handler.

Specified by:

getResourceId in interface ExecutionScriptHandler<T extends ExecutionScript>

Parameters:

context - the current execution context

script - the target script (nullable)

Returns:

the required resource ID

Throws:

InterruptedException - if this operation is interrupted

IOException - if failed to setup the target environment

getProperties

public Map<String,String> getProperties(ExecutionContext context,
                                        ExecutionScript script)
                                 throws InterruptedException,
                                        IOException

Description copied from interface: ExecutionScriptHandler

Returns desired system/hadoop properties to execute scripts using this handler.

Specified by:

getProperties in interface ExecutionScriptHandler<T extends ExecutionScript>

Parameters:

context - the current execution context

script - the target script (nullable)

Returns:

desired system or hadoop properties

Throws:

InterruptedException - if this operation is interrupted

IOException - if failed to setup the target environment

getEnvironmentVariables

public Map<String,String> getEnvironmentVariables(ExecutionContext context,
                                                  ExecutionScript script)
                                           throws InterruptedException,
                                                  IOException

Description copied from interface: ExecutionScriptHandler

Returns desired environment variables to execute scripts using this handler.

Specified by:

getEnvironmentVariables in interface ExecutionScriptHandler<T extends ExecutionScript>

Parameters:

context - the current execution context

script - the target script (nullable)

Returns:

desired environment variables

Throws:

InterruptedException - if this operation is interrupted

IOException - if failed to setup the target environment

setUp

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

Description copied from interface: ExecutionScriptHandler

Setup the target environment.

Specified by:

setUp in interface ExecutionScriptHandler<T extends ExecutionScript>

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

execute

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

Description copied from interface: ExecutionScriptHandler

Executes the specified script.

Specified by:

execute in interface ExecutionScriptHandler<T extends ExecutionScript>

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 interface: ExecutionScriptHandler

Cleanup the target environment.

Specified by:

cleanUp in interface ExecutionScriptHandler<T extends ExecutionScript>

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