From commits-return-78765-apmail-hbase-commits-archive=hbase.apache.org@hbase.apache.org Tue Oct 2 14:53:56 2018 Return-Path: X-Original-To: apmail-hbase-commits-archive@www.apache.org Delivered-To: apmail-hbase-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D27F51D6D3 for ; Tue, 2 Oct 2018 14:53:56 +0000 (UTC) Received: (qmail 39546 invoked by uid 500); 2 Oct 2018 14:53:54 -0000 Delivered-To: apmail-hbase-commits-archive@hbase.apache.org Received: (qmail 39424 invoked by uid 500); 2 Oct 2018 14:53:54 -0000 Mailing-List: contact commits-help@hbase.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@hbase.apache.org Delivered-To: mailing list commits@hbase.apache.org Received: (qmail 38823 invoked by uid 99); 2 Oct 2018 14:53:54 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Oct 2018 14:53:54 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 21685E11A6; Tue, 2 Oct 2018 14:53:52 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: git-site-role@apache.org To: commits@hbase.apache.org Date: Tue, 02 Oct 2018 14:54:08 -0000 Message-Id: <8b0c3990743641638eef8859919abdb8@git.apache.org> In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [17/26] hbase-site git commit: Published site at 42aa3dd463c0d30a9b940d296b87316b5c67e1f5. http://git-wip-us.apache.org/repos/asf/hbase-site/blob/37b8a04a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationGlobalSourceSource.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationGlobalSourceSource.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationGlobalSourceSource.html index 13d09d1..6c7169e 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationGlobalSourceSource.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationGlobalSourceSource.html @@ -60,209 +60,215 @@ 052 private final MutableFastCounter repeatedFileBytes; 053 private final MutableFastCounter completedWAL; 054 private final MutableFastCounter completedRecoveryQueue; -055 -056 public MetricsReplicationGlobalSourceSource(MetricsReplicationSourceImpl rms) { -057 this.rms = rms; -058 -059 ageOfLastShippedOpHist = rms.getMetricsRegistry().getHistogram(SOURCE_AGE_OF_LAST_SHIPPED_OP); -060 -061 sizeOfLogQueueGauge = rms.getMetricsRegistry().getGauge(SOURCE_SIZE_OF_LOG_QUEUE, 0L); -062 -063 shippedBatchesCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_BATCHES, 0L); -064 -065 shippedOpsCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_OPS, 0L); -066 -067 shippedKBsCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_KBS, 0L); -068 -069 shippedBytesCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_BYTES, 0L); -070 -071 logReadInBytesCounter = rms.getMetricsRegistry().getCounter(SOURCE_LOG_READ_IN_BYTES, 0L); -072 -073 logReadInEditsCounter = rms.getMetricsRegistry().getCounter(SOURCE_LOG_READ_IN_EDITS, 0L); -074 -075 logEditsFilteredCounter = rms.getMetricsRegistry().getCounter(SOURCE_LOG_EDITS_FILTERED, 0L); -076 -077 shippedHFilesCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_HFILES, 0L); -078 -079 sizeOfHFileRefsQueueGauge = -080 rms.getMetricsRegistry().getGauge(SOURCE_SIZE_OF_HFILE_REFS_QUEUE, 0L); -081 -082 unknownFileLengthForClosedWAL = rms.getMetricsRegistry() -083 .getCounter(SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH, 0L); -084 uncleanlyClosedWAL = rms.getMetricsRegistry().getCounter(SOURCE_UNCLEANLY_CLOSED_LOGS, 0L); -085 uncleanlyClosedSkippedBytes = rms.getMetricsRegistry() -086 .getCounter(SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES, 0L); -087 restartWALReading = rms.getMetricsRegistry().getCounter(SOURCE_RESTARTED_LOG_READING, 0L); -088 repeatedFileBytes = rms.getMetricsRegistry().getCounter(SOURCE_REPEATED_LOG_FILE_BYTES, 0L); -089 completedWAL = rms.getMetricsRegistry().getCounter(SOURCE_COMPLETED_LOGS, 0L); -090 completedRecoveryQueue = rms.getMetricsRegistry() -091 .getCounter(SOURCE_COMPLETED_RECOVERY_QUEUES, 0L); -092 } -093 -094 @Override public void setLastShippedAge(long age) { -095 ageOfLastShippedOpHist.add(age); -096 } -097 -098 @Override public void incrSizeOfLogQueue(int size) { -099 sizeOfLogQueueGauge.incr(size); -100 } -101 -102 @Override public void decrSizeOfLogQueue(int size) { -103 sizeOfLogQueueGauge.decr(size); -104 } -105 -106 @Override public void incrLogReadInEdits(long size) { -107 logReadInEditsCounter.incr(size); -108 } -109 -110 @Override public void incrLogEditsFiltered(long size) { -111 logEditsFilteredCounter.incr(size); -112 } -113 -114 @Override public void incrBatchesShipped(int batches) { -115 shippedBatchesCounter.incr(batches); -116 } -117 -118 @Override public void incrOpsShipped(long ops) { -119 shippedOpsCounter.incr(ops); -120 } -121 -122 @Override public void incrShippedBytes(long size) { -123 shippedBytesCounter.incr(size); -124 // obtained value maybe smaller than 1024. We should make sure that KB count -125 // eventually picks up even from multiple smaller updates. -126 incrementKBsCounter(shippedBytesCounter, shippedKBsCounter); -127 } -128 -129 static void incrementKBsCounter(MutableFastCounter bytesCounter, MutableFastCounter kbsCounter) { -130 // Following code should be thread-safe. -131 long delta = 0; -132 while(true) { -133 long bytes = bytesCounter.value(); -134 delta = (bytes / 1024) - kbsCounter.value(); -135 if (delta > 0) { -136 kbsCounter.incr(delta); -137 } else { -138 break; -139 } -140 } -141 } -142 -143 @Override public void incrLogReadInBytes(long size) { -144 logReadInBytesCounter.incr(size); -145 } -146 -147 @Override public void clear() { +055 private final MutableFastCounter failedRecoveryQueue; +056 +057 public MetricsReplicationGlobalSourceSource(MetricsReplicationSourceImpl rms) { +058 this.rms = rms; +059 +060 ageOfLastShippedOpHist = rms.getMetricsRegistry().getHistogram(SOURCE_AGE_OF_LAST_SHIPPED_OP); +061 +062 sizeOfLogQueueGauge = rms.getMetricsRegistry().getGauge(SOURCE_SIZE_OF_LOG_QUEUE, 0L); +063 +064 shippedBatchesCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_BATCHES, 0L); +065 +066 shippedOpsCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_OPS, 0L); +067 +068 shippedKBsCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_KBS, 0L); +069 +070 shippedBytesCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_BYTES, 0L); +071 +072 logReadInBytesCounter = rms.getMetricsRegistry().getCounter(SOURCE_LOG_READ_IN_BYTES, 0L); +073 +074 logReadInEditsCounter = rms.getMetricsRegistry().getCounter(SOURCE_LOG_READ_IN_EDITS, 0L); +075 +076 logEditsFilteredCounter = rms.getMetricsRegistry().getCounter(SOURCE_LOG_EDITS_FILTERED, 0L); +077 +078 shippedHFilesCounter = rms.getMetricsRegistry().getCounter(SOURCE_SHIPPED_HFILES, 0L); +079 +080 sizeOfHFileRefsQueueGauge = +081 rms.getMetricsRegistry().getGauge(SOURCE_SIZE_OF_HFILE_REFS_QUEUE, 0L); +082 +083 unknownFileLengthForClosedWAL = rms.getMetricsRegistry() +084 .getCounter(SOURCE_CLOSED_LOGS_WITH_UNKNOWN_LENGTH, 0L); +085 uncleanlyClosedWAL = rms.getMetricsRegistry().getCounter(SOURCE_UNCLEANLY_CLOSED_LOGS, 0L); +086 uncleanlyClosedSkippedBytes = rms.getMetricsRegistry() +087 .getCounter(SOURCE_UNCLEANLY_CLOSED_IGNORED_IN_BYTES, 0L); +088 restartWALReading = rms.getMetricsRegistry().getCounter(SOURCE_RESTARTED_LOG_READING, 0L); +089 repeatedFileBytes = rms.getMetricsRegistry().getCounter(SOURCE_REPEATED_LOG_FILE_BYTES, 0L); +090 completedWAL = rms.getMetricsRegistry().getCounter(SOURCE_COMPLETED_LOGS, 0L); +091 completedRecoveryQueue = rms.getMetricsRegistry() +092 .getCounter(SOURCE_COMPLETED_RECOVERY_QUEUES, 0L); +093 failedRecoveryQueue = rms.getMetricsRegistry() +094 .getCounter(SOURCE_FAILED_RECOVERY_QUEUES, 0L); +095 } +096 +097 @Override public void setLastShippedAge(long age) { +098 ageOfLastShippedOpHist.add(age); +099 } +100 +101 @Override public void incrSizeOfLogQueue(int size) { +102 sizeOfLogQueueGauge.incr(size); +103 } +104 +105 @Override public void decrSizeOfLogQueue(int size) { +106 sizeOfLogQueueGauge.decr(size); +107 } +108 +109 @Override public void incrLogReadInEdits(long size) { +110 logReadInEditsCounter.incr(size); +111 } +112 +113 @Override public void incrLogEditsFiltered(long size) { +114 logEditsFilteredCounter.incr(size); +115 } +116 +117 @Override public void incrBatchesShipped(int batches) { +118 shippedBatchesCounter.incr(batches); +119 } +120 +121 @Override public void incrOpsShipped(long ops) { +122 shippedOpsCounter.incr(ops); +123 } +124 +125 @Override public void incrShippedBytes(long size) { +126 shippedBytesCounter.incr(size); +127 // obtained value maybe smaller than 1024. We should make sure that KB count +128 // eventually picks up even from multiple smaller updates. +129 incrementKBsCounter(shippedBytesCounter, shippedKBsCounter); +130 } +131 +132 static void incrementKBsCounter(MutableFastCounter bytesCounter, MutableFastCounter kbsCounter) { +133 // Following code should be thread-safe. +134 long delta = 0; +135 while(true) { +136 long bytes = bytesCounter.value(); +137 delta = (bytes / 1024) - kbsCounter.value(); +138 if (delta > 0) { +139 kbsCounter.incr(delta); +140 } else { +141 break; +142 } +143 } +144 } +145 +146 @Override public void incrLogReadInBytes(long size) { +147 logReadInBytesCounter.incr(size); 148 } 149 -150 @Override -151 public long getLastShippedAge() { -152 return ageOfLastShippedOpHist.getMax(); -153 } -154 -155 @Override public void incrHFilesShipped(long hfiles) { -156 shippedHFilesCounter.incr(hfiles); -157 } -158 -159 @Override -160 public void incrSizeOfHFileRefsQueue(long size) { -161 sizeOfHFileRefsQueueGauge.incr(size); -162 } -163 -164 @Override -165 public void decrSizeOfHFileRefsQueue(long size) { -166 sizeOfHFileRefsQueueGauge.decr(size); -167 } -168 -169 @Override -170 public int getSizeOfLogQueue() { -171 return (int)sizeOfLogQueueGauge.value(); -172 } -173 -174 @Override -175 public void incrUnknownFileLengthForClosedWAL() { -176 unknownFileLengthForClosedWAL.incr(1L); -177 } -178 @Override -179 public void incrUncleanlyClosedWALs() { -180 uncleanlyClosedWAL.incr(1L); -181 } -182 @Override -183 public void incrBytesSkippedInUncleanlyClosedWALs(final long bytes) { -184 uncleanlyClosedSkippedBytes.incr(bytes); -185 } -186 @Override -187 public void incrRestartedWALReading() { -188 restartWALReading.incr(1L); -189 } -190 @Override -191 public void incrRepeatedFileBytes(final long bytes) { -192 repeatedFileBytes.incr(bytes); -193 } -194 @Override -195 public void incrCompletedWAL() { -196 completedWAL.incr(1L); -197 } -198 @Override -199 public void incrCompletedRecoveryQueue() { -200 completedRecoveryQueue.incr(1L); -201 } -202 -203 @Override -204 public void init() { -205 rms.init(); -206 } -207 -208 @Override -209 public void setGauge(String gaugeName, long value) { -210 rms.setGauge(KEY_PREFIX + gaugeName, value); -211 } -212 -213 @Override -214 public void incGauge(String gaugeName, long delta) { -215 rms.incGauge(KEY_PREFIX + gaugeName, delta); -216 } -217 -218 @Override -219 public void decGauge(String gaugeName, long delta) { -220 rms.decGauge(KEY_PREFIX + gaugeName, delta); -221 } -222 -223 @Override -224 public void removeMetric(String key) { -225 rms.removeMetric(KEY_PREFIX + key); -226 } -227 -228 @Override -229 public void incCounters(String counterName, long delta) { -230 rms.incCounters(KEY_PREFIX + counterName, delta); -231 } -232 -233 @Override -234 public void updateHistogram(String name, long value) { -235 rms.updateHistogram(KEY_PREFIX + name, value); -236 } -237 -238 @Override -239 public String getMetricsContext() { -240 return rms.getMetricsContext(); -241 } -242 -243 @Override -244 public String getMetricsDescription() { -245 return rms.getMetricsDescription(); -246 } -247 -248 @Override -249 public String getMetricsJmxContext() { -250 return rms.getMetricsJmxContext(); -251 } -252 -253 @Override -254 public String getMetricsName() { -255 return rms.getMetricsName(); -256 } -257} +150 @Override public void clear() { +151 } +152 +153 @Override +154 public long getLastShippedAge() { +155 return ageOfLastShippedOpHist.getMax(); +156 } +157 +158 @Override public void incrHFilesShipped(long hfiles) { +159 shippedHFilesCounter.incr(hfiles); +160 } +161 +162 @Override +163 public void incrSizeOfHFileRefsQueue(long size) { +164 sizeOfHFileRefsQueueGauge.incr(size); +165 } +166 +167 @Override +168 public void decrSizeOfHFileRefsQueue(long size) { +169 sizeOfHFileRefsQueueGauge.decr(size); +170 } +171 +172 @Override +173 public int getSizeOfLogQueue() { +174 return (int)sizeOfLogQueueGauge.value(); +175 } +176 +177 @Override +178 public void incrUnknownFileLengthForClosedWAL() { +179 unknownFileLengthForClosedWAL.incr(1L); +180 } +181 @Override +182 public void incrUncleanlyClosedWALs() { +183 uncleanlyClosedWAL.incr(1L); +184 } +185 @Override +186 public void incrBytesSkippedInUncleanlyClosedWALs(final long bytes) { +187 uncleanlyClosedSkippedBytes.incr(bytes); +188 } +189 @Override +190 public void incrRestartedWALReading() { +191 restartWALReading.incr(1L); +192 } +193 @Override +194 public void incrRepeatedFileBytes(final long bytes) { +195 repeatedFileBytes.incr(bytes); +196 } +197 @Override +198 public void incrCompletedWAL() { +199 completedWAL.incr(1L); +200 } +201 @Override +202 public void incrCompletedRecoveryQueue() { +203 completedRecoveryQueue.incr(1L); +204 } +205 @Override +206 public void incrFailedRecoveryQueue() { +207 failedRecoveryQueue.incr(1L); +208 } +209 @Override +210 public void init() { +211 rms.init(); +212 } +213 +214 @Override +215 public void setGauge(String gaugeName, long value) { +216 rms.setGauge(KEY_PREFIX + gaugeName, value); +217 } +218 +219 @Override +220 public void incGauge(String gaugeName, long delta) { +221 rms.incGauge(KEY_PREFIX + gaugeName, delta); +222 } +223 +224 @Override +225 public void decGauge(String gaugeName, long delta) { +226 rms.decGauge(KEY_PREFIX + gaugeName, delta); +227 } +228 +229 @Override +230 public void removeMetric(String key) { +231 rms.removeMetric(KEY_PREFIX + key); +232 } +233 +234 @Override +235 public void incCounters(String counterName, long delta) { +236 rms.incCounters(KEY_PREFIX + counterName, delta); +237 } +238 +239 @Override +240 public void updateHistogram(String name, long value) { +241 rms.updateHistogram(KEY_PREFIX + name, value); +242 } +243 +244 @Override +245 public String getMetricsContext() { +246 return rms.getMetricsContext(); +247 } +248 +249 @Override +250 public String getMetricsDescription() { +251 return rms.getMetricsDescription(); +252 } +253 +254 @Override +255 public String getMetricsJmxContext() { +256 return rms.getMetricsJmxContext(); +257 } +258 +259 @Override +260 public String getMetricsName() { +261 return rms.getMetricsName(); +262 } +263} http://git-wip-us.apache.org/repos/asf/hbase-site/blob/37b8a04a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSource.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSource.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSource.html index 411b879..9152601 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSource.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSource.html @@ -61,30 +61,32 @@ 053 public static final String SOURCE_REPEATED_LOG_FILE_BYTES = "source.repeatedLogFileBytes"; 054 public static final String SOURCE_COMPLETED_LOGS = "source.completedLogs"; 055 public static final String SOURCE_COMPLETED_RECOVERY_QUEUES = "source.completedRecoverQueues"; -056 -057 void setLastShippedAge(long age); -058 void incrSizeOfLogQueue(int size); -059 void decrSizeOfLogQueue(int size); -060 void incrLogEditsFiltered(long size); -061 void incrBatchesShipped(int batches); -062 void incrOpsShipped(long ops); -063 void incrShippedBytes(long size); -064 void incrLogReadInBytes(long size); -065 void incrLogReadInEdits(long size); -066 void clear(); -067 long getLastShippedAge(); -068 int getSizeOfLogQueue(); -069 void incrHFilesShipped(long hfiles); -070 void incrSizeOfHFileRefsQueue(long size); -071 void decrSizeOfHFileRefsQueue(long size); -072 void incrUnknownFileLengthForClosedWAL(); -073 void incrUncleanlyClosedWALs(); -074 void incrBytesSkippedInUncleanlyClosedWALs(final long bytes); -075 void incrRestartedWALReading(); -076 void incrRepeatedFileBytes(final long bytes); -077 void incrCompletedWAL(); -078 void incrCompletedRecoveryQueue(); -079} +056 public static final String SOURCE_FAILED_RECOVERY_QUEUES = "source.failedRecoverQueues"; +057 +058 void setLastShippedAge(long age); +059 void incrSizeOfLogQueue(int size); +060 void decrSizeOfLogQueue(int size); +061 void incrLogEditsFiltered(long size); +062 void incrBatchesShipped(int batches); +063 void incrOpsShipped(long ops); +064 void incrShippedBytes(long size); +065 void incrLogReadInBytes(long size); +066 void incrLogReadInEdits(long size); +067 void clear(); +068 long getLastShippedAge(); +069 int getSizeOfLogQueue(); +070 void incrHFilesShipped(long hfiles); +071 void incrSizeOfHFileRefsQueue(long size); +072 void decrSizeOfHFileRefsQueue(long size); +073 void incrUnknownFileLengthForClosedWAL(); +074 void incrUncleanlyClosedWALs(); +075 void incrBytesSkippedInUncleanlyClosedWALs(final long bytes); +076 void incrRestartedWALReading(); +077 void incrRepeatedFileBytes(final long bytes); +078 void incrCompletedWAL(); +079 void incrCompletedRecoveryQueue(); +080 void incrFailedRecoveryQueue(); +081} http://git-wip-us.apache.org/repos/asf/hbase-site/blob/37b8a04a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSourceImpl.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSourceImpl.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSourceImpl.html index 6263bb7..6a6f905 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSourceImpl.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsReplicationSourceSourceImpl.html @@ -266,60 +266,63 @@ 258 } 259 260 @Override -261 public void init() { -262 rms.init(); -263 } -264 -265 @Override -266 public void setGauge(String gaugeName, long value) { -267 rms.setGauge(this.keyPrefix + gaugeName, value); -268 } -269 -270 @Override -271 public void incGauge(String gaugeName, long delta) { -272 rms.incGauge(this.keyPrefix + gaugeName, delta); -273 } -274 -275 @Override -276 public void decGauge(String gaugeName, long delta) { -277 rms.decGauge(this.keyPrefix + gaugeName, delta); -278 } -279 -280 @Override -281 public void removeMetric(String key) { -282 rms.removeMetric(this.keyPrefix + key); -283 } -284 -285 @Override -286 public void incCounters(String counterName, long delta) { -287 rms.incCounters(this.keyPrefix + counterName, delta); -288 } -289 -290 @Override -291 public void updateHistogram(String name, long value) { -292 rms.updateHistogram(this.keyPrefix + name, value); -293 } -294 -295 @Override -296 public String getMetricsContext() { -297 return rms.getMetricsContext(); -298 } -299 -300 @Override -301 public String getMetricsDescription() { -302 return rms.getMetricsDescription(); -303 } -304 -305 @Override -306 public String getMetricsJmxContext() { -307 return rms.getMetricsJmxContext(); -308 } -309 -310 @Override -311 public String getMetricsName() { -312 return rms.getMetricsName(); -313 } -314} +261 public void incrFailedRecoveryQueue() {/*no op*/} +262 +263 @Override +264 public void init() { +265 rms.init(); +266 } +267 +268 @Override +269 public void setGauge(String gaugeName, long value) { +270 rms.setGauge(this.keyPrefix + gaugeName, value); +271 } +272 +273 @Override +274 public void incGauge(String gaugeName, long delta) { +275 rms.incGauge(this.keyPrefix + gaugeName, delta); +276 } +277 +278 @Override +279 public void decGauge(String gaugeName, long delta) { +280 rms.decGauge(this.keyPrefix + gaugeName, delta); +281 } +282 +283 @Override +284 public void removeMetric(String key) { +285 rms.removeMetric(this.keyPrefix + key); +286 } +287 +288 @Override +289 public void incCounters(String counterName, long delta) { +290 rms.incCounters(this.keyPrefix + counterName, delta); +291 } +292 +293 @Override +294 public void updateHistogram(String name, long value) { +295 rms.updateHistogram(this.keyPrefix + name, value); +296 } +297 +298 @Override +299 public String getMetricsContext() { +300 return rms.getMetricsContext(); +301 } +302 +303 @Override +304 public String getMetricsDescription() { +305 return rms.getMetricsDescription(); +306 } +307 +308 @Override +309 public String getMetricsJmxContext() { +310 return rms.getMetricsJmxContext(); +311 } +312 +313 @Override +314 public String getMetricsName() { +315 return rms.getMetricsName(); +316 } +317} http://git-wip-us.apache.org/repos/asf/hbase-site/blob/37b8a04a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html ---------------------------------------------------------------------- diff --git a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html index 338ff72..ef7b9d4 100644 --- a/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html +++ b/devapidocs/src-html/org/apache/hadoop/hbase/replication/regionserver/MetricsSource.html @@ -334,73 +334,77 @@ 326 globalSourceSource.incrCompletedRecoveryQueue(); 327 } 328 -329 @Override -330 public void init() { -331 singleSourceSource.init(); -332 globalSourceSource.init(); -333 } -334 -335 @Override -336 public void setGauge(String gaugeName, long value) { -337 singleSourceSource.setGauge(gaugeName, value); -338 globalSourceSource.setGauge(gaugeName, value); -339 } -340 -341 @Override -342 public void incGauge(String gaugeName, long delta) { -343 singleSourceSource.incGauge(gaugeName, delta); -344 globalSourceSource.incGauge(gaugeName, delta); -345 } -346 -347 @Override -348 public void decGauge(String gaugeName, long delta) { -349 singleSourceSource.decGauge(gaugeName, delta); -350 globalSourceSource.decGauge(gaugeName, delta); -351 } -352 -353 @Override -354 public void removeMetric(String key) { -355 singleSourceSource.removeMetric(key); -356 globalSourceSource.removeMetric(key); -357 } -358 -359 @Override -360 public void incCounters(String counterName, long delta) { -361 singleSourceSource.incCounters(counterName, delta); -362 globalSourceSource.incCounters(counterName, delta); -363 } -364 -365 @Override -366 public void updateHistogram(String name, long value) { -367 singleSourceSource.updateHistogram(name, value); -368 globalSourceSource.updateHistogram(name, value); -369 } -370 -371 @Override -372 public String getMetricsContext() { -373 return globalSourceSource.getMetricsContext(); -374 } -375 -376 @Override -377 public String getMetricsDescription() { -378 return globalSourceSource.getMetricsDescription(); -379 } -380 -381 @Override -382 public String getMetricsJmxContext() { -383 return globalSourceSource.getMetricsJmxContext(); -384 } -385 -386 @Override -387 public String getMetricsName() { -388 return globalSourceSource.getMetricsName(); -389 } -390 -391 @VisibleForTesting -392 public Map<String, MetricsReplicationSourceSource> getSingleSourceSourceByTable() { -393 return singleSourceSourceByTable; -394 } -395} +329 public void incrFailedRecoveryQueue() { +330 globalSourceSource.incrFailedRecoveryQueue(); +331 } +332 +333 @Override +334 public void init() { +335 singleSourceSource.init(); +336 globalSourceSource.init(); +337 } +338 +339 @Override +340 public void setGauge(String gaugeName, long value) { +341 singleSourceSource.setGauge(gaugeName, value); +342 globalSourceSource.setGauge(gaugeName, value); +343 } +344 +345 @Override +346 public void incGauge(String gaugeName, long delta) { +347 singleSourceSource.incGauge(gaugeName, delta); +348 globalSourceSource.incGauge(gaugeName, delta); +349 } +350 +351 @Override +352 public void decGauge(String gaugeName, long delta) { +353 singleSourceSource.decGauge(gaugeName, delta); +354 globalSourceSource.decGauge(gaugeName, delta); +355 } +356 +357 @Override +358 public void removeMetric(String key) { +359 singleSourceSource.removeMetric(key); +360 globalSourceSource.removeMetric(key); +361 } +362 +363 @Override +364 public void incCounters(String counterName, long delta) { +365 singleSourceSource.incCounters(counterName, delta); +366 globalSourceSource.incCounters(counterName, delta); +367 } +368 +369 @Override +370 public void updateHistogram(String name, long value) { +371 singleSourceSource.updateHistogram(name, value); +372 globalSourceSource.updateHistogram(name, value); +373 } +374 +375 @Override +376 public String getMetricsContext() { +377 return globalSourceSource.getMetricsContext(); +378 } +379 +380 @Override +381 public String getMetricsDescription() { +382 return globalSourceSource.getMetricsDescription(); +383 } +384 +385 @Override +386 public String getMetricsJmxContext() { +387 return globalSourceSource.getMetricsJmxContext(); +388 } +389 +390 @Override +391 public String getMetricsName() { +392 return globalSourceSource.getMetricsName(); +393 } +394 +395 @VisibleForTesting +396 public Map<String, MetricsReplicationSourceSource> getSingleSourceSourceByTable() { +397 return singleSourceSourceByTable; +398 } +399}