Class BlockManagerMessages.BlockLocationsAndStatus

Object
org.apache.spark.storage.BlockManagerMessages.BlockLocationsAndStatus
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product, scala.Serializable
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:
  • Constructor Details

    • BlockLocationsAndStatus

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

    • locations

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

      public BlockStatus status()
    • localDirs

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