org.kepler.hadoop.execution

Class KeplerApp4Match

java.lang.Object

org.kepler.hadoop.execution.KeplerAppBase

org.kepler.hadoop.execution.KeplerApp4Match

All Implemented Interfaces:

ExecutionListener

public class KeplerApp4Match
extends KeplerAppBase

This class will parse match 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
KeplerApp4Match(org.apache.hadoop.conf.Configuration hadoopConf)

Method Summary

Modifier and Type	Method and Description
java.util.List<KeyValuePair>	executeWf(org.apache.hadoop.io.WritableComparable key, org.apache.hadoop.io.Writable value1, 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

KeplerApp4Match

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

Method Detail

executeWf

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

Throws:

java.io.IOException