co.cask.cdap.etl.spark.function

Interface FlatMapFunc<T,R>

Type Parameters:

T - type of input object

R - type of output objects

All Superinterfaces:

Serializable

All Known Implementing Classes:

AggregatorAggregateFunction, AlertPassFilter, BatchSourceFunction, ErrorPassFilter, ErrorTransformFunction, JoinMergeFunction, MultiOutputTransformFunction, OutputPassFilter, TransformFunction

public interface FlatMapFunc<T,R>
extends Serializable

A function that returns zero or more output records from each input record. Used by the application instead of Spark's FlatMapFunction because the Spark API is different in Spark1 and Spark2.

Method Summary

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

Method Detail

call

Iterable<R> call(T t)
          throws Exception

Throws:

Exception