org.apache.spark

Interface PartitionEvaluatorFactory<T,U>

All Superinterfaces:

java.io.Serializable

public interface PartitionEvaluatorFactory<T,U>
extends java.io.Serializable

A factory to create PartitionEvaluator. Spark serializes and sends PartitionEvaluatorFactory to executors, and then creates PartitionEvaluator via the factory at the executor side.

Method Summary

Modifier and Type	Method and Description
PartitionEvaluator<T,U>	createEvaluator() Creates a partition evaluator.

Method Detail

createEvaluator

PartitionEvaluator<T,U> createEvaluator()

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

Returns:

(undocumented)