Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 42651200AE1 for ; Mon, 6 Jun 2016 20:26:41 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 40982160A5B; Mon, 6 Jun 2016 18:26:41 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 4FA47160A5D for ; Mon, 6 Jun 2016 20:26:39 +0200 (CEST) Received: (qmail 30729 invoked by uid 500); 6 Jun 2016 18:26:30 -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 27765 invoked by uid 99); 6 Jun 2016 18:26:28 -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; Mon, 06 Jun 2016 18:26:28 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id E83CEE1777; Mon, 6 Jun 2016 18:26:27 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: misty@apache.org To: commits@hbase.apache.org Date: Mon, 06 Jun 2016 18:27:08 -0000 Message-Id: In-Reply-To: <203f91de9c4c4d4690df8b84ed183740@git.apache.org> References: <203f91de9c4c4d4690df8b84ed183740@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [43/52] [partial] hbase-site git commit: Published site at b21c56e7958652ca6e6daf04642eb51abaf2b3d7. archived-at: Mon, 06 Jun 2016 18:26:41 -0000 http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/apidocs/src-html/org/apache/hadoop/hbase/ServerLoad.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/ServerLoad.html b/apidocs/src-html/org/apache/hadoop/hbase/ServerLoad.html index 87f3def..8459fb8 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/ServerLoad.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/ServerLoad.html @@ -65,281 +65,283 @@ 057 private long totalCompactingKVs = 0; 058 private long currentCompactedKVs = 0; 059 -060 public ServerLoad(ClusterStatusProtos.ServerLoad serverLoad) { -061 this.serverLoad = serverLoad; -062 for (ClusterStatusProtos.RegionLoad rl: serverLoad.getRegionLoadsList()) { -063 stores += rl.getStores(); -064 storefiles += rl.getStorefiles(); -065 storeUncompressedSizeMB += rl.getStoreUncompressedSizeMB(); -066 storefileSizeMB += rl.getStorefileSizeMB(); -067 memstoreSizeMB += rl.getMemstoreSizeMB(); -068 storefileIndexSizeMB += rl.getStorefileIndexSizeMB(); -069 readRequestsCount += rl.getReadRequestsCount(); -070 filteredReadRequestsCount += rl.getFilteredReadRequestsCount(); -071 writeRequestsCount += rl.getWriteRequestsCount(); -072 rootIndexSizeKB += rl.getRootIndexSizeKB(); -073 totalStaticIndexSizeKB += rl.getTotalStaticIndexSizeKB(); -074 totalStaticBloomSizeKB += rl.getTotalStaticBloomSizeKB(); -075 totalCompactingKVs += rl.getTotalCompactingKVs(); -076 currentCompactedKVs += rl.getCurrentCompactedKVs(); -077 } -078 -079 } -080 -081 // NOTE: Function name cannot start with "get" because then an OpenDataException is thrown because -082 // HBaseProtos.ServerLoad cannot be converted to an open data type(see HBASE-5967). -083 /* @return the underlying ServerLoad protobuf object */ -084 public ClusterStatusProtos.ServerLoad obtainServerLoadPB() { -085 return serverLoad; -086 } -087 -088 protected ClusterStatusProtos.ServerLoad serverLoad; +060 @InterfaceAudience.Private +061 public ServerLoad(ClusterStatusProtos.ServerLoad serverLoad) { +062 this.serverLoad = serverLoad; +063 for (ClusterStatusProtos.RegionLoad rl: serverLoad.getRegionLoadsList()) { +064 stores += rl.getStores(); +065 storefiles += rl.getStorefiles(); +066 storeUncompressedSizeMB += rl.getStoreUncompressedSizeMB(); +067 storefileSizeMB += rl.getStorefileSizeMB(); +068 memstoreSizeMB += rl.getMemstoreSizeMB(); +069 storefileIndexSizeMB += rl.getStorefileIndexSizeMB(); +070 readRequestsCount += rl.getReadRequestsCount(); +071 filteredReadRequestsCount += rl.getFilteredReadRequestsCount(); +072 writeRequestsCount += rl.getWriteRequestsCount(); +073 rootIndexSizeKB += rl.getRootIndexSizeKB(); +074 totalStaticIndexSizeKB += rl.getTotalStaticIndexSizeKB(); +075 totalStaticBloomSizeKB += rl.getTotalStaticBloomSizeKB(); +076 totalCompactingKVs += rl.getTotalCompactingKVs(); +077 currentCompactedKVs += rl.getCurrentCompactedKVs(); +078 } +079 +080 } +081 +082 // NOTE: Function name cannot start with "get" because then an OpenDataException is thrown because +083 // HBaseProtos.ServerLoad cannot be converted to an open data type(see HBASE-5967). +084 /* @return the underlying ServerLoad protobuf object */ +085 @InterfaceAudience.Private +086 public ClusterStatusProtos.ServerLoad obtainServerLoadPB() { +087 return serverLoad; +088 } 089 -090 /* @return number of requests since last report. */ -091 public long getNumberOfRequests() { -092 return serverLoad.getNumberOfRequests(); -093 } -094 public boolean hasNumberOfRequests() { -095 return serverLoad.hasNumberOfRequests(); -096 } -097 -098 /* @return total Number of requests from the start of the region server. */ -099 public long getTotalNumberOfRequests() { -100 return serverLoad.getTotalNumberOfRequests(); -101 } -102 public boolean hasTotalNumberOfRequests() { -103 return serverLoad.hasTotalNumberOfRequests(); -104 } -105 -106 /* @return the amount of used heap, in MB. */ -107 public int getUsedHeapMB() { -108 return serverLoad.getUsedHeapMB(); -109 } -110 public boolean hasUsedHeapMB() { -111 return serverLoad.hasUsedHeapMB(); -112 } -113 -114 /* @return the maximum allowable size of the heap, in MB. */ -115 public int getMaxHeapMB() { -116 return serverLoad.getMaxHeapMB(); -117 } -118 public boolean hasMaxHeapMB() { -119 return serverLoad.hasMaxHeapMB(); -120 } -121 -122 public int getStores() { -123 return stores; -124 } -125 -126 public int getStorefiles() { -127 return storefiles; -128 } -129 -130 public int getStoreUncompressedSizeMB() { -131 return storeUncompressedSizeMB; -132 } -133 -134 public int getStorefileSizeInMB() { -135 return storefileSizeMB; -136 } -137 -138 public int getMemstoreSizeInMB() { -139 return memstoreSizeMB; -140 } -141 -142 public int getStorefileIndexSizeInMB() { -143 return storefileIndexSizeMB; -144 } -145 -146 public long getReadRequestsCount() { -147 return readRequestsCount; -148 } -149 -150 public long getFilteredReadRequestsCount() { -151 return filteredReadRequestsCount; -152 } -153 -154 public long getWriteRequestsCount() { -155 return writeRequestsCount; -156 } -157 -158 public int getRootIndexSizeKB() { -159 return rootIndexSizeKB; -160 } -161 -162 public int getTotalStaticIndexSizeKB() { -163 return totalStaticIndexSizeKB; -164 } -165 -166 public int getTotalStaticBloomSizeKB() { -167 return totalStaticBloomSizeKB; -168 } -169 -170 public long getTotalCompactingKVs() { -171 return totalCompactingKVs; -172 } -173 -174 public long getCurrentCompactedKVs() { -175 return currentCompactedKVs; -176 } -177 -178 /** -179 * @return the number of regions -180 */ -181 public int getNumberOfRegions() { -182 return serverLoad.getRegionLoadsCount(); -183 } -184 -185 public int getInfoServerPort() { -186 return serverLoad.getInfoServerPort(); -187 } -188 -189 /** -190 * Call directly from client such as hbase shell -191 * @return the list of ReplicationLoadSource -192 */ -193 public List<ReplicationLoadSource> getReplicationLoadSourceList() { -194 return ProtobufUtil.toReplicationLoadSourceList(serverLoad.getReplLoadSourceList()); -195 } -196 -197 /** -198 * Call directly from client such as hbase shell -199 * @return ReplicationLoadSink -200 */ -201 public ReplicationLoadSink getReplicationLoadSink() { -202 if (serverLoad.hasReplLoadSink()) { -203 return ProtobufUtil.toReplicationLoadSink(serverLoad.getReplLoadSink()); -204 } else { -205 return null; -206 } -207 } -208 -209 /** -210 * Originally, this method factored in the effect of requests going to the -211 * server as well. However, this does not interact very well with the current -212 * region rebalancing code, which only factors number of regions. For the -213 * interim, until we can figure out how to make rebalancing use all the info -214 * available, we're just going to make load purely the number of regions. -215 * -216 * @return load factor for this server -217 */ -218 public int getLoad() { -219 // See above comment -220 // int load = numberOfRequests == 0 ? 1 : numberOfRequests; -221 // load *= numberOfRegions == 0 ? 1 : numberOfRegions; -222 // return load; -223 return getNumberOfRegions(); -224 } -225 -226 /** -227 * @return region load metrics -228 */ -229 public Map<byte[], RegionLoad> getRegionsLoad() { -230 Map<byte[], RegionLoad> regionLoads = -231 new TreeMap<byte[], RegionLoad>(Bytes.BYTES_COMPARATOR); -232 for (ClusterStatusProtos.RegionLoad rl : serverLoad.getRegionLoadsList()) { -233 RegionLoad regionLoad = new RegionLoad(rl); -234 regionLoads.put(regionLoad.getName(), regionLoad); -235 } -236 return regionLoads; -237 } -238 -239 /** -240 * Return the RegionServer-level coprocessors -241 * @return string array of loaded RegionServer-level coprocessors -242 */ -243 public String[] getRegionServerCoprocessors() { -244 List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList(); -245 String [] ret = new String[list.size()]; -246 int i = 0; -247 for (Coprocessor elem : list) { -248 ret[i++] = elem.getName(); -249 } -250 -251 return ret; -252 } -253 -254 /** -255 * Return the RegionServer-level and Region-level coprocessors -256 * @return string array of loaded RegionServer-level and -257 * Region-level coprocessors -258 */ -259 public String[] getRsCoprocessors() { -260 // Need a set to remove duplicates, but since generated Coprocessor class -261 // is not Comparable, make it a Set<String> instead of Set<Coprocessor> -262 TreeSet<String> coprocessSet = new TreeSet<String>(); -263 for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) { -264 coprocessSet.add(coprocessor.getName()); -265 } -266 return coprocessSet.toArray(new String[coprocessSet.size()]); -267 } -268 -269 /** -270 * @return number of requests per second received since the last report -271 */ -272 public double getRequestsPerSecond() { -273 return getNumberOfRequests(); -274 } -275 -276 /** -277 * @see java.lang.Object#toString() -278 */ -279 @Override -280 public String toString() { -281 StringBuilder sb = -282 Strings.appendKeyValue(new StringBuilder(), "requestsPerSecond", -283 Double.valueOf(getRequestsPerSecond())); -284 Strings.appendKeyValue(sb, "numberOfOnlineRegions", Integer.valueOf(getNumberOfRegions())); -285 sb = Strings.appendKeyValue(sb, "usedHeapMB", Integer.valueOf(this.getUsedHeapMB())); -286 sb = Strings.appendKeyValue(sb, "maxHeapMB", Integer.valueOf(getMaxHeapMB())); -287 sb = Strings.appendKeyValue(sb, "numberOfStores", Integer.valueOf(this.stores)); -288 sb = Strings.appendKeyValue(sb, "numberOfStorefiles", Integer.valueOf(this.storefiles)); -289 sb = -290 Strings.appendKeyValue(sb, "storefileUncompressedSizeMB", -291 Integer.valueOf(this.storeUncompressedSizeMB)); -292 sb = Strings.appendKeyValue(sb, "storefileSizeMB", Integer.valueOf(this.storefileSizeMB)); -293 if (this.storeUncompressedSizeMB != 0) { -294 sb = -295 Strings.appendKeyValue( -296 sb, -297 "compressionRatio", -298 String.format("%.4f", (float) this.storefileSizeMB -299 / (float) this.storeUncompressedSizeMB)); -300 } -301 sb = Strings.appendKeyValue(sb, "memstoreSizeMB", Integer.valueOf(this.memstoreSizeMB)); -302 sb = -303 Strings.appendKeyValue(sb, "storefileIndexSizeMB", -304 Integer.valueOf(this.storefileIndexSizeMB)); -305 sb = Strings.appendKeyValue(sb, "readRequestsCount", Long.valueOf(this.readRequestsCount)); -306 sb = Strings.appendKeyValue(sb, "filteredReadRequestsCount", -307 Long.valueOf(this.filteredReadRequestsCount)); -308 sb = Strings.appendKeyValue(sb, "writeRequestsCount", Long.valueOf(this.writeRequestsCount)); -309 sb = Strings.appendKeyValue(sb, "rootIndexSizeKB", Integer.valueOf(this.rootIndexSizeKB)); -310 sb = -311 Strings.appendKeyValue(sb, "totalStaticIndexSizeKB", -312 Integer.valueOf(this.totalStaticIndexSizeKB)); -313 sb = -314 Strings.appendKeyValue(sb, "totalStaticBloomSizeKB", -315 Integer.valueOf(this.totalStaticBloomSizeKB)); -316 sb = Strings.appendKeyValue(sb, "totalCompactingKVs", Long.valueOf(this.totalCompactingKVs)); -317 sb = Strings.appendKeyValue(sb, "currentCompactedKVs", Long.valueOf(this.currentCompactedKVs)); -318 float compactionProgressPct = Float.NaN; -319 if (this.totalCompactingKVs > 0) { -320 compactionProgressPct = -321 Float.valueOf((float) this.currentCompactedKVs / this.totalCompactingKVs); -322 } -323 sb = Strings.appendKeyValue(sb, "compactionProgressPct", compactionProgressPct); -324 -325 String[] coprocessorStrings = getRsCoprocessors(); -326 if (coprocessorStrings != null) { -327 sb = Strings.appendKeyValue(sb, "coprocessors", Arrays.toString(coprocessorStrings)); -328 } -329 return sb.toString(); -330 } -331 -332 public static final ServerLoad EMPTY_SERVERLOAD = -333 new ServerLoad(ClusterStatusProtos.ServerLoad.newBuilder().build()); -334} +090 protected ClusterStatusProtos.ServerLoad serverLoad; +091 +092 /* @return number of requests since last report. */ +093 public long getNumberOfRequests() { +094 return serverLoad.getNumberOfRequests(); +095 } +096 public boolean hasNumberOfRequests() { +097 return serverLoad.hasNumberOfRequests(); +098 } +099 +100 /* @return total Number of requests from the start of the region server. */ +101 public long getTotalNumberOfRequests() { +102 return serverLoad.getTotalNumberOfRequests(); +103 } +104 public boolean hasTotalNumberOfRequests() { +105 return serverLoad.hasTotalNumberOfRequests(); +106 } +107 +108 /* @return the amount of used heap, in MB. */ +109 public int getUsedHeapMB() { +110 return serverLoad.getUsedHeapMB(); +111 } +112 public boolean hasUsedHeapMB() { +113 return serverLoad.hasUsedHeapMB(); +114 } +115 +116 /* @return the maximum allowable size of the heap, in MB. */ +117 public int getMaxHeapMB() { +118 return serverLoad.getMaxHeapMB(); +119 } +120 public boolean hasMaxHeapMB() { +121 return serverLoad.hasMaxHeapMB(); +122 } +123 +124 public int getStores() { +125 return stores; +126 } +127 +128 public int getStorefiles() { +129 return storefiles; +130 } +131 +132 public int getStoreUncompressedSizeMB() { +133 return storeUncompressedSizeMB; +134 } +135 +136 public int getStorefileSizeInMB() { +137 return storefileSizeMB; +138 } +139 +140 public int getMemstoreSizeInMB() { +141 return memstoreSizeMB; +142 } +143 +144 public int getStorefileIndexSizeInMB() { +145 return storefileIndexSizeMB; +146 } +147 +148 public long getReadRequestsCount() { +149 return readRequestsCount; +150 } +151 +152 public long getFilteredReadRequestsCount() { +153 return filteredReadRequestsCount; +154 } +155 +156 public long getWriteRequestsCount() { +157 return writeRequestsCount; +158 } +159 +160 public int getRootIndexSizeKB() { +161 return rootIndexSizeKB; +162 } +163 +164 public int getTotalStaticIndexSizeKB() { +165 return totalStaticIndexSizeKB; +166 } +167 +168 public int getTotalStaticBloomSizeKB() { +169 return totalStaticBloomSizeKB; +170 } +171 +172 public long getTotalCompactingKVs() { +173 return totalCompactingKVs; +174 } +175 +176 public long getCurrentCompactedKVs() { +177 return currentCompactedKVs; +178 } +179 +180 /** +181 * @return the number of regions +182 */ +183 public int getNumberOfRegions() { +184 return serverLoad.getRegionLoadsCount(); +185 } +186 +187 public int getInfoServerPort() { +188 return serverLoad.getInfoServerPort(); +189 } +190 +191 /** +192 * Call directly from client such as hbase shell +193 * @return the list of ReplicationLoadSource +194 */ +195 public List<ReplicationLoadSource> getReplicationLoadSourceList() { +196 return ProtobufUtil.toReplicationLoadSourceList(serverLoad.getReplLoadSourceList()); +197 } +198 +199 /** +200 * Call directly from client such as hbase shell +201 * @return ReplicationLoadSink +202 */ +203 public ReplicationLoadSink getReplicationLoadSink() { +204 if (serverLoad.hasReplLoadSink()) { +205 return ProtobufUtil.toReplicationLoadSink(serverLoad.getReplLoadSink()); +206 } else { +207 return null; +208 } +209 } +210 +211 /** +212 * Originally, this method factored in the effect of requests going to the +213 * server as well. However, this does not interact very well with the current +214 * region rebalancing code, which only factors number of regions. For the +215 * interim, until we can figure out how to make rebalancing use all the info +216 * available, we're just going to make load purely the number of regions. +217 * +218 * @return load factor for this server +219 */ +220 public int getLoad() { +221 // See above comment +222 // int load = numberOfRequests == 0 ? 1 : numberOfRequests; +223 // load *= numberOfRegions == 0 ? 1 : numberOfRegions; +224 // return load; +225 return getNumberOfRegions(); +226 } +227 +228 /** +229 * @return region load metrics +230 */ +231 public Map<byte[], RegionLoad> getRegionsLoad() { +232 Map<byte[], RegionLoad> regionLoads = +233 new TreeMap<byte[], RegionLoad>(Bytes.BYTES_COMPARATOR); +234 for (ClusterStatusProtos.RegionLoad rl : serverLoad.getRegionLoadsList()) { +235 RegionLoad regionLoad = new RegionLoad(rl); +236 regionLoads.put(regionLoad.getName(), regionLoad); +237 } +238 return regionLoads; +239 } +240 +241 /** +242 * Return the RegionServer-level coprocessors +243 * @return string array of loaded RegionServer-level coprocessors +244 */ +245 public String[] getRegionServerCoprocessors() { +246 List<Coprocessor> list = obtainServerLoadPB().getCoprocessorsList(); +247 String [] ret = new String[list.size()]; +248 int i = 0; +249 for (Coprocessor elem : list) { +250 ret[i++] = elem.getName(); +251 } +252 +253 return ret; +254 } +255 +256 /** +257 * Return the RegionServer-level and Region-level coprocessors +258 * @return string array of loaded RegionServer-level and +259 * Region-level coprocessors +260 */ +261 public String[] getRsCoprocessors() { +262 // Need a set to remove duplicates, but since generated Coprocessor class +263 // is not Comparable, make it a Set<String> instead of Set<Coprocessor> +264 TreeSet<String> coprocessSet = new TreeSet<String>(); +265 for (Coprocessor coprocessor : obtainServerLoadPB().getCoprocessorsList()) { +266 coprocessSet.add(coprocessor.getName()); +267 } +268 return coprocessSet.toArray(new String[coprocessSet.size()]); +269 } +270 +271 /** +272 * @return number of requests per second received since the last report +273 */ +274 public double getRequestsPerSecond() { +275 return getNumberOfRequests(); +276 } +277 +278 /** +279 * @see java.lang.Object#toString() +280 */ +281 @Override +282 public String toString() { +283 StringBuilder sb = +284 Strings.appendKeyValue(new StringBuilder(), "requestsPerSecond", +285 Double.valueOf(getRequestsPerSecond())); +286 Strings.appendKeyValue(sb, "numberOfOnlineRegions", Integer.valueOf(getNumberOfRegions())); +287 sb = Strings.appendKeyValue(sb, "usedHeapMB", Integer.valueOf(this.getUsedHeapMB())); +288 sb = Strings.appendKeyValue(sb, "maxHeapMB", Integer.valueOf(getMaxHeapMB())); +289 sb = Strings.appendKeyValue(sb, "numberOfStores", Integer.valueOf(this.stores)); +290 sb = Strings.appendKeyValue(sb, "numberOfStorefiles", Integer.valueOf(this.storefiles)); +291 sb = +292 Strings.appendKeyValue(sb, "storefileUncompressedSizeMB", +293 Integer.valueOf(this.storeUncompressedSizeMB)); +294 sb = Strings.appendKeyValue(sb, "storefileSizeMB", Integer.valueOf(this.storefileSizeMB)); +295 if (this.storeUncompressedSizeMB != 0) { +296 sb = +297 Strings.appendKeyValue( +298 sb, +299 "compressionRatio", +300 String.format("%.4f", (float) this.storefileSizeMB +301 / (float) this.storeUncompressedSizeMB)); +302 } +303 sb = Strings.appendKeyValue(sb, "memstoreSizeMB", Integer.valueOf(this.memstoreSizeMB)); +304 sb = +305 Strings.appendKeyValue(sb, "storefileIndexSizeMB", +306 Integer.valueOf(this.storefileIndexSizeMB)); +307 sb = Strings.appendKeyValue(sb, "readRequestsCount", Long.valueOf(this.readRequestsCount)); +308 sb = Strings.appendKeyValue(sb, "filteredReadRequestsCount", +309 Long.valueOf(this.filteredReadRequestsCount)); +310 sb = Strings.appendKeyValue(sb, "writeRequestsCount", Long.valueOf(this.writeRequestsCount)); +311 sb = Strings.appendKeyValue(sb, "rootIndexSizeKB", Integer.valueOf(this.rootIndexSizeKB)); +312 sb = +313 Strings.appendKeyValue(sb, "totalStaticIndexSizeKB", +314 Integer.valueOf(this.totalStaticIndexSizeKB)); +315 sb = +316 Strings.appendKeyValue(sb, "totalStaticBloomSizeKB", +317 Integer.valueOf(this.totalStaticBloomSizeKB)); +318 sb = Strings.appendKeyValue(sb, "totalCompactingKVs", Long.valueOf(this.totalCompactingKVs)); +319 sb = Strings.appendKeyValue(sb, "currentCompactedKVs", Long.valueOf(this.currentCompactedKVs)); +320 float compactionProgressPct = Float.NaN; +321 if (this.totalCompactingKVs > 0) { +322 compactionProgressPct = +323 Float.valueOf((float) this.currentCompactedKVs / this.totalCompactingKVs); +324 } +325 sb = Strings.appendKeyValue(sb, "compactionProgressPct", compactionProgressPct); +326 +327 String[] coprocessorStrings = getRsCoprocessors(); +328 if (coprocessorStrings != null) { +329 sb = Strings.appendKeyValue(sb, "coprocessors", Arrays.toString(coprocessorStrings)); +330 } +331 return sb.toString(); +332 } +333 +334 public static final ServerLoad EMPTY_SERVERLOAD = +335 new ServerLoad(ClusterStatusProtos.ServerLoad.newBuilder().build()); +336} http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/apidocs/src-html/org/apache/hadoop/hbase/client/RegionLoadStats.html ---------------------------------------------------------------------- diff --git a/apidocs/src-html/org/apache/hadoop/hbase/client/RegionLoadStats.html b/apidocs/src-html/org/apache/hadoop/hbase/client/RegionLoadStats.html index 31ec3ce..b3f266f 100644 --- a/apidocs/src-html/org/apache/hadoop/hbase/client/RegionLoadStats.html +++ b/apidocs/src-html/org/apache/hadoop/hbase/client/RegionLoadStats.html @@ -28,11 +28,11 @@ 020import org.apache.hadoop.hbase.classification.InterfaceAudience; 021import org.apache.hadoop.hbase.classification.InterfaceStability; 022 -023@InterfaceAudience.Public -024@InterfaceStability.Evolving -025/** -026 * POJO representing region server load -027 */ +023/** +024 * POJO representing region server load +025 */ +026@InterfaceAudience.Public +027@InterfaceStability.Evolving 028public class RegionLoadStats { 029 int memstoreLoad; 030 int heapOccupancy; http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/book.html ---------------------------------------------------------------------- diff --git a/book.html b/book.html index 9a6fcee..90c03b2 100644 --- a/book.html +++ b/book.html @@ -33696,7 +33696,7 @@ The server will return cellblocks compressed using this same compressor as long http://git-wip-us.apache.org/repos/asf/hbase-site/blob/d434d867/bulk-loads.html ---------------------------------------------------------------------- diff --git a/bulk-loads.html b/bulk-loads.html index e94d21b..e468776 100644 --- a/bulk-loads.html +++ b/bulk-loads.html @@ -7,7 +7,7 @@ - + Apache HBase – Bulk Loads in Apache HBase (TM) @@ -305,7 +305,7 @@ under the License. --> <a href="http://www.apache.org/">The Apache Software Foundation</a>. All rights reserved. - <li id="publishDate" class="pull-right">Last Published: 2016-06-01</li> + <li id="publishDate" class="pull-right">Last Published: 2016-06-06</li> </p> </div>