Class JavaHadoopRDD<K,V>

Object
org.apache.spark.api.java.JavaPairRDD<K,V>
org.apache.spark.api.java.JavaHadoopRDD<K,V>
All Implemented Interfaces:
Serializable, JavaRDDLike<scala.Tuple2<K,V>,JavaPairRDD<K,V>>, scala.Serializable

public class JavaHadoopRDD<K,V> extends JavaPairRDD<K,V>
See Also:
  • Constructor Details

    • JavaHadoopRDD

      public JavaHadoopRDD(HadoopRDD<K,V> rdd, scala.reflect.ClassTag<K> kClassTag, scala.reflect.ClassTag<V> vClassTag)
  • Method Details

    • kClassTag

      public scala.reflect.ClassTag<K> kClassTag()
      Overrides:
      kClassTag in class JavaPairRDD<K,V>
    • mapPartitionsWithInputSplit

      public <R> JavaRDD<R> mapPartitionsWithInputSplit(Function2<org.apache.hadoop.mapred.InputSplit,Iterator<scala.Tuple2<K,V>>,Iterator<R>> f, boolean preservesPartitioning)
      Maps over a partition, providing the InputSplit that was used as the base of the partition.
    • vClassTag

      public scala.reflect.ClassTag<V> vClassTag()
      Overrides:
      vClassTag in class JavaPairRDD<K,V>