org.apache.spark.rdd

Class NewHadoopPartition

Object

org.apache.spark.rdd.NewHadoopPartition

All Implemented Interfaces:

java.io.Serializable, Partition

public class NewHadoopPartition
extends Object
implements Partition

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NewHadoopPartition(int rddId, int index, org.apache.hadoop.mapreduce.InputSplit rawSplit)

Method Summary

Methods

Modifier and Type	Method and Description
int	hashCode()
int	index() Get the partition's index within its parent RDD
SerializableWritable<org.apache.hadoop.mapreduce.InputSplit>	serializableHadoopSplit()

Methods inherited from class Object

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

Constructor Detail

NewHadoopPartition

public NewHadoopPartition(int rddId,
                  int index,
                  org.apache.hadoop.mapreduce.InputSplit rawSplit)

Method Detail

index

public int index()

Description copied from interface: Partition

Get the partition's index within its parent RDD

Specified by:

index in interface Partition

serializableHadoopSplit

public SerializableWritable<org.apache.hadoop.mapreduce.InputSplit> serializableHadoopSplit()

hashCode

public int hashCode()

Specified by:

hashCode in interface Partition

Overrides:

hashCode in class Object