Skip to content
Snippets Groups Projects
Commit d0533f70 authored by Patrick Wendell's avatar Patrick Wendell
Browse files

Rename to Client

parent 3d939e5f
No related branches found
No related tags found
No related merge requests found
......@@ -15,22 +15,19 @@
* limitations under the License.
*/
package org.apache.spark.deploy.client
package org.apache.spark.deploy
import scala.collection.JavaConversions._
import scala.collection.mutable.Map
import scala.concurrent._
import akka.actor._
import akka.actor.Actor
import org.apache.log4j.{Level, Logger}
import org.apache.spark.{Logging, SparkConf}
import org.apache.spark.deploy.{Command, DriverDescription}
import org.apache.spark.deploy.DeployMessages._
import org.apache.spark.deploy.master.Master
import org.apache.spark.util.{AkkaUtils, Utils}
import org.apache.log4j.{Logger, Level}
import akka.remote.RemotingLifecycleEvent
/**
* Actor that sends a single message to the standalone master and returns the response in the
......@@ -61,7 +58,7 @@ class DriverActor(master: String, response: Promise[(Boolean, String)]) extends
object DriverClient {
def main(args: Array[String]) {
val driverArgs = new DriverClientArguments(args)
val driverArgs = new ClientArguments(args)
val conf = new SparkConf()
if (!driverArgs.logLevel.isGreaterOrEqual(Level.WARN)) {
......
......@@ -15,7 +15,7 @@
* limitations under the License.
*/
package org.apache.spark.deploy.client
package org.apache.spark.deploy
import scala.collection.mutable.ListBuffer
......@@ -24,7 +24,7 @@ import org.apache.log4j.Level
/**
* Command-line parser for the driver client.
*/
private[spark] class DriverClientArguments(args: Array[String]) {
private[spark] class ClientArguments(args: Array[String]) {
val defaultCores = 1
val defaultMemory = 512
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment