org.deeplearning4j.spark.impl.common.repartition

Class MapTupleToPairFlatMap<T,U>

java.lang.Object

org.deeplearning4j.spark.util.BasePairFlatMapFunctionAdaptee<java.util.Iterator<scala.Tuple2<T,U>>,T,U>

org.deeplearning4j.spark.impl.common.repartition.MapTupleToPairFlatMap<T,U>

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.PairFlatMapFunction<java.util.Iterator<scala.Tuple2<T,U>>,T,U>

public class MapTupleToPairFlatMap<T,U>
extends BasePairFlatMapFunctionAdaptee<java.util.Iterator<scala.Tuple2<T,U>>,T,U>

This is a simple function used to convert a JavaRDD<Tuple2<T,U>> to a JavaPairRDD<T,U> via a {JavaRDD.mappartitionsToPair()} call.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.deeplearning4j.spark.util.BasePairFlatMapFunctionAdaptee

adapter

Constructor Summary

Constructors

Constructor and Description
MapTupleToPairFlatMap()

Method Summary

Methods inherited from class org.deeplearning4j.spark.util.BasePairFlatMapFunctionAdaptee

call

Methods inherited from class java.lang.Object

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

Constructor Detail

MapTupleToPairFlatMap

public MapTupleToPairFlatMap()