You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by gi...@apache.org on 2018/09/29 14:52:24 UTC
[06/41] hbase-site git commit: Published site at
fdbaa4c3f0253700d12b6bd61cacf29ca7fbc19f.
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/testdevapidocs/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html b/testdevapidocs/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html
index d22d14d..cdd2bf4 100644
--- a/testdevapidocs/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html
+++ b/testdevapidocs/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html
@@ -929,7 +929,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>createWALKey</h4>
-<pre>private org.apache.hadoop.hbase.wal.WALKeyImpl <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1141">createWALKey</a>(org.apache.hadoop.hbase.TableName tableName,
+<pre>private org.apache.hadoop.hbase.wal.WALKeyImpl <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1143">createWALKey</a>(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.HRegionInfo hri,
org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl mvcc,
<a href="https://docs.oracle.com/javase/8/docs/api/java/util/NavigableMap.html?is-external=true" title="class or interface in java.util">NavigableMap</a><byte[],<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Integer.html?is-external=true" title="class or interface in java.lang">Integer</a>> scopes)</pre>
@@ -941,7 +941,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>createWALEdit</h4>
-<pre>private org.apache.hadoop.hbase.wal.WALEdit <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1146">createWALEdit</a>(byte[] rowName,
+<pre>private org.apache.hadoop.hbase.wal.WALEdit <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1148">createWALEdit</a>(byte[] rowName,
byte[] family,
org.apache.hadoop.hbase.util.EnvironmentEdge ee,
int index)</pre>
@@ -953,7 +953,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>createFSWALEntry</h4>
-<pre>private org.apache.hadoop.hbase.regionserver.wal.FSWALEntry <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1155">createFSWALEntry</a>(org.apache.hadoop.hbase.HTableDescriptor htd,
+<pre>private org.apache.hadoop.hbase.regionserver.wal.FSWALEntry <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1157">createFSWALEntry</a>(org.apache.hadoop.hbase.HTableDescriptor htd,
org.apache.hadoop.hbase.HRegionInfo hri,
long sequence,
byte[] rowName,
@@ -975,7 +975,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>addWALEdits</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1165">addWALEdits</a>(org.apache.hadoop.hbase.TableName tableName,
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1167">addWALEdits</a>(org.apache.hadoop.hbase.TableName tableName,
org.apache.hadoop.hbase.HRegionInfo hri,
byte[] rowName,
byte[] family,
@@ -998,7 +998,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>addRegionEdits</h4>
-<pre>static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><org.apache.hadoop.hbase.client.Put> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1176">addRegionEdits</a>(byte[] rowName,
+<pre>static <a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><org.apache.hadoop.hbase.client.Put> <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1178">addRegionEdits</a>(byte[] rowName,
byte[] family,
int count,
org.apache.hadoop.hbase.util.EnvironmentEdge ee,
@@ -1017,7 +1017,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>createBasic3FamilyHRegionInfo</h4>
-<pre>private org.apache.hadoop.hbase.HRegionInfo <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1194">createBasic3FamilyHRegionInfo</a>(org.apache.hadoop.hbase.TableName tableName)</pre>
+<pre>private org.apache.hadoop.hbase.HRegionInfo <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1196">createBasic3FamilyHRegionInfo</a>(org.apache.hadoop.hbase.TableName tableName)</pre>
</li>
</ul>
<a name="runWALSplit-org.apache.hadoop.conf.Configuration-">
@@ -1026,7 +1026,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>runWALSplit</h4>
-<pre>private org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1204">runWALSplit</a>(org.apache.hadoop.conf.Configuration c)
+<pre>private org.apache.hadoop.fs.Path <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1206">runWALSplit</a>(org.apache.hadoop.conf.Configuration c)
throws <a href="https://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>
@@ -1040,7 +1040,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>createBasic3FamilyHTD</h4>
-<pre>private org.apache.hadoop.hbase.HTableDescriptor <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1215">createBasic3FamilyHTD</a>(org.apache.hadoop.hbase.TableName tableName)</pre>
+<pre>private org.apache.hadoop.hbase.HTableDescriptor <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1217">createBasic3FamilyHTD</a>(org.apache.hadoop.hbase.TableName tableName)</pre>
</li>
</ul>
<a name="writerWALFile-org.apache.hadoop.fs.Path-java.util.List-">
@@ -1049,7 +1049,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockList">
<li class="blockList">
<h4>writerWALFile</h4>
-<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1226">writerWALFile</a>(org.apache.hadoop.fs.Path file,
+<pre>private void <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1228">writerWALFile</a>(org.apache.hadoop.fs.Path file,
<a href="https://docs.oracle.com/javase/8/docs/api/java/util/List.html?is-external=true" title="class or interface in java.util">List</a><org.apache.hadoop.hbase.regionserver.wal.FSWALEntry> entries)
throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a>,
org.apache.hadoop.hbase.util.CommonFSUtils.StreamLacksCapabilityException</pre>
@@ -1066,7 +1066,7 @@ extends <a href="https://docs.oracle.com/javase/8/docs/api/java/lang/Object.html
<ul class="blockListLast">
<li class="blockList">
<h4>createWAL</h4>
-<pre>protected abstract org.apache.hadoop.hbase.wal.WAL <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1238">createWAL</a>(org.apache.hadoop.conf.Configuration c,
+<pre>protected abstract org.apache.hadoop.hbase.wal.WAL <a href="../../../../../../src-html/org/apache/hadoop/hbase/regionserver/wal/AbstractTestWALReplay.html#line.1240">createWAL</a>(org.apache.hadoop.conf.Configuration c,
org.apache.hadoop.fs.Path hbaseRootDir,
<a href="https://docs.oracle.com/javase/8/docs/api/java/lang/String.html?is-external=true" title="class or interface in java.lang">String</a> logName)
throws <a href="https://docs.oracle.com/javase/8/docs/api/java/io/IOException.html?is-external=true" title="class or interface in java.io">IOException</a></pre>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/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 ff48e4c..5ad4f9a 100644
--- a/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html
+++ b/testdevapidocs/org/apache/hadoop/hbase/test/package-tree.html
@@ -253,9 +253,9 @@
<ul>
<li type="circle">java.lang.<a href="https://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="https://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="https://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/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/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.Verify.Counts.html" title="enum in org.apache.hadoop.hbase.test"><span class="typeNameLink">IntegrationTestBigLinkedList.Verify.Counts</span></a></li>
</ul>
</li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/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 9e0700e..b21ae88 100644
--- a/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html
+++ b/testdevapidocs/org/apache/hadoop/hbase/wal/package-tree.html
@@ -141,9 +141,9 @@
<ul>
<li type="circle">java.lang.<a href="https://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="https://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="https://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/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>
-<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>
</ul>
</li>
</ul>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/testdevapidocs/overview-tree.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/overview-tree.html b/testdevapidocs/overview-tree.html
index 77e50b6..de1db56 100644
--- a/testdevapidocs/overview-tree.html
+++ b/testdevapidocs/overview-tree.html
@@ -618,6 +618,7 @@
<li type="circle">org.apache.hadoop.hbase.master.balancer.<a href="org/apache/hadoop/hbase/master/balancer/TestStochasticLoadBalancerRegionReplicaReplicationGreaterThanNumNodes.html" title="class in org.apache.hadoop.hbase.master.balancer"><span class="typeNameLink">TestStochasticLoadBalancerRegionReplicaReplicationGreaterThanNumNodes</span></a></li>
</ul>
</li>
+<li type="circle">org.apache.hadoop.hbase.master.balancer.<a href="org/apache/hadoop/hbase/master/balancer/TestBalancerStatusTagInJMXMetrics.html" title="class in org.apache.hadoop.hbase.master.balancer"><span class="typeNameLink">TestBalancerStatusTagInJMXMetrics</span></a></li>
<li type="circle">org.apache.hadoop.hbase.master.balancer.<a href="org/apache/hadoop/hbase/master/balancer/TestBaseLoadBalancer.html" title="class in org.apache.hadoop.hbase.master.balancer"><span class="typeNameLink">TestBaseLoadBalancer</span></a></li>
<li type="circle">org.apache.hadoop.hbase.master.balancer.<a href="org/apache/hadoop/hbase/master/balancer/TestDefaultLoadBalancer.html" title="class in org.apache.hadoop.hbase.master.balancer"><span class="typeNameLink">TestDefaultLoadBalancer</span></a></li>
<li type="circle">org.apache.hadoop.hbase.master.balancer.<a href="org/apache/hadoop/hbase/master/balancer/TestFavoredStochasticBalancerPickers.html" title="class in org.apache.hadoop.hbase.master.balancer"><span class="typeNameLink">TestFavoredStochasticBalancerPickers</span></a></li>
@@ -3260,6 +3261,7 @@
<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="org/apache/hadoop/hbase/regionserver/TestRegionInfoBuilder.html" title="class in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestRegionInfoBuilder</span></a></li>
<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/TestRegionInfoDisplay.html" title="class in org.apache.hadoop.hbase.client"><span class="typeNameLink">TestRegionInfoDisplay</span></a></li>
<li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/TestRegionLoad.html" title="class in org.apache.hadoop.hbase"><span class="typeNameLink">TestRegionLoad</span></a></li>
+<li type="circle">org.apache.hadoop.hbase.client.<a href="org/apache/hadoop/hbase/client/TestRegionLocationCaching.html" title="class in org.apache.hadoop.hbase.client"><span class="typeNameLink">TestRegionLocationCaching</span></a></li>
<li type="circle">org.apache.hadoop.hbase.master.balancer.<a href="org/apache/hadoop/hbase/master/balancer/TestRegionLocationFinder.html" title="class in org.apache.hadoop.hbase.master.balancer"><span class="typeNameLink">TestRegionLocationFinder</span></a></li>
<li type="circle">org.apache.hadoop.hbase.<a href="org/apache/hadoop/hbase/TestRegionLocations.html" title="class in org.apache.hadoop.hbase"><span class="typeNameLink">TestRegionLocations</span></a></li>
<li type="circle">org.apache.hadoop.hbase.regionserver.<a href="org/apache/hadoop/hbase/regionserver/TestRegionMergeTransactionOnCluster.html" title="class in org.apache.hadoop.hbase.regionserver"><span class="typeNameLink">TestRegionMergeTransactionOnCluster</span></a></li>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestRegionLocationCaching.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestRegionLocationCaching.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestRegionLocationCaching.html
new file mode 100644
index 0000000..303dab8
--- /dev/null
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/client/TestRegionLocationCaching.html
@@ -0,0 +1,249 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<html lang="en">
+<head>
+<title>Source code</title>
+<link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style">
+</head>
+<body>
+<div class="sourceContainer">
+<pre><span class="sourceLineNo">001</span>/**<a name="line.1"></a>
+<span class="sourceLineNo">002</span> * Licensed to the Apache Software Foundation (ASF) under one<a name="line.2"></a>
+<span class="sourceLineNo">003</span> * or more contributor license agreements. See the NOTICE file<a name="line.3"></a>
+<span class="sourceLineNo">004</span> * distributed with this work for additional information<a name="line.4"></a>
+<span class="sourceLineNo">005</span> * regarding copyright ownership. The ASF licenses this file<a name="line.5"></a>
+<span class="sourceLineNo">006</span> * to you under the Apache License, Version 2.0 (the<a name="line.6"></a>
+<span class="sourceLineNo">007</span> * "License"); you may not use this file except in compliance<a name="line.7"></a>
+<span class="sourceLineNo">008</span> * with the License. You may obtain a copy of the License at<a name="line.8"></a>
+<span class="sourceLineNo">009</span> *<a name="line.9"></a>
+<span class="sourceLineNo">010</span> * http://www.apache.org/licenses/LICENSE-2.0<a name="line.10"></a>
+<span class="sourceLineNo">011</span> *<a name="line.11"></a>
+<span class="sourceLineNo">012</span> * Unless required by applicable law or agreed to in writing, software<a name="line.12"></a>
+<span class="sourceLineNo">013</span> * distributed under the License is distributed on an "AS IS" BASIS,<a name="line.13"></a>
+<span class="sourceLineNo">014</span> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.<a name="line.14"></a>
+<span class="sourceLineNo">015</span> * See the License for the specific language governing permissions and<a name="line.15"></a>
+<span class="sourceLineNo">016</span> * limitations under the License.<a name="line.16"></a>
+<span class="sourceLineNo">017</span> */<a name="line.17"></a>
+<span class="sourceLineNo">018</span><a name="line.18"></a>
+<span class="sourceLineNo">019</span>package org.apache.hadoop.hbase.client;<a name="line.19"></a>
+<span class="sourceLineNo">020</span><a name="line.20"></a>
+<span class="sourceLineNo">021</span>import static org.junit.Assert.assertNotEquals;<a name="line.21"></a>
+<span class="sourceLineNo">022</span>import static org.junit.Assert.assertNull;<a name="line.22"></a>
+<span class="sourceLineNo">023</span>import static org.junit.Assert.assertTrue;<a name="line.23"></a>
+<span class="sourceLineNo">024</span><a name="line.24"></a>
+<span class="sourceLineNo">025</span>import java.io.IOException;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import java.util.ArrayList;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import java.util.List;<a name="line.27"></a>
+<span class="sourceLineNo">028</span><a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.apache.hadoop.hbase.HBaseClassTestRule;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.apache.hadoop.hbase.HBaseTestingUtility;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.apache.hadoop.hbase.TableName;<a name="line.31"></a>
+<span class="sourceLineNo">032</span>import org.apache.hadoop.hbase.testclassification.ClientTests;<a name="line.32"></a>
+<span class="sourceLineNo">033</span>import org.apache.hadoop.hbase.testclassification.MediumTests;<a name="line.33"></a>
+<span class="sourceLineNo">034</span>import org.apache.hadoop.hbase.util.Bytes;<a name="line.34"></a>
+<span class="sourceLineNo">035</span>import org.junit.AfterClass;<a name="line.35"></a>
+<span class="sourceLineNo">036</span>import org.junit.BeforeClass;<a name="line.36"></a>
+<span class="sourceLineNo">037</span>import org.junit.ClassRule;<a name="line.37"></a>
+<span class="sourceLineNo">038</span>import org.junit.Test;<a name="line.38"></a>
+<span class="sourceLineNo">039</span>import org.junit.experimental.categories.Category;<a name="line.39"></a>
+<span class="sourceLineNo">040</span><a name="line.40"></a>
+<span class="sourceLineNo">041</span>@Category({MediumTests.class, ClientTests.class})<a name="line.41"></a>
+<span class="sourceLineNo">042</span>public class TestRegionLocationCaching {<a name="line.42"></a>
+<span class="sourceLineNo">043</span><a name="line.43"></a>
+<span class="sourceLineNo">044</span> @ClassRule<a name="line.44"></a>
+<span class="sourceLineNo">045</span> public static final HBaseClassTestRule CLASS_RULE =<a name="line.45"></a>
+<span class="sourceLineNo">046</span> HBaseClassTestRule.forClass(TestRegionLocationCaching.class);<a name="line.46"></a>
+<span class="sourceLineNo">047</span><a name="line.47"></a>
+<span class="sourceLineNo">048</span> private final static HBaseTestingUtility TEST_UTIL = new HBaseTestingUtility();<a name="line.48"></a>
+<span class="sourceLineNo">049</span> private static int SLAVES = 1;<a name="line.49"></a>
+<span class="sourceLineNo">050</span> private static int PER_REGIONSERVER_QUEUE_SIZE = 100000;<a name="line.50"></a>
+<span class="sourceLineNo">051</span> private static TableName TABLE_NAME = TableName.valueOf("TestRegionLocationCaching");<a name="line.51"></a>
+<span class="sourceLineNo">052</span> private static byte[] FAMILY = Bytes.toBytes("testFamily");<a name="line.52"></a>
+<span class="sourceLineNo">053</span> private static byte[] QUALIFIER = Bytes.toBytes("testQualifier");<a name="line.53"></a>
+<span class="sourceLineNo">054</span><a name="line.54"></a>
+<span class="sourceLineNo">055</span> @BeforeClass<a name="line.55"></a>
+<span class="sourceLineNo">056</span> public static void setUpBeforeClass() throws Exception {<a name="line.56"></a>
+<span class="sourceLineNo">057</span> TEST_UTIL.startMiniCluster(SLAVES);<a name="line.57"></a>
+<span class="sourceLineNo">058</span> TEST_UTIL.createTable(TABLE_NAME, new byte[][] { FAMILY });<a name="line.58"></a>
+<span class="sourceLineNo">059</span> TEST_UTIL.waitUntilAllRegionsAssigned(TABLE_NAME);<a name="line.59"></a>
+<span class="sourceLineNo">060</span> }<a name="line.60"></a>
+<span class="sourceLineNo">061</span><a name="line.61"></a>
+<span class="sourceLineNo">062</span> @AfterClass<a name="line.62"></a>
+<span class="sourceLineNo">063</span> public static void tearDownAfterClass() throws Exception {<a name="line.63"></a>
+<span class="sourceLineNo">064</span> TEST_UTIL.shutdownMiniCluster();<a name="line.64"></a>
+<span class="sourceLineNo">065</span> }<a name="line.65"></a>
+<span class="sourceLineNo">066</span><a name="line.66"></a>
+<span class="sourceLineNo">067</span> @Test<a name="line.67"></a>
+<span class="sourceLineNo">068</span> public void testCachingForHTableMultiplexerSinglePut() throws Exception {<a name="line.68"></a>
+<span class="sourceLineNo">069</span> HTableMultiplexer multiplexer =<a name="line.69"></a>
+<span class="sourceLineNo">070</span> new HTableMultiplexer(TEST_UTIL.getConfiguration(), PER_REGIONSERVER_QUEUE_SIZE);<a name="line.70"></a>
+<span class="sourceLineNo">071</span> byte[] row = Bytes.toBytes("htable_multiplexer_single_put");<a name="line.71"></a>
+<span class="sourceLineNo">072</span> byte[] value = Bytes.toBytes("value");<a name="line.72"></a>
+<span class="sourceLineNo">073</span><a name="line.73"></a>
+<span class="sourceLineNo">074</span> Put put = new Put(row);<a name="line.74"></a>
+<span class="sourceLineNo">075</span> put.addColumn(FAMILY, QUALIFIER, value);<a name="line.75"></a>
+<span class="sourceLineNo">076</span> assertTrue("Put request not accepted by multiplexer queue", multiplexer.put(TABLE_NAME, put));<a name="line.76"></a>
+<span class="sourceLineNo">077</span><a name="line.77"></a>
+<span class="sourceLineNo">078</span> checkRegionLocationIsCached(TABLE_NAME, multiplexer.getConnection());<a name="line.78"></a>
+<span class="sourceLineNo">079</span> checkExistence(TABLE_NAME, row, FAMILY, QUALIFIER);<a name="line.79"></a>
+<span class="sourceLineNo">080</span><a name="line.80"></a>
+<span class="sourceLineNo">081</span> multiplexer.close();<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> @Test<a name="line.84"></a>
+<span class="sourceLineNo">085</span> public void testCachingForHTableMultiplexerMultiPut() throws Exception {<a name="line.85"></a>
+<span class="sourceLineNo">086</span> HTableMultiplexer multiplexer =<a name="line.86"></a>
+<span class="sourceLineNo">087</span> new HTableMultiplexer(TEST_UTIL.getConfiguration(), PER_REGIONSERVER_QUEUE_SIZE);<a name="line.87"></a>
+<span class="sourceLineNo">088</span><a name="line.88"></a>
+<span class="sourceLineNo">089</span> List<Put> multiput = new ArrayList<Put>();<a name="line.89"></a>
+<span class="sourceLineNo">090</span> for (int i = 0; i < 10; i++) {<a name="line.90"></a>
+<span class="sourceLineNo">091</span> Put put = new Put(Bytes.toBytes("htable_multiplexer_multi_put" + i));<a name="line.91"></a>
+<span class="sourceLineNo">092</span> byte[] value = Bytes.toBytes("value_" + i);<a name="line.92"></a>
+<span class="sourceLineNo">093</span> put.addColumn(FAMILY, QUALIFIER, value);<a name="line.93"></a>
+<span class="sourceLineNo">094</span> multiput.add(put);<a name="line.94"></a>
+<span class="sourceLineNo">095</span> }<a name="line.95"></a>
+<span class="sourceLineNo">096</span><a name="line.96"></a>
+<span class="sourceLineNo">097</span> List<Put> failedPuts = multiplexer.put(TABLE_NAME, multiput);<a name="line.97"></a>
+<span class="sourceLineNo">098</span> assertNull("All put requests were not accepted by multiplexer queue", failedPuts);<a name="line.98"></a>
+<span class="sourceLineNo">099</span><a name="line.99"></a>
+<span class="sourceLineNo">100</span> checkRegionLocationIsCached(TABLE_NAME, multiplexer.getConnection());<a name="line.100"></a>
+<span class="sourceLineNo">101</span> for (int i = 0; i < 10; i++) {<a name="line.101"></a>
+<span class="sourceLineNo">102</span> checkExistence(TABLE_NAME, Bytes.toBytes("htable_multiplexer_multi_put" + i), FAMILY,<a name="line.102"></a>
+<span class="sourceLineNo">103</span> QUALIFIER);<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> multiplexer.close();<a name="line.106"></a>
+<span class="sourceLineNo">107</span> }<a name="line.107"></a>
+<span class="sourceLineNo">108</span><a name="line.108"></a>
+<span class="sourceLineNo">109</span> @Test<a name="line.109"></a>
+<span class="sourceLineNo">110</span> public void testCachingForHTableSinglePut() throws Exception {<a name="line.110"></a>
+<span class="sourceLineNo">111</span> byte[] row = Bytes.toBytes("htable_single_put");<a name="line.111"></a>
+<span class="sourceLineNo">112</span> byte[] value = Bytes.toBytes("value");<a name="line.112"></a>
+<span class="sourceLineNo">113</span><a name="line.113"></a>
+<span class="sourceLineNo">114</span> Put put = new Put(row);<a name="line.114"></a>
+<span class="sourceLineNo">115</span> put.addColumn(FAMILY, QUALIFIER, value);<a name="line.115"></a>
+<span class="sourceLineNo">116</span><a name="line.116"></a>
+<span class="sourceLineNo">117</span> try (Table table = TEST_UTIL.getConnection().getTable(TABLE_NAME)) {<a name="line.117"></a>
+<span class="sourceLineNo">118</span> table.put(put);<a name="line.118"></a>
+<span class="sourceLineNo">119</span> }<a name="line.119"></a>
+<span class="sourceLineNo">120</span><a name="line.120"></a>
+<span class="sourceLineNo">121</span> checkRegionLocationIsCached(TABLE_NAME, TEST_UTIL.getConnection());<a name="line.121"></a>
+<span class="sourceLineNo">122</span> checkExistence(TABLE_NAME, row, FAMILY, QUALIFIER);<a name="line.122"></a>
+<span class="sourceLineNo">123</span> }<a name="line.123"></a>
+<span class="sourceLineNo">124</span><a name="line.124"></a>
+<span class="sourceLineNo">125</span> @Test<a name="line.125"></a>
+<span class="sourceLineNo">126</span> public void testCachingForHTableMultiPut() throws Exception {<a name="line.126"></a>
+<span class="sourceLineNo">127</span> List<Put> multiput = new ArrayList<Put>();<a name="line.127"></a>
+<span class="sourceLineNo">128</span> for (int i = 0; i < 10; i++) {<a name="line.128"></a>
+<span class="sourceLineNo">129</span> Put put = new Put(Bytes.toBytes("htable_multi_put" + i));<a name="line.129"></a>
+<span class="sourceLineNo">130</span> byte[] value = Bytes.toBytes("value_" + i);<a name="line.130"></a>
+<span class="sourceLineNo">131</span> put.addColumn(FAMILY, QUALIFIER, value);<a name="line.131"></a>
+<span class="sourceLineNo">132</span> multiput.add(put);<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> try (Table table = TEST_UTIL.getConnection().getTable(TABLE_NAME)) {<a name="line.135"></a>
+<span class="sourceLineNo">136</span> table.put(multiput);<a name="line.136"></a>
+<span class="sourceLineNo">137</span> }<a name="line.137"></a>
+<span class="sourceLineNo">138</span> checkRegionLocationIsCached(TABLE_NAME, TEST_UTIL.getConnection());<a name="line.138"></a>
+<span class="sourceLineNo">139</span> for (int i = 0; i < 10; i++) {<a name="line.139"></a>
+<span class="sourceLineNo">140</span> checkExistence(TABLE_NAME, Bytes.toBytes("htable_multi_put" + i), FAMILY, QUALIFIER);<a name="line.140"></a>
+<span class="sourceLineNo">141</span> }<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> /**<a name="line.144"></a>
+<span class="sourceLineNo">145</span> * Method to check whether the cached region location is non-empty for the given table. It repeats<a name="line.145"></a>
+<span class="sourceLineNo">146</span> * the same check several times as clearing of cache by some async operations may not reflect<a name="line.146"></a>
+<span class="sourceLineNo">147</span> * immediately.<a name="line.147"></a>
+<span class="sourceLineNo">148</span> */<a name="line.148"></a>
+<span class="sourceLineNo">149</span> private void checkRegionLocationIsCached(final TableName tableName, final Connection conn)<a name="line.149"></a>
+<span class="sourceLineNo">150</span> throws InterruptedException, IOException {<a name="line.150"></a>
+<span class="sourceLineNo">151</span> for (int count = 0; count < 50; count++) {<a name="line.151"></a>
+<span class="sourceLineNo">152</span> int number = ((ConnectionImplementation) conn).getNumberOfCachedRegionLocations(tableName);<a name="line.152"></a>
+<span class="sourceLineNo">153</span> assertNotEquals("Expected non-zero number of cached region locations", 0, number);<a name="line.153"></a>
+<span class="sourceLineNo">154</span> Thread.sleep(100);<a name="line.154"></a>
+<span class="sourceLineNo">155</span> }<a name="line.155"></a>
+<span class="sourceLineNo">156</span> }<a name="line.156"></a>
+<span class="sourceLineNo">157</span><a name="line.157"></a>
+<span class="sourceLineNo">158</span> /**<a name="line.158"></a>
+<span class="sourceLineNo">159</span> * Method to check whether the passed row exists in the given table<a name="line.159"></a>
+<span class="sourceLineNo">160</span> */<a name="line.160"></a>
+<span class="sourceLineNo">161</span> private static void checkExistence(final TableName tableName, final byte[] row,<a name="line.161"></a>
+<span class="sourceLineNo">162</span> final byte[] family, final byte[] qualifier) throws Exception {<a name="line.162"></a>
+<span class="sourceLineNo">163</span> // verify that the row exists<a name="line.163"></a>
+<span class="sourceLineNo">164</span> Result r;<a name="line.164"></a>
+<span class="sourceLineNo">165</span> Get get = new Get(row);<a name="line.165"></a>
+<span class="sourceLineNo">166</span> get.addColumn(family, qualifier);<a name="line.166"></a>
+<span class="sourceLineNo">167</span> int nbTry = 0;<a name="line.167"></a>
+<span class="sourceLineNo">168</span> try (Table table = TEST_UTIL.getConnection().getTable(tableName)) {<a name="line.168"></a>
+<span class="sourceLineNo">169</span> do {<a name="line.169"></a>
+<span class="sourceLineNo">170</span> assertTrue("Failed to get row after " + nbTry + " tries", nbTry < 50);<a name="line.170"></a>
+<span class="sourceLineNo">171</span> nbTry++;<a name="line.171"></a>
+<span class="sourceLineNo">172</span> Thread.sleep(100);<a name="line.172"></a>
+<span class="sourceLineNo">173</span> r = table.get(get);<a name="line.173"></a>
+<span class="sourceLineNo">174</span> } while (r == null || r.getValue(family, qualifier) == null);<a name="line.174"></a>
+<span class="sourceLineNo">175</span> }<a name="line.175"></a>
+<span class="sourceLineNo">176</span> }<a name="line.176"></a>
+<span class="sourceLineNo">177</span>}<a name="line.177"></a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+</pre>
+</div>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/testdevapidocs/src-html/org/apache/hadoop/hbase/master/balancer/TestBalancerStatusTagInJMXMetrics.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/master/balancer/TestBalancerStatusTagInJMXMetrics.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/balancer/TestBalancerStatusTagInJMXMetrics.html
new file mode 100644
index 0000000..3dac70d
--- /dev/null
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/master/balancer/TestBalancerStatusTagInJMXMetrics.html
@@ -0,0 +1,187 @@
+<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
+<html lang="en">
+<head>
+<title>Source code</title>
+<link rel="stylesheet" type="text/css" href="../../../../../../../stylesheet.css" title="Style">
+</head>
+<body>
+<div class="sourceContainer">
+<pre><span class="sourceLineNo">001</span>/**<a name="line.1"></a>
+<span class="sourceLineNo">002</span> * Licensed to the Apache Software Foundation (ASF) under one or more contributor license<a name="line.2"></a>
+<span class="sourceLineNo">003</span> * agreements. See the NOTICE file distributed with this work for additional information regarding<a name="line.3"></a>
+<span class="sourceLineNo">004</span> * copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the<a name="line.4"></a>
+<span class="sourceLineNo">005</span> * "License"); you may not use this file except in compliance with the License. You may obtain a<a name="line.5"></a>
+<span class="sourceLineNo">006</span> * copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable<a name="line.6"></a>
+<span class="sourceLineNo">007</span> * law or agreed to in writing, software distributed under the License is distributed on an "AS IS"<a name="line.7"></a>
+<span class="sourceLineNo">008</span> * BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License<a name="line.8"></a>
+<span class="sourceLineNo">009</span> * for the specific language governing permissions and limitations under the License.<a name="line.9"></a>
+<span class="sourceLineNo">010</span> */<a name="line.10"></a>
+<span class="sourceLineNo">011</span><a name="line.11"></a>
+<span class="sourceLineNo">012</span>package org.apache.hadoop.hbase.master.balancer;<a name="line.12"></a>
+<span class="sourceLineNo">013</span><a name="line.13"></a>
+<span class="sourceLineNo">014</span>import static org.junit.Assert.assertEquals;<a name="line.14"></a>
+<span class="sourceLineNo">015</span><a name="line.15"></a>
+<span class="sourceLineNo">016</span>import java.util.Random;<a name="line.16"></a>
+<span class="sourceLineNo">017</span><a name="line.17"></a>
+<span class="sourceLineNo">018</span>import org.apache.commons.logging.Log;<a name="line.18"></a>
+<span class="sourceLineNo">019</span>import org.apache.commons.logging.LogFactory;<a name="line.19"></a>
+<span class="sourceLineNo">020</span>import org.apache.hadoop.conf.Configuration;<a name="line.20"></a>
+<span class="sourceLineNo">021</span>import org.apache.hadoop.hbase.HBaseClassTestRule;<a name="line.21"></a>
+<span class="sourceLineNo">022</span>import org.apache.hadoop.hbase.HBaseTestingUtility;<a name="line.22"></a>
+<span class="sourceLineNo">023</span>import org.apache.hadoop.hbase.MiniHBaseCluster;<a name="line.23"></a>
+<span class="sourceLineNo">024</span>import org.apache.hadoop.hbase.master.HMaster;<a name="line.24"></a>
+<span class="sourceLineNo">025</span>import org.apache.hadoop.hbase.testclassification.MediumTests;<a name="line.25"></a>
+<span class="sourceLineNo">026</span>import org.apache.hadoop.metrics2.MetricsSource;<a name="line.26"></a>
+<span class="sourceLineNo">027</span>import org.apache.hadoop.metrics2.MetricsTag;<a name="line.27"></a>
+<span class="sourceLineNo">028</span>import org.apache.hadoop.metrics2.lib.DefaultMetricsSystem;<a name="line.28"></a>
+<span class="sourceLineNo">029</span>import org.junit.AfterClass;<a name="line.29"></a>
+<span class="sourceLineNo">030</span>import org.junit.BeforeClass;<a name="line.30"></a>
+<span class="sourceLineNo">031</span>import org.junit.ClassRule;<a name="line.31"></a>
+<span class="sourceLineNo">032</span>import org.junit.Test;<a name="line.32"></a>
+<span class="sourceLineNo">033</span>import org.junit.experimental.categories.Category;<a name="line.33"></a>
+<span class="sourceLineNo">034</span><a name="line.34"></a>
+<span class="sourceLineNo">035</span>@Category({ MediumTests.class })<a name="line.35"></a>
+<span class="sourceLineNo">036</span>public class TestBalancerStatusTagInJMXMetrics extends BalancerTestBase {<a name="line.36"></a>
+<span class="sourceLineNo">037</span><a name="line.37"></a>
+<span class="sourceLineNo">038</span> @ClassRule<a name="line.38"></a>
+<span class="sourceLineNo">039</span> public static final HBaseClassTestRule CLASS_RULE =<a name="line.39"></a>
+<span class="sourceLineNo">040</span> HBaseClassTestRule.forClass(TestBalancerStatusTagInJMXMetrics.class);<a name="line.40"></a>
+<span class="sourceLineNo">041</span><a name="line.41"></a>
+<span class="sourceLineNo">042</span> private static final Log LOG = LogFactory.getLog(TestBalancerStatusTagInJMXMetrics.class);<a name="line.42"></a>
+<span class="sourceLineNo">043</span> private static HBaseTestingUtility UTIL = new HBaseTestingUtility();<a name="line.43"></a>
+<span class="sourceLineNo">044</span> private static int connectorPort = 61120;<a name="line.44"></a>
+<span class="sourceLineNo">045</span> private static HMaster master;<a name="line.45"></a>
+<span class="sourceLineNo">046</span> private static MiniHBaseCluster cluster;<a name="line.46"></a>
+<span class="sourceLineNo">047</span> private static Configuration conf = null;<a name="line.47"></a>
+<span class="sourceLineNo">048</span><a name="line.48"></a>
+<span class="sourceLineNo">049</span> /**<a name="line.49"></a>
+<span class="sourceLineNo">050</span> * Setup the environment for the test.<a name="line.50"></a>
+<span class="sourceLineNo">051</span> */<a name="line.51"></a>
+<span class="sourceLineNo">052</span> @BeforeClass<a name="line.52"></a>
+<span class="sourceLineNo">053</span> public static void setupBeforeClass() throws Exception {<a name="line.53"></a>
+<span class="sourceLineNo">054</span><a name="line.54"></a>
+<span class="sourceLineNo">055</span> conf = UTIL.getConfiguration();<a name="line.55"></a>
+<span class="sourceLineNo">056</span> Random rand = new Random();<a name="line.56"></a>
+<span class="sourceLineNo">057</span> for (int i = 0; i < 10; i++) {<a name="line.57"></a>
+<span class="sourceLineNo">058</span> do {<a name="line.58"></a>
+<span class="sourceLineNo">059</span> int sign = i % 2 == 0 ? 1 : -1;<a name="line.59"></a>
+<span class="sourceLineNo">060</span> connectorPort += sign * rand.nextInt(100);<a name="line.60"></a>
+<span class="sourceLineNo">061</span> } while (!HBaseTestingUtility.available(connectorPort));<a name="line.61"></a>
+<span class="sourceLineNo">062</span> try {<a name="line.62"></a>
+<span class="sourceLineNo">063</span> conf.setInt("regionserver.rmi.registry.port", connectorPort);<a name="line.63"></a>
+<span class="sourceLineNo">064</span> cluster = UTIL.startMiniCluster();<a name="line.64"></a>
+<span class="sourceLineNo">065</span> LOG.info("Waiting for active/ready master");<a name="line.65"></a>
+<span class="sourceLineNo">066</span> cluster.waitForActiveAndReadyMaster();<a name="line.66"></a>
+<span class="sourceLineNo">067</span> master = cluster.getMaster();<a name="line.67"></a>
+<span class="sourceLineNo">068</span> break;<a name="line.68"></a>
+<span class="sourceLineNo">069</span> } catch (Exception e) {<a name="line.69"></a>
+<span class="sourceLineNo">070</span> LOG.debug("Encountered exception when starting mini cluster. Trying port " + connectorPort,<a name="line.70"></a>
+<span class="sourceLineNo">071</span> e);<a name="line.71"></a>
+<span class="sourceLineNo">072</span> try {<a name="line.72"></a>
+<span class="sourceLineNo">073</span> // this is to avoid "IllegalStateException: A mini-cluster is already running"<a name="line.73"></a>
+<span class="sourceLineNo">074</span> UTIL.shutdownMiniCluster();<a name="line.74"></a>
+<span class="sourceLineNo">075</span> } catch (Exception ex) {<a name="line.75"></a>
+<span class="sourceLineNo">076</span> LOG.debug("Encountered exception shutting down cluster", ex);<a name="line.76"></a>
+<span class="sourceLineNo">077</span> }<a name="line.77"></a>
+<span class="sourceLineNo">078</span> }<a name="line.78"></a>
+<span class="sourceLineNo">079</span> }<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> @AfterClass<a name="line.82"></a>
+<span class="sourceLineNo">083</span> public static void tearDownAfterClass() throws Exception {<a name="line.83"></a>
+<span class="sourceLineNo">084</span> UTIL.shutdownMiniCluster();<a name="line.84"></a>
+<span class="sourceLineNo">085</span> }<a name="line.85"></a>
+<span class="sourceLineNo">086</span><a name="line.86"></a>
+<span class="sourceLineNo">087</span> /**<a name="line.87"></a>
+<span class="sourceLineNo">088</span> * Tests the status change using the Default Metrics System<a name="line.88"></a>
+<span class="sourceLineNo">089</span> */<a name="line.89"></a>
+<span class="sourceLineNo">090</span> @Test<a name="line.90"></a>
+<span class="sourceLineNo">091</span> public void testJmxMetrics() throws Exception {<a name="line.91"></a>
+<span class="sourceLineNo">092</span><a name="line.92"></a>
+<span class="sourceLineNo">093</span> assertEquals(getStatus(), "true");<a name="line.93"></a>
+<span class="sourceLineNo">094</span> master.getLoadBalancer().updateBalancerStatus(false);<a name="line.94"></a>
+<span class="sourceLineNo">095</span> assertEquals(getStatus(), "false");<a name="line.95"></a>
+<span class="sourceLineNo">096</span><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> * Gets the balancer status tag from the Metrics registry<a name="line.100"></a>
+<span class="sourceLineNo">101</span> */<a name="line.101"></a>
+<span class="sourceLineNo">102</span> public String getStatus() throws Exception {<a name="line.102"></a>
+<span class="sourceLineNo">103</span> MetricsSource source =<a name="line.103"></a>
+<span class="sourceLineNo">104</span> DefaultMetricsSystem.instance().getSource(MetricsBalancerSource.METRICS_JMX_CONTEXT);<a name="line.104"></a>
+<span class="sourceLineNo">105</span> if (source instanceof MetricsBalancerSourceImpl) {<a name="line.105"></a>
+<span class="sourceLineNo">106</span> MetricsTag status = ((MetricsBalancerSourceImpl) source).getMetricsRegistry()<a name="line.106"></a>
+<span class="sourceLineNo">107</span> .getTag(MetricsBalancerSource.BALANCER_STATUS);<a name="line.107"></a>
+<span class="sourceLineNo">108</span> return status.value();<a name="line.108"></a>
+<span class="sourceLineNo">109</span> } else {<a name="line.109"></a>
+<span class="sourceLineNo">110</span> LOG.warn("Balancer JMX Metrics not registered");<a name="line.110"></a>
+<span class="sourceLineNo">111</span> throw new Exception("MetricsBalancer JMX Context not found");<a name="line.111"></a>
+<span class="sourceLineNo">112</span> }<a name="line.112"></a>
+<span class="sourceLineNo">113</span> }<a name="line.113"></a>
+<span class="sourceLineNo">114</span><a name="line.114"></a>
+<span class="sourceLineNo">115</span>}<a name="line.115"></a>
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+</pre>
+</div>
+</body>
+</html>
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/83fd16f2/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHeapMemoryManager.BlockCacheStub.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHeapMemoryManager.BlockCacheStub.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHeapMemoryManager.BlockCacheStub.html
index 9ce16ac..5aaf744 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHeapMemoryManager.BlockCacheStub.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/regionserver/TestHeapMemoryManager.BlockCacheStub.html
@@ -766,174 +766,175 @@
<span class="sourceLineNo">758</span> }<a name="line.758"></a>
<span class="sourceLineNo">759</span><a name="line.759"></a>
<span class="sourceLineNo">760</span> @Override<a name="line.760"></a>
-<span class="sourceLineNo">761</span> public void requestFlush(HRegion region, boolean forceFlushAllStores,<a name="line.761"></a>
+<span class="sourceLineNo">761</span> public boolean requestFlush(HRegion region, boolean forceFlushAllStores,<a name="line.761"></a>
<span class="sourceLineNo">762</span> FlushLifeCycleTracker tracker) {<a name="line.762"></a>
<span class="sourceLineNo">763</span> this.listener.flushRequested(flushType, region);<a name="line.763"></a>
-<span class="sourceLineNo">764</span> }<a name="line.764"></a>
-<span class="sourceLineNo">765</span><a name="line.765"></a>
-<span class="sourceLineNo">766</span> @Override<a name="line.766"></a>
-<span class="sourceLineNo">767</span> public void requestDelayedFlush(HRegion region, long delay, boolean forceFlushAllStores) {<a name="line.767"></a>
-<span class="sourceLineNo">768</span><a name="line.768"></a>
-<span class="sourceLineNo">769</span> }<a name="line.769"></a>
-<span class="sourceLineNo">770</span><a name="line.770"></a>
-<span class="sourceLineNo">771</span> @Override<a name="line.771"></a>
-<span class="sourceLineNo">772</span> public void registerFlushRequestListener(FlushRequestListener listener) {<a name="line.772"></a>
-<span class="sourceLineNo">773</span> this.listener = listener;<a name="line.773"></a>
-<span class="sourceLineNo">774</span> }<a name="line.774"></a>
-<span class="sourceLineNo">775</span><a name="line.775"></a>
-<span class="sourceLineNo">776</span> @Override<a name="line.776"></a>
-<span class="sourceLineNo">777</span> public boolean unregisterFlushRequestListener(FlushRequestListener listener) {<a name="line.777"></a>
-<span class="sourceLineNo">778</span> return false;<a name="line.778"></a>
-<span class="sourceLineNo">779</span> }<a name="line.779"></a>
-<span class="sourceLineNo">780</span><a name="line.780"></a>
-<span class="sourceLineNo">781</span> @Override<a name="line.781"></a>
-<span class="sourceLineNo">782</span> public void setGlobalMemStoreLimit(long globalMemStoreSize) {<a name="line.782"></a>
-<span class="sourceLineNo">783</span> this.memstoreSize = globalMemStoreSize;<a name="line.783"></a>
-<span class="sourceLineNo">784</span> }<a name="line.784"></a>
-<span class="sourceLineNo">785</span> }<a name="line.785"></a>
-<span class="sourceLineNo">786</span><a name="line.786"></a>
-<span class="sourceLineNo">787</span> private static class RegionServerStub implements Server {<a name="line.787"></a>
-<span class="sourceLineNo">788</span> private Configuration conf;<a name="line.788"></a>
-<span class="sourceLineNo">789</span> private boolean stopped = false;<a name="line.789"></a>
-<span class="sourceLineNo">790</span><a name="line.790"></a>
-<span class="sourceLineNo">791</span> public RegionServerStub(Configuration conf) {<a name="line.791"></a>
-<span class="sourceLineNo">792</span> this.conf = conf;<a name="line.792"></a>
-<span class="sourceLineNo">793</span> }<a name="line.793"></a>
-<span class="sourceLineNo">794</span><a name="line.794"></a>
-<span class="sourceLineNo">795</span> @Override<a name="line.795"></a>
-<span class="sourceLineNo">796</span> public void abort(String why, Throwable e) {<a name="line.796"></a>
-<span class="sourceLineNo">797</span><a name="line.797"></a>
-<span class="sourceLineNo">798</span> }<a name="line.798"></a>
-<span class="sourceLineNo">799</span><a name="line.799"></a>
-<span class="sourceLineNo">800</span> @Override<a name="line.800"></a>
-<span class="sourceLineNo">801</span> public boolean isAborted() {<a name="line.801"></a>
-<span class="sourceLineNo">802</span> return false;<a name="line.802"></a>
-<span class="sourceLineNo">803</span> }<a name="line.803"></a>
-<span class="sourceLineNo">804</span><a name="line.804"></a>
-<span class="sourceLineNo">805</span> @Override<a name="line.805"></a>
-<span class="sourceLineNo">806</span> public void stop(String why) {<a name="line.806"></a>
-<span class="sourceLineNo">807</span> this.stopped = true;<a name="line.807"></a>
-<span class="sourceLineNo">808</span> }<a name="line.808"></a>
-<span class="sourceLineNo">809</span><a name="line.809"></a>
-<span class="sourceLineNo">810</span> @Override<a name="line.810"></a>
-<span class="sourceLineNo">811</span> public boolean isStopped() {<a name="line.811"></a>
-<span class="sourceLineNo">812</span> return this.stopped;<a name="line.812"></a>
-<span class="sourceLineNo">813</span> }<a name="line.813"></a>
-<span class="sourceLineNo">814</span><a name="line.814"></a>
-<span class="sourceLineNo">815</span> @Override<a name="line.815"></a>
-<span class="sourceLineNo">816</span> public Configuration getConfiguration() {<a name="line.816"></a>
-<span class="sourceLineNo">817</span> return this.conf;<a name="line.817"></a>
-<span class="sourceLineNo">818</span> }<a name="line.818"></a>
-<span class="sourceLineNo">819</span><a name="line.819"></a>
-<span class="sourceLineNo">820</span> @Override<a name="line.820"></a>
-<span class="sourceLineNo">821</span> public ZKWatcher getZooKeeper() {<a name="line.821"></a>
-<span class="sourceLineNo">822</span> return null;<a name="line.822"></a>
-<span class="sourceLineNo">823</span> }<a name="line.823"></a>
-<span class="sourceLineNo">824</span><a name="line.824"></a>
-<span class="sourceLineNo">825</span> @Override<a name="line.825"></a>
-<span class="sourceLineNo">826</span> public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.826"></a>
-<span class="sourceLineNo">827</span> return null;<a name="line.827"></a>
-<span class="sourceLineNo">828</span> }<a name="line.828"></a>
-<span class="sourceLineNo">829</span><a name="line.829"></a>
-<span class="sourceLineNo">830</span> @Override<a name="line.830"></a>
-<span class="sourceLineNo">831</span> public ClusterConnection getConnection() {<a name="line.831"></a>
-<span class="sourceLineNo">832</span> return null;<a name="line.832"></a>
-<span class="sourceLineNo">833</span> }<a name="line.833"></a>
-<span class="sourceLineNo">834</span><a name="line.834"></a>
-<span class="sourceLineNo">835</span> @Override<a name="line.835"></a>
-<span class="sourceLineNo">836</span> public MetaTableLocator getMetaTableLocator() {<a name="line.836"></a>
-<span class="sourceLineNo">837</span> return null;<a name="line.837"></a>
-<span class="sourceLineNo">838</span> }<a name="line.838"></a>
-<span class="sourceLineNo">839</span><a name="line.839"></a>
-<span class="sourceLineNo">840</span> @Override<a name="line.840"></a>
-<span class="sourceLineNo">841</span> public ServerName getServerName() {<a name="line.841"></a>
-<span class="sourceLineNo">842</span> return ServerName.valueOf("server1",4000,12345);<a name="line.842"></a>
-<span class="sourceLineNo">843</span> }<a name="line.843"></a>
-<span class="sourceLineNo">844</span><a name="line.844"></a>
-<span class="sourceLineNo">845</span> @Override<a name="line.845"></a>
-<span class="sourceLineNo">846</span> public ChoreService getChoreService() {<a name="line.846"></a>
-<span class="sourceLineNo">847</span> return null;<a name="line.847"></a>
-<span class="sourceLineNo">848</span> }<a name="line.848"></a>
-<span class="sourceLineNo">849</span><a name="line.849"></a>
-<span class="sourceLineNo">850</span> @Override<a name="line.850"></a>
-<span class="sourceLineNo">851</span> public ClusterConnection getClusterConnection() {<a name="line.851"></a>
-<span class="sourceLineNo">852</span> // TODO Auto-generated method stub<a name="line.852"></a>
-<span class="sourceLineNo">853</span> return null;<a name="line.853"></a>
-<span class="sourceLineNo">854</span> }<a name="line.854"></a>
-<span class="sourceLineNo">855</span><a name="line.855"></a>
-<span class="sourceLineNo">856</span> @Override<a name="line.856"></a>
-<span class="sourceLineNo">857</span> public FileSystem getFileSystem() {<a name="line.857"></a>
-<span class="sourceLineNo">858</span> return null;<a name="line.858"></a>
-<span class="sourceLineNo">859</span> }<a name="line.859"></a>
-<span class="sourceLineNo">860</span><a name="line.860"></a>
-<span class="sourceLineNo">861</span> @Override<a name="line.861"></a>
-<span class="sourceLineNo">862</span> public boolean isStopping() {<a name="line.862"></a>
-<span class="sourceLineNo">863</span> return false;<a name="line.863"></a>
-<span class="sourceLineNo">864</span> }<a name="line.864"></a>
-<span class="sourceLineNo">865</span><a name="line.865"></a>
-<span class="sourceLineNo">866</span> @Override<a name="line.866"></a>
-<span class="sourceLineNo">867</span> public Connection createConnection(Configuration conf) throws IOException {<a name="line.867"></a>
-<span class="sourceLineNo">868</span> return null;<a name="line.868"></a>
-<span class="sourceLineNo">869</span> }<a name="line.869"></a>
-<span class="sourceLineNo">870</span> }<a name="line.870"></a>
-<span class="sourceLineNo">871</span><a name="line.871"></a>
-<span class="sourceLineNo">872</span> static class CustomHeapMemoryTuner implements HeapMemoryTuner {<a name="line.872"></a>
-<span class="sourceLineNo">873</span> static float blockCacheSize = 0.4f;<a name="line.873"></a>
-<span class="sourceLineNo">874</span> static float memstoreSize = 0.4f;<a name="line.874"></a>
-<span class="sourceLineNo">875</span><a name="line.875"></a>
-<span class="sourceLineNo">876</span> @Override<a name="line.876"></a>
-<span class="sourceLineNo">877</span> public Configuration getConf() {<a name="line.877"></a>
-<span class="sourceLineNo">878</span> return null;<a name="line.878"></a>
-<span class="sourceLineNo">879</span> }<a name="line.879"></a>
-<span class="sourceLineNo">880</span><a name="line.880"></a>
-<span class="sourceLineNo">881</span> @Override<a name="line.881"></a>
-<span class="sourceLineNo">882</span> public void setConf(Configuration arg0) {<a name="line.882"></a>
-<span class="sourceLineNo">883</span><a name="line.883"></a>
-<span class="sourceLineNo">884</span> }<a name="line.884"></a>
-<span class="sourceLineNo">885</span><a name="line.885"></a>
-<span class="sourceLineNo">886</span> @Override<a name="line.886"></a>
-<span class="sourceLineNo">887</span> public TunerResult tune(TunerContext context) {<a name="line.887"></a>
-<span class="sourceLineNo">888</span> TunerResult result = new TunerResult(true);<a name="line.888"></a>
-<span class="sourceLineNo">889</span> result.setBlockCacheSize(blockCacheSize);<a name="line.889"></a>
-<span class="sourceLineNo">890</span> result.setMemStoreSize(memstoreSize);<a name="line.890"></a>
-<span class="sourceLineNo">891</span> return result;<a name="line.891"></a>
-<span class="sourceLineNo">892</span> }<a name="line.892"></a>
-<span class="sourceLineNo">893</span> }<a name="line.893"></a>
-<span class="sourceLineNo">894</span><a name="line.894"></a>
-<span class="sourceLineNo">895</span> private static class RegionServerAccountingStub extends RegionServerAccounting {<a name="line.895"></a>
-<span class="sourceLineNo">896</span> boolean offheap;<a name="line.896"></a>
-<span class="sourceLineNo">897</span><a name="line.897"></a>
-<span class="sourceLineNo">898</span> public RegionServerAccountingStub(Configuration conf) {<a name="line.898"></a>
-<span class="sourceLineNo">899</span> super(conf);<a name="line.899"></a>
-<span class="sourceLineNo">900</span> }<a name="line.900"></a>
-<span class="sourceLineNo">901</span><a name="line.901"></a>
-<span class="sourceLineNo">902</span> public RegionServerAccountingStub(Configuration conf, boolean offheap) {<a name="line.902"></a>
-<span class="sourceLineNo">903</span> super(conf);<a name="line.903"></a>
-<span class="sourceLineNo">904</span> this.offheap = offheap;<a name="line.904"></a>
-<span class="sourceLineNo">905</span> }<a name="line.905"></a>
-<span class="sourceLineNo">906</span><a name="line.906"></a>
-<span class="sourceLineNo">907</span> private long testMemstoreSize = 0;<a name="line.907"></a>
-<span class="sourceLineNo">908</span><a name="line.908"></a>
-<span class="sourceLineNo">909</span> @Override<a name="line.909"></a>
-<span class="sourceLineNo">910</span> public long getGlobalMemStoreDataSize() {<a name="line.910"></a>
-<span class="sourceLineNo">911</span> return testMemstoreSize;<a name="line.911"></a>
-<span class="sourceLineNo">912</span> }<a name="line.912"></a>
-<span class="sourceLineNo">913</span><a name="line.913"></a>
-<span class="sourceLineNo">914</span> @Override<a name="line.914"></a>
-<span class="sourceLineNo">915</span> public long getGlobalMemStoreHeapSize() {<a name="line.915"></a>
-<span class="sourceLineNo">916</span> return testMemstoreSize;<a name="line.916"></a>
-<span class="sourceLineNo">917</span> }<a name="line.917"></a>
-<span class="sourceLineNo">918</span><a name="line.918"></a>
-<span class="sourceLineNo">919</span> @Override<a name="line.919"></a>
-<span class="sourceLineNo">920</span> public boolean isOffheap() {<a name="line.920"></a>
-<span class="sourceLineNo">921</span> return offheap;<a name="line.921"></a>
-<span class="sourceLineNo">922</span> }<a name="line.922"></a>
-<span class="sourceLineNo">923</span><a name="line.923"></a>
-<span class="sourceLineNo">924</span> public void setTestMemstoreSize(long testMemstoreSize) {<a name="line.924"></a>
-<span class="sourceLineNo">925</span> this.testMemstoreSize = testMemstoreSize;<a name="line.925"></a>
-<span class="sourceLineNo">926</span> }<a name="line.926"></a>
-<span class="sourceLineNo">927</span> }<a name="line.927"></a>
-<span class="sourceLineNo">928</span>}<a name="line.928"></a>
+<span class="sourceLineNo">764</span> return true;<a name="line.764"></a>
+<span class="sourceLineNo">765</span> }<a name="line.765"></a>
+<span class="sourceLineNo">766</span><a name="line.766"></a>
+<span class="sourceLineNo">767</span> @Override<a name="line.767"></a>
+<span class="sourceLineNo">768</span> public boolean requestDelayedFlush(HRegion region, long delay, boolean forceFlushAllStores) {<a name="line.768"></a>
+<span class="sourceLineNo">769</span> return true;<a name="line.769"></a>
+<span class="sourceLineNo">770</span> }<a name="line.770"></a>
+<span class="sourceLineNo">771</span><a name="line.771"></a>
+<span class="sourceLineNo">772</span> @Override<a name="line.772"></a>
+<span class="sourceLineNo">773</span> public void registerFlushRequestListener(FlushRequestListener listener) {<a name="line.773"></a>
+<span class="sourceLineNo">774</span> this.listener = listener;<a name="line.774"></a>
+<span class="sourceLineNo">775</span> }<a name="line.775"></a>
+<span class="sourceLineNo">776</span><a name="line.776"></a>
+<span class="sourceLineNo">777</span> @Override<a name="line.777"></a>
+<span class="sourceLineNo">778</span> public boolean unregisterFlushRequestListener(FlushRequestListener listener) {<a name="line.778"></a>
+<span class="sourceLineNo">779</span> return false;<a name="line.779"></a>
+<span class="sourceLineNo">780</span> }<a name="line.780"></a>
+<span class="sourceLineNo">781</span><a name="line.781"></a>
+<span class="sourceLineNo">782</span> @Override<a name="line.782"></a>
+<span class="sourceLineNo">783</span> public void setGlobalMemStoreLimit(long globalMemStoreSize) {<a name="line.783"></a>
+<span class="sourceLineNo">784</span> this.memstoreSize = globalMemStoreSize;<a name="line.784"></a>
+<span class="sourceLineNo">785</span> }<a name="line.785"></a>
+<span class="sourceLineNo">786</span> }<a name="line.786"></a>
+<span class="sourceLineNo">787</span><a name="line.787"></a>
+<span class="sourceLineNo">788</span> private static class RegionServerStub implements Server {<a name="line.788"></a>
+<span class="sourceLineNo">789</span> private Configuration conf;<a name="line.789"></a>
+<span class="sourceLineNo">790</span> private boolean stopped = false;<a name="line.790"></a>
+<span class="sourceLineNo">791</span><a name="line.791"></a>
+<span class="sourceLineNo">792</span> public RegionServerStub(Configuration conf) {<a name="line.792"></a>
+<span class="sourceLineNo">793</span> this.conf = conf;<a name="line.793"></a>
+<span class="sourceLineNo">794</span> }<a name="line.794"></a>
+<span class="sourceLineNo">795</span><a name="line.795"></a>
+<span class="sourceLineNo">796</span> @Override<a name="line.796"></a>
+<span class="sourceLineNo">797</span> public void abort(String why, Throwable e) {<a name="line.797"></a>
+<span class="sourceLineNo">798</span><a name="line.798"></a>
+<span class="sourceLineNo">799</span> }<a name="line.799"></a>
+<span class="sourceLineNo">800</span><a name="line.800"></a>
+<span class="sourceLineNo">801</span> @Override<a name="line.801"></a>
+<span class="sourceLineNo">802</span> public boolean isAborted() {<a name="line.802"></a>
+<span class="sourceLineNo">803</span> return false;<a name="line.803"></a>
+<span class="sourceLineNo">804</span> }<a name="line.804"></a>
+<span class="sourceLineNo">805</span><a name="line.805"></a>
+<span class="sourceLineNo">806</span> @Override<a name="line.806"></a>
+<span class="sourceLineNo">807</span> public void stop(String why) {<a name="line.807"></a>
+<span class="sourceLineNo">808</span> this.stopped = true;<a name="line.808"></a>
+<span class="sourceLineNo">809</span> }<a name="line.809"></a>
+<span class="sourceLineNo">810</span><a name="line.810"></a>
+<span class="sourceLineNo">811</span> @Override<a name="line.811"></a>
+<span class="sourceLineNo">812</span> public boolean isStopped() {<a name="line.812"></a>
+<span class="sourceLineNo">813</span> return this.stopped;<a name="line.813"></a>
+<span class="sourceLineNo">814</span> }<a name="line.814"></a>
+<span class="sourceLineNo">815</span><a name="line.815"></a>
+<span class="sourceLineNo">816</span> @Override<a name="line.816"></a>
+<span class="sourceLineNo">817</span> public Configuration getConfiguration() {<a name="line.817"></a>
+<span class="sourceLineNo">818</span> return this.conf;<a name="line.818"></a>
+<span class="sourceLineNo">819</span> }<a name="line.819"></a>
+<span class="sourceLineNo">820</span><a name="line.820"></a>
+<span class="sourceLineNo">821</span> @Override<a name="line.821"></a>
+<span class="sourceLineNo">822</span> public ZKWatcher getZooKeeper() {<a name="line.822"></a>
+<span class="sourceLineNo">823</span> return null;<a name="line.823"></a>
+<span class="sourceLineNo">824</span> }<a name="line.824"></a>
+<span class="sourceLineNo">825</span><a name="line.825"></a>
+<span class="sourceLineNo">826</span> @Override<a name="line.826"></a>
+<span class="sourceLineNo">827</span> public CoordinatedStateManager getCoordinatedStateManager() {<a name="line.827"></a>
+<span class="sourceLineNo">828</span> return null;<a name="line.828"></a>
+<span class="sourceLineNo">829</span> }<a name="line.829"></a>
+<span class="sourceLineNo">830</span><a name="line.830"></a>
+<span class="sourceLineNo">831</span> @Override<a name="line.831"></a>
+<span class="sourceLineNo">832</span> public ClusterConnection getConnection() {<a name="line.832"></a>
+<span class="sourceLineNo">833</span> return null;<a name="line.833"></a>
+<span class="sourceLineNo">834</span> }<a name="line.834"></a>
+<span class="sourceLineNo">835</span><a name="line.835"></a>
+<span class="sourceLineNo">836</span> @Override<a name="line.836"></a>
+<span class="sourceLineNo">837</span> public MetaTableLocator getMetaTableLocator() {<a name="line.837"></a>
+<span class="sourceLineNo">838</span> return null;<a name="line.838"></a>
+<span class="sourceLineNo">839</span> }<a name="line.839"></a>
+<span class="sourceLineNo">840</span><a name="line.840"></a>
+<span class="sourceLineNo">841</span> @Override<a name="line.841"></a>
+<span class="sourceLineNo">842</span> public ServerName getServerName() {<a name="line.842"></a>
+<span class="sourceLineNo">843</span> return ServerName.valueOf("server1",4000,12345);<a name="line.843"></a>
+<span class="sourceLineNo">844</span> }<a name="line.844"></a>
+<span class="sourceLineNo">845</span><a name="line.845"></a>
+<span class="sourceLineNo">846</span> @Override<a name="line.846"></a>
+<span class="sourceLineNo">847</span> public ChoreService getChoreService() {<a name="line.847"></a>
+<span class="sourceLineNo">848</span> return null;<a name="line.848"></a>
+<span class="sourceLineNo">849</span> }<a name="line.849"></a>
+<span class="sourceLineNo">850</span><a name="line.850"></a>
+<span class="sourceLineNo">851</span> @Override<a name="line.851"></a>
+<span class="sourceLineNo">852</span> public ClusterConnection getClusterConnection() {<a name="line.852"></a>
+<span class="sourceLineNo">853</span> // TODO Auto-generated method stub<a name="line.853"></a>
+<span class="sourceLineNo">854</span> return null;<a name="line.854"></a>
+<span class="sourceLineNo">855</span> }<a name="line.855"></a>
+<span class="sourceLineNo">856</span><a name="line.856"></a>
+<span class="sourceLineNo">857</span> @Override<a name="line.857"></a>
+<span class="sourceLineNo">858</span> public FileSystem getFileSystem() {<a name="line.858"></a>
+<span class="sourceLineNo">859</span> return null;<a name="line.859"></a>
+<span class="sourceLineNo">860</span> }<a name="line.860"></a>
+<span class="sourceLineNo">861</span><a name="line.861"></a>
+<span class="sourceLineNo">862</span> @Override<a name="line.862"></a>
+<span class="sourceLineNo">863</span> public boolean isStopping() {<a name="line.863"></a>
+<span class="sourceLineNo">864</span> return false;<a name="line.864"></a>
+<span class="sourceLineNo">865</span> }<a name="line.865"></a>
+<span class="sourceLineNo">866</span><a name="line.866"></a>
+<span class="sourceLineNo">867</span> @Override<a name="line.867"></a>
+<span class="sourceLineNo">868</span> public Connection createConnection(Configuration conf) throws IOException {<a name="line.868"></a>
+<span class="sourceLineNo">869</span> return null;<a name="line.869"></a>
+<span class="sourceLineNo">870</span> }<a name="line.870"></a>
+<span class="sourceLineNo">871</span> }<a name="line.871"></a>
+<span class="sourceLineNo">872</span><a name="line.872"></a>
+<span class="sourceLineNo">873</span> static class CustomHeapMemoryTuner implements HeapMemoryTuner {<a name="line.873"></a>
+<span class="sourceLineNo">874</span> static float blockCacheSize = 0.4f;<a name="line.874"></a>
+<span class="sourceLineNo">875</span> static float memstoreSize = 0.4f;<a name="line.875"></a>
+<span class="sourceLineNo">876</span><a name="line.876"></a>
+<span class="sourceLineNo">877</span> @Override<a name="line.877"></a>
+<span class="sourceLineNo">878</span> public Configuration getConf() {<a name="line.878"></a>
+<span class="sourceLineNo">879</span> return null;<a name="line.879"></a>
+<span class="sourceLineNo">880</span> }<a name="line.880"></a>
+<span class="sourceLineNo">881</span><a name="line.881"></a>
+<span class="sourceLineNo">882</span> @Override<a name="line.882"></a>
+<span class="sourceLineNo">883</span> public void setConf(Configuration arg0) {<a name="line.883"></a>
+<span class="sourceLineNo">884</span><a name="line.884"></a>
+<span class="sourceLineNo">885</span> }<a name="line.885"></a>
+<span class="sourceLineNo">886</span><a name="line.886"></a>
+<span class="sourceLineNo">887</span> @Override<a name="line.887"></a>
+<span class="sourceLineNo">888</span> public TunerResult tune(TunerContext context) {<a name="line.888"></a>
+<span class="sourceLineNo">889</span> TunerResult result = new TunerResult(true);<a name="line.889"></a>
+<span class="sourceLineNo">890</span> result.setBlockCacheSize(blockCacheSize);<a name="line.890"></a>
+<span class="sourceLineNo">891</span> result.setMemStoreSize(memstoreSize);<a name="line.891"></a>
+<span class="sourceLineNo">892</span> return result;<a name="line.892"></a>
+<span class="sourceLineNo">893</span> }<a name="line.893"></a>
+<span class="sourceLineNo">894</span> }<a name="line.894"></a>
+<span class="sourceLineNo">895</span><a name="line.895"></a>
+<span class="sourceLineNo">896</span> private static class RegionServerAccountingStub extends RegionServerAccounting {<a name="line.896"></a>
+<span class="sourceLineNo">897</span> boolean offheap;<a name="line.897"></a>
+<span class="sourceLineNo">898</span><a name="line.898"></a>
+<span class="sourceLineNo">899</span> public RegionServerAccountingStub(Configuration conf) {<a name="line.899"></a>
+<span class="sourceLineNo">900</span> super(conf);<a name="line.900"></a>
+<span class="sourceLineNo">901</span> }<a name="line.901"></a>
+<span class="sourceLineNo">902</span><a name="line.902"></a>
+<span class="sourceLineNo">903</span> public RegionServerAccountingStub(Configuration conf, boolean offheap) {<a name="line.903"></a>
+<span class="sourceLineNo">904</span> super(conf);<a name="line.904"></a>
+<span class="sourceLineNo">905</span> this.offheap = offheap;<a name="line.905"></a>
+<span class="sourceLineNo">906</span> }<a name="line.906"></a>
+<span class="sourceLineNo">907</span><a name="line.907"></a>
+<span class="sourceLineNo">908</span> private long testMemstoreSize = 0;<a name="line.908"></a>
+<span class="sourceLineNo">909</span><a name="line.909"></a>
+<span class="sourceLineNo">910</span> @Override<a name="line.910"></a>
+<span class="sourceLineNo">911</span> public long getGlobalMemStoreDataSize() {<a name="line.911"></a>
+<span class="sourceLineNo">912</span> return testMemstoreSize;<a name="line.912"></a>
+<span class="sourceLineNo">913</span> }<a name="line.913"></a>
+<span class="sourceLineNo">914</span><a name="line.914"></a>
+<span class="sourceLineNo">915</span> @Override<a name="line.915"></a>
+<span class="sourceLineNo">916</span> public long getGlobalMemStoreHeapSize() {<a name="line.916"></a>
+<span class="sourceLineNo">917</span> return testMemstoreSize;<a name="line.917"></a>
+<span class="sourceLineNo">918</span> }<a name="line.918"></a>
+<span class="sourceLineNo">919</span><a name="line.919"></a>
+<span class="sourceLineNo">920</span> @Override<a name="line.920"></a>
+<span class="sourceLineNo">921</span> public boolean isOffheap() {<a name="line.921"></a>
+<span class="sourceLineNo">922</span> return offheap;<a name="line.922"></a>
+<span class="sourceLineNo">923</span> }<a name="line.923"></a>
+<span class="sourceLineNo">924</span><a name="line.924"></a>
+<span class="sourceLineNo">925</span> public void setTestMemstoreSize(long testMemstoreSize) {<a name="line.925"></a>
+<span class="sourceLineNo">926</span> this.testMemstoreSize = testMemstoreSize;<a name="line.926"></a>
+<span class="sourceLineNo">927</span> }<a name="line.927"></a>
+<span class="sourceLineNo">928</span> }<a name="line.928"></a>
+<span class="sourceLineNo">929</span>}<a name="line.929"></a>