Skip to content

Commit

Permalink
Change variable name to camel case
Browse files Browse the repository at this point in the history
  • Loading branch information
Wisely Chen committed Jul 3, 2015
1 parent 2c8ea89 commit 9e54bf0
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions core/src/main/scala/org/apache/spark/deploy/JsonProtocol.scala
Original file line number Diff line number Diff line change
Expand Up @@ -76,13 +76,13 @@ private[deploy] object JsonProtocol {
}

def writeMasterState(obj: MasterStateResponse): JObject = {
val alive_workers = obj.workers.filter(_.isAlive())
val aliveWorkers = obj.workers.filter(_.isAlive())
("url" -> obj.uri) ~
("workers" -> obj.workers.toList.map(writeWorkerInfo)) ~
("cores" -> alive_workers.map(_.cores).sum) ~
("coresused" -> alive_workers.map(_.coresUsed).sum) ~
("memory" -> alive_workers.map(_.memory).sum) ~
("memoryused" -> alive_workers.map(_.memoryUsed).sum) ~
("cores" -> aliveWorkers.map(_.cores).sum) ~
("coresused" -> aliveWorkers.map(_.coresUsed).sum) ~
("memory" -> aliveWorkers.map(_.memory).sum) ~
("memoryused" -> aliveWorkers.map(_.memoryUsed).sum) ~
("activeapps" -> obj.activeApps.toList.map(writeApplicationInfo)) ~
("completedapps" -> obj.completedApps.toList.map(writeApplicationInfo)) ~
("activedrivers" -> obj.activeDrivers.toList.map(writeDriverInfo)) ~
Expand Down

0 comments on commit 9e54bf0

Please sign in to comment.