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

Packages that use PairFlatMapFunc

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

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

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

Modifier and Type	Method and Description
static <T,K,V> org.apache.spark.api.java.function.PairFlatMapFunction<T,K,V>	Compat.convert(PairFlatMapFunc<T,K,V> func)

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

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

Modifier and Type	Class and Description
class	AggregatorGroupByFunction<GROUP_KEY,GROUP_VAL> Function that uses a BatchAggregator to perform the groupBy part of the aggregator.
class	BatchSinkFunction<IN,OUT_KEY,OUT_VAL> Function that uses a BatchSink to transform one object into a pair.
class	JoinOnFunction<JOIN_KEY,INPUT_RECORD> Function that uses a BatchJoiner to perform the joinOn part of the join.