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
DefaultPartitionCoalescer.PartitionLocations(RDD<?> prev)

Method Summary

Methods

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

DefaultPartitionCoalescer.PartitionLocations

public DefaultPartitionCoalescer.PartitionLocations(RDD<?> prev)

Method Detail

partsWithoutLocs

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

partsWithLocs

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

getAllPrefLocs

public void getAllPrefLocs(RDD<?> prev)