diff options
| author | Reynold Xin <rxin@apache.org> | 2014-08-14 11:22:41 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-08-14 11:22:41 -0700 |
| commit | eaeb0f76fa0f103c7db0f3975cb8562715410973 (patch) | |
| tree | 959c0d7e8f82a727c0762289be1122b3c72ba9ad /streaming | |
| parent | 267fdffe2743bc2dc706c8ac8af0ae33a358a5d3 (diff) | |
| download | spark-eaeb0f76fa0f103c7db0f3975cb8562715410973.tar.gz spark-eaeb0f76fa0f103c7db0f3975cb8562715410973.tar.bz2 spark-eaeb0f76fa0f103c7db0f3975cb8562715410973.zip | |
Minor cleanup of metrics.Source
- Added override.
- Marked some variables as private.
Author: Reynold Xin <rxin@apache.org>
Closes #1943 from rxin/metricsSource and squashes the following commits:
fbfa943 [Reynold Xin] Minor cleanup of metrics.Source. - Added override. - Marked some variables as private.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala b/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala index 774adc3c23..75f0e8716d 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/StreamingSource.scala @@ -23,10 +23,10 @@ import org.apache.spark.metrics.source.Source import org.apache.spark.streaming.ui.StreamingJobProgressListener private[streaming] class StreamingSource(ssc: StreamingContext) extends Source { - val metricRegistry = new MetricRegistry - val sourceName = "%s.StreamingMetrics".format(ssc.sparkContext.appName) + override val metricRegistry = new MetricRegistry + override val sourceName = "%s.StreamingMetrics".format(ssc.sparkContext.appName) - val streamingListener = ssc.uiTab.listener + private val streamingListener = ssc.uiTab.listener private def registerGauge[T](name: String, f: StreamingJobProgressListener => T, defaultValue: T) { |