org.datavec.spark.transform

Class BaseFlatMapFunctionAdaptee<K,V>

java.lang.Object

org.datavec.spark.transform.BaseFlatMapFunctionAdaptee<K,V>

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.FlatMapFunction<K,V>

Direct Known Subclasses:

ExecuteJoinFlatMapFunction, FilterAndFlattenJoinedValues, SequenceFlatMapFunction, SequenceSplitFunction, SequenceToRows, SparkTransformProcessFunction

public class BaseFlatMapFunctionAdaptee<K,V>
extends java.lang.Object
implements org.apache.spark.api.java.function.FlatMapFunction<K,V>

FlatMapFunction adapter to hide incompatibilities between Spark 1.x and Spark 2.x This class should be used instead of direct referral to FlatMapFunction

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected FlatMapFunctionAdapter<K,V>	adapter

Constructor Summary

Constructors

Constructor and Description
BaseFlatMapFunctionAdaptee(FlatMapFunctionAdapter<K,V> adapter)

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<V>	call(K k)

Methods inherited from class java.lang.Object

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

Field Detail

adapter

protected final FlatMapFunctionAdapter<K,V> adapter

Constructor Detail

BaseFlatMapFunctionAdaptee

public BaseFlatMapFunctionAdaptee(FlatMapFunctionAdapter<K,V> adapter)

Method Detail

call

public java.lang.Iterable<V> call(K k)
                           throws java.lang.Exception

Specified by:

call in interface org.apache.spark.api.java.function.FlatMapFunction<K,V>

Throws:

java.lang.Exception