Packages

c

org.apache.spark.storage

TopologyMapper

abstract class TopologyMapper extends AnyRef

Developer API

::DeveloperApi:: TopologyMapper provides topology information for a given host

Annotations
@DeveloperApi()
Source
TopologyMapper.scala
Linear Supertypes
AnyRef, Any
Known Subclasses
DefaultTopologyMapper, FileBasedTopologyMapper
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TopologyMapper
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new TopologyMapper(conf: SparkConf)

    conf

    SparkConf to get required properties, if needed

Abstract Value Members

  1. abstract def getTopologyForHost(hostname: String): Option[String]

    Gets the topology information given the host name

    Gets the topology information given the host name

    hostname

    Hostname

    returns

    topology information for the given hostname. One can use a 'topology delimiter' to make this topology information nested. For example : ‘/myrack/myhost’, where ‘/’ is the topology delimiter, ‘myrack’ is the topology identifier, and ‘myhost’ is the individual host. This function only returns the topology information without the hostname. This information can be used when choosing executors for block replication to discern executors from a different rack than a candidate executor, for example. An implementation can choose to use empty strings or None in case topology info is not available. This would imply that all such executors belong to the same rack.