public class StorageUtils
extends Object
Constructor and Description |
---|
StorageUtils() |
Modifier and Type | Method and Description |
---|---|
static scala.collection.Map<BlockId,scala.collection.Seq<String>> |
getRddBlockLocations(int rddId,
scala.collection.Seq<StorageStatus> statuses)
Return a mapping from block ID to its locations for each block that belongs to the given RDD.
|
static void |
updateRddInfo(scala.collection.Seq<RDDInfo> rddInfos,
scala.collection.Seq<StorageStatus> statuses)
Update the given list of RDDInfo with the given list of storage statuses.
|
public static void updateRddInfo(scala.collection.Seq<RDDInfo> rddInfos, scala.collection.Seq<StorageStatus> statuses)
public static scala.collection.Map<BlockId,scala.collection.Seq<String>> getRddBlockLocations(int rddId, scala.collection.Seq<StorageStatus> statuses)