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 and 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 Detail

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)