[01/50] hbase-site git commit: Published site at .

Fri, 01 Dec 2017 07:18:53 -0800 

Repository: hbase-site
Updated Branches:
  refs/heads/asf-site 1c7795626 -> a5c4dca3b


http://git-wip-us.apache.org/repos/asf/hbase-site/blob/a5c4dca3/testdevapidocs/src-html/org/apache/hadoop/hbase/rsgroup/VerifyingRSGroupAdminClient.html
----------------------------------------------------------------------
diff --git 
a/testdevapidocs/src-html/org/apache/hadoop/hbase/rsgroup/VerifyingRSGroupAdminClient.html
 
b/testdevapidocs/src-html/org/apache/hadoop/hbase/rsgroup/VerifyingRSGroupAdminClient.html
index d1eeec2..88ff92b 100644
--- 
a/testdevapidocs/src-html/org/apache/hadoop/hbase/rsgroup/VerifyingRSGroupAdminClient.html
+++ 
b/testdevapidocs/src-html/org/apache/hadoop/hbase/rsgroup/VerifyingRSGroupAdminClient.html
@@ -118,44 +118,50 @@
 <span class="sourceLineNo">110</span>    verify();<a name="line.110"></a>
 <span class="sourceLineNo">111</span>  }<a name="line.111"></a>
 <span class="sourceLineNo">112</span><a name="line.112"></a>
