org.kepler.hadoop.execution

Class KeplerApp4Cross

java.lang.Object

org.kepler.hadoop.execution.KeplerAppBase

org.kepler.hadoop.execution.KeplerApp4Cross

All Implemented Interfaces:

ExecutionListener

public class KeplerApp4Cross
extends KeplerAppBase

This class will parse cross sub-workflow, execute it according to its input, and return execution output. and send it out through fire().

Author:

Jianwu Wang (jianwu@sdsc.edu)

Field Summary

Fields inherited from class org.kepler.hadoop.execution.KeplerAppBase

_keplerManagerException, _manager, _model, _runWorkflowLifecyclePerInput, _sinkActor, _sourceActor

Constructor Summary

Constructors

Constructor and Description
KeplerApp4Cross(org.apache.hadoop.conf.Configuration hadoopConf)

Method Summary

Modifier and Type	Method and Description
java.util.List<KeyValuePair>	executeWf(org.apache.hadoop.io.WritableComparable key1, org.apache.hadoop.io.Writable value1, org.apache.hadoop.io.WritableComparable key2, org.apache.hadoop.io.Writable value2)

Methods inherited from class org.kepler.hadoop.execution.KeplerAppBase

cleanup, executionError, executionFinished, managerStateChanged

Methods inherited from class java.lang.Object

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

Constructor Detail

KeplerApp4Cross

public KeplerApp4Cross(org.apache.hadoop.conf.Configuration hadoopConf)

Method Detail

executeWf

public java.util.List<KeyValuePair> executeWf(org.apache.hadoop.io.WritableComparable key1,
                                              org.apache.hadoop.io.Writable value1,
                                              org.apache.hadoop.io.WritableComparable key2,
                                              org.apache.hadoop.io.Writable value2)
                                       throws java.io.IOException

Throws:

java.io.IOException