Class

io.radanalytics.silex.rdd.lineage

Dependency

Related Doc: package lineage

Permalink

class Dependency extends AnyRef

Encodes an RDD dependency arc in the lineage DAG of a target RDD.

Linear Supertypes

Ordering

Alphabetic
By Inheritance

Inherited

Dependency
AnyRef
Any

Hide All
Show All

Visibility

Public
All

Instance Constructors

new Dependency(rdd: RDD[_], depth: Int, successor: RDD[_])

rdd
The RDD dependency of the target
depth
The depth along the current path from the target RDD to this dependency. It is possible for an RDD to be reachable along multiple paths starting from the target. Therefore one dependency RDD may appear multiple times in the lineage, with differing values for depth depending on the particular path.
successor
The RDD whose immediate dependency this is.

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
val depth: Int

The depth along the current path from the target RDD to this dependency.
The depth along the current path from the target RDD to this dependency. It is possible for an RDD to be reachable along multiple paths starting from the target. Therefore one dependency RDD may appear multiple times in the lineage, with differing values for depth depending on the particular path.
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
val rdd: RDD[_]

The RDD dependency of the target
val successor: RDD[_]

The RDD whose immediate dependency this is.
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped