public class DefaultTopologyMapper extends TopologyMapper
|Modifier and Type||Method and Description|
Gets the topology information given the host name
public DefaultTopologyMapper(SparkConf conf)
public scala.Option<String> getTopologyForHost(String hostname)
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.