Class UnionRDD<T>

Object
org.apache.spark.rdd.RDD<T>
org.apache.spark.rdd.UnionRDD<T>
All Implemented Interfaces:
Serializable, org.apache.spark.internal.Logging

public class UnionRDD<T> extends RDD<T>
See Also:
  • Constructor Details

    • UnionRDD

      public UnionRDD(SparkContext sc, scala.collection.immutable.Seq<RDD<T>> rdds, scala.reflect.ClassTag<T> evidence$2)
  • Method Details

    • rdds

      public scala.collection.immutable.Seq<RDD<T>> rdds()
    • getPartitions

      public Partition[] getPartitions()
    • getDependencies

      public scala.collection.immutable.Seq<Dependency<?>> getDependencies()
    • compute

      public scala.collection.Iterator<T> compute(Partition s, TaskContext context)
      Description copied from class: RDD
      :: DeveloperApi :: Implemented by subclasses to compute a given partition.
      Specified by:
      compute in class RDD<T>
      Parameters:
      s - (undocumented)
      context - (undocumented)
      Returns:
      (undocumented)
    • getPreferredLocations

      public scala.collection.immutable.Seq<String> getPreferredLocations(Partition s)
    • clearDependencies

      public void clearDependencies()