package function
Set of interfaces to represent functions in Spark's Java API. Users create implementations of these interfaces to pass functions to various Java API methods for Spark. Please visit Spark's Java programming guide for more details.
- Source
- package.scala
Type Members
- trait CoGroupFunction[K, V1, V2, R] extends Serializable
- trait DoubleFlatMapFunction[T] extends Serializable
- trait DoubleFunction[T] extends Serializable
- trait FilterFunction[T] extends Serializable
- trait FlatMapFunction[T, R] extends Serializable
- trait FlatMapFunction2[T1, T2, R] extends Serializable
- trait FlatMapGroupsFunction[K, V, R] extends Serializable
- trait FlatMapGroupsWithStateFunction[K, V, S, R] extends Serializable
- trait ForeachFunction[T] extends Serializable
- trait ForeachPartitionFunction[T] extends Serializable
- trait Function[T1, R] extends Serializable
- trait Function0[R] extends Serializable
- trait Function2[T1, T2, R] extends Serializable
- trait Function3[T1, T2, T3, R] extends Serializable
- trait Function4[T1, T2, T3, T4, R] extends Serializable
- trait MapFunction[T, U] extends Serializable
- trait MapGroupsFunction[K, V, R] extends Serializable
- trait MapGroupsWithStateFunction[K, V, S, R] extends Serializable
- trait MapPartitionsFunction[T, U] extends Serializable
- trait PairFlatMapFunction[T, K, V] extends Serializable
- trait PairFunction[T, K, V] extends Serializable
- trait ReduceFunction[T] extends Serializable
- trait VoidFunction[T] extends Serializable
- trait VoidFunction2[T1, T2] extends Serializable