Class PairwiseRRDD<T>

Object
org.apache.spark.rdd.RDD<U>
org.apache.spark.api.r.BaseRRDD<T,scala.Tuple2<Object,byte[]>>
org.apache.spark.api.r.PairwiseRRDD<T>
All Implemented Interfaces:
Serializable, org.apache.spark.internal.Logging, scala.Serializable

public class PairwiseRRDD<T> extends BaseRRDD<T,scala.Tuple2<Object,byte[]>>
Form an RDD[(Int, Array[Byte])] from key-value pairs returned from R. This is used by SparkR's shuffle operations.
See Also:
  • Constructor Details

    • PairwiseRRDD

      public PairwiseRRDD(RDD<T> parent, int numPartitions, byte[] hashFunc, String deserializer, byte[] packageNames, Object[] broadcastVars, scala.reflect.ClassTag<T> evidence$3)
  • Method Details