aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2014-01-07 23:38:46 -0800
committerPatrick Wendell <pwendell@gmail.com>2014-01-07 23:38:51 -0800
commitd0533f704681adccc8fe2b814dc9e5082646057a (patch)
tree060fb7da3a486b89ac91983de220c6e607c97698 /core
parent3d939e5fe8930368b46eb49659a9cca8f41c8768 (diff)
downloadspark-d0533f704681adccc8fe2b814dc9e5082646057a.tar.gz
spark-d0533f704681adccc8fe2b814dc9e5082646057a.tar.bz2
spark-d0533f704681adccc8fe2b814dc9e5082646057a.zip
Rename to Client
Diffstat (limited to 'core')
-rw-r--r--core/src/main/scala/org/apache/spark/deploy/Client.scala (renamed from core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala)9
-rw-r--r--core/src/main/scala/org/apache/spark/deploy/ClientArguments.scala (renamed from core/src/main/scala/org/apache/spark/deploy/client/DriverClientArguments.scala)4
2 files changed, 5 insertions, 8 deletions
diff --git a/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala b/core/src/main/scala/org/apache/spark/deploy/Client.scala
index 8b066ba1a5..0475bb17c0 100644
--- a/core/src/main/scala/org/apache/spark/deploy/client/DriverClient.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/Client.scala
@@ -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)) {
diff --git a/core/src/main/scala/org/apache/spark/deploy/client/DriverClientArguments.scala b/core/src/main/scala/org/apache/spark/deploy/ClientArguments.scala
index 7774a5615c..50b92e1eab 100644
--- a/core/src/main/scala/org/apache/spark/deploy/client/DriverClientArguments.scala
+++ b/core/src/main/scala/org/apache/spark/deploy/ClientArguments.scala
@@ -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