http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/testdevapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html b/testdevapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html index b89116f..e6bc9ca 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/io/hfile/package-tree.html @@ -158,8 +158,8 @@ <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.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/TestCacheOnWrite.CacheOnWriteType.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="typeNameLink">TestCacheOnWrite.CacheOnWriteType</span></a></li> <li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/TagUsage.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="typeNameLink">TagUsage</span></a></li> +<li type="circle">org.apache.hadoop.hbase.io.hfile.<a href="../../../../../../org/apache/hadoop/hbase/io/hfile/TestCacheOnWrite.CacheOnWriteType.html" title="enum in org.apache.hadoop.hbase.io.hfile"><span class="typeNameLink">TestCacheOnWrite.CacheOnWriteType</span></a></li> </ul> </li> </ul>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/testdevapidocs/org/apache/hadoop/hbase/package-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/package-tree.html b/testdevapidocs/org/apache/hadoop/hbase/package-tree.html index eadf0cb..82d8979 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/package-tree.html @@ -542,15 +542,15 @@ <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.<a href="../../../../org/apache/hadoop/hbase/HBaseClusterManager.CommandProvider.Operation.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">HBaseClusterManager.CommandProvider.Operation</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/PerformanceEvaluation.Counter.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">PerformanceEvaluation.Counter</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/RESTApiClusterManager.Service.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">RESTApiClusterManager.Service</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/RESTApiClusterManager.RoleCommand.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">RESTApiClusterManager.RoleCommand</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/ResourceChecker.Phase.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">ResourceChecker.Phase</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/IntegrationTestRegionReplicaPerf.Stat.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">IntegrationTestRegionReplicaPerf.Stat</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/ScanPerformanceEvaluation.ScanCounter.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">ScanPerformanceEvaluation.ScanCounter</span></a></li> +<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/HBaseClusterManager.CommandProvider.Operation.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">HBaseClusterManager.CommandProvider.Operation</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/ClusterManager.ServiceType.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">ClusterManager.ServiceType</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/PerformanceEvaluation.Counter.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">PerformanceEvaluation.Counter</span></a></li> <li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/IntegrationTestDDLMasterFailover.ACTION.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">IntegrationTestDDLMasterFailover.ACTION</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/IntegrationTestRegionReplicaPerf.Stat.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">IntegrationTestRegionReplicaPerf.Stat</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/ResourceChecker.Phase.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">ResourceChecker.Phase</span></a></li> -<li type="circle">org.apache.hadoop.hbase.<a href="../../../../org/apache/hadoop/hbase/RESTApiClusterManager.RoleCommand.html" title="enum in org.apache.hadoop.hbase"><span class="typeNameLink">RESTApiClusterManager.RoleCommand</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html b/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html index eed5434..f73ba8e 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/procedure2/package-tree.html @@ -206,8 +206,8 @@ <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.procedure2.<a href="../../../../../org/apache/hadoop/hbase/procedure2/TestYieldProcedures.TestStateMachineProcedure.State.html" title="enum in org.apache.hadoop.hbase.procedure2"><span class="typeNameLink">TestYieldProcedures.TestStateMachineProcedure.State</span></a></li> -<li type="circle">org.apache.hadoop.hbase.procedure2.<a href="../../../../../org/apache/hadoop/hbase/procedure2/TestStateMachineProcedure.TestSMProcedureState.html" title="enum in org.apache.hadoop.hbase.procedure2"><span class="typeNameLink">TestStateMachineProcedure.TestSMProcedureState</span></a></li> <li type="circle">org.apache.hadoop.hbase.procedure2.<a href="../../../../../org/apache/hadoop/hbase/procedure2/TestProcedureRecovery.TestStateMachineProcedure.State.html" title="enum in org.apache.hadoop.hbase.procedure2"><span class="typeNameLink">TestProcedureRecovery.TestStateMachineProcedure.State</span></a></li> +<li type="circle">org.apache.hadoop.hbase.procedure2.<a href="../../../../../org/apache/hadoop/hbase/procedure2/TestStateMachineProcedure.TestSMProcedureState.html" title="enum in org.apache.hadoop.hbase.procedure2"><span class="typeNameLink">TestStateMachineProcedure.TestSMProcedureState</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/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 39eae31..b38f496 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/regionserver/package-tree.html @@ -624,10 +624,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.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/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/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/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/TestRegionServerReadRequestMetrics.Metric.html" title="enum in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestRegionServerReadRequestMetrics.Metric</span></a></li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/testdevapidocs/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html b/testdevapidocs/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html index d6750ec..9bdaca0 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html +++ b/testdevapidocs/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html @@ -18,7 +18,7 @@ catch(err) { } //--> -var methods = {"i0":9,"i1":10,"i2":10}; +var methods = {"i0":10,"i1":9,"i2":9,"i3":10,"i4":10}; var tabs = {65535:["t0","All Methods"],1:["t1","Static 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="#fields.inherited.from.class.org.apache.hadoop.hbase.security.token.SecureTestCluster">Field</a> | </li> +<li><a href="#field.summary">Field</a> | </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>Field | </li> +<li><a href="#field.detail">Field</a> | </li> <li><a href="#constructor.detail">Constr</a> | </li> <li><a href="#method.detail">Method</a></li> </ul> @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <hr> <br> -<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.51">TestDelegationTokenWithEncryption</a> +<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.57">TestDelegationTokenWithEncryption</a> extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/SecureTestCluster.html" title="class in org.apache.hadoop.hbase.security.token">SecureTestCluster</a></pre> </li> </ul> @@ -128,6 +128,21 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <!-- --> </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><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#rpcClientImpl">rpcClientImpl</a></span></code> </td> +</tr> +<tr class="rowColor"> +<td class="colFirst"><code>org.junit.rules.TestName</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#testName">testName</a></span></code> </td> +</tr> +</table> <ul class="blockList"> <li class="blockList"><a name="fields.inherited.from.class.org.apache.hadoop.hbase.security.token.SecureTestCluster"> <!-- --> @@ -167,16 +182,24 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <th class="colLast" scope="col">Method and Description</th> </tr> <tr id="i0" class="altColor"> +<td class="colFirst"><code>private org.apache.hadoop.hbase.TableName</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#getTestTableName--">getTestTableName</a></span>()</code> </td> +</tr> +<tr id="i1" class="rowColor"> +<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<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>[]></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#parameters--">parameters</a></span>()</code> </td> +</tr> +<tr id="i2" class="altColor"> <td class="colFirst"><code>static void</code></td> <td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#setUp--">setUp</a></span>()</code> </td> </tr> -<tr id="i1" class="rowColor"> +<tr id="i3" class="rowColor"> <td class="colFirst"><code>void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#testPutGetWithDelegationToken--">testPutGetWithDelegationToken</a></span>()</code> </td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#setUpBeforeMethod--">setUpBeforeMethod</a></span>()</code> </td> </tr> -<tr id="i2" class="altColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#testPutGetWithDelegationToken-java.lang.Class-">testPutGetWithDelegationToken</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.ipc.RpcClient> rpcImplClass)</code> </td> +<tr id="i4" class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#testPutGetWithDelegationToken--">testPutGetWithDelegationToken</a></span>()</code> </td> </tr> </table> <ul class="blockList"> @@ -201,6 +224,32 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <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="rpcClientImpl"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>rpcClientImpl</h4> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.77">rpcClientImpl</a></pre> +</li> +</ul> +<a name="testName"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>testName</h4> +<pre>public org.junit.rules.TestName <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.80">testName</a></pre> +</li> +</ul> +</li> +</ul> <!-- ========= CONSTRUCTOR DETAIL ======== --> <ul class="blockList"> <li class="blockList"><a name="constructor.detail"> @@ -213,7 +262,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <ul class="blockListLast"> <li class="blockList"> <h4>TestDelegationTokenWithEncryption</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.51">TestDelegationTokenWithEncryption</a>()</pre> +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.57">TestDelegationTokenWithEncryption</a>()</pre> </li> </ul> </li> @@ -230,7 +279,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <ul class="blockList"> <li class="blockList"> <h4>setUp</h4> -<pre>public static void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.54">setUp</a>() +<pre>public static void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.60">setUp</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> @@ -238,20 +287,31 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure </dl> </li> </ul> -<a name="testPutGetWithDelegationToken-java.lang.Class-"> +<a name="parameters--"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>testPutGetWithDelegationToken</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.60">testPutGetWithDelegationToken</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.ipc.RpcClient> rpcImplClass) - 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>, - com.google.protobuf.ServiceException</pre> -<dl> -<dt><span class="throwsLabel">Throws:</span></dt> -<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> -<dd><code>com.google.protobuf.ServiceException</code></dd> -</dl> +<h4>parameters</h4> +<pre>public static <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<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>[]> <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.71">parameters</a>()</pre> +</li> +</ul> +<a name="setUpBeforeMethod--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>setUpBeforeMethod</h4> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.83">setUpBeforeMethod</a>()</pre> +</li> +</ul> +<a name="getTestTableName--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>getTestTableName</h4> +<pre>private org.apache.hadoop.hbase.TableName <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.88">getTestTableName</a>()</pre> </li> </ul> <a name="testPutGetWithDelegationToken--"> @@ -260,7 +320,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <ul class="blockListLast"> <li class="blockList"> <h4>testPutGetWithDelegationToken</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.78">testPutGetWithDelegationToken</a>() +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestDelegationTokenWithEncryption.html#line.93">testPutGetWithDelegationToken</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> @@ -322,13 +382,13 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <ul class="subNavList"> <li>Summary: </li> <li>Nested | </li> -<li><a href="#fields.inherited.from.class.org.apache.hadoop.hbase.security.token.SecureTestCluster">Field</a> | </li> +<li><a href="#field.summary">Field</a> | </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>Field | </li> +<li><a href="#field.detail">Field</a> | </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/1b5f3a4b/testdevapidocs/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html b/testdevapidocs/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html index 349f3cc..60eb58c 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html +++ b/testdevapidocs/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html @@ -18,8 +18,8 @@ catch(err) { } //--> -var methods = {"i0":10,"i1":10}; -var tabs = {65535:["t0","All Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; +var methods = {"i0":9,"i1":9,"i2":10,"i3":10}; +var tabs = {65535:["t0","All Methods"],1:["t1","Static Methods"],2:["t2","Instance Methods"],8:["t4","Concrete Methods"]}; var altColor = "altColor"; var rowColor = "rowColor"; var tableTab = "tableTab"; @@ -75,13 +75,13 @@ var activeTableTab = "activeTableTab"; <ul class="subNavList"> <li>Summary: </li> <li>Nested | </li> -<li><a href="#fields.inherited.from.class.org.apache.hadoop.hbase.security.token.SecureTestCluster">Field</a> | </li> +<li><a href="#field.summary">Field</a> | </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>Field | </li> +<li><a href="#field.detail">Field</a> | </li> <li><a href="#constructor.detail">Constr</a> | </li> <li><a href="#method.detail">Method</a></li> </ul> @@ -114,7 +114,7 @@ var activeTableTab = "activeTableTab"; <li class="blockList"> <hr> <br> -<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.53">TestGenerateDelegationToken</a> +<pre>public class <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.63">TestGenerateDelegationToken</a> extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/SecureTestCluster.html" title="class in org.apache.hadoop.hbase.security.token">SecureTestCluster</a></pre> </li> </ul> @@ -128,6 +128,17 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <!-- --> </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><a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#rpcClientImpl">rpcClientImpl</a></span></code> </td> +</tr> +</table> <ul class="blockList"> <li class="blockList"><a name="fields.inherited.from.class.org.apache.hadoop.hbase.security.token.SecureTestCluster"> <!-- --> @@ -161,18 +172,26 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure </a> <h3>Method Summary</h3> <table class="memberSummary" border="0" cellpadding="3" cellspacing="0" summary="Method Summary table, listing methods, and an explanation"> -<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> +<caption><span id="t0" class="activeTableTab"><span>All Methods</span><span class="tabEnd"> </span></span><span id="t1" class="tableTab"><span><a href="javascript:show(1);">Static Methods</a></span><span class="tabEnd"> </span></span><span id="t2" class="tableTab"><span><a href="javascript:show(2);">Instance Methods</a></span><span class="tabEnd"> </span></span><span id="t4" class="tableTab"><span><a href="javascript:show(8);">Concrete Methods</a></span><span class="tabEnd"> </span></span></caption> <tr> <th class="colFirst" scope="col">Modifier and Type</th> <th class="colLast" scope="col">Method and Description</th> </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/security/token/TestGenerateDelegationToken.html#test--">test</a></span>()</code> </td> +<td class="colFirst"><code>static <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<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>[]></code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#parameters--">parameters</a></span>()</code> </td> </tr> <tr id="i1" class="rowColor"> -<td class="colFirst"><code>private void</code></td> -<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#testTokenAuth-java.lang.Class-">testTokenAuth</a></span>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.ipc.RpcClient> rpcImplClass)</code> </td> +<td class="colFirst"><code>static void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#setUp--">setUp</a></span>()</code> </td> +</tr> +<tr id="i2" class="altColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#setUpBeforeMethod--">setUpBeforeMethod</a></span>()</code> </td> +</tr> +<tr id="i3" class="rowColor"> +<td class="colFirst"><code>void</code></td> +<td class="colLast"><code><span class="memberNameLink"><a href="../../../../../../org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#test--">test</a></span>()</code> </td> </tr> </table> <ul class="blockList"> @@ -180,7 +199,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <!-- --> </a> <h3>Methods inherited from class org.apache.hadoop.hbase.security.token.<a href="../../../../../../org/apache/hadoop/hbase/security/token/SecureTestCluster.html" title="class in org.apache.hadoop.hbase.security.token">SecureTestCluster</a></h3> -<code><a href="../../../../../../org/apache/hadoop/hbase/security/token/SecureTestCluster.html#setUp--">setUp</a>, <a href="../../../../../../org/apache/hadoop/hbase/security/token/SecureTestCluster.html#tearDown--">tearDown</a></code></li> +<code><a href="../../../../../../org/apache/hadoop/hbase/security/token/SecureTestCluster.html#tearDown--">tearDown</a></code></li> </ul> <ul class="blockList"> <li class="blockList"><a name="methods.inherited.from.class.java.lang.Object"> @@ -197,6 +216,23 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <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="rpcClientImpl"> +<!-- --> +</a> +<ul class="blockListLast"> +<li class="blockList"> +<h4>rpcClientImpl</h4> +<pre>public <a href="http://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true"; title="class or interface in java.lang">String</a> <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.81">rpcClientImpl</a></pre> +</li> +</ul> +</li> +</ul> <!-- ========= CONSTRUCTOR DETAIL ======== --> <ul class="blockList"> <li class="blockList"><a name="constructor.detail"> @@ -209,7 +245,7 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <ul class="blockListLast"> <li class="blockList"> <h4>TestGenerateDelegationToken</h4> -<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.53">TestGenerateDelegationToken</a>()</pre> +<pre>public <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.63">TestGenerateDelegationToken</a>()</pre> </li> </ul> </li> @@ -220,29 +256,45 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <!-- --> </a> <h3>Method Detail</h3> -<a name="testTokenAuth-java.lang.Class-"> +<a name="setUp--"> <!-- --> </a> <ul class="blockList"> <li class="blockList"> -<h4>testTokenAuth</h4> -<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.55">testTokenAuth</a>(<a href="http://docs.oracle.com/javase/8/docs/api/java/lang/Class.html?is-external=true"; title="class or interface in java.lang">Class</a><? extends org.apache.hadoop.hbase.ipc.RpcClient> rpcImplClass) - 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>, - com.google.protobuf.ServiceException</pre> +<h4>setUp</h4> +<pre>public static void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.66">setUp</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> -<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> -<dd><code>com.google.protobuf.ServiceException</code></dd> +<dd><code><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></code></dd> </dl> </li> </ul> +<a name="parameters--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>parameters</h4> +<pre>public static <a href="http://docs.oracle.com/javase/8/docs/api/java/util/Collection.html?is-external=true"; title="class or interface in java.util">Collection</a><<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>[]> <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.75">parameters</a>()</pre> +</li> +</ul> +<a name="setUpBeforeMethod--"> +<!-- --> +</a> +<ul class="blockList"> +<li class="blockList"> +<h4>setUpBeforeMethod</h4> +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.84">setUpBeforeMethod</a>()</pre> +</li> +</ul> <a name="test--"> <!-- --> </a> <ul class="blockListLast"> <li class="blockList"> <h4>test</h4> -<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.78">test</a>() +<pre>public void <a href="../../../../../../src-html/org/apache/hadoop/hbase/security/token/TestGenerateDelegationToken.html#line.90">test</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> @@ -304,13 +356,13 @@ extends <a href="../../../../../../org/apache/hadoop/hbase/security/token/Secure <ul class="subNavList"> <li>Summary: </li> <li>Nested | </li> -<li><a href="#fields.inherited.from.class.org.apache.hadoop.hbase.security.token.SecureTestCluster">Field</a> | </li> +<li><a href="#field.summary">Field</a> | </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>Field | </li> +<li><a href="#field.detail">Field</a> | </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/1b5f3a4b/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 744f683..802b05a 100644 --- a/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html +++ b/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html @@ -248,9 +248,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.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/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/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/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/IntegrationTestWithCellVisibilityLoadAndVerify.Counters.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestWithCellVisibilityLoadAndVerify.Counters</span></a></li> </ul> </li> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/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 ea1befb..af22306 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/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/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/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/FaultyFSLog.FailureType.html" title="enum in org.apache.hadoop.hbase.wal"><span class="typeNameLink">FaultyFSLog.FailureType</span></a></li> </ul> </li> </ul> http://git-wip-us.apache.org/repos/asf/hbase-site/blob/1b5f3a4b/testdevapidocs/src-html/org/apache/hadoop/hbase/TestAcidGuarantees.AtomicGetReader.html ---------------------------------------------------------------------- diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/TestAcidGuarantees.AtomicGetReader.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/TestAcidGuarantees.AtomicGetReader.html index c693fbe..30bd8cb 100644 --- a/testdevapidocs/src-html/org/apache/hadoop/hbase/TestAcidGuarantees.AtomicGetReader.html +++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/TestAcidGuarantees.AtomicGetReader.html @@ -375,166 +375,168 @@ <span class="sourceLineNo">367</span> final boolean useMob) throws Exception {<a name="line.367"></a> <span class="sourceLineNo">368</span><a name="line.368"></a> <span class="sourceLineNo">369</span> createTableIfMissing(useMob);<a name="line.369"></a> -<span class="sourceLineNo">370</span> TestContext ctx = new TestContext(util.getConfiguration());<a name="line.370"></a> -<span class="sourceLineNo">371</span><a name="line.371"></a> -<span class="sourceLineNo">372</span> byte rows[][] = new byte[numUniqueRows][];<a name="line.372"></a> -<span class="sourceLineNo">373</span> for (int i = 0; i < numUniqueRows; i++) {<a name="line.373"></a> -<span class="sourceLineNo">374</span> rows[i] = Bytes.toBytes("test_row_" + i);<a name="line.374"></a> -<span class="sourceLineNo">375</span> }<a name="line.375"></a> -<span class="sourceLineNo">376</span><a name="line.376"></a> -<span class="sourceLineNo">377</span> List<AtomicityWriter> writers = Lists.newArrayList();<a name="line.377"></a> -<span class="sourceLineNo">378</span> for (int i = 0; i < numWriters; i++) {<a name="line.378"></a> -<span class="sourceLineNo">379</span> AtomicityWriter writer = new AtomicityWriter(<a name="line.379"></a> -<span class="sourceLineNo">380</span> ctx, rows, FAMILIES, getSharedThreadPool());<a name="line.380"></a> -<span class="sourceLineNo">381</span> writers.add(writer);<a name="line.381"></a> -<span class="sourceLineNo">382</span> ctx.addThread(writer);<a name="line.382"></a> -<span class="sourceLineNo">383</span> }<a name="line.383"></a> -<span class="sourceLineNo">384</span> // Add a flusher<a name="line.384"></a> -<span class="sourceLineNo">385</span> ctx.addThread(new RepeatingTestThread(ctx) {<a name="line.385"></a> -<span class="sourceLineNo">386</span> Admin admin = util.getAdmin();<a name="line.386"></a> -<span class="sourceLineNo">387</span> public void doAnAction() throws Exception {<a name="line.387"></a> -<span class="sourceLineNo">388</span> try {<a name="line.388"></a> -<span class="sourceLineNo">389</span> admin.flush(TABLE_NAME);<a name="line.389"></a> -<span class="sourceLineNo">390</span> } catch(IOException ioe) {<a name="line.390"></a> -<span class="sourceLineNo">391</span> LOG.warn("Ignoring exception while flushing: " + StringUtils.stringifyException(ioe));<a name="line.391"></a> -<span class="sourceLineNo">392</span> }<a name="line.392"></a> -<span class="sourceLineNo">393</span> // Flushing has been a source of ACID violations previously (see HBASE-2856), so ideally,<a name="line.393"></a> -<span class="sourceLineNo">394</span> // we would flush as often as possible. On a running cluster, this isn't practical:<a name="line.394"></a> -<span class="sourceLineNo">395</span> // (1) we will cause a lot of load due to all the flushing and compacting<a name="line.395"></a> -<span class="sourceLineNo">396</span> // (2) we cannot change the flushing/compacting related Configuration options to try to<a name="line.396"></a> -<span class="sourceLineNo">397</span> // alleviate this<a name="line.397"></a> -<span class="sourceLineNo">398</span> // (3) it is an unrealistic workload, since no one would actually flush that often.<a name="line.398"></a> -<span class="sourceLineNo">399</span> // Therefore, let's flush every minute to have more flushes than usual, but not overload<a name="line.399"></a> -<span class="sourceLineNo">400</span> // the running cluster.<a name="line.400"></a> -<span class="sourceLineNo">401</span> if (systemTest) Thread.sleep(60000);<a name="line.401"></a> -<span class="sourceLineNo">402</span> }<a name="line.402"></a> -<span class="sourceLineNo">403</span> });<a name="line.403"></a> -<span class="sourceLineNo">404</span><a name="line.404"></a> -<span class="sourceLineNo">405</span> List<AtomicGetReader> getters = Lists.newArrayList();<a name="line.405"></a> -<span class="sourceLineNo">406</span> for (int i = 0; i < numGetters; i++) {<a name="line.406"></a> -<span class="sourceLineNo">407</span> AtomicGetReader getter = new AtomicGetReader(<a name="line.407"></a> -<span class="sourceLineNo">408</span> ctx, rows[i % numUniqueRows], FAMILIES, getSharedThreadPool());<a name="line.408"></a> -<span class="sourceLineNo">409</span> getters.add(getter);<a name="line.409"></a> -<span class="sourceLineNo">410</span> ctx.addThread(getter);<a name="line.410"></a> -<span class="sourceLineNo">411</span> }<a name="line.411"></a> -<span class="sourceLineNo">412</span><a name="line.412"></a> -<span class="sourceLineNo">413</span> List<AtomicScanReader> scanners = Lists.newArrayList();<a name="line.413"></a> -<span class="sourceLineNo">414</span> for (int i = 0; i < numScanners; i++) {<a name="line.414"></a> -<span class="sourceLineNo">415</span> AtomicScanReader scanner = new AtomicScanReader(ctx, FAMILIES, getSharedThreadPool());<a name="line.415"></a> -<span class="sourceLineNo">416</span> scanners.add(scanner);<a name="line.416"></a> -<span class="sourceLineNo">417</span> ctx.addThread(scanner);<a name="line.417"></a> -<span class="sourceLineNo">418</span> }<a name="line.418"></a> -<span class="sourceLineNo">419</span><a name="line.419"></a> -<span class="sourceLineNo">420</span> ctx.startThreads();<a name="line.420"></a> -<span class="sourceLineNo">421</span> ctx.waitFor(millisToRun);<a name="line.421"></a> -<span class="sourceLineNo">422</span> ctx.stop();<a name="line.422"></a> -<span class="sourceLineNo">423</span><a name="line.423"></a> -<span class="sourceLineNo">424</span> LOG.info("Finished test. Writers:");<a name="line.424"></a> -<span class="sourceLineNo">425</span> for (AtomicityWriter writer : writers) {<a name="line.425"></a> -<span class="sourceLineNo">426</span> LOG.info(" wrote " + writer.numWritten.get());<a name="line.426"></a> -<span class="sourceLineNo">427</span> }<a name="line.427"></a> -<span class="sourceLineNo">428</span> LOG.info("Readers:");<a name="line.428"></a> -<span class="sourceLineNo">429</span> for (AtomicGetReader reader : getters) {<a name="line.429"></a> -<span class="sourceLineNo">430</span> LOG.info(" read " + reader.numRead.get());<a name="line.430"></a> -<span class="sourceLineNo">431</span> }<a name="line.431"></a> -<span class="sourceLineNo">432</span> LOG.info("Scanners:");<a name="line.432"></a> -<span class="sourceLineNo">433</span> for (AtomicScanReader scanner : scanners) {<a name="line.433"></a> -<span class="sourceLineNo">434</span> LOG.info(" scanned " + scanner.numScans.get());<a name="line.434"></a> -<span class="sourceLineNo">435</span> LOG.info(" verified " + scanner.numRowsScanned.get() + " rows");<a name="line.435"></a> -<span class="sourceLineNo">436</span> }<a name="line.436"></a> -<span class="sourceLineNo">437</span> }<a name="line.437"></a> -<span class="sourceLineNo">438</span><a name="line.438"></a> -<span class="sourceLineNo">439</span> @Before<a name="line.439"></a> -<span class="sourceLineNo">440</span> public void setUp() throws Exception {<a name="line.440"></a> -<span class="sourceLineNo">441</span> util.startMiniCluster(1);<a name="line.441"></a> -<span class="sourceLineNo">442</span> }<a name="line.442"></a> -<span class="sourceLineNo">443</span><a name="line.443"></a> -<span class="sourceLineNo">444</span> @After<a name="line.444"></a> -<span class="sourceLineNo">445</span> public void tearDown() throws Exception {<a name="line.445"></a> -<span class="sourceLineNo">446</span> util.shutdownMiniCluster();<a name="line.446"></a> -<span class="sourceLineNo">447</span> }<a name="line.447"></a> -<span class="sourceLineNo">448</span><a name="line.448"></a> -<span class="sourceLineNo">449</span> @Test<a name="line.449"></a> -<span class="sourceLineNo">450</span> public void testGetAtomicity() throws Exception {<a name="line.450"></a> -<span class="sourceLineNo">451</span> runTestAtomicity(20000, 5, 5, 0, 3);<a name="line.451"></a> -<span class="sourceLineNo">452</span> }<a name="line.452"></a> -<span class="sourceLineNo">453</span><a name="line.453"></a> -<span class="sourceLineNo">454</span> @Test<a name="line.454"></a> -<span class="sourceLineNo">455</span> public void testScanAtomicity() throws Exception {<a name="line.455"></a> -<span class="sourceLineNo">456</span> runTestAtomicity(20000, 5, 0, 5, 3);<a name="line.456"></a> -<span class="sourceLineNo">457</span> }<a name="line.457"></a> -<span class="sourceLineNo">458</span><a name="line.458"></a> -<span class="sourceLineNo">459</span> @Test<a name="line.459"></a> -<span class="sourceLineNo">460</span> public void testMixedAtomicity() throws Exception {<a name="line.460"></a> -<span class="sourceLineNo">461</span> runTestAtomicity(20000, 5, 2, 2, 3);<a name="line.461"></a> -<span class="sourceLineNo">462</span> }<a name="line.462"></a> -<span class="sourceLineNo">463</span><a name="line.463"></a> -<span class="sourceLineNo">464</span> @Test<a name="line.464"></a> -<span class="sourceLineNo">465</span> public void testMobGetAtomicity() throws Exception {<a name="line.465"></a> -<span class="sourceLineNo">466</span> boolean systemTest = false;<a name="line.466"></a> -<span class="sourceLineNo">467</span> boolean useMob = true;<a name="line.467"></a> -<span class="sourceLineNo">468</span> runTestAtomicity(20000, 5, 5, 0, 3, systemTest, useMob);<a name="line.468"></a> -<span class="sourceLineNo">469</span> }<a name="line.469"></a> -<span class="sourceLineNo">470</span><a name="line.470"></a> -<span class="sourceLineNo">471</span> @Test<a name="line.471"></a> -<span class="sourceLineNo">472</span> public void testMobScanAtomicity() throws Exception {<a name="line.472"></a> -<span class="sourceLineNo">473</span> boolean systemTest = false;<a name="line.473"></a> -<span class="sourceLineNo">474</span> boolean useMob = true;<a name="line.474"></a> -<span class="sourceLineNo">475</span> runTestAtomicity(20000, 5, 0, 5, 3, systemTest, useMob);<a name="line.475"></a> -<span class="sourceLineNo">476</span> }<a name="line.476"></a> -<span class="sourceLineNo">477</span><a name="line.477"></a> -<span class="sourceLineNo">478</span> @Test<a name="line.478"></a> -<span class="sourceLineNo">479</span> public void testMobMixedAtomicity() throws Exception {<a name="line.479"></a> -<span class="sourceLineNo">480</span> boolean systemTest = false;<a name="line.480"></a> -<span class="sourceLineNo">481</span> boolean useMob = true;<a name="line.481"></a> -<span class="sourceLineNo">482</span> runTestAtomicity(20000, 5, 2, 2, 3, systemTest, useMob);<a name="line.482"></a> -<span class="sourceLineNo">483</span> }<a name="line.483"></a> -<span class="sourceLineNo">484</span><a name="line.484"></a> -<span class="sourceLineNo">485</span> ////////////////////////////////////////////////////////////////////////////<a name="line.485"></a> -<span class="sourceLineNo">486</span> // Tool interface<a name="line.486"></a> +<span class="sourceLineNo">370</span> // set the max threads to avoid java.lang.OutOfMemoryError: unable to create new native thread<a name="line.370"></a> +<span class="sourceLineNo">371</span> util.getConfiguration().setInt("hbase.hconnection.threads.max", 40);<a name="line.371"></a> +<span class="sourceLineNo">372</span> TestContext ctx = new TestContext(util.getConfiguration());<a name="line.372"></a> +<span class="sourceLineNo">373</span><a name="line.373"></a> +<span class="sourceLineNo">374</span> byte rows[][] = new byte[numUniqueRows][];<a name="line.374"></a> +<span class="sourceLineNo">375</span> for (int i = 0; i < numUniqueRows; i++) {<a name="line.375"></a> +<span class="sourceLineNo">376</span> rows[i] = Bytes.toBytes("test_row_" + i);<a name="line.376"></a> +<span class="sourceLineNo">377</span> }<a name="line.377"></a> +<span class="sourceLineNo">378</span><a name="line.378"></a> +<span class="sourceLineNo">379</span> List<AtomicityWriter> writers = Lists.newArrayList();<a name="line.379"></a> +<span class="sourceLineNo">380</span> for (int i = 0; i < numWriters; i++) {<a name="line.380"></a> +<span class="sourceLineNo">381</span> AtomicityWriter writer = new AtomicityWriter(<a name="line.381"></a> +<span class="sourceLineNo">382</span> ctx, rows, FAMILIES, getSharedThreadPool());<a name="line.382"></a> +<span class="sourceLineNo">383</span> writers.add(writer);<a name="line.383"></a> +<span class="sourceLineNo">384</span> ctx.addThread(writer);<a name="line.384"></a> +<span class="sourceLineNo">385</span> }<a name="line.385"></a> +<span class="sourceLineNo">386</span> // Add a flusher<a name="line.386"></a> +<span class="sourceLineNo">387</span> ctx.addThread(new RepeatingTestThread(ctx) {<a name="line.387"></a> +<span class="sourceLineNo">388</span> Admin admin = util.getAdmin();<a name="line.388"></a> +<span class="sourceLineNo">389</span> public void doAnAction() throws Exception {<a name="line.389"></a> +<span class="sourceLineNo">390</span> try {<a name="line.390"></a> +<span class="sourceLineNo">391</span> admin.flush(TABLE_NAME);<a name="line.391"></a> +<span class="sourceLineNo">392</span> } catch(IOException ioe) {<a name="line.392"></a> +<span class="sourceLineNo">393</span> LOG.warn("Ignoring exception while flushing: " + StringUtils.stringifyException(ioe));<a name="line.393"></a> +<span class="sourceLineNo">394</span> }<a name="line.394"></a> +<span class="sourceLineNo">395</span> // Flushing has been a source of ACID violations previously (see HBASE-2856), so ideally,<a name="line.395"></a> +<span class="sourceLineNo">396</span> // we would flush as often as possible. On a running cluster, this isn't practical:<a name="line.396"></a> +<span class="sourceLineNo">397</span> // (1) we will cause a lot of load due to all the flushing and compacting<a name="line.397"></a> +<span class="sourceLineNo">398</span> // (2) we cannot change the flushing/compacting related Configuration options to try to<a name="line.398"></a> +<span class="sourceLineNo">399</span> // alleviate this<a name="line.399"></a> +<span class="sourceLineNo">400</span> // (3) it is an unrealistic workload, since no one would actually flush that often.<a name="line.400"></a> +<span class="sourceLineNo">401</span> // Therefore, let's flush every minute to have more flushes than usual, but not overload<a name="line.401"></a> +<span class="sourceLineNo">402</span> // the running cluster.<a name="line.402"></a> +<span class="sourceLineNo">403</span> if (systemTest) Thread.sleep(60000);<a name="line.403"></a> +<span class="sourceLineNo">404</span> }<a name="line.404"></a> +<span class="sourceLineNo">405</span> });<a name="line.405"></a> +<span class="sourceLineNo">406</span><a name="line.406"></a> +<span class="sourceLineNo">407</span> List<AtomicGetReader> getters = Lists.newArrayList();<a name="line.407"></a> +<span class="sourceLineNo">408</span> for (int i = 0; i < numGetters; i++) {<a name="line.408"></a> +<span class="sourceLineNo">409</span> AtomicGetReader getter = new AtomicGetReader(<a name="line.409"></a> +<span class="sourceLineNo">410</span> ctx, rows[i % numUniqueRows], FAMILIES, getSharedThreadPool());<a name="line.410"></a> +<span class="sourceLineNo">411</span> getters.add(getter);<a name="line.411"></a> +<span class="sourceLineNo">412</span> ctx.addThread(getter);<a name="line.412"></a> +<span class="sourceLineNo">413</span> }<a name="line.413"></a> +<span class="sourceLineNo">414</span><a name="line.414"></a> +<span class="sourceLineNo">415</span> List<AtomicScanReader> scanners = Lists.newArrayList();<a name="line.415"></a> +<span class="sourceLineNo">416</span> for (int i = 0; i < numScanners; i++) {<a name="line.416"></a> +<span class="sourceLineNo">417</span> AtomicScanReader scanner = new AtomicScanReader(ctx, FAMILIES, getSharedThreadPool());<a name="line.417"></a> +<span class="sourceLineNo">418</span> scanners.add(scanner);<a name="line.418"></a> +<span class="sourceLineNo">419</span> ctx.addThread(scanner);<a name="line.419"></a> +<span class="sourceLineNo">420</span> }<a name="line.420"></a> +<span class="sourceLineNo">421</span><a name="line.421"></a> +<span class="sourceLineNo">422</span> ctx.startThreads();<a name="line.422"></a> +<span class="sourceLineNo">423</span> ctx.waitFor(millisToRun);<a name="line.423"></a> +<span class="sourceLineNo">424</span> ctx.stop();<a name="line.424"></a> +<span class="sourceLineNo">425</span><a name="line.425"></a> +<span class="sourceLineNo">426</span> LOG.info("Finished test. Writers:");<a name="line.426"></a> +<span class="sourceLineNo">427</span> for (AtomicityWriter writer : writers) {<a name="line.427"></a> +<span class="sourceLineNo">428</span> LOG.info(" wrote " + writer.numWritten.get());<a name="line.428"></a> +<span class="sourceLineNo">429</span> }<a name="line.429"></a> +<span class="sourceLineNo">430</span> LOG.info("Readers:");<a name="line.430"></a> +<span class="sourceLineNo">431</span> for (AtomicGetReader reader : getters) {<a name="line.431"></a> +<span class="sourceLineNo">432</span> LOG.info(" read " + reader.numRead.get());<a name="line.432"></a> +<span class="sourceLineNo">433</span> }<a name="line.433"></a> +<span class="sourceLineNo">434</span> LOG.info("Scanners:");<a name="line.434"></a> +<span class="sourceLineNo">435</span> for (AtomicScanReader scanner : scanners) {<a name="line.435"></a> +<span class="sourceLineNo">436</span> LOG.info(" scanned " + scanner.numScans.get());<a name="line.436"></a> +<span class="sourceLineNo">437</span> LOG.info(" verified " + scanner.numRowsScanned.get() + " rows");<a name="line.437"></a> +<span class="sourceLineNo">438</span> }<a name="line.438"></a> +<span class="sourceLineNo">439</span> }<a name="line.439"></a> +<span class="sourceLineNo">440</span><a name="line.440"></a> +<span class="sourceLineNo">441</span> @Before<a name="line.441"></a> +<span class="sourceLineNo">442</span> public void setUp() throws Exception {<a name="line.442"></a> +<span class="sourceLineNo">443</span> util.startMiniCluster(1);<a name="line.443"></a> +<span class="sourceLineNo">444</span> }<a name="line.444"></a> +<span class="sourceLineNo">445</span><a name="line.445"></a> +<span class="sourceLineNo">446</span> @After<a name="line.446"></a> +<span class="sourceLineNo">447</span> public void tearDown() throws Exception {<a name="line.447"></a> +<span class="sourceLineNo">448</span> util.shutdownMiniCluster();<a name="line.448"></a> +<span class="sourceLineNo">449</span> }<a name="line.449"></a> +<span class="sourceLineNo">450</span><a name="line.450"></a> +<span class="sourceLineNo">451</span> @Test<a name="line.451"></a> +<span class="sourceLineNo">452</span> public void testGetAtomicity() throws Exception {<a name="line.452"></a> +<span class="sourceLineNo">453</span> runTestAtomicity(20000, 5, 5, 0, 3);<a name="line.453"></a> +<span class="sourceLineNo">454</span> }<a name="line.454"></a> +<span class="sourceLineNo">455</span><a name="line.455"></a> +<span class="sourceLineNo">456</span> @Test<a name="line.456"></a> +<span class="sourceLineNo">457</span> public void testScanAtomicity() throws Exception {<a name="line.457"></a> +<span class="sourceLineNo">458</span> runTestAtomicity(20000, 5, 0, 5, 3);<a name="line.458"></a> +<span class="sourceLineNo">459</span> }<a name="line.459"></a> +<span class="sourceLineNo">460</span><a name="line.460"></a> +<span class="sourceLineNo">461</span> @Test<a name="line.461"></a> +<span class="sourceLineNo">462</span> public void testMixedAtomicity() throws Exception {<a name="line.462"></a> +<span class="sourceLineNo">463</span> runTestAtomicity(20000, 5, 2, 2, 3);<a name="line.463"></a> +<span class="sourceLineNo">464</span> }<a name="line.464"></a> +<span class="sourceLineNo">465</span><a name="line.465"></a> +<span class="sourceLineNo">466</span> @Test<a name="line.466"></a> +<span class="sourceLineNo">467</span> public void testMobGetAtomicity() throws Exception {<a name="line.467"></a> +<span class="sourceLineNo">468</span> boolean systemTest = false;<a name="line.468"></a> +<span class="sourceLineNo">469</span> boolean useMob = true;<a name="line.469"></a> +<span class="sourceLineNo">470</span> runTestAtomicity(20000, 5, 5, 0, 3, systemTest, useMob);<a name="line.470"></a> +<span class="sourceLineNo">471</span> }<a name="line.471"></a> +<span class="sourceLineNo">472</span><a name="line.472"></a> +<span class="sourceLineNo">473</span> @Test<a name="line.473"></a> +<span class="sourceLineNo">474</span> public void testMobScanAtomicity() throws Exception {<a name="line.474"></a> +<span class="sourceLineNo">475</span> boolean systemTest = false;<a name="line.475"></a> +<span class="sourceLineNo">476</span> boolean useMob = true;<a name="line.476"></a> +<span class="sourceLineNo">477</span> runTestAtomicity(20000, 5, 0, 5, 3, systemTest, useMob);<a name="line.477"></a> +<span class="sourceLineNo">478</span> }<a name="line.478"></a> +<span class="sourceLineNo">479</span><a name="line.479"></a> +<span class="sourceLineNo">480</span> @Test<a name="line.480"></a> +<span class="sourceLineNo">481</span> public void testMobMixedAtomicity() throws Exception {<a name="line.481"></a> +<span class="sourceLineNo">482</span> boolean systemTest = false;<a name="line.482"></a> +<span class="sourceLineNo">483</span> boolean useMob = true;<a name="line.483"></a> +<span class="sourceLineNo">484</span> runTestAtomicity(20000, 5, 2, 2, 3, systemTest, useMob);<a name="line.484"></a> +<span class="sourceLineNo">485</span> }<a name="line.485"></a> +<span class="sourceLineNo">486</span><a name="line.486"></a> <span class="sourceLineNo">487</span> ////////////////////////////////////////////////////////////////////////////<a name="line.487"></a> -<span class="sourceLineNo">488</span> @Override<a name="line.488"></a> -<span class="sourceLineNo">489</span> public Configuration getConf() {<a name="line.489"></a> -<span class="sourceLineNo">490</span> return conf;<a name="line.490"></a> -<span class="sourceLineNo">491</span> }<a name="line.491"></a> -<span class="sourceLineNo">492</span><a name="line.492"></a> -<span class="sourceLineNo">493</span> @Override<a name="line.493"></a> -<span class="sourceLineNo">494</span> public void setConf(Configuration c) {<a name="line.494"></a> -<span class="sourceLineNo">495</span> this.conf = c;<a name="line.495"></a> -<span class="sourceLineNo">496</span> this.util = new HBaseTestingUtility(c);<a name="line.496"></a> -<span class="sourceLineNo">497</span> }<a name="line.497"></a> -<span class="sourceLineNo">498</span><a name="line.498"></a> -<span class="sourceLineNo">499</span> @Override<a name="line.499"></a> -<span class="sourceLineNo">500</span> public int run(String[] arg0) throws Exception {<a name="line.500"></a> -<span class="sourceLineNo">501</span> Configuration c = getConf();<a name="line.501"></a> -<span class="sourceLineNo">502</span> int millis = c.getInt("millis", 5000);<a name="line.502"></a> -<span class="sourceLineNo">503</span> int numWriters = c.getInt("numWriters", 50);<a name="line.503"></a> -<span class="sourceLineNo">504</span> int numGetters = c.getInt("numGetters", 2);<a name="line.504"></a> -<span class="sourceLineNo">505</span> int numScanners = c.getInt("numScanners", 2);<a name="line.505"></a> -<span class="sourceLineNo">506</span> int numUniqueRows = c.getInt("numUniqueRows", 3);<a name="line.506"></a> -<span class="sourceLineNo">507</span> boolean useMob = c.getBoolean("useMob",false);<a name="line.507"></a> -<span class="sourceLineNo">508</span> assert useMob && c.getInt("hfile.format.version", 2) == 3 : "Mob runs must use hfile v3";<a name="line.508"></a> -<span class="sourceLineNo">509</span> runTestAtomicity(millis, numWriters, numGetters, numScanners, numUniqueRows, true, useMob);<a name="line.509"></a> -<span class="sourceLineNo">510</span> return 0;<a name="line.510"></a> -<span class="sourceLineNo">511</span> }<a name="line.511"></a> -<span class="sourceLineNo">512</span><a name="line.512"></a> -<span class="sourceLineNo">513</span> public static void main(String args[]) throws Exception {<a name="line.513"></a> -<span class="sourceLineNo">514</span> Configuration c = HBaseConfiguration.create();<a name="line.514"></a> -<span class="sourceLineNo">515</span> int status;<a name="line.515"></a> -<span class="sourceLineNo">516</span> try {<a name="line.516"></a> -<span class="sourceLineNo">517</span> TestAcidGuarantees test = new TestAcidGuarantees(CompactingMemStore<a name="line.517"></a> -<span class="sourceLineNo">518</span> .COMPACTING_MEMSTORE_TYPE_DEFAULT);<a name="line.518"></a> -<span class="sourceLineNo">519</span> status = ToolRunner.run(c, test, args);<a name="line.519"></a> -<span class="sourceLineNo">520</span> } catch (Exception e) {<a name="line.520"></a> -<span class="sourceLineNo">521</span> LOG.error("Exiting due to error", e);<a name="line.521"></a> -<span class="sourceLineNo">522</span> status = -1;<a name="line.522"></a> -<span class="sourceLineNo">523</span> }<a name="line.523"></a> -<span class="sourceLineNo">524</span> System.exit(status);<a name="line.524"></a> -<span class="sourceLineNo">525</span> }<a name="line.525"></a> -<span class="sourceLineNo">526</span><a name="line.526"></a> -<span class="sourceLineNo">527</span><a name="line.527"></a> -<span class="sourceLineNo">528</span>}<a name="line.528"></a> +<span class="sourceLineNo">488</span> // Tool interface<a name="line.488"></a> +<span class="sourceLineNo">489</span> ////////////////////////////////////////////////////////////////////////////<a name="line.489"></a> +<span class="sourceLineNo">490</span> @Override<a name="line.490"></a> +<span class="sourceLineNo">491</span> public Configuration getConf() {<a name="line.491"></a> +<span class="sourceLineNo">492</span> return conf;<a name="line.492"></a> +<span class="sourceLineNo">493</span> }<a name="line.493"></a> +<span class="sourceLineNo">494</span><a name="line.494"></a> +<span class="sourceLineNo">495</span> @Override<a name="line.495"></a> +<span class="sourceLineNo">496</span> public void setConf(Configuration c) {<a name="line.496"></a> +<span class="sourceLineNo">497</span> this.conf = c;<a name="line.497"></a> +<span class="sourceLineNo">498</span> this.util = new HBaseTestingUtility(c);<a name="line.498"></a> +<span class="sourceLineNo">499</span> }<a name="line.499"></a> +<span class="sourceLineNo">500</span><a name="line.500"></a> +<span class="sourceLineNo">501</span> @Override<a name="line.501"></a> +<span class="sourceLineNo">502</span> public int run(String[] arg0) throws Exception {<a name="line.502"></a> +<span class="sourceLineNo">503</span> Configuration c = getConf();<a name="line.503"></a> +<span class="sourceLineNo">504</span> int millis = c.getInt("millis", 5000);<a name="line.504"></a> +<span class="sourceLineNo">505</span> int numWriters = c.getInt("numWriters", 50);<a name="line.505"></a> +<span class="sourceLineNo">506</span> int numGetters = c.getInt("numGetters", 2);<a name="line.506"></a> +<span class="sourceLineNo">507</span> int numScanners = c.getInt("numScanners", 2);<a name="line.507"></a> +<span class="sourceLineNo">508</span> int numUniqueRows = c.getInt("numUniqueRows", 3);<a name="line.508"></a> +<span class="sourceLineNo">509</span> boolean useMob = c.getBoolean("useMob",false);<a name="line.509"></a> +<span class="sourceLineNo">510</span> assert useMob && c.getInt("hfile.format.version", 2) == 3 : "Mob runs must use hfile v3";<a name="line.510"></a> +<span class="sourceLineNo">511</span> runTestAtomicity(millis, numWriters, numGetters, numScanners, numUniqueRows, true, useMob);<a name="line.511"></a> +<span class="sourceLineNo">512</span> return 0;<a name="line.512"></a> +<span class="sourceLineNo">513</span> }<a name="line.513"></a> +<span class="sourceLineNo">514</span><a name="line.514"></a> +<span class="sourceLineNo">515</span> public static void main(String args[]) throws Exception {<a name="line.515"></a> +<span class="sourceLineNo">516</span> Configuration c = HBaseConfiguration.create();<a name="line.516"></a> +<span class="sourceLineNo">517</span> int status;<a name="line.517"></a> +<span class="sourceLineNo">518</span> try {<a name="line.518"></a> +<span class="sourceLineNo">519</span> TestAcidGuarantees test = new TestAcidGuarantees(CompactingMemStore<a name="line.519"></a> +<span class="sourceLineNo">520</span> .COMPACTING_MEMSTORE_TYPE_DEFAULT);<a name="line.520"></a> +<span class="sourceLineNo">521</span> status = ToolRunner.run(c, test, args);<a name="line.521"></a> +<span class="sourceLineNo">522</span> } catch (Exception e) {<a name="line.522"></a> +<span class="sourceLineNo">523</span> LOG.error("Exiting due to error", e);<a name="line.523"></a> +<span class="sourceLineNo">524</span> status = -1;<a name="line.524"></a> +<span class="sourceLineNo">525</span> }<a name="line.525"></a> +<span class="sourceLineNo">526</span> System.exit(status);<a name="line.526"></a> +<span class="sourceLineNo">527</span> }<a name="line.527"></a> +<span class="sourceLineNo">528</span><a name="line.528"></a> <span class="sourceLineNo">529</span><a name="line.529"></a> +<span class="sourceLineNo">530</span>}<a name="line.530"></a> +<span class="sourceLineNo">531</span><a name="line.531"></a>
