Package org.apache.spark

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:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RangeDependency(RDD<T> rdd, int inStart, int outStart, int length)

Method Summary

Modifier and Type	Method	Description
scala.collection.immutable.List<Object>	getParents(int partitionId)	Get the parent partitions for a child partition.

Methods inherited from class org.apache.spark.NarrowDependency

rdd

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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