org.apache.spark.rdd

Class ParallelCollectionPartition<T>

Object

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

All Implemented Interfaces:

java.io.Serializable, Partition

public class ParallelCollectionPartition<T>
extends Object
implements Partition, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ParallelCollectionPartition(long rddId, int slice, scala.collection.Seq<T> values, scala.reflect.ClassTag<T> evidence$1)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object other)
int	hashCode()
int	index() Get the split's index within its parent RDD
scala.collection.Iterator<T>	iterator()
long	rddId()
int	slice()
scala.collection.Seq<T>	values()

Methods inherited from class Object

getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParallelCollectionPartition

public ParallelCollectionPartition(long rddId,
                           int slice,
                           scala.collection.Seq<T> values,
                           scala.reflect.ClassTag<T> evidence$1)

Method Detail

rddId

public long rddId()

slice

public int slice()

values

public scala.collection.Seq<T> values()

iterator

public scala.collection.Iterator<T> iterator()

hashCode

public int hashCode()

Specified by:

hashCode in interface Partition

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Overrides:

equals in class Object

index

public int index()

Description copied from interface: Partition

Get the split's index within its parent RDD

Specified by:

index in interface Partition