org.kepler.stratosphere.stub

Class ScriptEngineReduceStub

java.lang.Object

eu.stratosphere.api.common.functions.AbstractFunction

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

org.kepler.stratosphere.stub.ScriptEngineReduceStub

All Implemented Interfaces:

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

public class ScriptEngineReduceStub
extends eu.stratosphere.api.java.record.functions.ReduceFunction

A Stratosphere Reduce stub that executes a ScriptEngine. The engine is loaded in configure(), and the reduce() function invoked each time this class's reduce() is called.

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
ScriptEngineReduceStub()

Method Summary

Modifier and Type	Method and Description
void	close()
void	open(eu.stratosphere.configuration.Configuration parameters)
void	reduce(java.util.Iterator<eu.stratosphere.types.Record> records, eu.stratosphere.util.Collector<eu.stratosphere.types.Record> out)

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 eu.stratosphere.api.common.functions.Function

getRuntimeContext, setRuntimeContext

Constructor Detail

ScriptEngineReduceStub

public ScriptEngineReduceStub()

Method Detail

close

public void close()
           throws java.lang.Exception

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

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

reduce

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

Specified by:

reduce in interface eu.stratosphere.api.common.functions.GenericReducer<eu.stratosphere.types.Record,eu.stratosphere.types.Record>

Specified by:

reduce in class eu.stratosphere.api.java.record.functions.ReduceFunction

Throws:

java.lang.Exception