Uses of Interface
co.cask.cdap.etl.spark.function.FlatMapFunc

Packages that use FlatMapFunc

Package	Description
co.cask.cdap.etl.spark
co.cask.cdap.etl.spark.function

Uses of FlatMapFunc in co.cask.cdap.etl.spark

Methods in co.cask.cdap.etl.spark with parameters of type FlatMapFunc

Modifier and Type	Method and Description
static <T,R> org.apache.spark.api.java.function.FlatMapFunction<T,R>	Compat.convert(FlatMapFunc<T,R> func)

Uses of FlatMapFunc in co.cask.cdap.etl.spark.function

Classes in co.cask.cdap.etl.spark.function that implement FlatMapFunc

Modifier and Type	Class and Description
class	AggregatorAggregateFunction<GROUP_KEY,GROUP_VAL,OUT> Function that uses a BatchAggregator to perform the aggregate part of the aggregator.
class	AlertPassFilter Filters a SparkCollection containing both output and errors to one that just contains alerts.
class	BatchSourceFunction Function that uses a BatchSource to transform a pair of objects into a single object.
class	ErrorPassFilter<T> Filters a SparkCollection containing both output and errors to one that just contains errors.
class	ErrorTransformFunction<T,U> Function that uses an ErrorTransform to perform a flatmap.
class	JoinMergeFunction<JOIN_KEY,INPUT_RECORD,OUT> Function that merges a join result using a BatchJoiner.
class	MultiOutputTransformFunction<T> Function that uses a MultiOutputTransform to perform a flatmap.
class	OutputPassFilter<T> Filters a SparkCollection containing both output and errors to one that just contains output from a specific port.
class	TransformFunction<T> Function that uses a Transform to perform a flatmap.