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

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

package function

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

Inherited from AnyRef

Inherited from Any

Ungrouped