-<span class="sourceLineNo">113</span>  public void verify() throws IOException 
{<a name="line.113"></a>
-<span class="sourceLineNo">114</span>    Map&lt;String, RSGroupInfo&gt; 
groupMap = Maps.newHashMap();<a name="line.114"></a>
-<span class="sourceLineNo">115</span>    Set&lt;RSGroupInfo&gt; zList = 
Sets.newHashSet();<a name="line.115"></a>
-<span class="sourceLineNo">116</span><a name="line.116"></a>
-<span class="sourceLineNo">117</span>    for (Result result : 
table.getScanner(new Scan())) {<a name="line.117"></a>
-<span class="sourceLineNo">118</span>      RSGroupProtos.RSGroupInfo proto =<a 
name="line.118"></a>
-<span class="sourceLineNo">119</span>          
RSGroupProtos.RSGroupInfo.parseFrom(<a name="line.119"></a>
-<span class="sourceLineNo">120</span>              result.getValue(<a 
name="line.120"></a>
-<span class="sourceLineNo">121</span>                  
RSGroupInfoManager.META_FAMILY_BYTES,<a name="line.121"></a>
-<span class="sourceLineNo">122</span>                  
RSGroupInfoManager.META_QUALIFIER_BYTES));<a name="line.122"></a>
-<span class="sourceLineNo">123</span>      groupMap.put(proto.getName(), 
RSGroupProtobufUtil.toGroupInfo(proto));<a name="line.123"></a>
-<span class="sourceLineNo">124</span>    }<a name="line.124"></a>
-<span class="sourceLineNo">125</span>    
Assert.assertEquals(Sets.newHashSet(groupMap.values()),<a name="line.125"></a>
-<span class="sourceLineNo">126</span>        
Sets.newHashSet(wrapped.listRSGroups()));<a name="line.126"></a>
-<span class="sourceLineNo">127</span>    try {<a name="line.127"></a>
-<span class="sourceLineNo">128</span>      String groupBasePath = 
ZNodePaths.joinZNode(zkw.znodePaths.baseZNode, "rsgroup");<a 
name="line.128"></a>
-<span class="sourceLineNo">129</span>      for(String znode: 
ZKUtil.listChildrenNoWatch(zkw, groupBasePath)) {<a name="line.129"></a>
-<span class="sourceLineNo">130</span>        byte[] data = ZKUtil.getData(zkw, 
ZNodePaths.joinZNode(groupBasePath, znode));<a name="line.130"></a>
-<span class="sourceLineNo">131</span>        if(data.length &gt; 0) {<a 
name="line.131"></a>
-<span class="sourceLineNo">132</span>          
ProtobufUtil.expectPBMagicPrefix(data);<a name="line.132"></a>
-<span class="sourceLineNo">133</span>          ByteArrayInputStream bis = new 
ByteArrayInputStream(<a name="line.133"></a>
-<span class="sourceLineNo">134</span>              data, 
ProtobufUtil.lengthOfPBMagic(), data.length);<a name="line.134"></a>
-<span class="sourceLineNo">135</span>          
zList.add(RSGroupProtobufUtil.toGroupInfo(RSGroupProtos.RSGroupInfo.parseFrom(bis)));<a
 name="line.135"></a>
-<span class="sourceLineNo">136</span>        }<a name="line.136"></a>
-<span class="sourceLineNo">137</span>      }<a name="line.137"></a>
-<span class="sourceLineNo">138</span>      Assert.assertEquals(zList.size(), 
groupMap.size());<a name="line.138"></a>
-<span class="sourceLineNo">139</span>      for(RSGroupInfo RSGroupInfo : 
zList) {<a name="line.139"></a>
-<span class="sourceLineNo">140</span>        
Assert.assertTrue(groupMap.get(RSGroupInfo.getName()).equals(RSGroupInfo));<a 
name="line.140"></a>
-<span class="sourceLineNo">141</span>      }<a name="line.141"></a>
-<span class="sourceLineNo">142</span>    } catch (KeeperException e) {<a 
name="line.142"></a>
-<span class="sourceLineNo">143</span>      throw new IOException("ZK 
verification failed", e);<a name="line.143"></a>
-<span class="sourceLineNo">144</span>    } catch (DeserializationException e) 
{<a name="line.144"></a>
-<span class="sourceLineNo">145</span>      throw new IOException("ZK 
verification failed", e);<a name="line.145"></a>
-<span class="sourceLineNo">146</span>    } catch (InterruptedException e) {<a 
name="line.146"></a>
-<span class="sourceLineNo">147</span>      throw new IOException("ZK 
verification failed", e);<a name="line.147"></a>
-<span class="sourceLineNo">148</span>    }<a name="line.148"></a>
-<span class="sourceLineNo">149</span>  }<a name="line.149"></a>
-<span class="sourceLineNo">150</span>}<a name="line.150"></a>
+<span class="sourceLineNo">113</span>  @Override<a name="line.113"></a>
+<span class="sourceLineNo">114</span>  public void 
removeServers(Set&lt;Address&gt; servers) throws IOException {<a 
name="line.114"></a>
+<span class="sourceLineNo">115</span>    wrapped.removeServers(servers);<a 
name="line.115"></a>
+<span class="sourceLineNo">116</span>    verify();<a name="line.116"></a>
+<span class="sourceLineNo">117</span>  }<a name="line.117"></a>
+<span class="sourceLineNo">118</span><a name="line.118"></a>
+<span class="sourceLineNo">119</span>  public void verify() throws IOException 
{<a name="line.119"></a>
+<span class="sourceLineNo">120</span>    Map&lt;String, RSGroupInfo&gt; 
groupMap = Maps.newHashMap();<a name="line.120"></a>
+<span class="sourceLineNo">121</span>    Set&lt;RSGroupInfo&gt; zList = 
Sets.newHashSet();<a name="line.121"></a>
+<span class="sourceLineNo">122</span><a name="line.122"></a>
+<span class="sourceLineNo">123</span>    for (Result result : 
table.getScanner(new Scan())) {<a name="line.123"></a>
+<span class="sourceLineNo">124</span>      RSGroupProtos.RSGroupInfo proto =<a 
name="line.124"></a>
+<span class="sourceLineNo">125</span>          
RSGroupProtos.RSGroupInfo.parseFrom(<a name="line.125"></a>
+<span class="sourceLineNo">126</span>              result.getValue(<a 
name="line.126"></a>
+<span class="sourceLineNo">127</span>                  
RSGroupInfoManager.META_FAMILY_BYTES,<a name="line.127"></a>
+<span class="sourceLineNo">128</span>                  
RSGroupInfoManager.META_QUALIFIER_BYTES));<a name="line.128"></a>
+<span class="sourceLineNo">129</span>      groupMap.put(proto.getName(), 
RSGroupProtobufUtil.toGroupInfo(proto));<a name="line.129"></a>
+<span class="sourceLineNo">130</span>    }<a name="line.130"></a>
+<span class="sourceLineNo">131</span>    
Assert.assertEquals(Sets.newHashSet(groupMap.values()),<a name="line.131"></a>
+<span class="sourceLineNo">132</span>        
Sets.newHashSet(wrapped.listRSGroups()));<a name="line.132"></a>
+<span class="sourceLineNo">133</span>    try {<a name="line.133"></a>
+<span class="sourceLineNo">134</span>      String groupBasePath = 
ZNodePaths.joinZNode(zkw.znodePaths.baseZNode, "rsgroup");<a 
name="line.134"></a>
+<span class="sourceLineNo">135</span>      for(String znode: 
ZKUtil.listChildrenNoWatch(zkw, groupBasePath)) {<a name="line.135"></a>
+<span class="sourceLineNo">136</span>        byte[] data = ZKUtil.getData(zkw, 
ZNodePaths.joinZNode(groupBasePath, znode));<a name="line.136"></a>
+<span class="sourceLineNo">137</span>        if(data.length &gt; 0) {<a 
name="line.137"></a>
+<span class="sourceLineNo">138</span>          
ProtobufUtil.expectPBMagicPrefix(data);<a name="line.138"></a>
+<span class="sourceLineNo">139</span>          ByteArrayInputStream bis = new 
ByteArrayInputStream(<a name="line.139"></a>
+<span class="sourceLineNo">140</span>              data, 
ProtobufUtil.lengthOfPBMagic(), data.length);<a name="line.140"></a>
+<span class="sourceLineNo">141</span>          
zList.add(RSGroupProtobufUtil.toGroupInfo(RSGroupProtos.RSGroupInfo.parseFrom(bis)));<a
 name="line.141"></a>
+<span class="sourceLineNo">142</span>        }<a name="line.142"></a>
+<span class="sourceLineNo">143</span>      }<a name="line.143"></a>
+<span class="sourceLineNo">144</span>      Assert.assertEquals(zList.size(), 
groupMap.size());<a name="line.144"></a>
+<span class="sourceLineNo">145</span>      for(RSGroupInfo RSGroupInfo : 
zList) {<a name="line.145"></a>
+<span class="sourceLineNo">146</span>        
Assert.assertTrue(groupMap.get(RSGroupInfo.getName()).equals(RSGroupInfo));<a 
name="line.146"></a>
+<span class="sourceLineNo">147</span>      }<a name="line.147"></a>
+<span class="sourceLineNo">148</span>    } catch (KeeperException e) {<a 
name="line.148"></a>
+<span class="sourceLineNo">149</span>      throw new IOException("ZK 
verification failed", e);<a name="line.149"></a>
+<span class="sourceLineNo">150</span>    } catch (DeserializationException e) 
{<a name="line.150"></a>
+<span class="sourceLineNo">151</span>      throw new IOException("ZK 
verification failed", e);<a name="line.151"></a>
+<span class="sourceLineNo">152</span>    } catch (InterruptedException e) {<a 
name="line.152"></a>
+<span class="sourceLineNo">153</span>      throw new IOException("ZK 
verification failed", e);<a name="line.153"></a>
+<span class="sourceLineNo">154</span>    }<a name="line.154"></a>
+<span class="sourceLineNo">155</span>  }<a name="line.155"></a>
+<span class="sourceLineNo">156</span>}<a name="line.156"></a>

Reply via email to