org.apache.spark.rdd

Class DefaultPartitionCoalescer.PartitionLocations

Object

org.apache.spark.rdd.DefaultPartitionCoalescer.PartitionLocations

Enclosing class:

DefaultPartitionCoalescer

public class DefaultPartitionCoalescer.PartitionLocations
extends Object

Constructor Summary

Constructors

Constructor and Description
PartitionLocations(RDD<?> prev)

Method Summary

Modifier and Type	Method and Description
void	getAllPrefLocs(RDD<?> prev)
scala.collection.mutable.ArrayBuffer<scala.Tuple2<String,Partition>>	partsWithLocs()
scala.collection.mutable.ArrayBuffer<Partition>	partsWithoutLocs()

Methods inherited from class Object

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

Constructor Detail

PartitionLocations

public PartitionLocations(RDD<?> prev)

Method Detail

getAllPrefLocs

public void getAllPrefLocs(RDD<?> prev)

partsWithLocs

public scala.collection.mutable.ArrayBuffer<scala.Tuple2<String,Partition>> partsWithLocs()

partsWithoutLocs

public scala.collection.mutable.ArrayBuffer<Partition> partsWithoutLocs()