Class RangeDependency<T>

Object
org.apache.spark.Dependency<T>
org.apache.spark.NarrowDependency<T>
org.apache.spark.RangeDependency<T>
All Implemented Interfaces:
Serializable, scala.Serializable

public class RangeDependency<T> extends NarrowDependency<T>
:: DeveloperApi :: Represents a one-to-one dependency between ranges of partitions in the parent and child RDDs. param: rdd the parent RDD param: inStart the start of the range in the parent RDD param: outStart the start of the range in the child RDD param: length the length of the range
See Also:
  • Constructor Details

    • RangeDependency

      public RangeDependency(RDD<T> rdd, int inStart, int outStart, int length)
  • Method Details

    • getParents

      public scala.collection.immutable.List<Object> getParents(int partitionId)
      Description copied from class: NarrowDependency
      Get the parent partitions for a child partition.
      Specified by:
      getParents in class NarrowDependency<T>
      Parameters:
      partitionId - a partition of the child RDD
      Returns:
      the partitions of the parent RDD that the child partition depends upon