org.kepler.stratosphere.stub

Class KeplerCrossStub

java.lang.Object

eu.stratosphere.api.common.functions.AbstractFunction

eu.stratosphere.api.java.record.functions.CrossFunction

org.kepler.stratosphere.stub.KeplerCrossStub

All Implemented Interfaces:

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

public class KeplerCrossStub
extends eu.stratosphere.api.java.record.functions.CrossFunction
implements ExecutionListener

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

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
KeplerCrossStub()

Method Summary

Modifier and Type	Method and Description
void	close() Free resources.
void	cross(eu.stratosphere.types.Record record1, eu.stratosphere.types.Record record2, 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.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

KeplerCrossStub

public KeplerCrossStub()

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

cross

public void cross(eu.stratosphere.types.Record record1,
                  eu.stratosphere.types.Record record2,
                  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:

cross in interface eu.stratosphere.api.common.functions.GenericCrosser<eu.stratosphere.types.Record,eu.stratosphere.types.Record,eu.stratosphere.types.Record>

Specified by:

cross in class eu.stratosphere.api.java.record.functions.CrossFunction

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()