org.apache.spark.rdd

Class UnionPartition<T>

Object

org.apache.spark.rdd.UnionPartition<T>

All Implemented Interfaces:

java.io.Serializable, Partition

public class UnionPartition<T>
extends Object
implements Partition

Partition for UnionRDD.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
UnionPartition(int idx, RDD<T> rdd, int parentRddIndex, int parentRddPartitionIndex, scala.reflect.ClassTag<T> evidence$1)

Method Summary

Methods

Modifier and Type	Method and Description
int	index() Get the partition's index within its parent RDD
Partition	parentPartition()
int	parentRddIndex()
scala.collection.Seq<String>	preferredLocations()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.Partition

hashCode

Constructor Detail

UnionPartition

public UnionPartition(int idx,
              RDD<T> rdd,
              int parentRddIndex,
              int parentRddPartitionIndex,
              scala.reflect.ClassTag<T> evidence$1)

Method Detail

parentRddIndex

public int parentRddIndex()

parentPartition

public Partition parentPartition()

preferredLocations

public scala.collection.Seq<String> preferredLocations()

index

public int index()

Description copied from interface: Partition

Get the partition's index within its parent RDD

Specified by:

index in interface Partition