Packages

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
Linear Supertypes
AnyRef, Any

Type Members

  1. trait CoGroupFunction[K, V1, V2, R] extends Serializable
    Annotations
    @FunctionalInterface()
  2. trait DoubleFlatMapFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  3. trait DoubleFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  4. trait FilterFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  5. trait FlatMapFunction[T, R] extends Serializable
    Annotations
    @FunctionalInterface()
  6. trait FlatMapFunction2[T1, T2, R] extends Serializable
    Annotations
    @FunctionalInterface()
  7. trait FlatMapGroupsFunction[K, V, R] extends Serializable
    Annotations
    @FunctionalInterface()
  8. trait FlatMapGroupsWithStateFunction[K, V, S, R] extends Serializable
    Annotations
    @Experimental() @Evolving()
  9. trait ForeachFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  10. trait ForeachPartitionFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  11. trait Function[T1, R] extends Serializable
    Annotations
    @FunctionalInterface()
  12. trait Function0[R] extends Serializable
    Annotations
    @FunctionalInterface()
  13. trait Function2[T1, T2, R] extends Serializable
    Annotations
    @FunctionalInterface()
  14. trait Function3[T1, T2, T3, R] extends Serializable
    Annotations
    @FunctionalInterface()
  15. trait Function4[T1, T2, T3, T4, R] extends Serializable
    Annotations
    @FunctionalInterface()
  16. trait MapFunction[T, U] extends Serializable
    Annotations
    @FunctionalInterface()
  17. trait MapGroupsFunction[K, V, R] extends Serializable
    Annotations
    @FunctionalInterface()
  18. trait MapGroupsWithStateFunction[K, V, S, R] extends Serializable
    Annotations
    @Experimental() @Evolving()
  19. trait MapPartitionsFunction[T, U] extends Serializable
    Annotations
    @FunctionalInterface()
  20. trait PairFlatMapFunction[T, K, V] extends Serializable
    Annotations
    @FunctionalInterface()
  21. trait PairFunction[T, K, V] extends Serializable
    Annotations
    @FunctionalInterface()
  22. trait ReduceFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  23. trait VoidFunction[T] extends Serializable
    Annotations
    @FunctionalInterface()
  24. trait VoidFunction2[T1, T2] extends Serializable
    Annotations
    @FunctionalInterface()

Inherited from AnyRef

Inherited from Any

Ungrouped