org.datavec.spark.functions

Interface FlatMapFunctionAdapter<T,R>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

ExecuteJoinFlatMapFunctionAdapter, FilterAndFlattenJoinedValuesAdapter, SequenceFlatMapFunctionAdapter, SequenceSplitFunctionAdapter, SequenceToRowsAdapter, SparkTransformProcessFunctionAdapter

public interface FlatMapFunctionAdapter<T,R>
extends java.io.Serializable

A function that returns zero or more output records from each input record. Adapter for Spark interface in order to freeze interface changes between spark versions

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<R>	call(T t)

Method Detail

call

java.lang.Iterable<R> call(T t)
                    throws java.lang.Exception

Throws:

java.lang.Exception