com.asakusafw.runtime.flow

Class RuntimeResourceManager

java.lang.Object

org.apache.hadoop.conf.Configured

com.asakusafw.runtime.flow.RuntimeResourceManager

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable

public class RuntimeResourceManager
extends org.apache.hadoop.conf.Configured

Manages lifecycle of RuntimeResource objects.

Since:

0.1.0

Version:

0.7.3

Field Summary

Fields

Modifier and Type	Field and Description
static String	CONFIGURATION_FILE_NAME The standard name of the framework configuration file.
static String	CONFIGURATION_FILE_PATH The path to configuration file (relative from $ASAKUSA_HOME).

Constructor Summary

Constructors

Constructor and Description
RuntimeResourceManager(org.apache.hadoop.conf.Configuration configuration) Creates a new instance.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Finalizes and releases the managed resources.
protected List<RuntimeResource>	load() Loads the available resources.
void	setup() Initializes the managed resources.

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

Field Detail

CONFIGURATION_FILE_NAME

public static final String CONFIGURATION_FILE_NAME

The standard name of the framework configuration file.

See Also:

Constant Field Values

CONFIGURATION_FILE_PATH

public static final String CONFIGURATION_FILE_PATH

The path to configuration file (relative from $ASAKUSA_HOME).

Since:

0.2.5

See Also:

Constant Field Values

Constructor Detail

RuntimeResourceManager

public RuntimeResourceManager(org.apache.hadoop.conf.Configuration configuration)

Creates a new instance.

Parameters:

configuration - the current configuration

Throws:

IllegalArgumentException - if the parameter is null

Method Detail

setup

public void setup()
           throws IOException,
                  InterruptedException

Initializes the managed resources.

Throws:

IOException - if failed to initialize resources

InterruptedException - if interrupted while initializing resources

IllegalArgumentException - if the configuration is something wrong

IllegalStateException - if the current lifecycle is something wrong

cleanup

public void cleanup()
             throws IOException,
                    InterruptedException

Finalizes and releases the managed resources.

Throws:

IOException - if failed to finalize resources

InterruptedException - if interrupted while initializing resources

IllegalArgumentException - if the configuration is something wrong

IllegalStateException - if the current lifecycle is something wrong

load

protected List<RuntimeResource> load()
                              throws IOException

Loads the available resources. In this implementation, the method collects service information from META-INF/services/com.asakusafw.runtime.core.RuntimeResource and creates RuntimeResource implementations on them via SPI.

Returns:

the loaded resources

Throws:

IOException - if failed to load the resources