public interface PartitionEvaluator<T,U>
PartitionEvaluatorFactory
to executors, and then creates PartitionEvaluator
via the
factory at the executor side.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.
|
scala.collection.Iterator<U> eval(int partitionIndex, scala.collection.Seq<scala.collection.Iterator<T>> inputs)
partitionIndex
- (undocumented)inputs
- (undocumented)