org.apache.spark.rdd

Class ZippedPartitionsPartition

Object

org.apache.spark.rdd.ZippedPartitionsPartition

All Implemented Interfaces:

java.io.Serializable, Partition

public class ZippedPartitionsPartition
extends Object
implements Partition

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ZippedPartitionsPartition(int idx, scala.collection.Seq<RDD<?>> rdds, scala.collection.Seq<String> preferredLocations)

Method Summary

Methods

Modifier and Type	Method and Description
int	index() Get the split's index within its parent RDD
scala.collection.Seq<Partition>	partitions()
scala.collection.Seq<Partition>	partitionValues()
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

ZippedPartitionsPartition

public ZippedPartitionsPartition(int idx,
                         scala.collection.Seq<RDD<?>> rdds,
                         scala.collection.Seq<String> preferredLocations)

Method Detail

preferredLocations

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

index

public int index()

Description copied from interface: Partition

Get the split's index within its parent RDD

Specified by:

index in interface Partition

partitionValues

public scala.collection.Seq<Partition> partitionValues()

partitions

public scala.collection.Seq<Partition> partitions()