Package org.apache.spark

Interface PartitionEvaluator<T,U>

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

  • Method Summary

    Modifier and Type
    Method
    Description
    scala.collection.Iterator<U>
    eval(int partitionIndex, scala.collection.Seq<scala.collection.Iterator<T>> inputs)
    Evaluates the RDD partition at the given index.

  • Method Details

    • eval

      scala.collection.Iterator<U> eval(int partitionIndex, scala.collection.Seq<scala.collection.Iterator<T>> inputs)
      Evaluates the RDD partition at the given index. There can be more than one input iterator, if the RDD was zipped from multiple RDDs.
      Parameters:
      partitionIndex - (undocumented)
      inputs - (undocumented)
      Returns:
      (undocumented)