Searched refs:MasterStateResponse (Results 1 – 8 of 8) sorted by relevance
29 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, RequestMasterState}173 private def getMasterState: MasterStateResponse = {174 master.self.askWithRetry[MasterStateResponse](RequestMasterState)
23 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, WorkerStateResponse}78 def writeMasterState(obj: MasterStateResponse): JObject = {
175 case class MasterStateResponse( caseClass
27 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, WorkerStateResponse}71 val stateResponse = new MasterStateResponse(
28 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, RequestMasterState}
24 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, RequestMasterState}37 val state = master.askWithRetry[MasterStateResponse](RequestMasterState)
26 import org.apache.spark.deploy.DeployMessages.{KillDriverResponse, MasterStateResponse, RequestKill…35 def getMasterState: MasterStateResponse = {36 master.askWithRetry[MasterStateResponse](RequestMasterState)
482 context.reply(MasterStateResponse(