org.kepler.stratosphere.stub

Class ScriptEngineMapStub

java.lang.Object

eu.stratosphere.api.common.functions.AbstractFunction

eu.stratosphere.api.java.record.functions.MapFunction

org.kepler.stratosphere.stub.ScriptEngineMapStub

All Implemented Interfaces:

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

public class ScriptEngineMapStub
extends eu.stratosphere.api.java.record.functions.MapFunction

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

Author:

Daniel Crawl

Constructor Summary

Constructors

Constructor and Description
ScriptEngineMapStub()

Method Summary

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

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

ScriptEngineMapStub

public ScriptEngineMapStub()

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

map

public void map(eu.stratosphere.types.Record record,
                eu.stratosphere.util.Collector<eu.stratosphere.types.Record> out)
         throws java.lang.Exception

Specified by:

map in interface eu.stratosphere.api.common.functions.GenericMapper<eu.stratosphere.types.Record,eu.stratosphere.types.Record>

Specified by:

map in class eu.stratosphere.api.java.record.functions.MapFunction

Throws:

java.lang.Exception