org.apache.spark.storage

Class BlockManagerMessages.BlockLocationsAndStatus

Object

org.apache.spark.storage.BlockManagerMessages.BlockLocationsAndStatus

All Implemented Interfaces:

java.io.Serializable, scala.Equals, scala.Product

Enclosing class:

BlockManagerMessages

public static class BlockManagerMessages.BlockLocationsAndStatus
extends Object
implements scala.Product, scala.Serializable

The response message of GetLocationsAndStatus request.

param: localDirs if it is persisted-to-disk on the same host as the requester executor is running on then localDirs will be Some and the cached data will be in a file in one of those dirs, otherwise it is None.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BlockLocationsAndStatus(scala.collection.Seq<BlockManagerId> locations, BlockStatus status, scala.Option<String[]> localDirs)

Method Summary

Modifier and Type	Method and Description
scala.Option<String[]>	localDirs()
scala.collection.Seq<BlockManagerId>	locations()
BlockStatus	status()

Methods inherited from class Object

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

Methods inherited from interface scala.Product

$init$, productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

BlockLocationsAndStatus

public BlockLocationsAndStatus(scala.collection.Seq<BlockManagerId> locations,
                               BlockStatus status,
                               scala.Option<String[]> localDirs)

Method Detail

locations

public scala.collection.Seq<BlockManagerId> locations()

status

public BlockStatus status()

localDirs

public scala.Option<String[]> localDirs()