From 8452309a13522685d8d2fa7f7ee4bce4f006bcdc Mon Sep 17 00:00:00 2001 From: Patrick Wendell Date: Sat, 5 Apr 2014 16:53:08 -0700 Subject: [PATCH] Style fixes --- core/src/main/scala/org/apache/spark/Aggregator.scala | 1 - core/src/main/scala/org/apache/spark/SparkContext.scala | 3 --- .../main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala | 2 +- core/src/main/scala/org/apache/spark/rdd/RDD.scala | 1 - 4 files changed, 1 insertion(+), 6 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/Aggregator.scala b/core/src/main/scala/org/apache/spark/Aggregator.scala index ad00b838e14a2..d03f653375898 100644 --- a/core/src/main/scala/org/apache/spark/Aggregator.scala +++ b/core/src/main/scala/org/apache/spark/Aggregator.scala @@ -27,7 +27,6 @@ import org.apache.spark.util.collection.{AppendOnlyMap, ExternalAppendOnlyMap} * @param mergeValue function to merge a new value into the aggregation result. * @param mergeCombiners function to merge outputs from multiple mergeValue function. */ - case class Aggregator[K, V, C] ( createCombiner: V => C, mergeValue: (C, V) => C, diff --git a/core/src/main/scala/org/apache/spark/SparkContext.scala b/core/src/main/scala/org/apache/spark/SparkContext.scala index 40d3b67b684b6..5042d4b5bc824 100644 --- a/core/src/main/scala/org/apache/spark/SparkContext.scala +++ b/core/src/main/scala/org/apache/spark/SparkContext.scala @@ -667,7 +667,6 @@ class SparkContext( /** * DEVELOPER API - * * Register a listener to receive up-calls from events that happen during execution. */ def addSparkListener(listener: SparkListener) { @@ -980,7 +979,6 @@ class SparkContext( /** * DEVELOPER API - * * Run a job that can return approximate results. */ def runApproximateJob[T, U, R]( @@ -999,7 +997,6 @@ class SparkContext( /** * EXPERIMENTAL API - * * Submit a job for execution and return a FutureJob holding the result. */ def submitJob[T, U, R]( diff --git a/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala b/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala index 7ccdd8649aac8..7ab40aca439af 100644 --- a/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/PartitionPruningRDD.scala @@ -22,7 +22,7 @@ import scala.reflect.ClassTag import org.apache.spark.{NarrowDependency, Partition, TaskContext} private[spark] class PartitionPruningRDDPartition(idx: Int, val parentSplit: Partition) - extends Partition { + extends Partition { override val index = idx } diff --git a/core/src/main/scala/org/apache/spark/rdd/RDD.scala b/core/src/main/scala/org/apache/spark/rdd/RDD.scala index a5eea008933da..66ecf1b4a1296 100644 --- a/core/src/main/scala/org/apache/spark/rdd/RDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/RDD.scala @@ -856,7 +856,6 @@ abstract class RDD[T: ClassTag]( /** * EXPERIMENTAL API - * * Return approximate number of distinct elements in the RDD. * * The accuracy of approximation can be controlled through the relative standard deviation