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
  2. trait DoubleFlatMapFunction[T] extends Serializable
  3. trait DoubleFunction[T] extends Serializable
  4. trait FilterFunction[T] extends Serializable
  5. trait FlatMapFunction[T, R] extends Serializable
  6. trait FlatMapFunction2[T1, T2, R] extends Serializable
  7. trait FlatMapGroupsFunction[K, V, R] extends Serializable
  8. trait FlatMapGroupsWithStateFunction[K, V, S, R] extends Serializable
  9. trait ForeachFunction[T] extends Serializable
  10. trait ForeachPartitionFunction[T] extends Serializable
  11. trait Function[T1, R] extends Serializable
  12. trait Function0[R] extends Serializable
  13. trait Function2[T1, T2, R] extends Serializable
  14. trait Function3[T1, T2, T3, R] extends Serializable
  15. trait Function4[T1, T2, T3, T4, R] extends Serializable
  16. trait MapFunction[T, U] extends Serializable
  17. trait MapGroupsFunction[K, V, R] extends Serializable
  18. trait MapGroupsWithStateFunction[K, V, S, R] extends Serializable
  19. trait MapPartitionsFunction[T, U] extends Serializable
  20. trait PairFlatMapFunction[T, K, V] extends Serializable
  21. trait PairFunction[T, K, V] extends Serializable
  22. trait ReduceFunction[T] extends Serializable
  23. trait VoidFunction[T] extends Serializable
  24. trait VoidFunction2[T1, T2] extends Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped