org.kepler.hadoop.execution

Class KeplerAppBase

java.lang.Object

org.kepler.hadoop.execution.KeplerAppBase

All Implemented Interfaces:

ExecutionListener

Direct Known Subclasses:

KeplerApp4CoGroup, KeplerApp4Cross, KeplerApp4Map, KeplerApp4Match, KeplerApp4Reduce

public class KeplerAppBase
extends java.lang.Object
implements ExecutionListener

A base class for Hadoop stubs that execute Kepler workflows.

Author:

Daniel Crawl

Field Summary

Fields

Modifier and Type	Field and Description
protected java.io.IOException	_keplerManagerException If the workflow is running in a separate thread (_runWorkflowLifecyclePerInput = false) and an exception is thrown, this field is set to that exception.
protected Manager	_manager Manager to execute the workflow.
protected CompositeActor	_model The workflow to execute.
protected boolean	_runWorkflowLifecyclePerInput If true, the entire workflow lifecycle is executed for each input.
protected StubSinkActor	_sinkActor The actor reading output from the workflow.
protected StubSourceActor	_sourceActor The actor writing input to the workflow.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	KeplerAppBase(org.apache.hadoop.conf.Configuration hadoopConf, java.lang.String sourceActorName, java.lang.String sinkActorName) Create a new KeplerAppBase.

Method Summary

Modifier and Type	Method and Description
void	cleanup() Perform cleanup after all inputs are processed.
void	executionError(Manager manager, java.lang.Throwable throwable) Report an execution failure.
void	executionFinished(Manager manager) Report that the current execution has finished and the wrapup sequence has completed normally.
void	managerStateChanged(Manager manager) Report that the manager has changed state.

Methods inherited from class java.lang.Object

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

Field Detail

_model

protected CompositeActor _model

The workflow to execute.

_manager

protected Manager _manager

Manager to execute the workflow.

_runWorkflowLifecyclePerInput

protected boolean _runWorkflowLifecyclePerInput

If true, the entire workflow lifecycle is executed for each input.

_sourceActor

protected StubSourceActor _sourceActor

The actor writing input to the workflow.

_sinkActor

protected StubSinkActor _sinkActor

The actor reading output from the workflow.

_keplerManagerException

protected java.io.IOException _keplerManagerException

If the workflow is running in a separate thread (_runWorkflowLifecyclePerInput = false) and an exception is thrown, this field is set to that exception.

Constructor Detail

KeplerAppBase

protected KeplerAppBase(org.apache.hadoop.conf.Configuration hadoopConf,
                        java.lang.String sourceActorName,
                        java.lang.String sinkActorName)

Create a new KeplerAppBase.

Parameters:

hadoopConf - the hadoop configuration object.

sourceActorName - the name of the source actor in the workflow.

sinkActorName - the name of the sink actor in the workflow.

Method Detail

cleanup

public void cleanup()
             throws java.lang.InterruptedException

Perform cleanup after all inputs are processed.

Throws:

java.lang.InterruptedException

executionError

public void executionError(Manager manager,
                           java.lang.Throwable throwable)

Description copied from interface: ExecutionListener

Report an execution failure. This method will be called when an exception or error is caught by a manager. Exceptions are reported this way when the run() or startRun() methods of the manager are used to perform the execution. If instead the execute() method is used, then exceptions are not caught, and are instead just passed up to the caller of the execute() method. Those exceptions are not reported here (unless, of course, the caller of the execute() method does so).

Specified by:

executionError in interface ExecutionListener

Parameters:

manager - The manager controlling the execution.

throwable - The throwable to report.

executionFinished

public void executionFinished(Manager manager)

Description copied from interface: ExecutionListener

Report that the current execution has finished and the wrapup sequence has completed normally. The number of successfully completed iterations can be obtained by calling getIterationCount() on the manager.

Specified by:

executionFinished in interface ExecutionListener

Parameters:

manager - The manager controlling the execution.

managerStateChanged

public void managerStateChanged(Manager manager)

Description copied from interface: ExecutionListener

Report that the manager has changed state. To access the new state, use the getState() method of Manager.

Specified by:

managerStateChanged in interface ExecutionListener

Parameters:

manager - The manager controlling the execution.

See Also:

Manager.getState()