org.datavec.spark.transform.join

Class ExecuteJoinFlatMapFunction

java.lang.Object

org.datavec.spark.transform.BaseFlatMapFunctionAdaptee<scala.Tuple2<java.util.List<Writable>,java.lang.Iterable<JoinValue>>,java.util.List<Writable>>

org.datavec.spark.transform.join.ExecuteJoinFlatMapFunction

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.api.java.function.FlatMapFunction<scala.Tuple2<java.util.List<Writable>,java.lang.Iterable<JoinValue>>,java.util.List<Writable>>

public class ExecuteJoinFlatMapFunction
extends BaseFlatMapFunctionAdaptee<scala.Tuple2<java.util.List<Writable>,java.lang.Iterable<JoinValue>>,java.util.List<Writable>>

Execute a join

See Also:

Serialized Form

Field Summary

Fields inherited from class org.datavec.spark.transform.BaseFlatMapFunctionAdaptee

adapter

Constructor Summary

Constructors

Constructor and Description
ExecuteJoinFlatMapFunction(Join join)

Method Summary

Methods inherited from class org.datavec.spark.transform.BaseFlatMapFunctionAdaptee

call

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecuteJoinFlatMapFunction

public ExecuteJoinFlatMapFunction(Join join)