Searched refs:getRackForHost (Results 1 – 4 of 4) sorted by relevance
35 override def getRackForHost(hostPort: String): Option[String] = {
72 def getRackForHost(host: String): Option[String] = { method96 for ((execId, host) <- liveExecutors; rack <- getRackForHost(host)) {109 for (rack <- getRackForHost(hostId); hosts <- hostsByRack.get(rack)) {132 for (rack <- getRackForHost(host)) {137 override def getRackForHost(value: String): Option[String] = FakeRackUtil.getRackForHost(value)
200 for (rack <- sched.getRackForHost(loc.host)) {328 for (rack <- sched.getRackForHost(host)) {330 val racks = tasks(index).preferredLocations.map(_.host).flatMap(sched.getRackForHost)379 rack <- sched.getRackForHost(host)
306 for (rack <- getRackForHost(o.host)) {565 for (rack <- getRackForHost(host); hosts <- hostsByRack.get(rack)) {604 def getRackForHost(value: String): Option[String] = None method