public class CoalescedRDDPartition extends Object implements Partition, scala.Product, scala.Serializable
Constructor and Description |
---|
CoalescedRDDPartition(int index,
RDD<?> rdd,
int[] parentsIndices,
String preferredLocation) |
Modifier and Type | Method and Description |
---|---|
int |
index()
Get the split's index within its parent RDD
|
double |
localFraction()
Computes the fraction of the parents' partitions containing preferredLocation within
their getPreferredLocs.
|
scala.collection.Seq<Partition> |
parents() |
int[] |
parentsIndices() |
String |
preferredLocation() |
Object |
rdd() |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public CoalescedRDDPartition(int index, RDD<?> rdd, int[] parentsIndices, String preferredLocation)
public int index()
Partition
public Object rdd()
public int[] parentsIndices()
public String preferredLocation()
public scala.collection.Seq<Partition> parents()
public double localFraction()