public class SplitPartitionsFunction2<T,U>
extends java.lang.Object
implements org.apache.spark.api.java.function.Function2<java.lang.Integer,java.util.Iterator<scala.Tuple2<T,U>>,java.util.Iterator<scala.Tuple2<T,U>>>
SplitPartitionsFunction
, but for JavaPairRDD
sConstructor and Description |
---|
SplitPartitionsFunction2() |
Modifier and Type | Method and Description |
---|---|
java.util.Iterator<scala.Tuple2<T,U>> |
call(java.lang.Integer v1,
java.util.Iterator<scala.Tuple2<T,U>> iter) |