org.kepler.hadoop.execution

Class KeplerApp4Reduce

java.lang.Object

org.kepler.hadoop.execution.KeplerAppBase

org.kepler.hadoop.execution.KeplerApp4Reduce

All Implemented Interfaces:

ExecutionListener

public class KeplerApp4Reduce
extends KeplerAppBase

This class will parse reduce sub-workflow, execute it according to its input, and return execution output.

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
KeplerApp4Reduce(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, java.util.Iterator<org.apache.hadoop.io.Writable> values)

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

KeplerApp4Reduce

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

Method Detail

executeWf

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

Throws:

java.io.IOException