org.kepler.stratosphere.stub

Class KeplerCombineAndReduceStub

java.lang.Object

eu.stratosphere.api.common.functions.AbstractFunction

eu.stratosphere.api.java.record.functions.ReduceFunction

org.kepler.stratosphere.stub.KeplerReduceStub

org.kepler.stratosphere.stub.KeplerCombineAndReduceStub

All Implemented Interfaces:

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

public class KeplerCombineAndReduceStub
extends KeplerReduceStub
implements ExecutionListener

A PACT Reduce stub that runs a Kepler workflow. This stub is used for both Combine and Reduce.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
KeplerCombineAndReduceStub()

Method Summary

Modifier and Type	Method and Description
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 org.kepler.stratosphere.stub.KeplerReduceStub

close, executionError, executionFinished, managerStateChanged, reduce

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

combine

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 ptolemy.actor.ExecutionListener

executionError, executionFinished, managerStateChanged

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

getRuntimeContext, setRuntimeContext

Constructor Detail

KeplerCombineAndReduceStub

public KeplerCombineAndReduceStub()

Method Detail

open

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

Description copied from class: KeplerReduceStub

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 KeplerReduceStub

Throws:

java.lang.Exception