org.apache.spark.rdd

Class CoGroupPartition

Object

org.apache.spark.rdd.CoGroupPartition

All Implemented Interfaces:

java.io.Serializable, Partition

public class CoGroupPartition
extends Object
implements Partition, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CoGroupPartition(int idx, CoGroupSplitDep[] deps)

Method Summary

Methods

Modifier and Type	Method and Description
CoGroupSplitDep[]	deps()
int	hashCode()
int	index() Get the partition's index within its parent RDD

Methods inherited from class Object

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

Constructor Detail

CoGroupPartition

public CoGroupPartition(int idx,
                CoGroupSplitDep[] deps)

Method Detail

deps

public CoGroupSplitDep[] deps()

index

public int index()

Description copied from interface: Partition

Get the partition's index within its parent RDD

Specified by:

index in interface Partition

hashCode

public int hashCode()

Specified by:

hashCode in interface Partition

Overrides:

hashCode in class Object