http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html b/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html index 91bba23..3af30ba 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html +++ b/testdevapidocs/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html @@ -597,7 +597,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>createTable</h4> -<pre>private static org.apache.hadoop.hbase.client.Table <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.105">createTable</a>() +<pre>private static org.apache.hadoop.hbase.client.Table <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.107">createTable</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -611,7 +611,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>testReadRequests</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.117">testReadRequests</a>(long resultCount, +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.119">testReadRequests</a>(long resultCount, long expectedReadRequests, long expectedFilteredReadRequests) throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, @@ -629,7 +629,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>updateMetricsMap</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.145">updateMetricsMap</a>() +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.147">updateMetricsMap</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> @@ -645,7 +645,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>getReadRequest</h4> -<pre>private static long <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.186">getReadRequest</a>(org.apache.hadoop.hbase.ServerLoad serverLoad, +<pre>private static long <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.188">getReadRequest</a>(org.apache.hadoop.hbase.ServerLoad serverLoad, org.apache.hadoop.hbase.RegionLoad regionLoad, <a href="../../../../../org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.Metric.html" title="enum in org.apache.hadoop.hbase.regionserver">TestRegionServerReadRequestMetrics.Metric</a> metric)</pre> </li> @@ -656,7 +656,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>putData</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.201">putData</a>() +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.203">putData</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -670,7 +670,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>putTTLExpiredData</h4> -<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.219">putTTLExpiredData</a>() +<pre>private static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.221">putTTLExpiredData</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a>, <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/InterruptedException.html?is-external=true"; title="class or interface in java.lang">InterruptedException</a></pre> <dl> @@ -686,7 +686,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>tearDownOnce</h4> -<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.241">tearDownOnce</a>() +<pre>public static void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.243">tearDownOnce</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -700,7 +700,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>testReadRequestsCountNotFiltered</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.246">testReadRequestsCountNotFiltered</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.248">testReadRequestsCountNotFiltered</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -714,7 +714,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>testReadRequestsCountWithFilter</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.314">testReadRequestsCountWithFilter</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.316">testReadRequestsCountWithFilter</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -728,7 +728,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockList"> <li class="blockList"> <h4>testReadRequestsCountWithDeletedRow</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.360">testReadRequestsCountWithDeletedRow</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.362">testReadRequestsCountWithDeletedRow</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt> @@ -742,7 +742,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>testReadRequestsCountWithTTLExpiration</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.382">testReadRequestsCountWithTTLExpiration</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.html#line.384">testReadRequestsCountWithTTLExpiration</a>() throws <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Exception.html?is-external=true"; title="class or interface in java.lang">Exception</a></pre> <dl> <dt><span class="throwsLabel">Throws:</span></dt>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html b/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html index 944d41f..7556c15 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -626,9 +626,9 @@ <ul> <li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/TestAtomicOperation.TestStep.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestAtomicOperation.TestStep</span></a></li> <li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/TestCacheOnWriteInSchema.CacheOnWriteType.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestCacheOnWriteInSchema.CacheOnWriteType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/TestMultiLogThreshold.ActionType.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestMultiLogThreshold.ActionType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.Metric.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestRegionServerReadRequestMetrics.Metric</span></a></li> <li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/DataBlockEncodingTool.Manipulation.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">DataBlockEncodingTool.Manipulation</span></a></li> +<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/TestRegionServerReadRequestMetrics.Metric.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestRegionServerReadRequestMetrics.Metric</span></a></li> +<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="../../../../../org/apache/hadoop/hbase/regionserver/TestMultiLogThreshold.ActionType.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestMultiLogThreshold.ActionType</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html b/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html index 48d8abf..a5f4c09 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html @@ -248,10 +248,10 @@ <ul> <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true"; title="class or interface in java.lang">Comparable</a><T>, java.io.<a href="http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>) <ul> +<li type="circle">org.apache.hadoop.hbase.test.<a href="../../../../../org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.Counters.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestLoadAndVerify.Counters</span></a></li> <li type="circle">org.apache.hadoop.hbase.test.<a href="../../../../../org/apache/hadoop/hbase/test/IntegrationTestWithCellVisibilityLoadAndVerify.Counters.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestWithCellVisibilityLoadAndVerify.Counters</span></a></li> <li type="circle">org.apache.hadoop.hbase.test.<a href="../../../../../org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.Generator.Counts.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestBigLinkedList.Generator.Counts</span></a></li> <li type="circle">org.apache.hadoop.hbase.test.<a href="../../../../../org/apache/hadoop/hbase/test/IntegrationTestBigLinkedList.Verify.Counts.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestBigLinkedList.Verify.Counts</span></a></li> -<li type="circle">org.apache.hadoop.hbase.test.<a href="../../../../../org/apache/hadoop/hbase/test/IntegrationTestLoadAndVerify.Counters.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestLoadAndVerify.Counters</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html b/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html index 8e1c1ad..d8c3b5b 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html @@ -140,9 +140,9 @@ <ul> <li type="circle">java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Enum.html?is-external=true"; title="class or interface in java.lang"><span class="typeNameLink">Enum</span></a><E> (implements java.lang.<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Comparable.html?is-external=true"; title="class or interface in java.lang">Comparable</a><T>, java.io.<a href="http://docs.oracle.com/javase/8/docs/api/java/io/Serializable.html?is-external=true"; title="class or interface in java.io">Serializable</a>) <ul> -<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/TestWALSplit.Corruptions.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">TestWALSplit.Corruptions</span></a></li> <li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/IOTestProvider.AllowedOperations.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">IOTestProvider.AllowedOperations</span></a></li> <li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/FaultyFSLog.FailureType.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">FaultyFSLog.FailureType</span></a></li> +<li type="circle">org.apache.hadoop.hbase.wal.<a href="../../../../../org/apache/hadoop/hbase/wal/TestWALSplit.Corruptions.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">TestWALSplit.Corruptions</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html b/testdevapidocs/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html index b95de2d..a38ac1c 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html +++ b/testdevapidocs/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10}; +var methods = {"i0":10}; var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; @@ -75,13 +75,13 @@ var activeTableTab = "activeTableTab"; <ul class="subNavList"> <li>Summary: </li> <li>Nested | </li> -<li><a href="#field.summary">Field</a> | </li> +<li>Field | </li> <li><a href="#constructor.summary">Constr</a> | </li> <li><a href="#method.summary">Method</a></li> </ul> <ul class="subNavList"> <li>Detail: </li> -<li><a href="#field.detail">Field</a> | </li> +<li>Field | </li> <li><a href="#constructor.detail">Constr</a> | </li> <li><a href="#method.detail">Method</a></li> </ul> @@ -109,7 +109,7 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <hr> <br> -<pre>public class <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.40">TestZooKeeperWatcher</a> +<pre>public class <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.33">TestZooKeeperWatcher</a> extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html?is-external=true"; title="class or interface in java.lang">Object</a></pre> </li> </ul> @@ -117,25 +117,6 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <div class="summary"> <ul class="blockList"> <li class="blockList"> -<!-- =========== FIELD SUMMARY =========== --> -<ul class="blockList"> -<li class="blockList"><a name="field.summary"> -<!-- --> -</a> -<h3>Field Summary</h3> -<table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Field Summary table, listing fields, and an explanation"> -<caption><span>Fields</span><span class="tabEnd"> </span></caption> -<tr> -<th class="colFirst" scope="col">Modifier and Type</th> -<th class="colLast" scope="col">Field and Description</th> -</tr> -<tr class="altColor"> -<td class="colFirst"><code>private static org.apache.commons.logging.Log</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#LOG">LOG</a></span></code> </td> -</tr> -</table> -</li> -</ul> <!-- ======== CONSTRUCTOR SUMMARY ======== --> <ul class="blockList"> <li class="blockList"><a name="constructor.summary"> @@ -167,10 +148,6 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? </tr> <tr id="i0" class="altColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#testConnectionEvent--">testConnectionEvent</a></span>()</code> </td> -</tr> -<tr id="i1" class="rowColor"> -<td class="colFirst"><code>void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#testIsClientReadable--">testIsClientReadable</a></span>()</code> </td> </tr> </table> @@ -189,23 +166,6 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <div class="details"> <ul class="blockList"> <li class="blockList"> -<!-- ============ FIELD DETAIL =========== --> -<ul class="blockList"> -<li class="blockList"><a name="field.detail"> -<!-- --> -</a> -<h3>Field Detail</h3> -<a name="LOG"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>LOG</h4> -<pre>private static final org.apache.commons.logging.Log <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.41">LOG</a></pre> -</li> -</ul> -</li> -</ul> <!-- ========= CONSTRUCTOR DETAIL ======== --> <ul class="blockList"> <li class="blockList"><a name="constructor.detail"> @@ -218,7 +178,7 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="blockListLast"> <li class="blockList"> <h4>TestZooKeeperWatcher</h4> -<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.40">TestZooKeeperWatcher</a>()</pre> +<pre>public <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.33">TestZooKeeperWatcher</a>()</pre> </li> </ul> </li> @@ -232,10 +192,10 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <a name="testIsClientReadable--"> <!-- --> </a> -<ul class="blockList"> +<ul class="blockListLast"> <li class="blockList"> <h4>testIsClientReadable</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.44">testIsClientReadable</a>() +<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.36">testIsClientReadable</a>() throws org.apache.hadoop.hbase.ZooKeeperConnectionException, <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> <dl> @@ -245,22 +205,6 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? </dl> </li> </ul> -<a name="testConnectionEvent--"> -<!-- --> -</a> -<ul class="blockListLast"> -<li class="blockList"> -<h4>testConnectionEvent</h4> -<pre>public void <a href="../../../../../src-html/org/apache/hadoop/hbase/zookeeper/TestZooKeeperWatcher.html#line.69">testConnectionEvent</a>() - throws org.apache.hadoop.hbase.ZooKeeperConnectionException, - <a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></pre> -<dl> -<dt><span class="throwsLabel">Throws:</span></dt> -<dd><code>org.apache.hadoop.hbase.ZooKeeperConnectionException</code></dd> -<dd><code><a href="http://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true"; title="class or interface in java.io">IOException</a></code></dd> -</dl> -</li> -</ul> </li> </ul> </li> @@ -315,13 +259,13 @@ extends <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Object.html? <ul class="subNavList"> <li>Summary: </li> <li>Nested | </li> -<li><a href="#field.summary">Field</a> | </li> +<li>Field | </li> <li><a href="#constructor.summary">Constr</a> | </li> <li><a href="#method.summary">Method</a></li> </ul> <ul class="subNavList"> <li>Detail: </li> -<li><a href="#field.detail">Field</a> | </li> +<li>Field | </li> <li><a href="#constructor.detail">Constr</a> | </li> <li><a href="#method.detail">Method</a></li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/overview-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/overview-tree.html b/testdevapidocs/overview-tree.html index 3a462a4..51d9626 100644 --- a/testdevapidocs/overview-tree.html +++ b/testdevapidocs/overview-tree.html @@ -3151,6 +3151,7 @@ <li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/TestResultFromCoprocessor.MyObserver.html" title="class in org.apache.hadoop.hbase.client"><span class="typeNameLink">TestResultFromCoprocessor.MyObserver</span></a> (implements org.apache.hadoop.hbase.coprocessor.RegionObserver)</li> <li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/TestResultSizeEstimation.html" title="class in org.apache.hadoop.hbase.client"><span class="typeNameLink">TestResultSizeEstimation</span></a></li> <li type="circle">org.apache.hadoop.hbase.regionserver.<a href="org/apache/hadoop/hbase/regionserver/TestReversibleScanners.html" title="class in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestReversibleScanners</span></a></li> +<li type="circle">org.apache.hadoop.hbase.master.assignment.<a href="org/apache/hadoop/hbase/master/assignment/TestRogueRSAssignment.html" title="class in org.apache.hadoop.hbase.master.assignment"><span class="typeNameLink">TestRogueRSAssignment</span></a></li> <li type="circle">org.apache.hadoop.hbase.master.<a href="org/apache/hadoop/hbase/master/TestRollingRestart.html" title="class in org.apache.hadoop.hbase.master"><span class="typeNameLink">TestRollingRestart</span></a></li> <li type="circle">org.apache.hadoop.hbase.mapreduce.<a href="org/apache/hadoop/hbase/mapreduce/TestRowCounter.html" title="class in org.apache.hadoop.hbase.mapreduce"><span class="typeNameLink">TestRowCounter</span></a></li> <li type="circle">org.apache.hadoop.hbase.mapred.<a href="org/apache/hadoop/hbase/mapred/TestRowCounter.html" title="class in org.apache.hadoop.hbase.mapred"><span class="typeNameLink">TestRowCounter</span></a></li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/src-html/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.html index 2d153d1..dba064b 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/chaos/util/ChaosMonkeyRunner.html @@ -60,113 +60,135 @@ <span class="sourceLineNo">052</span> protected boolean noClusterCleanUp = false;<a name="line.52"></a> <span class="sourceLineNo">053</span> private String tableName = "ChaosMonkeyRunner.tableName";<a name="line.53"></a> <span class="sourceLineNo">054</span> private String familyName = "ChaosMonkeyRunner.familyName";<a name="line.54"></a> -<span class="sourceLineNo">055</span><a name="line.55"></a> -<span class="sourceLineNo">056</span> @Override<a name="line.56"></a> -<span class="sourceLineNo">057</span> public void addOptions() {<a name="line.57"></a> -<span class="sourceLineNo">058</span> addOptWithArg("m", MONKEY_LONG_OPT, "Which chaos monkey to run");<a name="line.58"></a> -<span class="sourceLineNo">059</span> addOptWithArg(CHAOS_MONKEY_PROPS, "The properties file for specifying chaos "<a name="line.59"></a> -<span class="sourceLineNo">060</span> + "monkey properties.");<a name="line.60"></a> -<span class="sourceLineNo">061</span> addOptWithArg(TABLE_NAME_OPT, "Table name in the test to run chaos monkey against");<a name="line.61"></a> -<span class="sourceLineNo">062</span> addOptWithArg(FAMILY_NAME_OPT, "Family name in the test to run chaos monkey against");<a name="line.62"></a> -<span class="sourceLineNo">063</span> }<a name="line.63"></a> -<span class="sourceLineNo">064</span><a name="line.64"></a> -<span class="sourceLineNo">065</span> @Override<a name="line.65"></a> -<span class="sourceLineNo">066</span> protected void processOptions(CommandLine cmd) {<a name="line.66"></a> -<span class="sourceLineNo">067</span> if (cmd.hasOption(MONKEY_LONG_OPT)) {<a name="line.67"></a> -<span class="sourceLineNo">068</span> monkeyToUse = cmd.getOptionValue(MONKEY_LONG_OPT);<a name="line.68"></a> -<span class="sourceLineNo">069</span> }<a name="line.69"></a> -<span class="sourceLineNo">070</span> monkeyProps = new Properties();<a name="line.70"></a> -<span class="sourceLineNo">071</span> if (cmd.hasOption(CHAOS_MONKEY_PROPS)) {<a name="line.71"></a> -<span class="sourceLineNo">072</span> String chaosMonkeyPropsFile = cmd.getOptionValue(CHAOS_MONKEY_PROPS);<a name="line.72"></a> -<span class="sourceLineNo">073</span> if (StringUtils.isNotEmpty(chaosMonkeyPropsFile)) {<a name="line.73"></a> -<span class="sourceLineNo">074</span> try {<a name="line.74"></a> -<span class="sourceLineNo">075</span> monkeyProps.load(this.getClass().getClassLoader()<a name="line.75"></a> -<span class="sourceLineNo">076</span> .getResourceAsStream(chaosMonkeyPropsFile));<a name="line.76"></a> -<span class="sourceLineNo">077</span> } catch (IOException e) {<a name="line.77"></a> -<span class="sourceLineNo">078</span> LOG.warn(e);<a name="line.78"></a> -<span class="sourceLineNo">079</span> System.exit(EXIT_FAILURE);<a name="line.79"></a> -<span class="sourceLineNo">080</span> }<a name="line.80"></a> -<span class="sourceLineNo">081</span> }<a name="line.81"></a> -<span class="sourceLineNo">082</span> }<a name="line.82"></a> -<span class="sourceLineNo">083</span> if (cmd.hasOption(TABLE_NAME_OPT)) {<a name="line.83"></a> -<span class="sourceLineNo">084</span> this.tableName = cmd.getOptionValue(TABLE_NAME_OPT);<a name="line.84"></a> -<span class="sourceLineNo">085</span> }<a name="line.85"></a> -<span class="sourceLineNo">086</span> if (cmd.hasOption(FAMILY_NAME_OPT)) {<a name="line.86"></a> -<span class="sourceLineNo">087</span> this.familyName = cmd.getOptionValue(FAMILY_NAME_OPT);<a name="line.87"></a> -<span class="sourceLineNo">088</span> }<a name="line.88"></a> -<span class="sourceLineNo">089</span> }<a name="line.89"></a> -<span class="sourceLineNo">090</span><a name="line.90"></a> -<span class="sourceLineNo">091</span> @Override<a name="line.91"></a> -<span class="sourceLineNo">092</span> protected int doWork() throws Exception {<a name="line.92"></a> -<span class="sourceLineNo">093</span> setUpCluster();<a name="line.93"></a> -<span class="sourceLineNo">094</span> getAndStartMonkey();<a name="line.94"></a> -<span class="sourceLineNo">095</span> while (true) {// loop here until got killed<a name="line.95"></a> -<span class="sourceLineNo">096</span> Thread.sleep(10000);<a name="line.96"></a> -<span class="sourceLineNo">097</span> }<a name="line.97"></a> -<span class="sourceLineNo">098</span> }<a name="line.98"></a> -<span class="sourceLineNo">099</span><a name="line.99"></a> -<span class="sourceLineNo">100</span> public void setUpCluster() throws Exception {<a name="line.100"></a> -<span class="sourceLineNo">101</span> util = getTestingUtil(getConf());<a name="line.101"></a> -<span class="sourceLineNo">102</span> boolean isDistributed = isDistributedCluster(getConf());<a name="line.102"></a> -<span class="sourceLineNo">103</span> if (isDistributed) {<a name="line.103"></a> -<span class="sourceLineNo">104</span> util.createDistributedHBaseCluster();<a name="line.104"></a> -<span class="sourceLineNo">105</span> util.checkNodeCount(1);// make sure there's at least 1 alive rs<a name="line.105"></a> -<span class="sourceLineNo">106</span> } else {<a name="line.106"></a> -<span class="sourceLineNo">107</span> throw new RuntimeException("ChaosMonkeyRunner must run againt a distributed cluster,"<a name="line.107"></a> -<span class="sourceLineNo">108</span> + " please check and point to the right configuration dir");<a name="line.108"></a> -<span class="sourceLineNo">109</span> }<a name="line.109"></a> -<span class="sourceLineNo">110</span> this.setConf(util.getConfiguration());<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> private boolean isDistributedCluster(Configuration conf) {<a name="line.113"></a> -<span class="sourceLineNo">114</span> return conf.getBoolean(HConstants.CLUSTER_DISTRIBUTED, false);<a name="line.114"></a> -<span class="sourceLineNo">115</span> }<a name="line.115"></a> -<span class="sourceLineNo">116</span><a name="line.116"></a> -<span class="sourceLineNo">117</span> public void getAndStartMonkey() throws Exception {<a name="line.117"></a> -<span class="sourceLineNo">118</span> util = getTestingUtil(getConf());<a name="line.118"></a> -<span class="sourceLineNo">119</span> MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);<a name="line.119"></a> -<span class="sourceLineNo">120</span> if (fact == null) {<a name="line.120"></a> -<span class="sourceLineNo">121</span> fact = getDefaultMonkeyFactory();<a name="line.121"></a> -<span class="sourceLineNo">122</span> }<a name="line.122"></a> -<span class="sourceLineNo">123</span> monkey =<a name="line.123"></a> -<span class="sourceLineNo">124</span> fact.setUtil(util).setTableName(getTablename()).setProperties(monkeyProps)<a name="line.124"></a> -<span class="sourceLineNo">125</span> .setColumnFamilies(getColumnFamilies()).build();<a name="line.125"></a> -<span class="sourceLineNo">126</span> monkey.start();<a name="line.126"></a> -<span class="sourceLineNo">127</span> }<a name="line.127"></a> -<span class="sourceLineNo">128</span><a name="line.128"></a> -<span class="sourceLineNo">129</span> protected IntegrationTestingUtility getTestingUtil(Configuration conf) {<a name="line.129"></a> -<span class="sourceLineNo">130</span> if (this.util == null) {<a name="line.130"></a> -<span class="sourceLineNo">131</span> if (conf == null) {<a name="line.131"></a> -<span class="sourceLineNo">132</span> this.util = new IntegrationTestingUtility();<a name="line.132"></a> -<span class="sourceLineNo">133</span> this.setConf(util.getConfiguration());<a name="line.133"></a> -<span class="sourceLineNo">134</span> } else {<a name="line.134"></a> -<span class="sourceLineNo">135</span> this.util = new IntegrationTestingUtility(conf);<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> return util;<a name="line.138"></a> -<span class="sourceLineNo">139</span> }<a name="line.139"></a> -<span class="sourceLineNo">140</span><a name="line.140"></a> -<span class="sourceLineNo">141</span> protected MonkeyFactory getDefaultMonkeyFactory() {<a name="line.141"></a> -<span class="sourceLineNo">142</span> // Run with slow deterministic monkey by default<a name="line.142"></a> -<span class="sourceLineNo">143</span> return MonkeyFactory.getFactory(MonkeyFactory.SLOW_DETERMINISTIC);<a name="line.143"></a> -<span class="sourceLineNo">144</span> }<a name="line.144"></a> -<span class="sourceLineNo">145</span><a name="line.145"></a> -<span class="sourceLineNo">146</span> public TableName getTablename() {<a name="line.146"></a> -<span class="sourceLineNo">147</span> return TableName.valueOf(tableName);<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> protected Set<String> getColumnFamilies() {<a name="line.150"></a> -<span class="sourceLineNo">151</span> return Sets.newHashSet(familyName);<a name="line.151"></a> -<span class="sourceLineNo">152</span> }<a name="line.152"></a> -<span class="sourceLineNo">153</span><a name="line.153"></a> -<span class="sourceLineNo">154</span> public static void main(String[] args) throws Exception {<a name="line.154"></a> -<span class="sourceLineNo">155</span> Configuration conf = HBaseConfiguration.create();<a name="line.155"></a> -<span class="sourceLineNo">156</span> IntegrationTestingUtility.setUseDistributedCluster(conf);<a name="line.156"></a> -<span class="sourceLineNo">157</span> int ret = ToolRunner.run(conf, new ChaosMonkeyRunner(), args);<a name="line.157"></a> -<span class="sourceLineNo">158</span> System.exit(ret);<a name="line.158"></a> -<span class="sourceLineNo">159</span> }<a name="line.159"></a> -<span class="sourceLineNo">160</span><a name="line.160"></a> -<span class="sourceLineNo">161</span>}<a name="line.161"></a> +<span class="sourceLineNo">055</span> private volatile boolean stop = false;<a name="line.55"></a> +<span class="sourceLineNo">056</span><a name="line.56"></a> +<span class="sourceLineNo">057</span> @Override<a name="line.57"></a> +<span class="sourceLineNo">058</span> public void addOptions() {<a name="line.58"></a> +<span class="sourceLineNo">059</span> addOptWithArg("m", MONKEY_LONG_OPT, "Which chaos monkey to run");<a name="line.59"></a> +<span class="sourceLineNo">060</span> addOptWithArg(CHAOS_MONKEY_PROPS, "The properties file for specifying chaos "<a name="line.60"></a> +<span class="sourceLineNo">061</span> + "monkey properties.");<a name="line.61"></a> +<span class="sourceLineNo">062</span> addOptWithArg(TABLE_NAME_OPT, "Table name in the test to run chaos monkey against");<a name="line.62"></a> +<span class="sourceLineNo">063</span> addOptWithArg(FAMILY_NAME_OPT, "Family name in the test to run chaos monkey against");<a name="line.63"></a> +<span class="sourceLineNo">064</span> }<a name="line.64"></a> +<span class="sourceLineNo">065</span><a name="line.65"></a> +<span class="sourceLineNo">066</span> @Override<a name="line.66"></a> +<span class="sourceLineNo">067</span> protected void processOptions(CommandLine cmd) {<a name="line.67"></a> +<span class="sourceLineNo">068</span> if (cmd.hasOption(MONKEY_LONG_OPT)) {<a name="line.68"></a> +<span class="sourceLineNo">069</span> monkeyToUse = cmd.getOptionValue(MONKEY_LONG_OPT);<a name="line.69"></a> +<span class="sourceLineNo">070</span> }<a name="line.70"></a> +<span class="sourceLineNo">071</span> monkeyProps = new Properties();<a name="line.71"></a> +<span class="sourceLineNo">072</span> if (cmd.hasOption(CHAOS_MONKEY_PROPS)) {<a name="line.72"></a> +<span class="sourceLineNo">073</span> String chaosMonkeyPropsFile = cmd.getOptionValue(CHAOS_MONKEY_PROPS);<a name="line.73"></a> +<span class="sourceLineNo">074</span> if (StringUtils.isNotEmpty(chaosMonkeyPropsFile)) {<a name="line.74"></a> +<span class="sourceLineNo">075</span> try {<a name="line.75"></a> +<span class="sourceLineNo">076</span> monkeyProps.load(this.getClass().getClassLoader()<a name="line.76"></a> +<span class="sourceLineNo">077</span> .getResourceAsStream(chaosMonkeyPropsFile));<a name="line.77"></a> +<span class="sourceLineNo">078</span> } catch (IOException e) {<a name="line.78"></a> +<span class="sourceLineNo">079</span> LOG.warn(e);<a name="line.79"></a> +<span class="sourceLineNo">080</span> System.exit(EXIT_FAILURE);<a name="line.80"></a> +<span class="sourceLineNo">081</span> }<a name="line.81"></a> +<span class="sourceLineNo">082</span> }<a name="line.82"></a> +<span class="sourceLineNo">083</span> }<a name="line.83"></a> +<span class="sourceLineNo">084</span> if (cmd.hasOption(TABLE_NAME_OPT)) {<a name="line.84"></a> +<span class="sourceLineNo">085</span> this.tableName = cmd.getOptionValue(TABLE_NAME_OPT);<a name="line.85"></a> +<span class="sourceLineNo">086</span> }<a name="line.86"></a> +<span class="sourceLineNo">087</span> if (cmd.hasOption(FAMILY_NAME_OPT)) {<a name="line.87"></a> +<span class="sourceLineNo">088</span> this.familyName = cmd.getOptionValue(FAMILY_NAME_OPT);<a name="line.88"></a> +<span class="sourceLineNo">089</span> }<a name="line.89"></a> +<span class="sourceLineNo">090</span> }<a name="line.90"></a> +<span class="sourceLineNo">091</span><a name="line.91"></a> +<span class="sourceLineNo">092</span> @Override<a name="line.92"></a> +<span class="sourceLineNo">093</span> protected int doWork() throws Exception {<a name="line.93"></a> +<span class="sourceLineNo">094</span> setUpCluster();<a name="line.94"></a> +<span class="sourceLineNo">095</span> getAndStartMonkey();<a name="line.95"></a> +<span class="sourceLineNo">096</span> while (!stop) {// loop here until got killed<a name="line.96"></a> +<span class="sourceLineNo">097</span> Thread.sleep(10000);<a name="line.97"></a> +<span class="sourceLineNo">098</span> }<a name="line.98"></a> +<span class="sourceLineNo">099</span> return 0;<a name="line.99"></a> +<span class="sourceLineNo">100</span> }<a name="line.100"></a> +<span class="sourceLineNo">101</span><a name="line.101"></a> +<span class="sourceLineNo">102</span> public void stopRunner() {<a name="line.102"></a> +<span class="sourceLineNo">103</span> stop = true;<a name="line.103"></a> +<span class="sourceLineNo">104</span> }<a name="line.104"></a> +<span class="sourceLineNo">105</span><a name="line.105"></a> +<span class="sourceLineNo">106</span> public void setUpCluster() throws Exception {<a name="line.106"></a> +<span class="sourceLineNo">107</span> util = getTestingUtil(getConf());<a name="line.107"></a> +<span class="sourceLineNo">108</span> boolean isDistributed = isDistributedCluster(getConf());<a name="line.108"></a> +<span class="sourceLineNo">109</span> if (isDistributed) {<a name="line.109"></a> +<span class="sourceLineNo">110</span> util.createDistributedHBaseCluster();<a name="line.110"></a> +<span class="sourceLineNo">111</span> util.checkNodeCount(1);// make sure there's at least 1 alive rs<a name="line.111"></a> +<span class="sourceLineNo">112</span> } else {<a name="line.112"></a> +<span class="sourceLineNo">113</span> throw new RuntimeException("ChaosMonkeyRunner must run againt a distributed cluster,"<a name="line.113"></a> +<span class="sourceLineNo">114</span> + " please check and point to the right configuration dir");<a name="line.114"></a> +<span class="sourceLineNo">115</span> }<a name="line.115"></a> +<span class="sourceLineNo">116</span> this.setConf(util.getConfiguration());<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> private boolean isDistributedCluster(Configuration conf) {<a name="line.119"></a> +<span class="sourceLineNo">120</span> return conf.getBoolean(HConstants.CLUSTER_DISTRIBUTED, false);<a name="line.120"></a> +<span class="sourceLineNo">121</span> }<a name="line.121"></a> +<span class="sourceLineNo">122</span><a name="line.122"></a> +<span class="sourceLineNo">123</span> public void getAndStartMonkey() throws Exception {<a name="line.123"></a> +<span class="sourceLineNo">124</span> util = getTestingUtil(getConf());<a name="line.124"></a> +<span class="sourceLineNo">125</span> MonkeyFactory fact = MonkeyFactory.getFactory(monkeyToUse);<a name="line.125"></a> +<span class="sourceLineNo">126</span> if (fact == null) {<a name="line.126"></a> +<span class="sourceLineNo">127</span> fact = getDefaultMonkeyFactory();<a name="line.127"></a> +<span class="sourceLineNo">128</span> }<a name="line.128"></a> +<span class="sourceLineNo">129</span> monkey =<a name="line.129"></a> +<span class="sourceLineNo">130</span> fact.setUtil(util).setTableName(getTablename()).setProperties(monkeyProps)<a name="line.130"></a> +<span class="sourceLineNo">131</span> .setColumnFamilies(getColumnFamilies()).build();<a name="line.131"></a> +<span class="sourceLineNo">132</span> monkey.start();<a name="line.132"></a> +<span class="sourceLineNo">133</span> }<a name="line.133"></a> +<span class="sourceLineNo">134</span><a name="line.134"></a> +<span class="sourceLineNo">135</span> protected IntegrationTestingUtility getTestingUtil(Configuration conf) {<a name="line.135"></a> +<span class="sourceLineNo">136</span> if (this.util == null) {<a name="line.136"></a> +<span class="sourceLineNo">137</span> if (conf == null) {<a name="line.137"></a> +<span class="sourceLineNo">138</span> this.util = new IntegrationTestingUtility();<a name="line.138"></a> +<span class="sourceLineNo">139</span> this.setConf(util.getConfiguration());<a name="line.139"></a> +<span class="sourceLineNo">140</span> } else {<a name="line.140"></a> +<span class="sourceLineNo">141</span> this.util = new IntegrationTestingUtility(conf);<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> return util;<a name="line.144"></a> +<span class="sourceLineNo">145</span> }<a name="line.145"></a> +<span class="sourceLineNo">146</span><a name="line.146"></a> +<span class="sourceLineNo">147</span> protected MonkeyFactory getDefaultMonkeyFactory() {<a name="line.147"></a> +<span class="sourceLineNo">148</span> // Run with slow deterministic monkey by default<a name="line.148"></a> +<span class="sourceLineNo">149</span> return MonkeyFactory.getFactory(MonkeyFactory.SLOW_DETERMINISTIC);<a name="line.149"></a> +<span class="sourceLineNo">150</span> }<a name="line.150"></a> +<span class="sourceLineNo">151</span><a name="line.151"></a> +<span class="sourceLineNo">152</span> public TableName getTablename() {<a name="line.152"></a> +<span class="sourceLineNo">153</span> return TableName.valueOf(tableName);<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> protected Set<String> getColumnFamilies() {<a name="line.156"></a> +<span class="sourceLineNo">157</span> return Sets.newHashSet(familyName);<a name="line.157"></a> +<span class="sourceLineNo">158</span> }<a name="line.158"></a> +<span class="sourceLineNo">159</span><a name="line.159"></a> +<span class="sourceLineNo">160</span> /*<a name="line.160"></a> +<span class="sourceLineNo">161</span> * If caller wants to add config parameters contained in a file, the path of conf file<a name="line.161"></a> +<span class="sourceLineNo">162</span> * can be passed as the first two arguments like this:<a name="line.162"></a> +<span class="sourceLineNo">163</span> * -c <path-to-conf><a name="line.163"></a> +<span class="sourceLineNo">164</span> */<a name="line.164"></a> +<span class="sourceLineNo">165</span> public static void main(String[] args) throws Exception {<a name="line.165"></a> +<span class="sourceLineNo">166</span> Configuration conf = HBaseConfiguration.create();<a name="line.166"></a> +<span class="sourceLineNo">167</span> String[] actualArgs = args;<a name="line.167"></a> +<span class="sourceLineNo">168</span> if (args.length > 0 && "-c".equals(args[0])) {<a name="line.168"></a> +<span class="sourceLineNo">169</span> int argCount = args.length - 2;<a name="line.169"></a> +<span class="sourceLineNo">170</span> if (argCount < 0) {<a name="line.170"></a> +<span class="sourceLineNo">171</span> throw new IllegalArgumentException("Missing path for -c parameter");<a name="line.171"></a> +<span class="sourceLineNo">172</span> }<a name="line.172"></a> +<span class="sourceLineNo">173</span> // load the resource specified by the second parameter<a name="line.173"></a> +<span class="sourceLineNo">174</span> conf.addResource(args[1]);<a name="line.174"></a> +<span class="sourceLineNo">175</span> actualArgs = new String[argCount];<a name="line.175"></a> +<span class="sourceLineNo">176</span> System.arraycopy(args, 2, actualArgs, 0, argCount);<a name="line.176"></a> +<span class="sourceLineNo">177</span> }<a name="line.177"></a> +<span class="sourceLineNo">178</span> IntegrationTestingUtility.setUseDistributedCluster(conf);<a name="line.178"></a> +<span class="sourceLineNo">179</span> int ret = ToolRunner.run(conf, new ChaosMonkeyRunner(), actualArgs);<a name="line.179"></a> +<span class="sourceLineNo">180</span> System.exit(ret);<a name="line.180"></a> +<span class="sourceLineNo">181</span> }<a name="line.181"></a> +<span class="sourceLineNo">182</span><a name="line.182"></a> +<span class="sourceLineNo">183</span>}<a name="line.183"></a> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/b7626a4c/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestClientClusterStatus.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestClientClusterStatus.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestClientClusterStatus.html index b031108..a9e0d0b 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestClientClusterStatus.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestClientClusterStatus.html @@ -73,7 +73,7 @@ <span class="sourceLineNo">065</span> RegionServerThread rst = rsts.get(rsts.size() - 1);<a name="line.65"></a> <span class="sourceLineNo">066</span> DEAD = rst.getRegionServer();<a name="line.66"></a> <span class="sourceLineNo">067</span> DEAD.stop("Test dead servers status");<a name="line.67"></a> -<span class="sourceLineNo">068</span> while (!DEAD.isStopped()) {<a name="line.68"></a> +<span class="sourceLineNo">068</span> while (rst.isAlive()) {<a name="line.68"></a> <span class="sourceLineNo">069</span> Thread.sleep(500);<a name="line.69"></a> <span class="sourceLineNo">070</span> }<a name="line.70"></a> <span class="sourceLineNo">071</span> }<a name="line.71"></a> @@ -163,71 +163,73 @@ <span class="sourceLineNo">155</span> Assert.assertNotNull(status);<a name="line.155"></a> <span class="sourceLineNo">156</span> Assert.assertNotNull(status.getServers());<a name="line.156"></a> <span class="sourceLineNo">157</span> // exclude a dead region server<a name="line.157"></a> -<span class="sourceLineNo">158</span> Assert.assertEquals(SLAVES, numRs);<a name="line.158"></a> -<span class="sourceLineNo">159</span> // live servers = primary master + nums of regionservers<a name="line.159"></a> -<span class="sourceLineNo">160</span> Assert.assertEquals(status.getServers().size() + 1 /*Master*/, numRs);<a name="line.160"></a> -<span class="sourceLineNo">161</span> Assert.assertTrue(status.getRegionsCount() > 0);<a name="line.161"></a> -<span class="sourceLineNo">162</span> Assert.assertNotNull(status.getDeadServerNames());<a name="line.162"></a> -<span class="sourceLineNo">163</span> Assert.assertEquals(1, status.getDeadServersSize());<a name="line.163"></a> -<span class="sourceLineNo">164</span> ServerName deadServerName = status.getDeadServerNames().iterator().next();<a name="line.164"></a> -<span class="sourceLineNo">165</span> Assert.assertEquals(DEAD.getServerName(), deadServerName);<a name="line.165"></a> -<span class="sourceLineNo">166</span> }<a name="line.166"></a> -<span class="sourceLineNo">167</span><a name="line.167"></a> -<span class="sourceLineNo">168</span> @Test<a name="line.168"></a> -<span class="sourceLineNo">169</span> public void testMasterAndBackupMastersStatus() throws Exception {<a name="line.169"></a> -<span class="sourceLineNo">170</span> // get all the master threads<a name="line.170"></a> -<span class="sourceLineNo">171</span> List<MasterThread> masterThreads = CLUSTER.getMasterThreads();<a name="line.171"></a> -<span class="sourceLineNo">172</span> int numActive = 0;<a name="line.172"></a> -<span class="sourceLineNo">173</span> int activeIndex = 0;<a name="line.173"></a> -<span class="sourceLineNo">174</span> ServerName activeName = null;<a name="line.174"></a> -<span class="sourceLineNo">175</span> HMaster active = null;<a name="line.175"></a> -<span class="sourceLineNo">176</span> for (int i = 0; i < masterThreads.size(); i++) {<a name="line.176"></a> -<span class="sourceLineNo">177</span> if (masterThreads.get(i).getMaster().isActiveMaster()) {<a name="line.177"></a> -<span class="sourceLineNo">178</span> numActive++;<a name="line.178"></a> -<span class="sourceLineNo">179</span> activeIndex = i;<a name="line.179"></a> -<span class="sourceLineNo">180</span> active = masterThreads.get(activeIndex).getMaster();<a name="line.180"></a> -<span class="sourceLineNo">181</span> activeName = active.getServerName();<a name="line.181"></a> -<span class="sourceLineNo">182</span> }<a name="line.182"></a> -<span class="sourceLineNo">183</span> }<a name="line.183"></a> -<span class="sourceLineNo">184</span> Assert.assertNotNull(active);<a name="line.184"></a> -<span class="sourceLineNo">185</span> Assert.assertEquals(1, numActive);<a name="line.185"></a> -<span class="sourceLineNo">186</span> Assert.assertEquals(MASTERS, masterThreads.size());<a name="line.186"></a> -<span class="sourceLineNo">187</span> // Retrieve master and backup masters infos only.<a name="line.187"></a> -<span class="sourceLineNo">188</span> ClusterStatus.Options options = Options.getDefaultOptions();<a name="line.188"></a> -<span class="sourceLineNo">189</span> options.excludeHBaseVersion()<a name="line.189"></a> -<span class="sourceLineNo">190</span> .excludeBalancerOn()<a name="line.190"></a> -<span class="sourceLineNo">191</span> .excludeClusterId()<a name="line.191"></a> -<span class="sourceLineNo">192</span> .excludeLiveServers()<a name="line.192"></a> -<span class="sourceLineNo">193</span> .excludeDeadServers()<a name="line.193"></a> -<span class="sourceLineNo">194</span> .excludeMasterCoprocessors()<a name="line.194"></a> -<span class="sourceLineNo">195</span> .excludeRegionState();<a name="line.195"></a> -<span class="sourceLineNo">196</span> ClusterStatus status = ADMIN.getClusterStatus(options);<a name="line.196"></a> -<span class="sourceLineNo">197</span> Assert.assertTrue(status.getMaster().equals(activeName));<a name="line.197"></a> -<span class="sourceLineNo">198</span> Assert.assertEquals(MASTERS - 1, status.getBackupMastersSize());<a name="line.198"></a> -<span class="sourceLineNo">199</span> }<a name="line.199"></a> -<span class="sourceLineNo">200</span><a name="line.200"></a> -<span class="sourceLineNo">201</span> @Test<a name="line.201"></a> -<span class="sourceLineNo">202</span> public void testOtherStatusInfos() throws Exception {<a name="line.202"></a> -<span class="sourceLineNo">203</span> ClusterStatus.Options options = Options.getDefaultOptions();<a name="line.203"></a> -<span class="sourceLineNo">204</span> options.excludeMaster()<a name="line.204"></a> -<span class="sourceLineNo">205</span> .excludeBackupMasters()<a name="line.205"></a> -<span class="sourceLineNo">206</span> .excludeRegionState()<a name="line.206"></a> -<span class="sourceLineNo">207</span> .excludeLiveServers()<a name="line.207"></a> -<span class="sourceLineNo">208</span> .excludeBackupMasters();<a name="line.208"></a> -<span class="sourceLineNo">209</span> ClusterStatus status = ADMIN.getClusterStatus(options);<a name="line.209"></a> -<span class="sourceLineNo">210</span> Assert.assertTrue(status.getMasterCoprocessors().length == 0);<a name="line.210"></a> -<span class="sourceLineNo">211</span> Assert.assertNotNull(status.getHBaseVersion());<a name="line.211"></a> -<span class="sourceLineNo">212</span> Assert.assertNotNull(status.getClusterId());<a name="line.212"></a> -<span class="sourceLineNo">213</span> Assert.assertTrue(status.getAverageLoad() == 0.0);<a name="line.213"></a> -<span class="sourceLineNo">214</span> Assert.assertNotNull(status.getBalancerOn() && !status.getBalancerOn());<a name="line.214"></a> -<span class="sourceLineNo">215</span> }<a name="line.215"></a> -<span class="sourceLineNo">216</span><a name="line.216"></a> -<span class="sourceLineNo">217</span> @AfterClass<a name="line.217"></a> -<span class="sourceLineNo">218</span> public static void tearDownAfterClass() throws Exception {<a name="line.218"></a> -<span class="sourceLineNo">219</span> if (ADMIN != null) ADMIN.close();<a name="line.219"></a> -<span class="sourceLineNo">220</span> UTIL.shutdownMiniCluster();<a name="line.220"></a> -<span class="sourceLineNo">221</span> }<a name="line.221"></a> -<span class="sourceLineNo">222</span>}<a name="line.222"></a> +<span class="sourceLineNo">158</span> Assert.assertEquals(SLAVES -1, numRs);<a name="line.158"></a> +<span class="sourceLineNo">159</span> // live servers = nums of regionservers<a name="line.159"></a> +<span class="sourceLineNo">160</span> // By default, HMaster don't carry any regions so it won't report its load.<a name="line.160"></a> +<span class="sourceLineNo">161</span> // Hence, it won't be in the server list.<a name="line.161"></a> +<span class="sourceLineNo">162</span> Assert.assertEquals(status.getServers().size(), numRs);<a name="line.162"></a> +<span class="sourceLineNo">163</span> Assert.assertTrue(status.getRegionsCount() > 0);<a name="line.163"></a> +<span class="sourceLineNo">164</span> Assert.assertNotNull(status.getDeadServerNames());<a name="line.164"></a> +<span class="sourceLineNo">165</span> Assert.assertEquals(1, status.getDeadServersSize());<a name="line.165"></a> +<span class="sourceLineNo">166</span> ServerName deadServerName = status.getDeadServerNames().iterator().next();<a name="line.166"></a> +<span class="sourceLineNo">167</span> Assert.assertEquals(DEAD.getServerName(), deadServerName);<a name="line.167"></a> +<span class="sourceLineNo">168</span> }<a name="line.168"></a> +<span class="sourceLineNo">169</span><a name="line.169"></a> +<span class="sourceLineNo">170</span> @Test<a name="line.170"></a> +<span class="sourceLineNo">171</span> public void testMasterAndBackupMastersStatus() throws Exception {<a name="line.171"></a> +<span class="sourceLineNo">172</span> // get all the master threads<a name="line.172"></a> +<span class="sourceLineNo">173</span> List<MasterThread> masterThreads = CLUSTER.getMasterThreads();<a name="line.173"></a> +<span class="sourceLineNo">174</span> int numActive = 0;<a name="line.174"></a> +<span class="sourceLineNo">175</span> int activeIndex = 0;<a name="line.175"></a> +<span class="sourceLineNo">176</span> ServerName activeName = null;<a name="line.176"></a> +<span class="sourceLineNo">177</span> HMaster active = null;<a name="line.177"></a> +<span class="sourceLineNo">178</span> for (int i = 0; i < masterThreads.size(); i++) {<a name="line.178"></a> +<span class="sourceLineNo">179</span> if (masterThreads.get(i).getMaster().isActiveMaster()) {<a name="line.179"></a> +<span class="sourceLineNo">180</span> numActive++;<a name="line.180"></a> +<span class="sourceLineNo">181</span> activeIndex = i;<a name="line.181"></a> +<span class="sourceLineNo">182</span> active = masterThreads.get(activeIndex).getMaster();<a name="line.182"></a> +<span class="sourceLineNo">183</span> activeName = active.getServerName();<a name="line.183"></a> +<span class="sourceLineNo">184</span> }<a name="line.184"></a> +<span class="sourceLineNo">185</span> }<a name="line.185"></a> +<span class="sourceLineNo">186</span> Assert.assertNotNull(active);<a name="line.186"></a> +<span class="sourceLineNo">187</span> Assert.assertEquals(1, numActive);<a name="line.187"></a> +<span class="sourceLineNo">188</span> Assert.assertEquals(MASTERS, masterThreads.size());<a name="line.188"></a> +<span class="sourceLineNo">189</span> // Retrieve master and backup masters infos only.<a name="line.189"></a> +<span class="sourceLineNo">190</span> ClusterStatus.Options options = Options.getDefaultOptions();<a name="line.190"></a> +<span class="sourceLineNo">191</span> options.excludeHBaseVersion()<a name="line.191"></a> +<span class="sourceLineNo">192</span> .excludeBalancerOn()<a name="line.192"></a> +<span class="sourceLineNo">193</span> .excludeClusterId()<a name="line.193"></a> +<span class="sourceLineNo">194</span> .excludeLiveServers()<a name="line.194"></a> +<span class="sourceLineNo">195</span> .excludeDeadServers()<a name="line.195"></a> +<span class="sourceLineNo">196</span> .excludeMasterCoprocessors()<a name="line.196"></a> +<span class="sourceLineNo">197</span> .excludeRegionState();<a name="line.197"></a> +<span class="sourceLineNo">198</span> ClusterStatus status = ADMIN.getClusterStatus(options);<a name="line.198"></a> +<span class="sourceLineNo">199</span> Assert.assertTrue(status.getMaster().equals(activeName));<a name="line.199"></a> +<span class="sourceLineNo">200</span> Assert.assertEquals(MASTERS - 1, status.getBackupMastersSize());<a name="line.200"></a> +<span class="sourceLineNo">201</span> }<a name="line.201"></a> +<span class="sourceLineNo">202</span><a name="line.202"></a> +<span class="sourceLineNo">203</span> @Test<a name="line.203"></a> +<span class="sourceLineNo">204</span> public void testOtherStatusInfos() throws Exception {<a name="line.204"></a> +<span class="sourceLineNo">205</span> ClusterStatus.Options options = Options.getDefaultOptions();<a name="line.205"></a> +<span class="sourceLineNo">206</span> options.excludeMaster()<a name="line.206"></a> +<span class="sourceLineNo">207</span> .excludeBackupMasters()<a name="line.207"></a> +<span class="sourceLineNo">208</span> .excludeRegionState()<a name="line.208"></a> +<span class="sourceLineNo">209</span> .excludeLiveServers()<a name="line.209"></a> +<span class="sourceLineNo">210</span> .excludeBackupMasters();<a name="line.210"></a> +<span class="sourceLineNo">211</span> ClusterStatus status = ADMIN.getClusterStatus(options);<a name="line.211"></a> +<span class="sourceLineNo">212</span> Assert.assertTrue(status.getMasterCoprocessors().length == 0);<a name="line.212"></a> +<span class="sourceLineNo">213</span> Assert.assertNotNull(status.getHBaseVersion());<a name="line.213"></a> +<span class="sourceLineNo">214</span> Assert.assertNotNull(status.getClusterId());<a name="line.214"></a> +<span class="sourceLineNo">215</span> Assert.assertTrue(status.getAverageLoad() == 0.0);<a name="line.215"></a> +<span class="sourceLineNo">216</span> Assert.assertNotNull(status.getBalancerOn() && !status.getBalancerOn());<a name="line.216"></a> +<span class="sourceLineNo">217</span> }<a name="line.217"></a> +<span class="sourceLineNo">218</span><a name="line.218"></a> +<span class="sourceLineNo">219</span> @AfterClass<a name="line.219"></a> +<span class="sourceLineNo">220</span> public static void tearDownAfterClass() throws Exception {<a name="line.220"></a> +<span class="sourceLineNo">221</span> if (ADMIN != null) ADMIN.close();<a name="line.221"></a> +<span class="sourceLineNo">222</span> UTIL.shutdownMiniCluster();<a name="line.222"></a> +<span class="sourceLineNo">223</span> }<a name="line.223"></a> +<span class="sourceLineNo">224</span>}<a name="line.224"></a>
