Small style fix
This commit is contained in:
parent
37bc64a205
commit
12d9c82c9b
|
@ -17,7 +17,7 @@
|
||||||
|
|
||||||
package spark.metrics
|
package spark.metrics
|
||||||
|
|
||||||
import com.codahale.metrics._
|
import com.codahale.metrics.{Metric, MetricFilter, MetricRegistry}
|
||||||
|
|
||||||
import java.util.Properties
|
import java.util.Properties
|
||||||
import java.util.concurrent.TimeUnit
|
import java.util.concurrent.TimeUnit
|
||||||
|
@ -95,7 +95,6 @@ private[spark] class MetricsSystem private (val instance: String) extends Loggin
|
||||||
|
|
||||||
def removeSource(source: Source) {
|
def removeSource(source: Source) {
|
||||||
sources -= source
|
sources -= source
|
||||||
println("Removing source: " + source.sourceName)
|
|
||||||
registry.removeMatching(new MetricFilter {
|
registry.removeMatching(new MetricFilter {
|
||||||
def matches(name: String, metric: Metric): Boolean = name.startsWith(source.sourceName)
|
def matches(name: String, metric: Metric): Boolean = name.startsWith(source.sourceName)
|
||||||
})
|
})
|
||||||
|
|
Loading…
Reference in a new issue