http://git-wip-us.apache.org/repos/asf/hbase-site/blob/f2065178/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.RandomWriteTest.html
----------------------------------------------------------------------
diff --git 
a/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.RandomWriteTest.html
 
b/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.RandomWriteTest.html
index 2510283..418c60c 100644
--- 
a/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.RandomWriteTest.html
+++ 
b/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.RandomWriteTest.html
@@ -77,77 +77,77 @@
 <span class="sourceLineNo">069</span>import 
org.apache.hadoop.hbase.client.RowMutations;<a name="line.69"></a>
 <span class="sourceLineNo">070</span>import 
org.apache.hadoop.hbase.client.Scan;<a name="line.70"></a>
 <span class="sourceLineNo">071</span>import 
org.apache.hadoop.hbase.client.Table;<a name="line.71"></a>
-<span class="sourceLineNo">072</span>import 
org.apache.hadoop.hbase.filter.BinaryComparator;<a name="line.72"></a>
-<span class="sourceLineNo">073</span>import 
org.apache.hadoop.hbase.filter.Filter;<a name="line.73"></a>
-<span class="sourceLineNo">074</span>import 
org.apache.hadoop.hbase.filter.FilterAllFilter;<a name="line.74"></a>
-<span class="sourceLineNo">075</span>import 
org.apache.hadoop.hbase.filter.FilterList;<a name="line.75"></a>
-<span class="sourceLineNo">076</span>import 
org.apache.hadoop.hbase.filter.PageFilter;<a name="line.76"></a>
-<span class="sourceLineNo">077</span>import 
org.apache.hadoop.hbase.filter.SingleColumnValueFilter;<a name="line.77"></a>
-<span class="sourceLineNo">078</span>import 
org.apache.hadoop.hbase.filter.WhileMatchFilter;<a name="line.78"></a>
-<span class="sourceLineNo">079</span>import 
org.apache.hadoop.hbase.io.compress.Compression;<a name="line.79"></a>
-<span class="sourceLineNo">080</span>import 
org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;<a name="line.80"></a>
-<span class="sourceLineNo">081</span>import 
org.apache.hadoop.hbase.io.hfile.RandomDistribution;<a name="line.81"></a>
-<span class="sourceLineNo">082</span>import 
org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;<a name="line.82"></a>
-<span class="sourceLineNo">083</span>import 
org.apache.hadoop.hbase.regionserver.BloomType;<a name="line.83"></a>
-<span class="sourceLineNo">084</span>import 
org.apache.hadoop.hbase.regionserver.CompactingMemStore;<a name="line.84"></a>
-<span class="sourceLineNo">085</span>import 
org.apache.hadoop.hbase.trace.HBaseHTraceConfiguration;<a name="line.85"></a>
-<span class="sourceLineNo">086</span>import 
org.apache.hadoop.hbase.trace.SpanReceiverHost;<a name="line.86"></a>
-<span class="sourceLineNo">087</span>import 
org.apache.hadoop.hbase.trace.TraceUtil;<a name="line.87"></a>
-<span class="sourceLineNo">088</span>import 
org.apache.hadoop.hbase.util.ByteArrayHashKey;<a name="line.88"></a>
-<span class="sourceLineNo">089</span>import 
org.apache.hadoop.hbase.util.Bytes;<a name="line.89"></a>
-<span class="sourceLineNo">090</span>import 
org.apache.hadoop.hbase.util.Hash;<a name="line.90"></a>
-<span class="sourceLineNo">091</span>import 
org.apache.hadoop.hbase.util.MurmurHash;<a name="line.91"></a>
-<span class="sourceLineNo">092</span>import 
org.apache.hadoop.hbase.util.Pair;<a name="line.92"></a>
-<span class="sourceLineNo">093</span>import 
org.apache.hadoop.hbase.util.YammerHistogramUtils;<a name="line.93"></a>
-<span class="sourceLineNo">094</span>import 
org.apache.hadoop.io.LongWritable;<a name="line.94"></a>
-<span class="sourceLineNo">095</span>import org.apache.hadoop.io.Text;<a 
name="line.95"></a>
-<span class="sourceLineNo">096</span>import org.apache.hadoop.mapreduce.Job;<a 
name="line.96"></a>
-<span class="sourceLineNo">097</span>import 
org.apache.hadoop.mapreduce.Mapper;<a name="line.97"></a>
-<span class="sourceLineNo">098</span>import 
org.apache.hadoop.mapreduce.lib.input.NLineInputFormat;<a name="line.98"></a>
-<span class="sourceLineNo">099</span>import 
org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;<a name="line.99"></a>
-<span class="sourceLineNo">100</span>import 
org.apache.hadoop.mapreduce.lib.reduce.LongSumReducer;<a name="line.100"></a>
-<span class="sourceLineNo">101</span>import org.apache.hadoop.util.Tool;<a 
name="line.101"></a>
-<span class="sourceLineNo">102</span>import 
org.apache.hadoop.util.ToolRunner;<a name="line.102"></a>
-<span class="sourceLineNo">103</span>import 
org.apache.htrace.core.ProbabilitySampler;<a name="line.103"></a>
-<span class="sourceLineNo">104</span>import org.apache.htrace.core.Sampler;<a 
name="line.104"></a>
-<span class="sourceLineNo">105</span>import 
org.apache.htrace.core.TraceScope;<a name="line.105"></a>
-<span class="sourceLineNo">106</span>import 
org.apache.yetus.audience.InterfaceAudience;<a name="line.106"></a>
-<span class="sourceLineNo">107</span>import org.slf4j.Logger;<a 
name="line.107"></a>
-<span class="sourceLineNo">108</span>import org.slf4j.LoggerFactory;<a 
name="line.108"></a>
-<span class="sourceLineNo">109</span>import 
org.apache.hbase.thirdparty.com.google.common.base.MoreObjects;<a 
name="line.109"></a>
-<span class="sourceLineNo">110</span>import 
org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFactoryBuilder;<a
 name="line.110"></a>
-<span class="sourceLineNo">111</span><a name="line.111"></a>
-<span class="sourceLineNo">112</span>/**<a name="line.112"></a>
-<span class="sourceLineNo">113</span> * Script used evaluating HBase 
performance and scalability.  Runs a HBase<a name="line.113"></a>
-<span class="sourceLineNo">114</span> * client that steps through one of a set 
of hardcoded tests or 'experiments'<a name="line.114"></a>
-<span class="sourceLineNo">115</span> * (e.g. a random reads test, a random 
writes test, etc.). Pass on the<a name="line.115"></a>
-<span class="sourceLineNo">116</span> * command-line which test to run and how 
many clients are participating in<a name="line.116"></a>
-<span class="sourceLineNo">117</span> * this experiment. Run {@code 
PerformanceEvaluation --help} to obtain usage.<a name="line.117"></a>
-<span class="sourceLineNo">118</span> *<a name="line.118"></a>
-<span class="sourceLineNo">119</span> * &lt;p&gt;This class sets up and runs 
the evaluation programs described in<a name="line.119"></a>
-<span class="sourceLineNo">120</span> * Section 7, &lt;i&gt;Performance 
Evaluation&lt;/i&gt;, of the &lt;a<a name="line.120"></a>
-<span class="sourceLineNo">121</span> * 
href="http://labs.google.com/papers/bigtable.html"&gt;Bigtable&lt;/a&gt;<a 
name="line.121"></a>
-<span class="sourceLineNo">122</span> * paper, pages 8-10.<a 
name="line.122"></a>
-<span class="sourceLineNo">123</span> *<a name="line.123"></a>
-<span class="sourceLineNo">124</span> * &lt;p&gt;By default, runs as a 
mapreduce job where each mapper runs a single test<a name="line.124"></a>
-<span class="sourceLineNo">125</span> * client. Can also run as a 
non-mapreduce, multithreaded application by<a name="line.125"></a>
-<span class="sourceLineNo">126</span> * specifying {@code --nomapred}. Each 
client does about 1GB of data, unless<a name="line.126"></a>
-<span class="sourceLineNo">127</span> * specified otherwise.<a 
name="line.127"></a>
-<span class="sourceLineNo">128</span> */<a name="line.128"></a>
-<span 
class="sourceLineNo">129</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.TOOLS)<a
 name="line.129"></a>
