-
- Downloads
Remove the semicolons at the end of Scala code to make it more pure Scala code.
Also remove unused imports as I found them along the way. Remove return statements when returning value in the Scala code. Passing compile and tests.
Showing
- core/src/main/scala/org/apache/spark/deploy/FaultToleranceTest.scala 14 additions, 14 deletions...in/scala/org/apache/spark/deploy/FaultToleranceTest.scala
- core/src/main/scala/org/apache/spark/rdd/CartesianRDD.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/rdd/CartesianRDD.scala
- core/src/test/scala/org/apache/spark/LocalSparkContext.scala 1 addition, 1 deletioncore/src/test/scala/org/apache/spark/LocalSparkContext.scala
- core/src/test/scala/org/apache/spark/PartitioningSuite.scala 5 additions, 5 deletionscore/src/test/scala/org/apache/spark/PartitioningSuite.scala
- examples/src/main/scala/org/apache/spark/examples/LocalALS.scala 1 addition, 1 deletion...s/src/main/scala/org/apache/spark/examples/LocalALS.scala
- examples/src/main/scala/org/apache/spark/examples/SparkTC.scala 1 addition, 1 deletion...es/src/main/scala/org/apache/spark/examples/SparkTC.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala 1 addition, 1 deletion.../org/apache/spark/streaming/examples/ActorWordCount.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/MQTTWordCount.scala 2 additions, 2 deletions...a/org/apache/spark/streaming/examples/MQTTWordCount.scala
- streaming/src/main/scala/org/apache/spark/streaming/Checkpoint.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/streaming/Checkpoint.scala
- streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala 3 additions, 4 deletions...pache/spark/streaming/api/java/JavaStreamingContext.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/FlumeInputDStream.scala 2 additions, 2 deletions...rg/apache/spark/streaming/dstream/FlumeInputDStream.scala
- streaming/src/test/scala/org/apache/spark/streaming/InputStreamsSuite.scala 2 additions, 2 deletions.../scala/org/apache/spark/streaming/InputStreamsSuite.scala
- streaming/src/test/scala/org/apache/spark/streaming/TestSuiteBase.scala 1 addition, 1 deletion...test/scala/org/apache/spark/streaming/TestSuiteBase.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala 3 additions, 1 deletion...cala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/Client.scala 12 additions, 15 deletions.../src/main/scala/org/apache/spark/deploy/yarn/Client.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/ClientDistributedCacheManager.scala 1 addition, 1 deletion...che/spark/deploy/yarn/ClientDistributedCacheManager.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/WorkerRunnable.scala 4 additions, 5 deletions...n/scala/org/apache/spark/deploy/yarn/WorkerRunnable.scala
- yarn/src/main/scala/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala 1 addition, 4 deletions...la/org/apache/spark/deploy/yarn/YarnSparkHadoopUtil.scala
Loading
Please register or sign in to comment