Home
last modified time | relevance | path

Searched refs:MasterStateResponse (Results 1 – 8 of 8) sorted by relevance

/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/client/
H A DAppClientSuite.scala29 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, RequestMasterState}
173 private def getMasterState: MasterStateResponse = {
174 master.self.askWithRetry[MasterStateResponse](RequestMasterState)
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/
H A DJsonProtocol.scala23 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, WorkerStateResponse}
78 def writeMasterState(obj: MasterStateResponse): JObject = {
H A DDeployMessage.scala175 case class MasterStateResponse( caseClass
/dports/devel/spark/spark-2.1.1/core/src/test/scala/org/apache/spark/deploy/
H A DJsonProtocolSuite.scala27 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, WorkerStateResponse}
71 val stateResponse = new MasterStateResponse(
H A DStandaloneDynamicAllocationSuite.scala28 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, RequestMasterState}
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/master/ui/
H A DApplicationPage.scala24 import org.apache.spark.deploy.DeployMessages.{MasterStateResponse, RequestMasterState}
37 val state = master.askWithRetry[MasterStateResponse](RequestMasterState)
H A DMasterPage.scala26 import org.apache.spark.deploy.DeployMessages.{KillDriverResponse, MasterStateResponse, RequestKill…
35 def getMasterState: MasterStateResponse = {
36 master.askWithRetry[MasterStateResponse](RequestMasterState)
/dports/devel/spark/spark-2.1.1/core/src/main/scala/org/apache/spark/deploy/master/
H A DMaster.scala482 context.reply(MasterStateResponse(