-<span class="sourceLineNo">130</span>public class PerformanceEvaluation 
extends Configured implements Tool {<a name="line.130"></a>
-<span class="sourceLineNo">131</span>  static final String RANDOM_SEEK_SCAN = 
"randomSeekScan";<a name="line.131"></a>
-<span class="sourceLineNo">132</span>  static final String RANDOM_READ = 
"randomRead";<a name="line.132"></a>
-<span class="sourceLineNo">133</span>  private static final Logger LOG = 
LoggerFactory.getLogger(PerformanceEvaluation.class.getName());<a 
name="line.133"></a>
-<span class="sourceLineNo">134</span>  private static final ObjectMapper 
MAPPER = new ObjectMapper();<a name="line.134"></a>
-<span class="sourceLineNo">135</span>  static {<a name="line.135"></a>
-<span class="sourceLineNo">136</span>    
MAPPER.configure(MapperFeature.SORT_PROPERTIES_ALPHABETICALLY, true);<a 
name="line.136"></a>
-<span class="sourceLineNo">137</span>  }<a name="line.137"></a>
-<span class="sourceLineNo">138</span><a name="line.138"></a>
-<span class="sourceLineNo">139</span>  public static final String TABLE_NAME = 
"TestTable";<a name="line.139"></a>
-<span class="sourceLineNo">140</span>  public static final byte[] FAMILY_NAME 
= Bytes.toBytes("info");<a name="line.140"></a>
-<span class="sourceLineNo">141</span>  public static final byte [] COLUMN_ZERO 
= Bytes.toBytes("" + 0);<a name="line.141"></a>
-<span class="sourceLineNo">142</span>  public static final byte [] 
QUALIFIER_NAME = COLUMN_ZERO;<a name="line.142"></a>
+<span class="sourceLineNo">072</span>import 
org.apache.hadoop.hbase.client.metrics.ScanMetrics;<a name="line.72"></a>
+<span class="sourceLineNo">073</span>import 
org.apache.hadoop.hbase.filter.BinaryComparator;<a name="line.73"></a>
+<span class="sourceLineNo">074</span>import 
org.apache.hadoop.hbase.filter.Filter;<a name="line.74"></a>
+<span class="sourceLineNo">075</span>import 
org.apache.hadoop.hbase.filter.FilterAllFilter;<a name="line.75"></a>
+<span class="sourceLineNo">076</span>import 
org.apache.hadoop.hbase.filter.FilterList;<a name="line.76"></a>
+<span class="sourceLineNo">077</span>import 
org.apache.hadoop.hbase.filter.PageFilter;<a name="line.77"></a>
+<span class="sourceLineNo">078</span>import 
org.apache.hadoop.hbase.filter.SingleColumnValueFilter;<a name="line.78"></a>
+<span class="sourceLineNo">079</span>import 
org.apache.hadoop.hbase.filter.WhileMatchFilter;<a name="line.79"></a>
+<span class="sourceLineNo">080</span>import 
org.apache.hadoop.hbase.io.compress.Compression;<a name="line.80"></a>
+<span class="sourceLineNo">081</span>import 
org.apache.hadoop.hbase.io.encoding.DataBlockEncoding;<a name="line.81"></a>
+<span class="sourceLineNo">082</span>import 
org.apache.hadoop.hbase.io.hfile.RandomDistribution;<a name="line.82"></a>
+<span class="sourceLineNo">083</span>import 
org.apache.hadoop.hbase.mapreduce.TableMapReduceUtil;<a name="line.83"></a>
+<span class="sourceLineNo">084</span>import 
org.apache.hadoop.hbase.regionserver.BloomType;<a name="line.84"></a>
+<span class="sourceLineNo">085</span>import 
org.apache.hadoop.hbase.regionserver.CompactingMemStore;<a name="line.85"></a>
+<span class="sourceLineNo">086</span>import 
org.apache.hadoop.hbase.trace.HBaseHTraceConfiguration;<a name="line.86"></a>
+<span class="sourceLineNo">087</span>import 
org.apache.hadoop.hbase.trace.SpanReceiverHost;<a name="line.87"></a>
+<span class="sourceLineNo">088</span>import 
org.apache.hadoop.hbase.trace.TraceUtil;<a name="line.88"></a>
+<span class="sourceLineNo">089</span>import 
org.apache.hadoop.hbase.util.ByteArrayHashKey;<a name="line.89"></a>
+<span class="sourceLineNo">090</span>import 
org.apache.hadoop.hbase.util.Bytes;<a name="line.90"></a>
+<span class="sourceLineNo">091</span>import 
org.apache.hadoop.hbase.util.Hash;<a name="line.91"></a>
+<span class="sourceLineNo">092</span>import 
org.apache.hadoop.hbase.util.MurmurHash;<a name="line.92"></a>
+<span class="sourceLineNo">093</span>import 
org.apache.hadoop.hbase.util.Pair;<a name="line.93"></a>
+<span class="sourceLineNo">094</span>import 
org.apache.hadoop.hbase.util.YammerHistogramUtils;<a name="line.94"></a>
+<span class="sourceLineNo">095</span>import 
org.apache.hadoop.io.LongWritable;<a name="line.95"></a>
+<span class="sourceLineNo">096</span>import org.apache.hadoop.io.Text;<a 
name="line.96"></a>
+<span class="sourceLineNo">097</span>import org.apache.hadoop.mapreduce.Job;<a 
name="line.97"></a>
+<span class="sourceLineNo">098</span>import 
org.apache.hadoop.mapreduce.Mapper;<a name="line.98"></a>
+<span class="sourceLineNo">099</span>import 
org.apache.hadoop.mapreduce.lib.input.NLineInputFormat;<a name="line.99"></a>
+<span class="sourceLineNo">100</span>import 
org.apache.hadoop.mapreduce.lib.output.TextOutputFormat;<a name="line.100"></a>
+<span class="sourceLineNo">101</span>import 
org.apache.hadoop.mapreduce.lib.reduce.LongSumReducer;<a name="line.101"></a>
+<span class="sourceLineNo">102</span>import org.apache.hadoop.util.Tool;<a 
name="line.102"></a>
+<span class="sourceLineNo">103</span>import 
org.apache.hadoop.util.ToolRunner;<a name="line.103"></a>
+<span class="sourceLineNo">104</span>import 
org.apache.htrace.core.ProbabilitySampler;<a name="line.104"></a>
+<span class="sourceLineNo">105</span>import org.apache.htrace.core.Sampler;<a 
name="line.105"></a>
+<span class="sourceLineNo">106</span>import 
org.apache.htrace.core.TraceScope;<a name="line.106"></a>
+<span class="sourceLineNo">107</span>import 
org.apache.yetus.audience.InterfaceAudience;<a name="line.107"></a>
+<span class="sourceLineNo">108</span>import org.slf4j.Logger;<a 
name="line.108"></a>
+<span class="sourceLineNo">109</span>import org.slf4j.LoggerFactory;<a 
name="line.109"></a>
+<span class="sourceLineNo">110</span>import 
org.apache.hbase.thirdparty.com.google.common.base.MoreObjects;<a 
name="line.110"></a>
+<span class="sourceLineNo">111</span>import 
org.apache.hbase.thirdparty.com.google.common.util.concurrent.ThreadFactoryBuilder;<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> * Script used evaluating HBase 
performance and scalability.  Runs a HBase<a name="line.114"></a>
+<span class="sourceLineNo">115</span> * client that steps through one of a set 
of hardcoded tests or 'experiments'<a name="line.115"></a>
+<span class="sourceLineNo">116</span> * (e.g. a random reads test, a random 
writes test, etc.). Pass on the<a name="line.116"></a>
+<span class="sourceLineNo">117</span> * command-line which test to run and how 
many clients are participating in<a name="line.117"></a>
+<span class="sourceLineNo">118</span> * this experiment. Run {@code 
PerformanceEvaluation --help} to obtain usage.<a name="line.118"></a>
+<span class="sourceLineNo">119</span> *<a name="line.119"></a>
+<span class="sourceLineNo">120</span> * &lt;p&gt;This class sets up and runs 
the evaluation programs described in<a name="line.120"></a>
+<span class="sourceLineNo">121</span> * Section 7, &lt;i&gt;Performance 
Evaluation&lt;/i&gt;, of the &lt;a<a name="line.121"></a>
+<span class="sourceLineNo">122</span> * 
href="http://labs.google.com/papers/bigtable.html"&gt;Bigtable&lt;/a&gt;<a 
name="line.122"></a>
+<span class="sourceLineNo">123</span> * paper, pages 8-10.<a 
name="line.123"></a>
+<span class="sourceLineNo">124</span> *<a name="line.124"></a>
+<span class="sourceLineNo">125</span> * &lt;p&gt;By default, runs as a 
mapreduce job where each mapper runs a single test<a name="line.125"></a>
+<span class="sourceLineNo">126</span> * client. Can also run as a 
non-mapreduce, multithreaded application by<a name="line.126"></a>
+<span class="sourceLineNo">127</span> * specifying {@code --nomapred}. Each 
client does about 1GB of data, unless<a name="line.127"></a>
+<span class="sourceLineNo">128</span> * specified otherwise.<a 
name="line.128"></a>
+<span class="sourceLineNo">129</span> */<a name="line.129"></a>
+<span 
class="sourceLineNo">130</span>@InterfaceAudience.LimitedPrivate(HBaseInterfaceAudience.TOOLS)<a
 name="line.130"></a>
+<span class="sourceLineNo">131</span>public class PerformanceEvaluation 
extends Configured implements Tool {<a name="line.131"></a>
+<span class="sourceLineNo">132</span>  static final String RANDOM_SEEK_SCAN = 
"randomSeekScan";<a name="line.132"></a>
+<span class="sourceLineNo">133</span>  static final String RANDOM_READ = 
"randomRead";<a name="line.133"></a>
+<span class="sourceLineNo">134</span>  private static final Logger LOG = 
LoggerFactory.getLogger(PerformanceEvaluation.class.getName());<a 
name="line.134"></a>
+<span class="sourceLineNo">135</span>  private static final ObjectMapper 
MAPPER = new ObjectMapper();<a name="line.135"></a>
+<span class="sourceLineNo">136</span>  static {<a name="line.136"></a>
+<span class="sourceLineNo">137</span>    
MAPPER.configure(MapperFeature.SORT_PROPERTIES_ALPHABETICALLY, true);<a 
name="line.137"></a>
+<span class="sourceLineNo">138</span>  }<a name="line.138"></a>
+<span class="sourceLineNo">139</span><a name="line.139"></a>
+<span class="sourceLineNo">140</span>  public static final String TABLE_NAME = 
"TestTable";<a name="line.140"></a>
+<span class="sourceLineNo">141</span>  public static final byte[] FAMILY_NAME 
= Bytes.toBytes("info");<a name="line.141"></a>
+<span class="sourceLineNo">142</span>  public static final byte [] COLUMN_ZERO 
= Bytes.toBytes("" + 0);<a name="line.142"></a>
 <span class="sourceLineNo">143</span>  public static final int 
DEFAULT_VALUE_LENGTH = 1000;<a name="line.143"></a>
 <span class="sourceLineNo">144</span>  public static final int ROW_LENGTH = 
26;<a name="line.144"></a>
 <span class="sourceLineNo">145</span><a name="line.145"></a>
@@ -1055,1591 +1055,1698 @@
 <span class="sourceLineNo">1047</span>    private String testName;<a 
name="line.1047"></a>
 <span class="sourceLineNo">1048</span>    private Histogram 
latencyHistogram;<a name="line.1048"></a>
 <span class="sourceLineNo">1049</span>    private Histogram 
valueSizeHistogram;<a name="line.1049"></a>
-<span class="sourceLineNo">1050</span>    private RandomDistribution.Zipf 
zipf;<a name="line.1050"></a>
-<span class="sourceLineNo">1051</span><a name="line.1051"></a>
-<span class="sourceLineNo">1052</span>    /**<a name="line.1052"></a>
-<span class="sourceLineNo">1053</span>     * Note that all subclasses of this 
class must provide a public constructor<a name="line.1053"></a>
-<span class="sourceLineNo">1054</span>     * that has the exact same list of 
arguments.<a name="line.1054"></a>
-<span class="sourceLineNo">1055</span>     */<a name="line.1055"></a>
-<span class="sourceLineNo">1056</span>    TestBase(final Configuration conf, 
final TestOptions options, final Status status) {<a name="line.1056"></a>
-<span class="sourceLineNo">1057</span>      this.conf = conf;<a 
name="line.1057"></a>
-<span class="sourceLineNo">1058</span>      this.receiverHost = this.conf == 
null? null: SpanReceiverHost.getInstance(conf);<a name="line.1058"></a>
-<span class="sourceLineNo">1059</span>      this.opts = options;<a 
name="line.1059"></a>
-<span class="sourceLineNo">1060</span>      this.status = status;<a 
name="line.1060"></a>
-<span class="sourceLineNo">1061</span>      this.testName = 
this.getClass().getSimpleName();<a name="line.1061"></a>
-<span class="sourceLineNo">1062</span>      if (options.traceRate &gt;= 1.0) 
{<a name="line.1062"></a>
-<span class="sourceLineNo">1063</span>        this.traceSampler = 
Sampler.ALWAYS;<a name="line.1063"></a>
-<span class="sourceLineNo">1064</span>      } else if (options.traceRate &gt; 
0.0) {<a name="line.1064"></a>
-<span class="sourceLineNo">1065</span>        
conf.setDouble("hbase.sampler.fraction", options.traceRate);<a 
name="line.1065"></a>
-<span class="sourceLineNo">1066</span>        this.traceSampler = new 
ProbabilitySampler(new HBaseHTraceConfiguration(conf));<a name="line.1066"></a>
-<span class="sourceLineNo">1067</span>      } else {<a name="line.1067"></a>
-<span class="sourceLineNo">1068</span>        this.traceSampler = 
Sampler.NEVER;<a name="line.1068"></a>
-<span class="sourceLineNo">1069</span>      }<a name="line.1069"></a>
-<span class="sourceLineNo">1070</span>      everyN = (int) (opts.totalRows / 
(opts.totalRows * opts.sampleRate));<a name="line.1070"></a>
-<span class="sourceLineNo">1071</span>      if (options.isValueZipf()) {<a 
name="line.1071"></a>
-<span class="sourceLineNo">1072</span>        this.zipf = new 
RandomDistribution.Zipf(this.rand, 1, options.getValueSize(), 1.2);<a 
name="line.1072"></a>
-<span class="sourceLineNo">1073</span>      }<a name="line.1073"></a>
-<span class="sourceLineNo">1074</span>      LOG.info("Sampling 1 every " + 
everyN + " out of " + opts.perClientRunRows + " total rows.");<a 
name="line.1074"></a>
-<span class="sourceLineNo">1075</span>    }<a name="line.1075"></a>
-<span class="sourceLineNo">1076</span><a name="line.1076"></a>
-<span class="sourceLineNo">1077</span>    int getValueLength(final Random r) 
{<a name="line.1077"></a>
-<span class="sourceLineNo">1078</span>      if (this.opts.isValueRandom()) {<a 
name="line.1078"></a>
-<span class="sourceLineNo">1079</span>        return 
r.nextInt(opts.valueSize);<a name="line.1079"></a>
-<span class="sourceLineNo">1080</span>      } else if 
(this.opts.isValueZipf()) {<a name="line.1080"></a>
-<span class="sourceLineNo">1081</span>        return 
Math.abs(this.zipf.nextInt());<a name="line.1081"></a>
-<span class="sourceLineNo">1082</span>      } else {<a name="line.1082"></a>
-<span class="sourceLineNo">1083</span>        return opts.valueSize;<a 
name="line.1083"></a>
-<span class="sourceLineNo">1084</span>      }<a name="line.1084"></a>
-<span class="sourceLineNo">1085</span>    }<a name="line.1085"></a>
-<span class="sourceLineNo">1086</span><a name="line.1086"></a>
-<span class="sourceLineNo">1087</span>    void updateValueSize(final Result [] 
rs) throws IOException {<a name="line.1087"></a>
-<span class="sourceLineNo">1088</span>      if (rs == null || 
!isRandomValueSize()) return;<a name="line.1088"></a>
-<span class="sourceLineNo">1089</span>      for (Result r: rs) 
updateValueSize(r);<a name="line.1089"></a>
-<span class="sourceLineNo">1090</span>    }<a name="line.1090"></a>
-<span class="sourceLineNo">1091</span><a name="line.1091"></a>
-<span class="sourceLineNo">1092</span>    void updateValueSize(final Result r) 
throws IOException {<a name="line.1092"></a>
-<span class="sourceLineNo">1093</span>      if (r == null || 
!isRandomValueSize()) return;<a name="line.1093"></a>
-<span class="sourceLineNo">1094</span>      int size = 0;<a 
name="line.1094"></a>
-<span class="sourceLineNo">1095</span>      for (CellScanner scanner = 
r.cellScanner(); scanner.advance();) {<a name="line.1095"></a>
-<span class="sourceLineNo">1096</span>        size += 
scanner.current().getValueLength();<a name="line.1096"></a>
-<span class="sourceLineNo">1097</span>      }<a name="line.1097"></a>
-<span class="sourceLineNo">1098</span>      updateValueSize(size);<a 
name="line.1098"></a>
-<span class="sourceLineNo">1099</span>    }<a name="line.1099"></a>
-<span class="sourceLineNo">1100</span><a name="line.1100"></a>
-<span class="sourceLineNo">1101</span>    void updateValueSize(final int 
valueSize) {<a name="line.1101"></a>
-<span class="sourceLineNo">1102</span>      if (!isRandomValueSize()) 
return;<a name="line.1102"></a>
-<span class="sourceLineNo">1103</span>      
this.valueSizeHistogram.update(valueSize);<a name="line.1103"></a>
-<span class="sourceLineNo">1104</span>    }<a name="line.1104"></a>
-<span class="sourceLineNo">1105</span><a name="line.1105"></a>
-<span class="sourceLineNo">1106</span>    String generateStatus(final int sr, 
final int i, final int lr) {<a name="line.1106"></a>
-<span class="sourceLineNo">1107</span>      return sr + "/" + i + "/" + lr + 
", latency " + getShortLatencyReport() +<a name="line.1107"></a>
-<span class="sourceLineNo">1108</span>        (!isRandomValueSize()? "": ", 
value size " + getShortValueSizeReport());<a name="line.1108"></a>
-<span class="sourceLineNo">1109</span>    }<a name="line.1109"></a>
-<span class="sourceLineNo">1110</span><a name="line.1110"></a>
-<span class="sourceLineNo">1111</span>    boolean isRandomValueSize() {<a 
name="line.1111"></a>
-<span class="sourceLineNo">1112</span>      return opts.valueRandom;<a 
name="line.1112"></a>
-<span class="sourceLineNo">1113</span>    }<a name="line.1113"></a>
-<span class="sourceLineNo">1114</span><a name="line.1114"></a>
-<span class="sourceLineNo">1115</span>    protected int getReportingPeriod() 
{<a name="line.1115"></a>
-<span class="sourceLineNo">1116</span>      return opts.period;<a 
name="line.1116"></a>
-<span class="sourceLineNo">1117</span>    }<a name="line.1117"></a>
-<span class="sourceLineNo">1118</span><a name="line.1118"></a>
-<span class="sourceLineNo">1119</span>    /**<a name="line.1119"></a>
-<span class="sourceLineNo">1120</span>     * Populated by testTakedown. Only 
implemented by RandomReadTest at the moment.<a name="line.1120"></a>
-<span class="sourceLineNo">1121</span>     */<a name="line.1121"></a>
-<span class="sourceLineNo">1122</span>    public Histogram 
getLatencyHistogram() {<a name="line.1122"></a>
-<span class="sourceLineNo">1123</span>      return latencyHistogram;<a 
name="line.1123"></a>
-<span class="sourceLineNo">1124</span>    }<a name="line.1124"></a>
-<span class="sourceLineNo">1125</span><a name="line.1125"></a>
-<span class="sourceLineNo">1126</span>    void testSetup() throws IOException 
{<a name="line.1126"></a>
-<span class="sourceLineNo">1127</span>      createConnection();<a 
name="line.1127"></a>
-<span class="sourceLineNo">1128</span>      onStartup();<a 
name="line.1128"></a>
-<span class="sourceLineNo">1129</span>      latencyHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1129"></a>
-<span class="sourceLineNo">1130</span>      valueSizeHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1130"></a>
-<span class="sourceLineNo">1131</span>    }<a name="line.1131"></a>
-<span class="sourceLineNo">1132</span><a name="line.1132"></a>
-<span class="sourceLineNo">1133</span>    abstract void createConnection() 
throws IOException;<a name="line.1133"></a>
-<span class="sourceLineNo">1134</span><a name="line.1134"></a>
-<span class="sourceLineNo">1135</span>    abstract void onStartup() throws 
IOException;<a name="line.1135"></a>
-<span class="sourceLineNo">1136</span><a name="line.1136"></a>
-<span class="sourceLineNo">1137</span>    void testTakedown() throws 
IOException {<a name="line.1137"></a>
-<span class="sourceLineNo">1138</span>      onTakedown();<a 
name="line.1138"></a>
-<span class="sourceLineNo">1139</span>      // Print all stats for this thread 
continuously.<a name="line.1139"></a>
-<span class="sourceLineNo">1140</span>      // Synchronize on Test.class so 
different threads don't intermingle the<a name="line.1140"></a>
-<span class="sourceLineNo">1141</span>      // output. We can't use 'this' 
here because each thread has its own instance of Test class.<a 
name="line.1141"></a>
-<span class="sourceLineNo">1142</span>      synchronized (Test.class) {<a 
name="line.1142"></a>
-<span class="sourceLineNo">1143</span>        status.setStatus("Test : " + 
testName + ", Thread : " + Thread.currentThread().getName());<a 
name="line.1143"></a>
-<span class="sourceLineNo">1144</span>        status.setStatus("Latency (us) : 
" + YammerHistogramUtils.getHistogramReport(<a name="line.1144"></a>
-<span class="sourceLineNo">1145</span>            latencyHistogram));<a 
name="line.1145"></a>
-<span class="sourceLineNo">1146</span>        status.setStatus("Num measures 
(latency) : " + latencyHistogram.getCount());<a name="line.1146"></a>
-<span class="sourceLineNo">1147</span>        
status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(latencyHistogram));<a
 name="line.1147"></a>
-<span class="sourceLineNo">1148</span>        status.setStatus("ValueSize 
(bytes) : "<a name="line.1148"></a>
-<span class="sourceLineNo">1149</span>            + 
YammerHistogramUtils.getHistogramReport(valueSizeHistogram));<a 
name="line.1149"></a>
-<span class="sourceLineNo">1150</span>        status.setStatus("Num measures 
(ValueSize): " + valueSizeHistogram.getCount());<a name="line.1150"></a>
-<span class="sourceLineNo">1151</span>        
status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(valueSizeHistogram));<a
 name="line.1151"></a>
-<span class="sourceLineNo">1152</span>      }<a name="line.1152"></a>
-<span class="sourceLineNo">1153</span>      closeConnection();<a 
name="line.1153"></a>
-<span class="sourceLineNo">1154</span>      receiverHost.closeReceivers();<a 
name="line.1154"></a>
-<span class="sourceLineNo">1155</span>    }<a name="line.1155"></a>
-<span class="sourceLineNo">1156</span><a name="line.1156"></a>
-<span class="sourceLineNo">1157</span>    abstract void onTakedown() throws 
IOException;<a name="line.1157"></a>
-<span class="sourceLineNo">1158</span><a name="line.1158"></a>
-<span class="sourceLineNo">1159</span>    abstract void closeConnection() 
throws IOException;<a name="line.1159"></a>
-<span class="sourceLineNo">1160</span><a name="line.1160"></a>
-<span class="sourceLineNo">1161</span>    /*<a name="line.1161"></a>
-<span class="sourceLineNo">1162</span>     * Run test<a name="line.1162"></a>
-<span class="sourceLineNo">1163</span>     * @return Elapsed time.<a 
name="line.1163"></a>
-<span class="sourceLineNo">1164</span>     * @throws IOException<a 
name="line.1164"></a>
-<span class="sourceLineNo">1165</span>     */<a name="line.1165"></a>
-<span class="sourceLineNo">1166</span>    long test() throws IOException, 
InterruptedException {<a name="line.1166"></a>
-<span class="sourceLineNo">1167</span>      testSetup();<a 
name="line.1167"></a>
-<span class="sourceLineNo">1168</span>      LOG.info("Timed test starting in 
thread " + Thread.currentThread().getName());<a name="line.1168"></a>
-<span class="sourceLineNo">1169</span>      final long startTime = 
System.nanoTime();<a name="line.1169"></a>
-<span class="sourceLineNo">1170</span>      try {<a name="line.1170"></a>
-<span class="sourceLineNo">1171</span>        testTimed();<a 
name="line.1171"></a>
-<span class="sourceLineNo">1172</span>      } finally {<a name="line.1172"></a>
-<span class="sourceLineNo">1173</span>        testTakedown();<a 
name="line.1173"></a>
-<span class="sourceLineNo">1174</span>      }<a name="line.1174"></a>
-<span class="sourceLineNo">1175</span>      return (System.nanoTime() - 
startTime) / 1000000;<a name="line.1175"></a>
-<span class="sourceLineNo">1176</span>    }<a name="line.1176"></a>
+<span class="sourceLineNo">1050</span>    private Histogram 
rpcCallsHistogram;<a name="line.1050"></a>
+<span class="sourceLineNo">1051</span>    private Histogram 
remoteRpcCallsHistogram;<a name="line.1051"></a>
+<span class="sourceLineNo">1052</span>    private Histogram 
millisBetweenNextHistogram;<a name="line.1052"></a>
+<span class="sourceLineNo">1053</span>    private Histogram 
regionsScannedHistogram;<a name="line.1053"></a>
+<span class="sourceLineNo">1054</span>    private Histogram 
bytesInResultsHistogram;<a name="line.1054"></a>
+<span class="sourceLineNo">1055</span>    private Histogram 
bytesInRemoteResultsHistogram;<a name="line.1055"></a>
+<span class="sourceLineNo">1056</span>    private RandomDistribution.Zipf 
zipf;<a name="line.1056"></a>
+<span class="sourceLineNo">1057</span><a name="line.1057"></a>
+<span class="sourceLineNo">1058</span>    /**<a name="line.1058"></a>
+<span class="sourceLineNo">1059</span>     * Note that all subclasses of this 
class must provide a public constructor<a name="line.1059"></a>
+<span class="sourceLineNo">1060</span>     * that has the exact same list of 
arguments.<a name="line.1060"></a>
+<span class="sourceLineNo">1061</span>     */<a name="line.1061"></a>
+<span class="sourceLineNo">1062</span>    TestBase(final Configuration conf, 
final TestOptions options, final Status status) {<a name="line.1062"></a>
+<span class="sourceLineNo">1063</span>      this.conf = conf;<a 
name="line.1063"></a>
+<span class="sourceLineNo">1064</span>      this.receiverHost = this.conf == 
null? null: SpanReceiverHost.getInstance(conf);<a name="line.1064"></a>
+<span class="sourceLineNo">1065</span>      this.opts = options;<a 
name="line.1065"></a>
+<span class="sourceLineNo">1066</span>      this.status = status;<a 
name="line.1066"></a>
+<span class="sourceLineNo">1067</span>      this.testName = 
this.getClass().getSimpleName();<a name="line.1067"></a>
+<span class="sourceLineNo">1068</span>      if (options.traceRate &gt;= 1.0) 
{<a name="line.1068"></a>
+<span class="sourceLineNo">1069</span>        this.traceSampler = 
Sampler.ALWAYS;<a name="line.1069"></a>
+<span class="sourceLineNo">1070</span>      } else if (options.traceRate &gt; 
0.0) {<a name="line.1070"></a>
+<span class="sourceLineNo">1071</span>        
conf.setDouble("hbase.sampler.fraction", options.traceRate);<a 
name="line.1071"></a>
+<span class="sourceLineNo">1072</span>        this.traceSampler = new 
ProbabilitySampler(new HBaseHTraceConfiguration(conf));<a name="line.1072"></a>
+<span class="sourceLineNo">1073</span>      } else {<a name="line.1073"></a>
+<span class="sourceLineNo">1074</span>        this.traceSampler = 
Sampler.NEVER;<a name="line.1074"></a>
+<span class="sourceLineNo">1075</span>      }<a name="line.1075"></a>
+<span class="sourceLineNo">1076</span>      everyN = (int) (opts.totalRows / 
(opts.totalRows * opts.sampleRate));<a name="line.1076"></a>
+<span class="sourceLineNo">1077</span>      if (options.isValueZipf()) {<a 
name="line.1077"></a>
+<span class="sourceLineNo">1078</span>        this.zipf = new 
RandomDistribution.Zipf(this.rand, 1, options.getValueSize(), 1.2);<a 
name="line.1078"></a>
+<span class="sourceLineNo">1079</span>      }<a name="line.1079"></a>
+<span class="sourceLineNo">1080</span>      LOG.info("Sampling 1 every " + 
everyN + " out of " + opts.perClientRunRows + " total rows.");<a 
name="line.1080"></a>
+<span class="sourceLineNo">1081</span>    }<a name="line.1081"></a>
+<span class="sourceLineNo">1082</span><a name="line.1082"></a>
+<span class="sourceLineNo">1083</span>    int getValueLength(final Random r) 
{<a name="line.1083"></a>
+<span class="sourceLineNo">1084</span>      if (this.opts.isValueRandom()) {<a 
name="line.1084"></a>
+<span class="sourceLineNo">1085</span>        return 
r.nextInt(opts.valueSize);<a name="line.1085"></a>
+<span class="sourceLineNo">1086</span>      } else if 
(this.opts.isValueZipf()) {<a name="line.1086"></a>
+<span class="sourceLineNo">1087</span>        return 
Math.abs(this.zipf.nextInt());<a name="line.1087"></a>
+<span class="sourceLineNo">1088</span>      } else {<a name="line.1088"></a>
+<span class="sourceLineNo">1089</span>        return opts.valueSize;<a 
name="line.1089"></a>
+<span class="sourceLineNo">1090</span>      }<a name="line.1090"></a>
+<span class="sourceLineNo">1091</span>    }<a name="line.1091"></a>
+<span class="sourceLineNo">1092</span><a name="line.1092"></a>
+<span class="sourceLineNo">1093</span>    void updateValueSize(final Result [] 
rs) throws IOException {<a name="line.1093"></a>
+<span class="sourceLineNo">1094</span>      if (rs == null || 
!isRandomValueSize()) return;<a name="line.1094"></a>
+<span class="sourceLineNo">1095</span>      for (Result r: rs) 
updateValueSize(r);<a name="line.1095"></a>
+<span class="sourceLineNo">1096</span>    }<a name="line.1096"></a>
+<span class="sourceLineNo">1097</span><a name="line.1097"></a>
+<span class="sourceLineNo">1098</span>    void updateValueSize(final Result r) 
throws IOException {<a name="line.1098"></a>
+<span class="sourceLineNo">1099</span>      if (r == null || 
!isRandomValueSize()) return;<a name="line.1099"></a>
+<span class="sourceLineNo">1100</span>      int size = 0;<a 
name="line.1100"></a>
+<span class="sourceLineNo">1101</span>      for (CellScanner scanner = 
r.cellScanner(); scanner.advance();) {<a name="line.1101"></a>
+<span class="sourceLineNo">1102</span>        size += 
scanner.current().getValueLength();<a name="line.1102"></a>
+<span class="sourceLineNo">1103</span>      }<a name="line.1103"></a>
+<span class="sourceLineNo">1104</span>      updateValueSize(size);<a 
name="line.1104"></a>
+<span class="sourceLineNo">1105</span>    }<a name="line.1105"></a>
+<span class="sourceLineNo">1106</span><a name="line.1106"></a>
+<span class="sourceLineNo">1107</span>    void updateValueSize(final int 
valueSize) {<a name="line.1107"></a>
+<span class="sourceLineNo">1108</span>      if (!isRandomValueSize()) 
return;<a name="line.1108"></a>
+<span class="sourceLineNo">1109</span>      
this.valueSizeHistogram.update(valueSize);<a name="line.1109"></a>
+<span class="sourceLineNo">1110</span>    }<a name="line.1110"></a>
+<span class="sourceLineNo">1111</span><a name="line.1111"></a>
+<span class="sourceLineNo">1112</span>    void updateScanMetrics(final 
ScanMetrics metrics) {<a name="line.1112"></a>
+<span class="sourceLineNo">1113</span>      Map&lt;String,Long&gt; metricsMap 
= metrics.getMetricsMap();<a name="line.1113"></a>
+<span class="sourceLineNo">1114</span>      Long rpcCalls = 
metricsMap.get(ScanMetrics.RPC_CALLS_METRIC_NAME);<a name="line.1114"></a>
+<span class="sourceLineNo">1115</span>      if (rpcCalls != null) {<a 
name="line.1115"></a>
+<span class="sourceLineNo">1116</span>        
this.rpcCallsHistogram.update(rpcCalls.longValue());<a name="line.1116"></a>
+<span class="sourceLineNo">1117</span>      }<a name="line.1117"></a>
+<span class="sourceLineNo">1118</span>      Long remoteRpcCalls = 
metricsMap.get(ScanMetrics.REMOTE_RPC_CALLS_METRIC_NAME);<a 
name="line.1118"></a>
+<span class="sourceLineNo">1119</span>      if (remoteRpcCalls != null) {<a 
name="line.1119"></a>
+<span class="sourceLineNo">1120</span>        
this.remoteRpcCallsHistogram.update(remoteRpcCalls.longValue());<a 
name="line.1120"></a>
+<span class="sourceLineNo">1121</span>      }<a name="line.1121"></a>
+<span class="sourceLineNo">1122</span>      Long millisBetweenNext = 
metricsMap.get(ScanMetrics.MILLIS_BETWEEN_NEXTS_METRIC_NAME);<a 
name="line.1122"></a>
+<span class="sourceLineNo">1123</span>      if (millisBetweenNext != null) {<a 
name="line.1123"></a>
+<span class="sourceLineNo">1124</span>        
this.millisBetweenNextHistogram.update(millisBetweenNext.longValue());<a 
name="line.1124"></a>
+<span class="sourceLineNo">1125</span>      }<a name="line.1125"></a>
+<span class="sourceLineNo">1126</span>      Long regionsScanned = 
metricsMap.get(ScanMetrics.REGIONS_SCANNED_METRIC_NAME);<a name="line.1126"></a>
+<span class="sourceLineNo">1127</span>      if (regionsScanned != null) {<a 
name="line.1127"></a>
+<span class="sourceLineNo">1128</span>        
this.regionsScannedHistogram.update(regionsScanned.longValue());<a 
name="line.1128"></a>
+<span class="sourceLineNo">1129</span>      }<a name="line.1129"></a>
+<span class="sourceLineNo">1130</span>      Long bytesInResults = 
metricsMap.get(ScanMetrics.BYTES_IN_RESULTS_METRIC_NAME);<a 
name="line.1130"></a>
+<span class="sourceLineNo">1131</span>      if (bytesInResults != null 
&amp;&amp; bytesInResults.longValue() &gt; 0) {<a name="line.1131"></a>
+<span class="sourceLineNo">1132</span>        
this.bytesInResultsHistogram.update(bytesInResults.longValue());<a 
name="line.1132"></a>
+<span class="sourceLineNo">1133</span>      }<a name="line.1133"></a>
+<span class="sourceLineNo">1134</span>      Long bytesInRemoteResults = 
metricsMap.get(ScanMetrics.BYTES_IN_REMOTE_RESULTS_METRIC_NAME);<a 
name="line.1134"></a>
+<span class="sourceLineNo">1135</span>      if (bytesInRemoteResults != null 
&amp;&amp; bytesInRemoteResults.longValue() &gt; 0) {<a name="line.1135"></a>
+<span class="sourceLineNo">1136</span>        
this.bytesInRemoteResultsHistogram.update(bytesInRemoteResults.longValue());<a 
name="line.1136"></a>
+<span class="sourceLineNo">1137</span>      }<a name="line.1137"></a>
+<span class="sourceLineNo">1138</span>    }<a name="line.1138"></a>
+<span class="sourceLineNo">1139</span><a name="line.1139"></a>
+<span class="sourceLineNo">1140</span>    String generateStatus(final int sr, 
final int i, final int lr) {<a name="line.1140"></a>
+<span class="sourceLineNo">1141</span>      return sr + "/" + i + "/" + lr + 
", latency " + getShortLatencyReport() +<a name="line.1141"></a>
+<span class="sourceLineNo">1142</span>        (!isRandomValueSize()? "": ", 
value size " + getShortValueSizeReport());<a name="line.1142"></a>
+<span class="sourceLineNo">1143</span>    }<a name="line.1143"></a>
+<span class="sourceLineNo">1144</span><a name="line.1144"></a>
+<span class="sourceLineNo">1145</span>    boolean isRandomValueSize() {<a 
name="line.1145"></a>
+<span class="sourceLineNo">1146</span>      return opts.valueRandom;<a 
name="line.1146"></a>
+<span class="sourceLineNo">1147</span>    }<a name="line.1147"></a>
+<span class="sourceLineNo">1148</span><a name="line.1148"></a>
+<span class="sourceLineNo">1149</span>    protected int getReportingPeriod() 
{<a name="line.1149"></a>
+<span class="sourceLineNo">1150</span>      return opts.period;<a 
name="line.1150"></a>
+<span class="sourceLineNo">1151</span>    }<a name="line.1151"></a>
+<span class="sourceLineNo">1152</span><a name="line.1152"></a>
+<span class="sourceLineNo">1153</span>    /**<a name="line.1153"></a>
+<span class="sourceLineNo">1154</span>     * Populated by testTakedown. Only 
implemented by RandomReadTest at the moment.<a name="line.1154"></a>
+<span class="sourceLineNo">1155</span>     */<a name="line.1155"></a>
+<span class="sourceLineNo">1156</span>    public Histogram 
getLatencyHistogram() {<a name="line.1156"></a>
+<span class="sourceLineNo">1157</span>      return latencyHistogram;<a 
name="line.1157"></a>
+<span class="sourceLineNo">1158</span>    }<a name="line.1158"></a>
+<span class="sourceLineNo">1159</span><a name="line.1159"></a>
+<span class="sourceLineNo">1160</span>    void testSetup() throws IOException 
{<a name="line.1160"></a>
+<span class="sourceLineNo">1161</span>      // test metrics<a 
name="line.1161"></a>
+<span class="sourceLineNo">1162</span>      latencyHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1162"></a>
+<span class="sourceLineNo">1163</span>      valueSizeHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1163"></a>
+<span class="sourceLineNo">1164</span>      // scan metrics<a 
name="line.1164"></a>
+<span class="sourceLineNo">1165</span>      rpcCallsHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1165"></a>
+<span class="sourceLineNo">1166</span>      remoteRpcCallsHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1166"></a>
+<span class="sourceLineNo">1167</span>      millisBetweenNextHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1167"></a>
+<span class="sourceLineNo">1168</span>      regionsScannedHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1168"></a>
+<span class="sourceLineNo">1169</span>      bytesInResultsHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1169"></a>
+<span class="sourceLineNo">1170</span>      bytesInRemoteResultsHistogram = 
YammerHistogramUtils.newHistogram(new UniformReservoir(1024 * 500));<a 
name="line.1170"></a>
+<span class="sourceLineNo">1171</span><a name="line.1171"></a>
+<span class="sourceLineNo">1172</span>      createConnection();<a 
name="line.1172"></a>
+<span class="sourceLineNo">1173</span>      onStartup();<a 
name="line.1173"></a>
+<span class="sourceLineNo">1174</span>    }<a name="line.1174"></a>
+<span class="sourceLineNo">1175</span><a name="line.1175"></a>
+<span class="sourceLineNo">1176</span>    abstract void createConnection() 
throws IOException;<a name="line.1176"></a>
 <span class="sourceLineNo">1177</span><a name="line.1177"></a>
-<span class="sourceLineNo">1178</span>    int getStartRow() {<a 
name="line.1178"></a>
-<span class="sourceLineNo">1179</span>      return opts.startRow;<a 
name="line.1179"></a>
-<span class="sourceLineNo">1180</span>    }<a name="line.1180"></a>
-<span class="sourceLineNo">1181</span><a name="line.1181"></a>
-<span class="sourceLineNo">1182</span>    int getLastRow() {<a 
name="line.1182"></a>
-<span class="sourceLineNo">1183</span>      return getStartRow() + 
opts.perClientRunRows;<a name="line.1183"></a>
-<span class="sourceLineNo">1184</span>    }<a name="line.1184"></a>
-<span class="sourceLineNo">1185</span><a name="line.1185"></a>
-<span class="sourceLineNo">1186</span>    /**<a name="line.1186"></a>
-<span class="sourceLineNo">1187</span>     * Provides an extension point for 
tests that don't want a per row invocation.<a name="line.1187"></a>
-<span class="sourceLineNo">1188</span>     */<a name="line.1188"></a>
-<span class="sourceLineNo">1189</span>    void testTimed() throws IOException, 
InterruptedException {<a name="line.1189"></a>
-<span class="sourceLineNo">1190</span>      int startRow = getStartRow();<a 
name="line.1190"></a>
-<span class="sourceLineNo">1191</span>      int lastRow = getLastRow();<a 
name="line.1191"></a>
-<span class="sourceLineNo">1192</span>      
TraceUtil.addSampler(traceSampler);<a name="line.1192"></a>
-<span class="sourceLineNo">1193</span>      // Report on completion of 1/10th 
of total.<a name="line.1193"></a>
-<span class="sourceLineNo">1194</span>      for (int ii = 0; ii &lt; 
opts.cycles; ii++) {<a name="line.1194"></a>
-<span class="sourceLineNo">1195</span>        if (opts.cycles &gt; 1) 
LOG.info("Cycle=" + ii + " of " + opts.cycles);<a name="line.1195"></a>
-<span class="sourceLineNo">1196</span>        for (int i = startRow; i &lt; 
lastRow; i++) {<a name="line.1196"></a>
-<span class="sourceLineNo">1197</span>          if (i % everyN != 0) 
continue;<a name="line.1197"></a>
-<span class="sourceLineNo">1198</span>          long startTime = 
System.nanoTime();<a name="line.1198"></a>
-<span class="sourceLineNo">1199</span>          try (TraceScope scope = 
TraceUtil.createTrace("test row")){<a name="line.1199"></a>
-<span class="sourceLineNo">1200</span>            testRow(i);<a 
name="line.1200"></a>
-<span class="sourceLineNo">1201</span>          }<a name="line.1201"></a>
-<span class="sourceLineNo">1202</span>          if ( (i - startRow) &gt; 
opts.measureAfter) {<a name="line.1202"></a>
-<span class="sourceLineNo">1203</span>            // If multiget is enabled, 
say set to 10, testRow() returns immediately first 9 times<a 
name="line.1203"></a>
-<span class="sourceLineNo">1204</span>            // and sends the actual get 
request in the 10th iteration. We should only set latency<a 
name="line.1204"></a>
-<span class="sourceLineNo">1205</span>            // when actual request is 
sent because otherwise it turns out to be 0.<a name="line.1205"></a>
-<span class="sourceLineNo">1206</span>            if (opts.multiGet == 0 || (i 
- startRow + 1) % opts.multiGet == 0) {<a name="line.1206"></a>
-<span class="sourceLineNo">1207</span>              
latencyHistogram.update((System.nanoTime() - startTime) / 1000);<a 
name="line.1207"></a>
-<span class="sourceLineNo">1208</span>            }<a name="line.1208"></a>
-<span class="sourceLineNo">1209</span>            if (status != null 
&amp;&amp; i &gt; 0 &amp;&amp; (i % getReportingPeriod()) == 0) {<a 
name="line.1209"></a>
-<span class="sourceLineNo">1210</span>              
status.setStatus(generateStatus(startRow, i, lastRow));<a name="line.1210"></a>
-<span class="sourceLineNo">1211</span>            }<a name="line.1211"></a>
-<span class="sourceLineNo">1212</span>          }<a name="line.1212"></a>
-<span class="sourceLineNo">1213</span>        }<a name="line.1213"></a>
-<span class="sourceLineNo">1214</span>      }<a name="line.1214"></a>
-<span class="sourceLineNo">1215</span>    }<a name="line.1215"></a>
-<span class="sourceLineNo">1216</span><a name="line.1216"></a>
-<span class="sourceLineNo">1217</span>    /**<a name="line.1217"></a>
-<span class="sourceLineNo">1218</span>     * @return Subset of the histograms' 
calculation.<a name="line.1218"></a>
-<span class="sourceLineNo">1219</span>     */<a name="line.1219"></a>
-<span class="sourceLineNo">1220</span>    public String 
getShortLatencyReport() {<a name="line.1220"></a>
-<span class="sourceLineNo">1221</span>      return 
YammerHistogramUtils.getShortHistogramReport(this.latencyHistogram);<a 
name="line.1221"></a>
+<span class="sourceLineNo">1178</span>    abstract void onStartup() throws 
IOException;<a name="line.1178"></a>
+<span class="sourceLineNo">1179</span><a name="line.1179"></a>
+<span class="sourceLineNo">1180</span>    void testTakedown() throws 
IOException {<a name="line.1180"></a>
+<span class="sourceLineNo">1181</span>      onTakedown();<a 
name="line.1181"></a>
+<span class="sourceLineNo">1182</span>      // Print all stats for this thread 
continuously.<a name="line.1182"></a>
+<span class="sourceLineNo">1183</span>      // Synchronize on Test.class so 
different threads don't intermingle the<a name="line.1183"></a>
+<span class="sourceLineNo">1184</span>      // output. We can't use 'this' 
here because each thread has its own instance of Test class.<a 
name="line.1184"></a>
+<span class="sourceLineNo">1185</span>      synchronized (Test.class) {<a 
name="line.1185"></a>
+<span class="sourceLineNo">1186</span>        status.setStatus("Test : " + 
testName + ", Thread : " + Thread.currentThread().getName());<a 
name="line.1186"></a>
+<span class="sourceLineNo">1187</span>        status.setStatus("Latency (us) : 
" + YammerHistogramUtils.getHistogramReport(<a name="line.1187"></a>
+<span class="sourceLineNo">1188</span>            latencyHistogram));<a 
name="line.1188"></a>
+<span class="sourceLineNo">1189</span>        status.setStatus("Num measures 
(latency) : " + latencyHistogram.getCount());<a name="line.1189"></a>
+<span class="sourceLineNo">1190</span>        
status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(latencyHistogram));<a
 name="line.1190"></a>
+<span class="sourceLineNo">1191</span>        status.setStatus("ValueSize 
(bytes) : "<a name="line.1191"></a>
+<span class="sourceLineNo">1192</span>            + 
YammerHistogramUtils.getHistogramReport(valueSizeHistogram));<a 
name="line.1192"></a>
+<span class="sourceLineNo">1193</span>        status.setStatus("Num measures 
(ValueSize): " + valueSizeHistogram.getCount());<a name="line.1193"></a>
+<span class="sourceLineNo">1194</span>        
status.setStatus(YammerHistogramUtils.getPrettyHistogramReport(valueSizeHistogram));<a
 name="line.1194"></a>
+<span class="sourceLineNo">1195</span>        if (rpcCallsHistogram.getCount() 
&gt; 0) {<a name="line.1195"></a>
+<span class="sourceLineNo">1196</span>          status.setStatus("rpcCalls 
(count): " +<a name="line.1196"></a>
+<span class="sourceLineNo">1197</span>              
YammerHistogramUtils.getHistogramReport(rpcCallsHistogram));<a 
name="line.1197"></a>
+<span class="sourceLineNo">1198</span>        }<a name="line.1198"></a>
+<span class="sourceLineNo">1199</span>        if 
(remoteRpcCallsHistogram.getCount() &gt; 0) {<a name="line.1199"></a>
+<span class="sourceLineNo">1200</span>          
status.setStatus("remoteRpcCalls (count): " +<a name="line.1200"></a>
+<span class="sourceLineNo">1201</span>              
YammerHistogramUtils.getHistogramReport(remoteRpcCallsHistogram));<a 
name="line.1201"></a>
+<span class="sourceLineNo">1202</span>        }<a name="line.1202"></a>
+<span class="sourceLineNo">1203</span>        if 
(millisBetweenNextHistogram.getCount() &gt; 0) {<a name="line.1203"></a>
+<span class="sourceLineNo">1204</span>          
status.setStatus("millisBetweenNext (latency): " +<a name="line.1204"></a>
+<span class="sourceLineNo">1205</span>              
YammerHistogramUtils.getHistogramReport(millisBetweenNextHistogram));<a 
name="line.1205"></a>
+<span class="sourceLineNo">1206</span>        }<a name="line.1206"></a>
+<span class="sourceLineNo">1207</span>        if 
(regionsScannedHistogram.getCount() &gt; 0) {<a name="line.1207"></a>
+<span class="sourceLineNo">1208</span>          
status.setStatus("regionsScanned (count): " +<a name="line.1208"></a>
+<span class="sourceLineNo">1209</span>              
YammerHistogramUtils.getHistogramReport(regionsScannedHistogram));<a 
name="line.1209"></a>
+<span class="sourceLineNo">1210</span>        }<a name="line.1210"></a>
+<span class="sourceLineNo">1211</span>        if 
(bytesInResultsHistogram.getCount() &gt; 0) {<a name="line.1211"></a>
+<span class="sourceLineNo">1212</span>          
status.setStatus("bytesInResults (size): " +<a name="line.1212"></a>
+<span class="sourceLineNo">1213</span>              
YammerHistogramUtils.getHistogramReport(bytesInResultsHistogram));<a 
name="line.1213"></a>
+<span class="sourceLineNo">1214</span>        }<a name="line.1214"></a>
+<span class="sourceLineNo">1215</span>        if 
(bytesInRemoteResultsHistogram.getCount() &gt; 0) {<a name="line.1215"></a>
+<span class="sourceLineNo">1216</span>          
status.setStatus("bytesInRemoteResults (size): " +<a name="line.1216"></a>
+<span class="sourceLineNo">1217</span>              
YammerHistogramUtils.getHistogramReport(bytesInRemoteResultsHistogram));<a 
name="line.1217"></a>
+<span class="sourceLineNo">1218</span>        }<a name="line.1218"></a>
+<span class="sourceLineNo">1219</span>      }<a name="line.1219"></a>
+<span class="sourceLineNo">1220</span>      closeConnection();<a 
name="line.1220"></a>
+<span class="sourceLineNo">1221</span>      receiverHost.closeReceivers();<a 
name="line.1221"></a>
 <span class="sourceLineNo">1222</span>    }<a name="line.1222"></a>
 <span class="sourceLineNo">1223</span><a name="line.1223"></a>
-<span class="sourceLineNo">1224</span>    /**<a name="line.1224"></a>
-<span class="sourceLineNo">1225</span>     * @return Subset of the histograms' 
calculation.<a name="line.1225"></a>
-<span class="sourceLineNo">1226</span>     */<a name="line.1226"></a>
-<span class="sourceLineNo">1227</span>    public String 
getShortValueSizeReport() {<a name="line.1227"></a>
-<span class="sourceLineNo">1228</span>      return 
YammerHistogramUtils.getShortHistogramReport(this.valueSizeHistogram);<a 
name="line.1228"></a>
-<span class="sourceLineNo">1229</span>    }<a name="line.1229"></a>
-<span class="sourceLineNo">1230</span><a name="line.1230"></a>
-<span class="sourceLineNo">1231</span>    /*<a name="line.1231"></a>
-<span class="sourceLineNo">1232</span>    * Test for individual row.<a 
name="line.1232"></a>
-<span class="sourceLineNo">1233</span>    * @param i Row index.<a 
name="line.1233"></a>
-<span class="sourceLineNo">1234</span>    */<a name="line.1234"></a>
-<span class="sourceLineNo">1235</span>    abstract void testRow(final int i) 
throws IOException, InterruptedException;<a name="line.1235"></a>
-<span class="sourceLineNo">1236</span>  }<a name="line.1236"></a>
-<span class="sourceLineNo">1237</span><a name="line.1237"></a>
-<span class="sourceLineNo">1238</span>  static abstract class Test extends 
TestBase {<a name="line.1238"></a>
-<span class="sourceLineNo">1239</span>    protected Connection connection;<a 
name="line.1239"></a>
-<span class="sourceLineNo">1240</span><a name="line.1240"></a>
-<span class="sourceLineNo">1241</span>    Test(final Connection con, final 
TestOptions options, final Status status) {<a name="line.1241"></a>
-<span class="sourceLineNo">1242</span>      super(con == null ? 
HBaseConfiguration.create() : con.getConfiguration(), options, status);<a 
name="line.1242"></a>
-<span class="sourceLineNo">1243</span>      this.connection = con;<a 
name="line.1243"></a>
-<span class="sourceLineNo">1244</span>    }<a name="line.1244"></a>
-<span class="sourceLineNo">1245</span><a name="line.1245"></a>
-<span class="sourceLineNo">1246</span>    @Override<a name="line.1246"></a>
-<span class="sourceLineNo">1247</span>    void createConnection() throws 
IOException {<a name="line.1247"></a>
-<span class="sourceLineNo">1248</span>      if (!opts.isOneCon()) {<a 
name="line.1248"></a>
-<span class="sourceLineNo">1249</span>        this.connection = 
ConnectionFactory.createConnection(conf);<a name="line.1249"></a>
-<span class="sourceLineNo">1250</span>      }<a name="line.1250"></a>
+<span class="sourceLineNo">1224</span>    abstract void onTakedown() throws 
IOException;<a name="line.1224"></a>
+<span class="sourceLineNo">1225</span><a name="line.1225"></a>
+<span class="sourceLineNo">1226</span>    abstract void closeConnection() 
throws IOException;<a name="line.1226"></a>
+<span class="sourceLineNo">1227</span><a name="line.1227"></a>
+<span class="sourceLineNo">1228</span>    /*<a name="line.1228"></a>
+<span class="sourceLineNo">1229</span>     * Run test<a name="line.1229"></a>
+<span class="sourceLineNo">1230</span>     * @return Elapsed time.<a 
name="line.1230"></a>
+<span class="sourceLineNo">1231</span>     * @throws IOException<a 
name="line.1231"></a>
+<span class="sourceLineNo">1232</span>     */<a name="line.1232"></a>
+<span class="sourceLineNo">1233</span>    long test() throws IOException, 
InterruptedException {<a name="line.1233"></a>
+<span class="sourceLineNo">1234</span>      testSetup();<a 
name="line.1234"></a>
+<span class="sourceLineNo">1235</span>      LOG.info("Timed test starting in 
thread " + Thread.currentThread().getName());<a name="line.1235"></a>
+<span class="sourceLineNo">1236</span>      final long startTime = 
System.nanoTime();<a name="line.1236"></a>
+<span class="sourceLineNo">1237</span>      try {<a name="line.1237"></a>
+<span class="sourceLineNo">1238</span>        testTimed();<a 
name="line.1238"></a>
+<span class="sourceLineNo">1239</span>      } finally {<a name="line.1239"></a>
+<span class="sourceLineNo">1240</span>        testTakedown();<a 
name="line.1240"></a>
+<span class="sourceLineNo">1241</span>      }<a name="line.1241"></a>
+<span class="sourceLineNo">1242</span>      return (System.nanoTime() - 
startTime) / 1000000;<a name="line.1242"></a>
+<span class="sourceLineNo">1243</span>    }<a name="line.1243"></a>
+<span class="sourceLineNo">1244</span><a name="line.1244"></a>
+<span class="sourceLineNo">1245</span>    int getStartRow() {<a 
name="line.1245"></a>
+<span class="sourceLineNo">1246</span>      return opts.startRow;<a 
name="line.1246"></a>
+<span class="sourceLineNo">1247</span>    }<a name="line.1247"></a>
+<span class="sourceLineNo">1248</span><a name="line.1248"></a>
+<span class="sourceLineNo">1249</span>    int getLastRow() {<a 
name="line.1249"></a>
+<span class="sourceLineNo">1250</span>      return getStartRow() + 
opts.perClientRunRows;<a name="line.1250"></a>
 <span class="sourceLineNo">1251</span>    }<a name="line.1251"></a>
 <span class="sourceLineNo">1252</span><a name="line.1252"></a>
-<span class="sourceLineNo">1253</span>    @Override<a name="line.1253"></a>
-<span class="sourceLineNo">1254</span>    void closeConnection() throws 
IOException {<a name="line.1254"></a>
-<span class="sourceLineNo">1255</span>      if (!opts.isOneCon()) {<a 
name="line.1255"></a>
-<span class="sourceLineNo">1256</span>        this.connection.close();<a 
name="line.1256"></a>
-<span class="sourceLineNo">1257</span>      }<a name="line.1257"></a>
-<span class="sourceLineNo">1258</span>    }<a name="line.1258"></a>
-<span class="sourceLineNo">1259</span>  }<a name="line.1259"></a>
-<span class="sourceLineNo">1260</span><a name="line.1260"></a>
-<span class="sourceLineNo">1261</span>  static abstract class AsyncTest 
extends TestBase {<a name="line.1261"></a>
-<span class="sourceLineNo">1262</span>    protected AsyncConnection 
connection;<a name="line.1262"></a>
-<span class="sourceLineNo">1263</span><a name="line.1263"></a>
-<span class="sourceLineNo">1264</span>    AsyncTest(final AsyncConnection con, 
final TestOptions options, final Status status) {<a name="line.1264"></a>
-<span class="sourceLineNo">1265</span>      super(con == null ? 
HBaseConfiguration.create() : con.getConfiguration(), options, status);<a 
name="line.1265"></a>
-<span class="sourceLineNo">1266</span>      this.connection = con;<a 
name="line.1266"></a>
-<span class="sourceLineNo">1267</span>    }<a name="line.1267"></a>
-<span class="sourceLineNo">1268</span><a name="line.1268"></a>
-<span class="sourceLineNo">1269</span>    @Override<a name="line.1269"></a>
-<span class="sourceLineNo">1270</span>    void createConnection() {<a 
name="line.1270"></a>
-<span class="sourceLineNo">1271</span>      if (!opts.isOneCon()) {<a 
name="line.1271"></a>
-<span class="sourceLineNo">1272</span>        try {<a name="line.1272"></a>
-<span class="sourceLineNo">1273</span>          this.connection = 
ConnectionFactory.createAsyncConnection(conf).get();<a name="line.1273"></a>
-<span class="sourceLineNo">1274</span>        } catch (InterruptedException | 
ExecutionException e) {<a name="line.1274"></a>
-<span class="sourceLineNo">1275</span>          LOG.error("Failed to create 
async connection", e);<a name="line.1275"></a>
-<span class="sourceLineNo">1276</span>        }<a name="line.1276"></a>
-<span class="sourceLineNo">1277</span>      }<a name="line.1277"></a>
-<span class="sourceLineNo">1278</span>    }<a name="line.1278"></a>
-<span class="sourceLineNo">1279</span><a name="line.1279"></a>
-<span class="sourceLineNo">1280</span>    @Override<a name="line.1280"></a>
-<span class="sourceLineNo">1281</span>    void closeConnection() throws 
IOException {<a name="line.1281"></a>
-<span class="sourceLineNo">1282</span>      if (!opts.isOneCon()) {<a 
name="line.1282"></a>
-<span class="sourceLineNo">1283</span>        this.connection.close();<a 
name="line.1283"></a>
-<span class="sourceLineNo">1284</span>      }<a name="line.1284"></a>
-<span class="sourceLineNo">1285</span>    }<a name="line.1285"></a>
-<span class="sourceLineNo">1286</span>  }<a name="line.1286"></a>
-<span class="sourceLineNo">1287</span><a name="line.1287"></a>
-<span class="sourceLineNo">1288</span>  static abstract class TableTest 
extends Test {<a name="line.1288"></a>
-<span class="sourceLineNo">1289</span>    protected Table table;<a 
name="line.1289"></a>
+<span class="sourceLineNo">1253</span>    /**<a name="line.1253"></a>
+<span class="sourceLineNo">1254</span>     * Provides an extension point for 
tests that don't want a per row invocation.<a name="line.1254"></a>
+<span class="sourceLineNo">1255</span>     */<a name="line.1255"></a>
+<span class="sourceLineNo">1256</span>    void testTimed() throws IOException, 
InterruptedException {<a name="line.1256"></a>
+<span class="sourceLineNo">1257</span>      int startRow = getStartRow();<a 
name="line.1257"></a>
+<span class="sourceLineNo">1258</span>      int lastRow = getLastRow();<a 
name="line.1258"></a>
+<span class="sourceLineNo">1259</span>      
TraceUtil.addSampler(traceSampler);<a name="line.1259"></a>
+<span class="sourceLineNo">1260</span>      // Report on completion of 1/10th 
of total.<a name="line.1260"></a>
+<span class="sourceLineNo">1261</span>      for (int ii = 0; ii &lt; 
opts.cycles; ii++) {<a name="line.1261"></a>
+<span class="sourceLineNo">1262</span>        if (opts.cycles &gt; 1) 
LOG.info("Cycle=" + ii + " of " + opts.cycles);<a name="line.1262"></a>
+<span class="sourceLineNo">1263</span>        for (int i = startRow; i &lt; 
lastRow; i++) {<a name="line.1263"></a>
+<span class="sourceLineNo">1264</span>          if (i % everyN != 0) 
continue;<a name="line.1264"></a>
+<span class="sourceLineNo">1265</span>          long startTime = 
System.nanoTime();<a name="line.1265"></a>
+<span class="sourceLineNo">1266</span>          try (TraceScope scope = 
TraceUtil.createTrace("test row")){<a name="line.1266"></a>
+<span class="sourceLineNo">1267</span>            testRow(i);<a 
name="line.1267"></a>
+<span class="sourceLineNo">1268</span>          }<a name="line.1268"></a>
+<span class="sourceLineNo">1269</span>          if ( (i - startRow) &gt; 
opts.measureAfter) {<a name="line.1269"></a>
+<span class="sourceLineNo">1270</span>            // If multiget is enabled, 
say set to 10, testRow() returns immediately first 9 times<a 
name="line.1270"></a>
+<span class="sourceLineNo">1271</span>            // and sends the actual get 
request in the 10th iteration. We should only set latency<a 
name="line.1271"></a>
+<span class="sourceLineNo">1272</span>            // when actual request is 
sent because otherwise it turns out to be 0.<a name="line.1272"></a>
+<span class="sourceLineNo">1273</span>            if (opts.multiGet == 0 || (i 
- startRow + 1) % opts.multiGet == 0) {<a name="line.1273"></a>
+<span class="sourceLineNo">1274</span>              
latencyHistogram.update((System.nanoTime() - startTime) / 1000);<a 
name="line.1274"></a>
+<span class="sourceLineNo">1275</span>            }<a name="line.1275"></a>
+<span class="sourceLineNo">1276</span>            if (status != null 
&amp;&amp; i &gt; 0 &amp;&amp; (i % getReportingPeriod()) == 0) {<a 
name="line.1276"></a>
+<span class="sourceLineNo">1277</span>              
status.setStatus(generateStatus(startRow, i, lastRow));<a name="line.1277"></a>
+<span class="sourceLineNo">1278</span>            }<a name="line.1278"></a>
+<span class="sourceLineNo">1279</span>          }<a name="line.1279"></a>
+<span class="sourceLineNo">1280</span>        }<a name="line.1280"></a>
+<span class="sourceLineNo">1281</span>      }<a name="line.1281"></a>
+<span class="sourceLineNo">1282</span>    }<a name="line.1282"></a>
+<span class="sourceLineNo">1283</span><a name="line.1283"></a>
+<span class="sourceLineNo">1284</span>    /**<a name="line.1284"></a>
+<span class="sourceLineNo">1285</span>     * @return Subset of the histograms' 
calculation.<a name="line.1285"></a>
+<span class="sourceLineNo">1286</span>     */<a name="line.1286"></a>
+<span class="sourceLineNo">1287</span>    public String 
getShortLatencyReport() {<a name="line.1287"></a>
+<span class="sourceLineNo">1288</span>      return 
YammerHistogramUtils.getShortHistogramReport(this.latencyHistogram);<a 
name="line.1288"></a>
+<span class="sourceLineNo">1289</span>    }<a name="line.1289"></a>
 <span class="sourceLineNo">1290</span><a name="line.1290"></a>
-<span class="sourceLineNo">1291</span>    TableTest(Connection con, 
TestOptions options, Status status) {<a name="line.1291"></a>
-<span class="sourceLineNo">1292</span>      super(con, options, status);<a 
name="line.1292"></a>
-<span class="sourceLineNo">1293</span>    }<a name="line.1293"></a>
-<span class="sourceLineNo">1294</span><a name="line.1294"></a>
-<span class="sourceLineNo">1295</span>    @Override<a name="line.1295"></a>
-<span class="sourceLineNo">1296</span>    void onStartup() throws IOException 
{<a name="line.1296"></a>
-<span class="sourceLineNo">1297</span>      this.table = 
connection.getTable(TableName.valueOf(opts.tableName));<a name="line.1297"></a>
-<span class="sourceLineNo">1298</span>    }<a name="line.1298"></a>
-<span class="sourceLineNo">1299</span><a name="line.1299"></a>
-<span class="sourceLineNo">1300</span>    @Override<a name="line.1300"></a>
-<span class="sourceLineNo">1301</span>    void onTakedown() throws IOException 
{<a name="line.1301"></a>
-<span class="sourceLineNo">1302</span>      table.close();<a 
name="line.1302"></a>
-<span class="sourceLineNo">1303</span>    }<a name="line.1303"></a>
-<span class="sourceLineNo">1304</span>  }<a name="line.1304"></a>
-<span class="sourceLineNo">1305</span><a name="line.1305"></a>
-<span class="sourceLineNo">1306</span>  static abstract class AsyncTableTest 
extends AsyncTest {<a name="line.1306"></a>
-<span class="sourceLineNo">1307</span>    protected AsyncTable&lt;?&gt; 
table;<a name="line.1307"></a>
-<span class="sourceLineNo">1308</span><a name="line.1308"></a>
-<span class="sourceLineNo">1309</span>    AsyncTableTest(AsyncConnection con, 
TestOptions options, Status status) {<a name="line.1309"></a>
-<span class="sourceLineNo">1310</span>      super(con, options, status);<a 
name="line.1310"></a>
+<span class="sourceLineNo">1291</span>    /**<a name="line.1291"></a>
+<span class="sourceLineNo">1292</span>     * @return Subset of the histograms' 
calculation.<a name="line.1292"></a>
+<span class="sourceLineNo">1293</span>     */<a name="line.1293"></a>
+<span class="sourceLineNo">1294</span>    public String 
getShortValueSizeReport() {<a name="line.1294"></a>
+<span class="sourceLineNo">1295</span>      return 
YammerHistogramUtils.getShortHistogramReport(this.valueSizeHistogram);<a 
name="line.1295"></a>
+<span class="sourceLineNo">1296</span>    }<a name="line.1296"></a>
+<span class="sourceLineNo">1297</span><a name="line.1297"></a>
+<span class="sourceLineNo">1298</span>    /*<a name="line.1298"></a>
+<span class="sourceLineNo">1299</span>    * Test for individual row.<a 
name="line.1299"></a>
+<span class="sourceLineNo">1300</span>    * @param i Row index.<a 
name="line.1300"></a>
+<span class="sourceLineNo">1301</span>    */<a name="line.1301"></a>
+<span class="sourceLineNo">1302</span>    abstract void testRow(final int i) 
throws IOException, InterruptedException;<a name="line.1302"></a>
+<span class="sourceLineNo">1303</span>  }<a name="line.1303"></a>
+<span class="sourceLineNo">1304</span><a name="line.1304"></a>
+<span class="sourceLineNo">1305</span>  static abstract class Test extends 
TestBase {<a name="line.1305"></a>
+<span class="sourceLineNo">1306</span>    protected Connection connection;<a 
name="line.1306"></a>
+<span class="sourceLineNo">1307</span><a name="line.1307"></a>
+<span class="sourceLineNo">1308</span>    Test(final Connection con, final 
TestOptions options, final Status status) {<a name="line.1308"></a>
+<span class="sourceLineNo">1309</span>      super(con == null ? 
HBaseConfiguration.create() : con.getConfiguration(), options, status);<a 
name="line.1309"></a>
+<span class="sourceLineNo">1310</span>      this.connection = con;<a 
name="line.1310"></a>
 <span class="sourceLineNo">1311</span>    }<a name="line.1311"></a>
 <span class="sourceLineNo">1312</span><a name="line.1312"></a>
 <span class="sourceLineNo">1313</span>    @Override<a name="line.1313"></a>
-<span class="sourceLineNo">1314</span>    void onStartup() throws IOException 
{<a name="line.1314"></a>
-<span class="sourceLineNo">1315</span>      this.table = 
connection.getTable(TableName.valueOf(opts.tableName));<a name="line.1315"></a>
-<span class="sourceLineNo">1316</span>    }<a name="line.1316"></a>
-<span class="sourceLineNo">1317</span><a name="line.1317"></a>
-<span class="sourceLineNo">1318</span>    @Override<a name="line.1318"></a>
-<span class="sourceLineNo">1319</span>    void onTakedown() throws IOException 
{<a name="line.1319"></a>
-<span class="sourceLineNo">1320</span>    }<a name="line.1320"></a>
-<span class="sourceLineNo">1321</span>  }<a name="line.1321"></a>
-<span class="sourceLineNo">1322</span><a name="line.1322"></a>
-<span class="sourceLineNo">1323</span>  static class AsyncRandomReadTest 
extends AsyncTableTest {<a name="line.1323"></a>
-<span class="sourceLineNo">1324</span>    private final Consistency 
consistency;<a name="line.1324"></a>
-<span class="sourceLineNo">1325</span>    private ArrayList&lt;Get&gt; gets;<a 
name="line.1325"></a>
-<span class="sourceLineNo">1326</span>    private Random rd = new Random();<a 
name="line.1326"></a>
+<span class="sourceLineNo">1314</span>    void createConnection() throws 
IOException {<a name="line.1314"></a>
+<span class="sourceLineNo">1315</span>      if (!opts.isOneCon()) {<a 
name="line.1315"></a>
+<span class="sourceLineNo">1316</span>        this.connection = 
ConnectionFactory.createConnection(conf);<a name="line.1316"></a>
+<span class="sourceLineNo">1317</span>      }<a name="line.1317"></a>
+<span class="sourceLineNo">1318</span>    }<a name="line.1318"></a>
+<span class="sourceLineNo">1319</span><a name="line.1319"></a>
+<span class="sourceLineNo">1320</span>    @Override<a name="line.1320"></a>
+<span class="sourceLineNo">1321</span>    void closeConnection() throws 
IOException {<a name="line.1321"></a>
+<span class="sourceLineNo">1322</span>      if (!opts.isOneCon()) {<a 
name="line.1322"></a>
+<span class="sourceLineNo">1323</span>        this.connection.close();<a 
name="line.1323"></a>
+<span class="sourceLineNo">1324</span>      }<a name="line.1324"></a>
+<span class="sourceLineNo">1325</span>    }<a name="line.1325"></a>
+<span class="sourceLineNo">1326</span>  }<a name="line.1326"></a>
 <span class="sourceLineNo">1327</span><a name="line.1327"></a>
-<span class="sourceLineNo">1328</span>    AsyncRandomReadTest(AsyncConnection 
con, TestOptions options, Status status) {<a name="line.1328"></a>
-<span class="sourceLineNo">1329</span>      super(con, options, status);<a 
name="line.1329"></a>
-<span class="sourceLineNo">1330</span>      consistency = options.replicas == 
DEFAULT_OPTS.replicas ? null : Consistency.TIMELINE;<a name="line.1330"></a>
-<span class="sourceLineNo">1331</span>      if (opts.multiGet &gt; 0) {<a 
name="line.1331"></a>
-<span class="sourceLineNo">1332</span>        LOG.info("MultiGet enabled. 
Sending GETs in batches of " + opts.multiGet + ".");<a name="line.1332"></a>
-<span class="sourceLineNo">1333</span>        this.gets = new 
ArrayList&lt;&gt;(opts.multiGet);<a name="line.1333"></a>
-<span class="sourceLineNo">1334</span>      }<a name="line.1334"></a>
-<span class="sourceLineNo">1335</span>    }<a name="line.1335"></a>
-<span class="sourceLineNo">1336</span><a name="line.1336"></a>
-<span class="sourceLineNo">1337</span>    @Override<a name="line.1337"></a>
-<span class="sourceLineNo">1338</span>    void testRow(final int i) throws 
IOException, InterruptedException {<a name="line.1338"></a>
-<span class="sourceLineNo">1339</span>      if (opts.randomSleep &gt; 0) {<a 
name="line.1339"></a>
-<span class="sourceLineNo">1340</span>        
Thread.sleep(rd.nextInt(opts.randomSleep));<a name="line.1340"></a>
-<span class="sourceLineNo">1341</span>      }<a name="line.1341"></a>
-<span class="sourceLineNo">1342</span>      Get get = new 
Get(getRandomRow(this.rand, opts.totalRows));<a name="line.1342"></a>
-<span class="sourceLineNo">1343</span>      if (opts.addColumns) {<a 
name="line.1343"></a>
-<span class="sourceLineNo">1344</span>        get.addColumn(FAMILY_NAME, 
QUALIFIER_NAME);<a name="line.1344"></a>
-<span class="sourceLineNo">1345</span>      } else {<a name="line.1345"></a>
-<span class="sourceLineNo">1346</span>        get.addFamily(FAMILY_NAME);<a 
name="line.1346"></a>
-<span class="sourceLineNo">1347</span>      }<a name="line.1347"></a>
-<span class="sourceLineNo">1348</span>      if (opts.filterAll) {<a 
name="line.1348"></a>
-<span class="sourceLineNo">1349</span>        get.setFilter(new 
FilterAllFilter());<a name="line.1349"></a>
-<span class="sourceLineNo">1350</span>      }<a name="line.1350"></a>
-<span class="sourceLineNo">1351</span>      get.setConsistency(consistency);<a 
name="line.1351"></a>
-<span class="sourceLineNo">1352</span>      if (LOG.isTraceEnabled()) 
LOG.trace(get.toString());<a name="line.1352"></a>
-<span class="sourceLineNo">1353</span>      try {<a name="line.1353"></a>
-<span class="sourceLineNo">1354</span>        if (opts.multiGet &gt; 0) {<a 
name="line.1354"></a>
-<span class="sourceLineNo">1355</span>          this.gets.add(get);<a 
name="line.1355"></a>
-<span class="sourceLineNo">1356</span>          if (this.gets.size() == 
opts.multiGet) {<a name="line.1356"></a>
-<span class="sourceLineNo">1357</span>            Result[] rs =<a 
name="line.1357"></a>
-<span class="sourceLineNo">1358</span>                
this.table.get(this.gets).stream().map(f -&gt; 
propagate(f::get)).toArray(Result[]::new);<a name="line.1358"></a>
-<span class="sourceLineNo">1359</span>            updateValueSize(rs);<a 
name="line.1359"></a>
-<span class="sourceLineNo">1360</span>            this.gets.clear();<a 
name="line.1360"></a>
-<span class="sourceLineNo">1361</span>          }<a name="line.1361"></a>
-<span class="sourceLineNo">1362</span>        } else {<a name="line.1362"></a>
-<span class="sourceLineNo">1363</span>          
updateValueSize(this.table.get(get).get());<a name="line.1363"></a>
-<span class="sourceLineNo">1364</span>        }<a name="line.1364"></a>
-<span class="sourceLineNo">1365</span>      } catch (ExecutionException e) {<a 
name="line.1365"></a>
-<span class="sourceLineNo">1366</span>        throw new IOException(e);<a 
name="line.1366"></a>
-<span class="sourceLineNo">1367</span>      }<a name="line.1367"></a>
-<span class="sourceLineNo">1368</span>    }<a name="line.1368"></a>
-<span class="sourceLineNo">1369</span><a name="line.1369"></a>
-<span class="sourceLineNo">1370</span>    public static RuntimeException 
runtime(Throwable e) {<a name="line.1370"></a>
-<span class="sourceLineNo">1371</span>      if (e instanceof RuntimeException) 
{<a name="line.1371"></a>
-<span class="sourceLineNo">1372</span>        return (RuntimeException) e;<a 
name="line.1372"></a>
-<span class="sourceLineNo">1373</span>      }<a name="line.1373"></a>
-<span class="sourceLineNo">1374</span>      return new RuntimeException(e);<a 
name="line.1374"></a>
-<span class="sourceLineNo">1375</span>    }<a name="line.1375"></a>
-<span class="sourceLineNo">1376</span><a name="line.1376"></a>
-<span class="sourceLineNo">1377</span>    public static &lt;V&gt; V 
propagate(Callable&lt;V&gt; callable) {<a name="line.1377"></a>
-<span class="sourceLineNo">1378</span>      try {<a name="line.1378"></a>
-<span class="sourceLineNo">1379</span>        return callable.call();<a 
name="line.1379"></a>
-<span class="sourceLineNo">1380</span>      } catch (Exception e) {<a 
name="line.1380"></a>
-<span class="sourceLineNo">1381</span>        throw runtime(e);<a 
name="line.1381"></a>
-<span class="sourceLineNo">1382</span>      }<a name="line.1382"></a>
+<span class="sourceLineNo">1328</span>  static abstract class AsyncTest 
extends TestBase {<a name="line.1328"></a>
+<span class="sourceLineNo">1329</span>    protected AsyncConnection 
connection;<a name="line.1329"></a>
+<span class="sourceLineNo">1330</span><a name="line.1330"></a>
+<span class="sourceLineNo">1331</span>    AsyncTest(final AsyncConnection con, 
final TestOptions options, final Status status) {<a name="line.1331"></a>
+<span class="sourceLineNo">1332</span>      super(con == null ? 
HBaseConfiguration.create() : con.getConfiguration(), options, status);<a 
name="line.1332"></a>
+<span class="sourceLineNo">1333</span>      this.connection = con;<a 
name="line.1333"></a>
+<span class="sourceLineNo">1334</span>    }<a name="line.1334"></a>
+<span class="sourceLineNo">1335</span><a name="line.1335"></a>
+<span class="sourceLineNo">1336</span>    @Override<a name="line.1336"></a>
+<span class="sourceLineNo">1337</span>    void createConnection() {<a 
name="line.1337"></a>
+<span class="sourceLineNo">1338</span>      if (!opts.isOneCon()) {<a 
name="line.1338"></a>
+<span class="sourceLineNo">1339</span>        try {<a name="line.1339"></a>
+<span class="sourceLineNo">1340</span>          this.connection = 
ConnectionFactory.createAsyncConnection(conf).get();<a name="line.1340"></a>
+<span class="sourceLineNo">1341</span>        } catch (InterruptedException | 
ExecutionException e) {<a name="line.1341"></a>
+<span class="sourceLineNo">1342</span>          LOG.error("Failed to create 
async connection", e);<a name="line.1342"></a>
+<span class="sourceLineNo">1343</span>        }<a name="line.1343"></a>
+<span class="sourceLineNo">1344</span>      }<a name="line.1344"></a>
+<span class="sourceLineNo">1345</span>    }<a name="line.1345"></a>
+<span class="sourceLineNo">1346</span><a name="line.1346"></a>
+<span class="sourceLineNo">1347</span>    @Override<a name="line.1347"></a>
+<span class="sourceLineNo">1348</span>    void closeConnection() throws 
IOException {<a name="line.1348"></a>
+<span class="sourceLineNo">1349</span>      if (!opts.isOneCon()) {<a 
name="line.1349"></a>
+<span class="sourceLineNo">1350</span>        this.connection.close();<a 
name="line.1350"></a>
+<span class="sourceLineNo">1351</span>      }<a name="line.1351"></a>
+<span class="sourceLineNo">1352</span>    }<a name="line.1352"></a>
+<span class="sourceLineNo">1353</span>  }<a name="line.1353"></a>
+<span class="sourceLineNo">1354</span><a name="line.1354"></a>
+<span class="sourceLineNo">1355</span>  static abstract class TableTest 
extends Test {<a name="line.1355"></a>
+<span class="sourceLineNo">1356</span>    protected Table table;<a 
name="line.1356"></a>
+<span class="sourceLineNo">1357</span><a name="line.1357"></a>
+<span class="sourceLineNo">1358</span>    TableTest(Connection con, 
TestOptions options, Status status) {<a name="line.1358"></a>
+<span class="sourceLineNo">1359</span>      super(con, options, status);<a 
name="line.1359"></a>
+<span class="sourceLineNo">1360</span>    }<a name="line.1360"></a>
+<span class="sourceLineNo">1361</span><a name="line.1361"></a>
+<span class="sourceLineNo">1362</span>    @Override<a name="line.1362"></a>
+<span class="sourceLineNo">1363</span>    void onStartup() throws IOException 
{<a name="line.1363"></a>
+<span class="sourceLineNo">1364</span>      this.table = 
connection.getTable(TableName.valueOf(opts.tableName));<a name="line.1364"></a>
+<span class="sourceLineNo">1365</span>    }<a name="line.1365"></a>
+<span class="sourceLineNo">1366</span><a name="line.1366"></a>
+<span class="sourceLineNo">1367</span>    @Override<a name="line.1367"></a>
+<span class="sourceLineNo">1368</span>    void onTakedown() throws IOException 
{<a name="line.1368"></a>
+<span class="sourceLineNo">1369</span>      table.close();<a 
name="line.1369"></a>
+<span class="sourceLineNo">1370</span>    }<a name="line.1370"></a>
+<span class="sourceLineNo">1371</span>  }<a name="line.1371"></a>
+<span class="sourceLineNo">1372</span><a name="line.1372"></a>
+<span class="sourceLineNo">1373</span>  static abstract class AsyncTableTest 
extends AsyncTest {<a name="line.1373"></a>
+<span class="sourceLineNo">1374</span>    protected AsyncTable&lt;?&gt; 
table;<a name="line.1374"></a>
+<span class="sourceLineNo">1375</span><a name="line.1375"></a>
+<span class="sourceLineNo">1376</span>    AsyncTableTest(AsyncConnection con, 
TestOptions options, Status status) {<a name="line.1376"></a>
+<span class="sourceLineNo">1377</span>      super(con, options, status);<a 
name="line.1377"></a>
+<span class="sourceLineNo">1378</span>    }<a name="line.1378"></a>
+<span class="sourceLineNo">1379</span><a name="line.1379"></a>
+<span class="sourceLineNo">1380</span>    @Override<a name="line.1380"></a>
+<span class="sourceLineNo">1381</span>    void onStartup() throws IOException 
{<a name="line.1381"></a>
+<span class="sourceLineNo">1382</span>      this.table = 
connection.getTable(TableName.valueOf(opts.tableName));<a name="line.1382"></a>
 <span class="sourceLineNo">1383</span>    }<a name="line.1383"></a>
 <span class="sourceLineNo">1384</span><a name="line.1384"></a>
 <span class="sourceLineNo">1385</span>    @Override<a name="line.1385"></a>
-<span class="sourceLineNo">1386</span>    protected int getReportingPeriod() 
{<a name="line.1386"></a>
-<span class="sourceLineNo">1387</span>      int period = opts.perClientRunRows 
/ 10;<a name="line.1387"></a>
-<span class="sourceLineNo">1388</span>      return period == 0 ? 
opts.perClientRunRows : period;<a name="line.1388"></a>
-<span class="sourceLineNo">1389</span>    }<a name="line.1389"></a>
-<span class="sourceLineNo">1390</span><a name="line.1390"></a>
-<span class="sourceLineNo">1391</span>    @Override<a name="line.1391"></a>
-<span class="sourceLineNo">1392</span>    protected void testTakedown() throws 
IOException {<a name="line.1392"></a>
-<span class="sourceLineNo">1393</span>      if (this.gets != null &amp;&amp; 
this.gets.size() &gt; 0) {<a name="line.1393"></a>
-<span class="sourceLineNo">1394</span>        this.table.get(gets);<a 
name="line.1394"></a>
-<span class="sourceLineNo">1395</span>        this.gets.clear();<a 
name="line.1395"></a>
-<span class="sourceLineNo">1396</span>      }<a name="line.1396"></a>
-<span class="sourceLineNo">1397</span>      super.testTakedown();<a 
name="line.1397"></a>
-<span class="sourceLineNo">1398</span>    }<a name="line.1398"></a>
-<span class="sourceLineNo">1399</span>  }<a name="line.1399"></a>
-<span class="sourceLineNo">1400</span><a name="line.1400"></a>
-<span class="sourceLineNo">1401</span>  static class AsyncRandomWriteTest 
extends AsyncTableTest {<a name="line.1401"></a>
-<span class="sourceLineNo">1402</span>    AsyncRandomWriteTest(AsyncConnection 
con, TestOptions options, Status status) {<a name="line.1402"></a>
-<span class="sourceLineNo">1403</span>      super(con, options, status);<a 
name="line.1403"></a>
-<span class="sourceLineNo">1404</span>    }<a name="line.1404"></a>
-<span class="sourceLineNo">1405</span><a name="line.1405"></a>
-<span class="sourceLineNo">1406</span>    @Override<a name="line.1406"></a>
-<span class="sourceLineNo">1407</span>    void testRow(final int i) throws 
IOException, InterruptedException {<a name="line.1407"></a>
-<span class="sourceLineNo">1408</span>      byte[] row = 
getRandomRow(this.rand, opts.totalRows);<a name="line.1408"></a>
-<span class="sourceLineNo">1409</span>      Put put = new Put(row);<a 
name="line.1409"></a>
-<span class="sourceLineNo">1410</span>      for (int column = 0; column &lt; 
opts.columns; column++) {<a name="line.1410"></a>
-<span class="sourceLineNo">1411</span>        byte[] qualifier = column == 0 ? 
COLUMN_ZERO : Bytes.toBytes("" + column);<a name="line.1411"></a>
-<span class="sourceLineNo">1412</span>        byte[] value = 
generateData(this.rand, getValueLength(this.rand));<a name="line.1412"></a>
-<span class="sourceLineNo">1413</span>        if (opts.useTags) {<a 
name="line.1413"></a>
-<span class="sourceLineNo">1414</span>          byte[] tag = 
generateData(this.rand, TAG_LENGTH);<a name="line.1414"></a>
-<span class="sourceLineNo">1415</span>          Tag[] tags = new 
Tag[opts.noOfTags];<a name="line.1415"></a>
-<span class="sourceLineNo">1416</span>          for (int n = 0; n &lt; 
opts.noOfTags; n++) {<a name="line.1416"></a>
-<span class="sourceLineNo">1417</span>            Tag t = new 
ArrayBackedTag((byte) n, tag);<a name="line.1417"></a>
-<span class="sourceLineNo">1418</span>            tags[n] = t;<a 
name="line.1418"></a>
-<span class="sourceLineNo">1419</span>          }<a name="line.1419"></a>
-<span class="sourceLineNo">1420</span>          KeyValue kv =<a 
name="line.1420"></a>
-<span class="sourceLineNo">1421</span>              new KeyValue(row, 
FAMILY_NAME, qualifier, HConstants.LATEST_TIMESTAMP, value, tags);<a 
name="line.1421"></a>
-<span class="sourceLineNo">1422</span>          put.add(kv);<a 
name="line.1422"></a>
-<span class="sourceLineNo">1423</span>          
updateValueSize(kv.getValueLength());<a name="line.1423"></a>
-<span class="sourceLineNo">1424</span>        } else {<a name="line.1424"></a>
-<span class="sourceLineNo">1425</span>          put.addColumn(FAMILY_NAME, 
qualifier, value);<a name="line.1425"></a>
-<span class="sourceLineNo">1426</span>          
updateValueSize(value.length);<a name="line.1426"></a>
-<span class="sourceLineNo">1427</span>        }<a name="line.1427"></a>
-<span class="sourceLineNo">1428</span>      }<a name="line.1428"></a>
-<span class="sourceLineNo">1429</span>      put.setDurability(opts.writeToWAL 
? Durability.SYNC_WAL : Durability.SKIP_WAL);<a name="line.1429"></a>
-<span class="sourceLineNo">1430</span>      try {<a name="line.1430"></a>
-<span class="sourceLineNo">1431</span>        table.put(put).get();<a 
name="line.1431"></a>
-<span class="sourceLineNo">1432</span>      } catch (ExecutionException e) {<a 
name="line.1432"></a>
-<span class="sourceLineNo">1433</span>        throw new IOException(e);<a 
name="line.1433"></a>
-<span class="sourceLineNo">1434</span>      }<a name="line.1434"></a>
-<span class="sourceLineNo">1435</span>    }<a name="line.1435"></a>
-<span class="sourceLineNo">1436</span>  }<a name="line.1436"></a>
-<span class="sourceLineNo">1437</span><a name="line.1437"></a>
-<span class="sourceLineNo">1438</span>  static class AsyncScanTest extends 
AsyncTableTest {<a name="line.1438"></a>
-<span class="sourceLineNo">1439</span>    private ResultScanner testScanner;<a 
name="line.1439"></a>
-<span class="sourceLineNo">1440</span>    private AsyncTable&lt;?&gt; 
asyncTable;<a name="line.1440"></a>
-<span class="sourceLineNo">1441</span><a name="line.1441"></a>
-<span class="sourceLineNo">1442</span>    AsyncScanTest(AsyncConnection con, 
TestOptions options, Status status) {<a name="line.1442"></a>
-<span class="sourceLineNo">1443</span>      super(con, options, status);<a 
name="line.1443"></a>
-<span class="sourceLineNo">1444</span>    }<a name="line.1444"></a>
-<span class="sourceLineNo">1445</span><a name="line.1445"></a>
-<span class="sourceLineNo">1446</span>    @Override<a name="line.1446"></a>
-<span class="sourceLineNo">1447</span>    void onStartup() throws IOException 
{<a name="line.1447"></a>
-<span class="sourceLineNo">1448</span>      this.asyncTable =<a 
name="line.1448"></a>
-<span class="sourceLineNo">1449</span>          
connection.getTable(TableName.valueOf(opts.tableName),<a name="line.1449"></a>
-<span class="sourceLineNo">1450</span>            
Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()));<a 
name="line.1450"></a>
-<span class="sourceLineNo">1451</span>    }<a name="line.1451"></a>
-<span class="sourceLineNo">1452</span><a name="line.1452"></a>
-<span class="sourceLineNo">1453</span>    @Override<a name="line.1453"></a>
-<span class="sourceLineNo">1454</span>    void testTakedown() throws 
IOException {<a name="line.1454"></a>
-<span class="sourceLineNo">1455</

<TRUNCATED>

Reply via email to