org.deeplearning4j.spark.util

Class BasePairFlatMapFunctionAdaptee<T,K,V>

java.lang.Object

org.deeplearning4j.spark.util.BasePairFlatMapFunctionAdaptee<T,K,V>

All Implemented Interfaces:

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

Direct Known Subclasses:

FeedForwardWithKeyFunction, GraphFeedForwardWithKeyFunction, MapTupleToPairFlatMap, ScoreExamplesWithKeyFunction, ScoreExamplesWithKeyFunction, SplitDataSetExamplesPairFlatMapFunction, VaeReconstructionErrorWithKeyFunction, VaeReconstructionProbWithKeyFunction

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

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

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.datavec.spark.functions.FlatMapFunctionAdapter<T,scala.Tuple2<K,V>>	adapter

Constructor Summary

Constructors

Constructor and Description
BasePairFlatMapFunctionAdaptee(org.datavec.spark.functions.FlatMapFunctionAdapter<T,scala.Tuple2<K,V>> adapter)

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<scala.Tuple2<K,V>>	call(T t)

Methods inherited from class java.lang.Object

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

Field Detail

adapter

protected final org.datavec.spark.functions.FlatMapFunctionAdapter<T,scala.Tuple2<K,V>> adapter

Constructor Detail

BasePairFlatMapFunctionAdaptee

public BasePairFlatMapFunctionAdaptee(org.datavec.spark.functions.FlatMapFunctionAdapter<T,scala.Tuple2<K,V>> adapter)

Method Detail

call

public java.lang.Iterable<scala.Tuple2<K,V>> call(T t)
                                           throws java.lang.Exception

Specified by:

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

Throws:

java.lang.Exception