|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Object org.apache.spark.Dependency<T> org.apache.spark.NarrowDependency<T>
public abstract class NarrowDependency<T>
:: DeveloperApi :: Base class for dependencies where each partition of the child RDD depends on a small number of partitions of the parent RDD. Narrow dependencies allow for pipelined execution.
Constructor Summary | |
---|---|
NarrowDependency(RDD<T> _rdd)
|
Method Summary | |
---|---|
abstract scala.collection.Seq<Object> |
getParents(int partitionId)
Get the parent partitions for a child partition. |
RDD<T> |
rdd()
|
Methods inherited from class Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public NarrowDependency(RDD<T> _rdd)
Method Detail |
---|
public abstract scala.collection.Seq<Object> getParents(int partitionId)
partitionId
- a partition of the child RDD
public RDD<T> rdd()
rdd
in class Dependency<T>
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |