diff options
author | Patrick Wendell <pwendell@gmail.com> | 2014-01-07 23:38:46 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-01-07 23:38:51 -0800 |
commit | d0533f704681adccc8fe2b814dc9e5082646057a (patch) | |
tree | 060fb7da3a486b89ac91983de220c6e607c97698 /core | |
parent | 3d939e5fe8930368b46eb49659a9cca8f41c8768 (diff) | |
download | spark-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 |