org.kepler.stratosphere.stub

Class KeplerCoGroupStub

java.lang.Object

eu.stratosphere.api.common.functions.AbstractFunction

eu.stratosphere.api.java.record.functions.CoGroupFunction

org.kepler.stratosphere.stub.KeplerCoGroupStub

All Implemented Interfaces:

eu.stratosphere.api.common.functions.Function, eu.stratosphere.api.common.functions.GenericCoGrouper<eu.stratosphere.types.Record,eu.stratosphere.types.Record,eu.stratosphere.types.Record>, ExecutionListener

public class KeplerCoGroupStub
extends eu.stratosphere.api.java.record.functions.CoGroupFunction
implements ExecutionListener

A PACT CoGroup stub that runs a Kepler workflow. The workflow is loaded in configure(), and executed each time coGroup() is called.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
KeplerCoGroupStub()

Method Summary

Modifier and Type	Method and Description
void	close() Free resources.
void	coGroup(java.util.Iterator<eu.stratosphere.types.Record> records1, java.util.Iterator<eu.stratosphere.types.Record> records2, eu.stratosphere.util.Collector<eu.stratosphere.types.Record> out) Transfer the data from Stratosphere to Kepler, execute the workflow, and then transfer the data from Kepler to Stratosphere.
void	executionError(Manager manager, java.lang.Throwable throwable) Report workflow execution errors to the log.
void	executionFinished(Manager manager) Do nothing.
void	managerStateChanged(Manager manager) Do nothing.
void	open(eu.stratosphere.configuration.Configuration parameters) Configure the stub by loading the workflow and setting the PACT data types from the workflow stub actors.

Methods inherited from class eu.stratosphere.api.java.record.functions.CoGroupFunction

combineFirst, combineSecond

Methods inherited from class eu.stratosphere.api.common.functions.AbstractFunction

getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Methods inherited from interface eu.stratosphere.api.common.functions.Function

getRuntimeContext, setRuntimeContext

Constructor Detail

KeplerCoGroupStub

public KeplerCoGroupStub()

Method Detail

close

public void close()
           throws java.lang.Exception

Free resources.

Specified by:

close in interface eu.stratosphere.api.common.functions.Function

Overrides:

close in class eu.stratosphere.api.common.functions.AbstractFunction

Throws:

java.lang.Exception

open

public void open(eu.stratosphere.configuration.Configuration parameters)
          throws java.lang.Exception

Configure the stub by loading the workflow and setting the PACT data types from the workflow stub actors.

Specified by:

open in interface eu.stratosphere.api.common.functions.Function

Overrides:

open in class eu.stratosphere.api.common.functions.AbstractFunction

Throws:

java.lang.Exception

coGroup

public void coGroup(java.util.Iterator<eu.stratosphere.types.Record> records1,
                    java.util.Iterator<eu.stratosphere.types.Record> records2,
                    eu.stratosphere.util.Collector<eu.stratosphere.types.Record> out)
             throws java.lang.Exception

Transfer the data from Stratosphere to Kepler, execute the workflow, and then transfer the data from Kepler to Stratosphere.

Specified by:

coGroup in interface eu.stratosphere.api.common.functions.GenericCoGrouper<eu.stratosphere.types.Record,eu.stratosphere.types.Record,eu.stratosphere.types.Record>

Specified by:

coGroup in class eu.stratosphere.api.java.record.functions.CoGroupFunction

Throws:

java.lang.Exception

executionError

public void executionError(Manager manager,
                           java.lang.Throwable throwable)

Report workflow execution errors to the log.

Specified by:

executionError in interface ExecutionListener

Parameters:

manager - The manager controlling the execution.

throwable - The throwable to report.

executionFinished

public void executionFinished(Manager manager)

Do nothing.

Specified by:

executionFinished in interface ExecutionListener

Parameters:

manager - The manager controlling the execution.

managerStateChanged

public void managerStateChanged(Manager manager)

Do nothing.

Specified by:

managerStateChanged in interface ExecutionListener

Parameters:

manager - The manager controlling the execution.

See Also:

Manager.getState()