Package org.apache.spark

Interface PartitionEvaluatorFactory<T,U>

All Superinterfaces:
Serializable
public interface PartitionEvaluatorFactory<T,U> extends 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 Details

    • 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)