Formatting changes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/3875ba17 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/3875ba17 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/3875ba17 Branch: refs/heads/master Commit: 3875ba170dc878596b67dabd4f3b191156191935 Parents: 985c72b Author: Aaron McCurry <[email protected]> Authored: Sun Dec 8 17:02:53 2013 -0500 Committer: Aaron McCurry <[email protected]> Committed: Sun Dec 8 22:02:14 2013 -0500 ---------------------------------------------------------------------- .../org/apache/blur/manager/IndexManager.java | 30 +++++++++++--------- 1 file changed, 17 insertions(+), 13 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/3875ba17/blur-core/src/main/java/org/apache/blur/manager/IndexManager.java ---------------------------------------------------------------------- diff --git a/blur-core/src/main/java/org/apache/blur/manager/IndexManager.java b/blur-core/src/main/java/org/apache/blur/manager/IndexManager.java index 6cd9f8e..9e077e1 100644 --- a/blur-core/src/main/java/org/apache/blur/manager/IndexManager.java +++ b/blur-core/src/main/java/org/apache/blur/manager/IndexManager.java @@ -156,19 +156,23 @@ public class IndexManager { _indexServer = indexServer; _clusterStatus = clusterStatus; _filterCache = filterCache; - _readRecordsMeter = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, BLUR, "Read Records/s"), "Records/s", - TimeUnit.SECONDS); - _readRowMeter = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, BLUR, "Read Row/s"), "Row/s", TimeUnit.SECONDS); - _writeRecordsMeter = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, BLUR, "Write Records/s"), "Records/s", - TimeUnit.SECONDS); - _writeRowMeter = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, BLUR, "Write Row/s"), "Row/s", TimeUnit.SECONDS); - - _queriesExternalMeter = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, BLUR, "External Queries/s"), - "External Queries/s", TimeUnit.SECONDS); - _queriesInternalMeter = Metrics.newMeter(new MetricName(ORG_APACHE_BLUR, BLUR, "Internal Queries/s"), - "Internal Queries/s", TimeUnit.SECONDS); - _fetchTimer = Metrics.newTimer(new MetricName(ORG_APACHE_BLUR, BLUR, "Fetch Timer"), TimeUnit.MICROSECONDS, - TimeUnit.SECONDS); + + MetricName metricName1 = new MetricName(ORG_APACHE_BLUR, BLUR, "Read Records/s"); + MetricName metricName2 = new MetricName(ORG_APACHE_BLUR, BLUR, "Read Row/s"); + MetricName metricName3 = new MetricName(ORG_APACHE_BLUR, BLUR, "Write Records/s"); + MetricName metricName4 = new MetricName(ORG_APACHE_BLUR, BLUR, "Write Row/s"); + MetricName metricName5 = new MetricName(ORG_APACHE_BLUR, BLUR, "External Queries/s"); + MetricName metricName6 = new MetricName(ORG_APACHE_BLUR, BLUR, "Internal Queries/s"); + MetricName metricName7 = new MetricName(ORG_APACHE_BLUR, BLUR, "Fetch Timer"); + + _readRecordsMeter = Metrics.newMeter(metricName1, "Records/s", TimeUnit.SECONDS); + _readRowMeter = Metrics.newMeter(metricName2, "Row/s", TimeUnit.SECONDS); + _writeRecordsMeter = Metrics.newMeter(metricName3, "Records/s", TimeUnit.SECONDS); + _writeRowMeter = Metrics.newMeter(metricName4, "Row/s", TimeUnit.SECONDS); + _queriesExternalMeter = Metrics.newMeter(metricName5, "External Queries/s", TimeUnit.SECONDS); + _queriesInternalMeter = Metrics.newMeter(metricName6, "Internal Queries/s", TimeUnit.SECONDS); + _fetchTimer = Metrics.newTimer(metricName7, TimeUnit.MICROSECONDS, TimeUnit.SECONDS); + if (threadCount == 0) { throw new RuntimeException("Thread Count cannot be 0."); }
