org.kepler.hadoop.execution

Class KeplerApp4CoGroup

java.lang.Object

org.kepler.hadoop.execution.KeplerAppBase

org.kepler.hadoop.execution.KeplerApp4CoGroup

All Implemented Interfaces:

ExecutionListener

public class KeplerApp4CoGroup
extends KeplerAppBase

This class will parse CoGroup 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
KeplerApp4CoGroup(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> values1, java.util.Iterator<org.apache.hadoop.io.Writable> values2)

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

KeplerApp4CoGroup

public KeplerApp4CoGroup(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> values1,
                                              java.util.Iterator<org.apache.hadoop.io.Writable> values2)
                                       throws java.io.IOException

Throws:

java.io.IOException