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.
Type Members
-
trait
CoGroupFunction[K, V1, V2, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
DoubleFlatMapFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
DoubleFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
FilterFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
FlatMapFunction[T, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
FlatMapFunction2[T1, T2, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
FlatMapGroupsFunction[K, V, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
FlatMapGroupsWithStateFunction[K, V, S, R] extends Serializable
- Annotations
- @Experimental() @Evolving()
-
trait
ForeachFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
ForeachPartitionFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
Function[T1, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
Function0[R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
Function2[T1, T2, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
Function3[T1, T2, T3, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
Function4[T1, T2, T3, T4, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
MapFunction[T, U] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
MapGroupsFunction[K, V, R] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
MapGroupsWithStateFunction[K, V, S, R] extends Serializable
- Annotations
- @Experimental() @Evolving()
-
trait
MapPartitionsFunction[T, U] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
PairFlatMapFunction[T, K, V] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
PairFunction[T, K, V] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
ReduceFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
VoidFunction[T] extends Serializable
- Annotations
- @FunctionalInterface()
-
trait
VoidFunction2[T1, T2] extends Serializable
- Annotations
- @FunctionalInterface()