Packages

t

org.apache.spark

PartitionEvaluatorFactory

trait PartitionEvaluatorFactory[T, U] extends Serializable

Developer API

A factory to create PartitionEvaluator. 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
PartitionEvaluatorFactory.scala
Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PartitionEvaluatorFactory
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Abstract Value Members

  1. abstract def createEvaluator(): PartitionEvaluator[T, U]

    Creates a partition evaluator.

    Creates a partition evaluator. Each RDD partition will create one evaluator instance, which means one evaluator instance will be used by only one thread.