org.kepler.hadoop.execution

Class KeplerApp4Map

java.lang.Object

org.kepler.hadoop.execution.KeplerAppBase

org.kepler.hadoop.execution.KeplerApp4Map

All Implemented Interfaces:

ExecutionListener

public class KeplerApp4Map
extends KeplerAppBase

This class will parse map 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
KeplerApp4Map(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 value, java.lang.String path, java.lang.String taskID)

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

KeplerApp4Map

public KeplerApp4Map(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 value,
                                              java.lang.String path,
                                              java.lang.String taskID)
                                       throws java.io.IOException

Throws:

java.io.IOException