diff options
| author | Wenchen Fan <cloud0fan@outlook.com> | 2015-03-13 14:08:56 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2015-03-13 14:08:56 +0000 |
| commit | ea3d2eed9b0a94b34543d9a9df87dc63a279deb1 (patch) | |
| tree | 95df0a1b6a25fd869d841962b1faa2b145ff6b54 | |
| parent | 9048e8102e3f564842fa0dc6e82edce70b7dd3d7 (diff) | |
| download | spark-ea3d2eed9b0a94b34543d9a9df87dc63a279deb1.tar.gz spark-ea3d2eed9b0a94b34543d9a9df87dc63a279deb1.tar.bz2 spark-ea3d2eed9b0a94b34543d9a9df87dc63a279deb1.zip | |
[CORE][minor] remove unnecessary ClassTag in `DAGScheduler`
This existed at the very beginning, but became unnecessary after [this commit](https://github.com/apache/spark/commit/37d8f37a8ec110416fba0d51d8ba70370ac380c1#diff-6a9ff7fb74fd490a50462d45db2d5e11L272). I think we should remove it if we don't plan to use it in the future.
Author: Wenchen Fan <cloud0fan@outlook.com>
Closes #4992 from cloud-fan/small and squashes the following commits:
e857f2e [Wenchen Fan] remove unnecessary ClassTag
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index bc84e2351a..e4170a55b7 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -26,7 +26,6 @@ import scala.collection.mutable.{ArrayBuffer, HashMap, HashSet, Map, Stack} import scala.concurrent.Await import scala.concurrent.duration._ import scala.language.postfixOps -import scala.reflect.ClassTag import scala.util.control.NonFatal import akka.pattern.ask @@ -497,7 +496,7 @@ class DAGScheduler( waiter } - def runJob[T, U: ClassTag]( + def runJob[T, U]( rdd: RDD[T], func: (TaskContext, Iterator[T]) => U, partitions: Seq[Int], |