org.kepler.spark.stub

Class ScriptEnginePairFlatMapFunction<T,K,V>

java.lang.Object

org.kepler.spark.stub.PairFlatMapFunctionBase<T,K,V>

org.kepler.spark.stub.ScriptEnginePairFlatMapFunction<T,K,V>

All Implemented Interfaces:

java.io.Externalizable, java.io.Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<T,K,V>

Direct Known Subclasses:

ScriptEngineMapStub, ScriptEngineReduceStub

public abstract class ScriptEnginePairFlatMapFunction<T,K,V>
extends PairFlatMapFunctionBase<T,K,V>

A Spark stub base class for executing a ScriptEngine.

Author:

Daniel Crawl

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected javax.script.Invocable	_invocable Interface to execute functions in scripts.
protected java.util.List<?>	_resultKeys A list of result keys.
protected java.util.List<?>	_resultValues A list of result values.

Fields inherited from class org.kepler.spark.stub.PairFlatMapFunctionBase

_parameters

Constructor Summary

Constructors

Constructor and Description
ScriptEnginePairFlatMapFunction()

Method Summary

Modifier and Type	Method and Description
protected void	_cleanup() Free resources.
protected void	_initialize() Configure the stub by loading the workflow and initialize the class fields.

Methods inherited from class org.kepler.spark.stub.PairFlatMapFunctionBase

readExternal, setConfiguration, writeExternal

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.spark.api.java.function.PairFlatMapFunction

call

Field Detail

_invocable

protected javax.script.Invocable _invocable

Interface to execute functions in scripts.

_resultKeys

protected java.util.List<?> _resultKeys

A list of result keys.

_resultValues

protected java.util.List<?> _resultValues

A list of result values.

Constructor Detail

ScriptEnginePairFlatMapFunction

public ScriptEnginePairFlatMapFunction()

Method Detail

_cleanup

protected void _cleanup()
                 throws java.lang.Exception

Free resources.

Throws:

java.lang.Exception

_initialize

protected void _initialize()
                    throws java.lang.Exception

Configure the stub by loading the workflow and initialize the class fields.

Throws:

java.lang.Exception