org.kepler.spark.stub

Class PairFlatMapFunctionBase<T,K,V>

java.lang.Object

org.kepler.spark.stub.PairFlatMapFunctionBase<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:

KeplerPairFlatMapFunction, ScriptEnginePairFlatMapFunction

public abstract class PairFlatMapFunctionBase<T,K,V>
extends java.lang.Object
implements org.apache.spark.api.java.function.PairFlatMapFunction<T,K,V>, java.io.Externalizable

A base class for PairFlatMapFunctions used in Kepler.

Author:

Daniel Crawl

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.hadoop.conf.Configuration	_parameters Configuration parameters.

Constructor Summary

Constructors

Constructor and Description
PairFlatMapFunctionBase()

Method Summary

Modifier and Type	Method and Description
void	readExternal(java.io.ObjectInput in) Deserialize the configuration.
void	setConfiguration(org.apache.hadoop.conf.Configuration parameters) Set the configuration parameters.
void	writeExternal(java.io.ObjectOutput out) Serialize the configuration.

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

_parameters

protected org.apache.hadoop.conf.Configuration _parameters

Configuration parameters.

Constructor Detail

PairFlatMapFunctionBase

public PairFlatMapFunctionBase()

Method Detail

setConfiguration

public void setConfiguration(org.apache.hadoop.conf.Configuration parameters)

Set the configuration parameters.

readExternal

public void readExternal(java.io.ObjectInput in)
                  throws java.io.IOException,
                         java.lang.ClassNotFoundException

Deserialize the configuration.

Specified by:

readExternal in interface java.io.Externalizable

Throws:

java.io.IOException

java.lang.ClassNotFoundException

writeExternal

public void writeExternal(java.io.ObjectOutput out)
                   throws java.io.IOException

Serialize the configuration.

Specified by:

writeExternal in interface java.io.Externalizable

Throws:

java.io.IOException