Interface PartitionEvaluatorFactory<T,U>

All Superinterfaces:

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.