Packages

t

org.apache.spark

PartitionEvaluator

trait PartitionEvaluator[T, U] extends AnyRef

Developer API

An evaluator for computing RDD partitions. Spark serializes and sends PartitionEvaluatorFactory to executors, and then creates PartitionEvaluator via the factory at the executor side.

Annotations
@DeveloperApi() @Since( "3.5.0" )
Source
PartitionEvaluator.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PartitionEvaluator
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def eval(partitionIndex: Int, inputs: Iterator[T]*): Iterator[U]

    Evaluates the RDD partition at the given index.

    Evaluates the RDD partition at the given index. There can be more than one input iterator, if the RDD was zipped from multiple RDDs.