Minor cleanup.

Marcelo Vanzin · Marcelo Vanzin · commit cf5c6ce74c18 · 2017-09-13T09:29:27.000-07:00
diff --git a/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala b/core/src/main/scala/org/apache/spark/scheduler/LiveListenerBus.scala
@@ -169,12 +169,8 @@ private[spark] class LiveListenerBus(conf: SparkConf) {
     }
   }
 
-  private[spark] def findListenersByClass[T <: SparkListenerInterface : ClassTag]():
-      Seq[T] = {
-    val c = implicitly[ClassTag[T]].runtimeClass
-    queues.asScala.flatMap { queue =>
-      queue.listeners.asScala.filter(_.getClass() == c).map(_.asInstanceOf[T])
-    }
+  private[spark] def findListenersByClass[T <: SparkListenerInterface : ClassTag](): Seq[T] = {
+    queues.asScala.flatMap { queue => queue.findListenersByClass[T]() }
   }
 
   private[spark] def listeners: JList[SparkListenerInterface] = {

Original file line number	Diff line number	Diff line change
`@@ -169,12 +169,8 @@ private[spark] class LiveListenerBus(conf: SparkConf) {`
`169`	`169`	`}`
`170`	`170`	`}`
`171`	`171`
`172`		`- private[spark] def findListenersByClass[T <: SparkListenerInterface : ClassTag]():`
`173`		`- Seq[T] = {`
`174`		`- val c = implicitly[ClassTag[T]].runtimeClass`
`175`		`- queues.asScala.flatMap { queue =>`
`176`		`- queue.listeners.asScala.filter(_.getClass() == c).map(_.asInstanceOf[T])`
`177`		`- }`
	`172`	`+ private[spark] def findListenersByClass[T <: SparkListenerInterface : ClassTag](): Seq[T] = {`
	`173`	`+ queues.asScala.flatMap { queue => queue.findListenersByClass[T]() }`
`178`	`174`	`}`
`179`	`175`
`180`	`176`	`private[spark] def listeners: JList[SparkListenerInterface] = {`