hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From git-site-r...@apache.org
Subject [21/43] hbase-site git commit: Published site at 993e74b7471a7fe483eae59ab198bb2533c55031.
Date Mon, 27 Aug 2018 14:47:26 GMT
http://git-wip-us.apache.org/repos/asf/hbase-site/blob/e312f773/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.FilteredScanTest.html
----------------------------------------------------------------------
diff --git a/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.FilteredScanTest.html b/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.FilteredScanTest.html
index e38835a..e11b644 100644
--- a/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.FilteredScanTest.html
+++ b/testdevapidocs/src-html/org/apache/hadoop/hbase/PerformanceEvaluation.FilteredScanTest.html
@@ -2220,698 +2220,702 @@
 <span class="sourceLineNo">2212</span><a name="line.2212"></a>
 <span class="sourceLineNo">2213</span>    FilteredScanTest(Connection con, TestOptions options, Status status) {<a name="line.2213"></a>
 <span class="sourceLineNo">2214</span>      super(con, options, status);<a name="line.2214"></a>
-<span class="sourceLineNo">2215</span>    }<a name="line.2215"></a>
-<span class="sourceLineNo">2216</span><a name="line.2216"></a>
-<span class="sourceLineNo">2217</span>    @Override<a name="line.2217"></a>
-<span class="sourceLineNo">2218</span>    boolean testRow(int i) throws IOException {<a name="line.2218"></a>
-<span class="sourceLineNo">2219</span>      byte[] value = generateData(this.rand, getValueLength(this.rand));<a name="line.2219"></a>
-<span class="sourceLineNo">2220</span>      Scan scan = constructScan(value);<a name="line.2220"></a>
-<span class="sourceLineNo">2221</span>      ResultScanner scanner = null;<a name="line.2221"></a>
-<span class="sourceLineNo">2222</span>      try {<a name="line.2222"></a>
-<span class="sourceLineNo">2223</span>        scanner = this.table.getScanner(scan);<a name="line.2223"></a>
-<span class="sourceLineNo">2224</span>        for (Result r = null; (r = scanner.next()) != null;) {<a name="line.2224"></a>
-<span class="sourceLineNo">2225</span>          updateValueSize(r);<a name="line.2225"></a>
-<span class="sourceLineNo">2226</span>        }<a name="line.2226"></a>
-<span class="sourceLineNo">2227</span>      } finally {<a name="line.2227"></a>
-<span class="sourceLineNo">2228</span>        if (scanner != null) {<a name="line.2228"></a>
-<span class="sourceLineNo">2229</span>          updateScanMetrics(scanner.getScanMetrics());<a name="line.2229"></a>
-<span class="sourceLineNo">2230</span>          scanner.close();<a name="line.2230"></a>
-<span class="sourceLineNo">2231</span>        }<a name="line.2231"></a>
-<span class="sourceLineNo">2232</span>      }<a name="line.2232"></a>
-<span class="sourceLineNo">2233</span>      return true;<a name="line.2233"></a>
-<span class="sourceLineNo">2234</span>    }<a name="line.2234"></a>
-<span class="sourceLineNo">2235</span><a name="line.2235"></a>
-<span class="sourceLineNo">2236</span>    protected Scan constructScan(byte[] valuePrefix) throws IOException {<a name="line.2236"></a>
-<span class="sourceLineNo">2237</span>      FilterList list = new FilterList();<a name="line.2237"></a>
-<span class="sourceLineNo">2238</span>      Filter filter = new SingleColumnValueFilter(FAMILY_ZERO, COLUMN_ZERO,<a name="line.2238"></a>
-<span class="sourceLineNo">2239</span>        CompareOperator.EQUAL, new BinaryComparator(valuePrefix));<a name="line.2239"></a>
-<span class="sourceLineNo">2240</span>      list.addFilter(filter);<a name="line.2240"></a>
-<span class="sourceLineNo">2241</span>      if (opts.filterAll) {<a name="line.2241"></a>
-<span class="sourceLineNo">2242</span>        list.addFilter(new FilterAllFilter());<a name="line.2242"></a>
-<span class="sourceLineNo">2243</span>      }<a name="line.2243"></a>
-<span class="sourceLineNo">2244</span>      Scan scan = new Scan().setCaching(opts.caching).setCacheBlocks(opts.cacheBlocks)<a name="line.2244"></a>
-<span class="sourceLineNo">2245</span>          .setAsyncPrefetch(opts.asyncPrefetch).setReadType(opts.scanReadType)<a name="line.2245"></a>
-<span class="sourceLineNo">2246</span>          .setScanMetricsEnabled(true);<a name="line.2246"></a>
-<span class="sourceLineNo">2247</span>      if (opts.addColumns) {<a name="line.2247"></a>
-<span class="sourceLineNo">2248</span>        for (int column = 0; column &lt; opts.columns; column++) {<a name="line.2248"></a>
-<span class="sourceLineNo">2249</span>          byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);<a name="line.2249"></a>
-<span class="sourceLineNo">2250</span>          scan.addColumn(FAMILY_ZERO, qualifier);<a name="line.2250"></a>
-<span class="sourceLineNo">2251</span>        }<a name="line.2251"></a>
-<span class="sourceLineNo">2252</span>      } else {<a name="line.2252"></a>
-<span class="sourceLineNo">2253</span>        scan.addFamily(FAMILY_ZERO);<a name="line.2253"></a>
-<span class="sourceLineNo">2254</span>      }<a name="line.2254"></a>
-<span class="sourceLineNo">2255</span>      scan.setFilter(list);<a name="line.2255"></a>
-<span class="sourceLineNo">2256</span>      return scan;<a name="line.2256"></a>
-<span class="sourceLineNo">2257</span>    }<a name="line.2257"></a>
-<span class="sourceLineNo">2258</span>  }<a name="line.2258"></a>
-<span class="sourceLineNo">2259</span><a name="line.2259"></a>
-<span class="sourceLineNo">2260</span>  /**<a name="line.2260"></a>
-<span class="sourceLineNo">2261</span>   * Compute a throughput rate in MB/s.<a name="line.2261"></a>
-<span class="sourceLineNo">2262</span>   * @param rows Number of records consumed.<a name="line.2262"></a>
-<span class="sourceLineNo">2263</span>   * @param timeMs Time taken in milliseconds.<a name="line.2263"></a>
-<span class="sourceLineNo">2264</span>   * @return String value with label, ie '123.76 MB/s'<a name="line.2264"></a>
-<span class="sourceLineNo">2265</span>   */<a name="line.2265"></a>
-<span class="sourceLineNo">2266</span>  private static String calculateMbps(int rows, long timeMs, final int valueSize, int families, int columns) {<a name="line.2266"></a>
-<span class="sourceLineNo">2267</span>    BigDecimal rowSize = BigDecimal.valueOf(ROW_LENGTH +<a name="line.2267"></a>
-<span class="sourceLineNo">2268</span>      ((valueSize + (FAMILY_NAME_BASE.length()+1) + COLUMN_ZERO.length) * columns) * families);<a name="line.2268"></a>
-<span class="sourceLineNo">2269</span>    BigDecimal mbps = BigDecimal.valueOf(rows).multiply(rowSize, CXT)<a name="line.2269"></a>
-<span class="sourceLineNo">2270</span>      .divide(BigDecimal.valueOf(timeMs), CXT).multiply(MS_PER_SEC, CXT)<a name="line.2270"></a>
-<span class="sourceLineNo">2271</span>      .divide(BYTES_PER_MB, CXT);<a name="line.2271"></a>
-<span class="sourceLineNo">2272</span>    return FMT.format(mbps) + " MB/s";<a name="line.2272"></a>
-<span class="sourceLineNo">2273</span>  }<a name="line.2273"></a>
-<span class="sourceLineNo">2274</span><a name="line.2274"></a>
-<span class="sourceLineNo">2275</span>  /*<a name="line.2275"></a>
-<span class="sourceLineNo">2276</span>   * Format passed integer.<a name="line.2276"></a>
-<span class="sourceLineNo">2277</span>   * @param number<a name="line.2277"></a>
-<span class="sourceLineNo">2278</span>   * @return Returns zero-prefixed ROW_LENGTH-byte wide decimal version of passed<a name="line.2278"></a>
-<span class="sourceLineNo">2279</span>   * number (Does absolute in case number is negative).<a name="line.2279"></a>
-<span class="sourceLineNo">2280</span>   */<a name="line.2280"></a>
-<span class="sourceLineNo">2281</span>  public static byte [] format(final int number) {<a name="line.2281"></a>
-<span class="sourceLineNo">2282</span>    byte [] b = new byte[ROW_LENGTH];<a name="line.2282"></a>
-<span class="sourceLineNo">2283</span>    int d = Math.abs(number);<a name="line.2283"></a>
-<span class="sourceLineNo">2284</span>    for (int i = b.length - 1; i &gt;= 0; i--) {<a name="line.2284"></a>
-<span class="sourceLineNo">2285</span>      b[i] = (byte)((d % 10) + '0');<a name="line.2285"></a>
-<span class="sourceLineNo">2286</span>      d /= 10;<a name="line.2286"></a>
-<span class="sourceLineNo">2287</span>    }<a name="line.2287"></a>
-<span class="sourceLineNo">2288</span>    return b;<a name="line.2288"></a>
-<span class="sourceLineNo">2289</span>  }<a name="line.2289"></a>
-<span class="sourceLineNo">2290</span><a name="line.2290"></a>
-<span class="sourceLineNo">2291</span>  /*<a name="line.2291"></a>
-<span class="sourceLineNo">2292</span>   * This method takes some time and is done inline uploading data.  For<a name="line.2292"></a>
-<span class="sourceLineNo">2293</span>   * example, doing the mapfile test, generation of the key and value<a name="line.2293"></a>
-<span class="sourceLineNo">2294</span>   * consumes about 30% of CPU time.<a name="line.2294"></a>
-<span class="sourceLineNo">2295</span>   * @return Generated random value to insert into a table cell.<a name="line.2295"></a>
-<span class="sourceLineNo">2296</span>   */<a name="line.2296"></a>
-<span class="sourceLineNo">2297</span>  public static byte[] generateData(final Random r, int length) {<a name="line.2297"></a>
-<span class="sourceLineNo">2298</span>    byte [] b = new byte [length];<a name="line.2298"></a>
-<span class="sourceLineNo">2299</span>    int i;<a name="line.2299"></a>
-<span class="sourceLineNo">2300</span><a name="line.2300"></a>
-<span class="sourceLineNo">2301</span>    for(i = 0; i &lt; (length-8); i += 8) {<a name="line.2301"></a>
-<span class="sourceLineNo">2302</span>      b[i] = (byte) (65 + r.nextInt(26));<a name="line.2302"></a>
-<span class="sourceLineNo">2303</span>      b[i+1] = b[i];<a name="line.2303"></a>
-<span class="sourceLineNo">2304</span>      b[i+2] = b[i];<a name="line.2304"></a>
-<span class="sourceLineNo">2305</span>      b[i+3] = b[i];<a name="line.2305"></a>
-<span class="sourceLineNo">2306</span>      b[i+4] = b[i];<a name="line.2306"></a>
-<span class="sourceLineNo">2307</span>      b[i+5] = b[i];<a name="line.2307"></a>
-<span class="sourceLineNo">2308</span>      b[i+6] = b[i];<a name="line.2308"></a>
-<span class="sourceLineNo">2309</span>      b[i+7] = b[i];<a name="line.2309"></a>
-<span class="sourceLineNo">2310</span>    }<a name="line.2310"></a>
-<span class="sourceLineNo">2311</span><a name="line.2311"></a>
-<span class="sourceLineNo">2312</span>    byte a = (byte) (65 + r.nextInt(26));<a name="line.2312"></a>
-<span class="sourceLineNo">2313</span>    for(; i &lt; length; i++) {<a name="line.2313"></a>
-<span class="sourceLineNo">2314</span>      b[i] = a;<a name="line.2314"></a>
-<span class="sourceLineNo">2315</span>    }<a name="line.2315"></a>
-<span class="sourceLineNo">2316</span>    return b;<a name="line.2316"></a>
-<span class="sourceLineNo">2317</span>  }<a name="line.2317"></a>
-<span class="sourceLineNo">2318</span><a name="line.2318"></a>
-<span class="sourceLineNo">2319</span>  static byte [] getRandomRow(final Random random, final int totalRows) {<a name="line.2319"></a>
-<span class="sourceLineNo">2320</span>    return format(generateRandomRow(random, totalRows));<a name="line.2320"></a>
+<span class="sourceLineNo">2215</span>      if (opts.perClientRunRows == DEFAULT_ROWS_PER_GB) {<a name="line.2215"></a>
+<span class="sourceLineNo">2216</span>        LOG.warn("Option \"rows\" unspecified. Using default value " + DEFAULT_ROWS_PER_GB +<a name="line.2216"></a>
+<span class="sourceLineNo">2217</span>                ". This could take a very long time.");<a name="line.2217"></a>
+<span class="sourceLineNo">2218</span>      }<a name="line.2218"></a>
+<span class="sourceLineNo">2219</span>    }<a name="line.2219"></a>
+<span class="sourceLineNo">2220</span><a name="line.2220"></a>
+<span class="sourceLineNo">2221</span>    @Override<a name="line.2221"></a>
+<span class="sourceLineNo">2222</span>    boolean testRow(int i) throws IOException {<a name="line.2222"></a>
+<span class="sourceLineNo">2223</span>      byte[] value = generateData(this.rand, getValueLength(this.rand));<a name="line.2223"></a>
+<span class="sourceLineNo">2224</span>      Scan scan = constructScan(value);<a name="line.2224"></a>
+<span class="sourceLineNo">2225</span>      ResultScanner scanner = null;<a name="line.2225"></a>
+<span class="sourceLineNo">2226</span>      try {<a name="line.2226"></a>
+<span class="sourceLineNo">2227</span>        scanner = this.table.getScanner(scan);<a name="line.2227"></a>
+<span class="sourceLineNo">2228</span>        for (Result r = null; (r = scanner.next()) != null;) {<a name="line.2228"></a>
+<span class="sourceLineNo">2229</span>          updateValueSize(r);<a name="line.2229"></a>
+<span class="sourceLineNo">2230</span>        }<a name="line.2230"></a>
+<span class="sourceLineNo">2231</span>      } finally {<a name="line.2231"></a>
+<span class="sourceLineNo">2232</span>        if (scanner != null) {<a name="line.2232"></a>
+<span class="sourceLineNo">2233</span>          updateScanMetrics(scanner.getScanMetrics());<a name="line.2233"></a>
+<span class="sourceLineNo">2234</span>          scanner.close();<a name="line.2234"></a>
+<span class="sourceLineNo">2235</span>        }<a name="line.2235"></a>
+<span class="sourceLineNo">2236</span>      }<a name="line.2236"></a>
+<span class="sourceLineNo">2237</span>      return true;<a name="line.2237"></a>
+<span class="sourceLineNo">2238</span>    }<a name="line.2238"></a>
+<span class="sourceLineNo">2239</span><a name="line.2239"></a>
+<span class="sourceLineNo">2240</span>    protected Scan constructScan(byte[] valuePrefix) throws IOException {<a name="line.2240"></a>
+<span class="sourceLineNo">2241</span>      FilterList list = new FilterList();<a name="line.2241"></a>
+<span class="sourceLineNo">2242</span>      Filter filter = new SingleColumnValueFilter(FAMILY_ZERO, COLUMN_ZERO,<a name="line.2242"></a>
+<span class="sourceLineNo">2243</span>        CompareOperator.EQUAL, new BinaryComparator(valuePrefix));<a name="line.2243"></a>
+<span class="sourceLineNo">2244</span>      list.addFilter(filter);<a name="line.2244"></a>
+<span class="sourceLineNo">2245</span>      if (opts.filterAll) {<a name="line.2245"></a>
+<span class="sourceLineNo">2246</span>        list.addFilter(new FilterAllFilter());<a name="line.2246"></a>
+<span class="sourceLineNo">2247</span>      }<a name="line.2247"></a>
+<span class="sourceLineNo">2248</span>      Scan scan = new Scan().setCaching(opts.caching).setCacheBlocks(opts.cacheBlocks)<a name="line.2248"></a>
+<span class="sourceLineNo">2249</span>          .setAsyncPrefetch(opts.asyncPrefetch).setReadType(opts.scanReadType)<a name="line.2249"></a>
+<span class="sourceLineNo">2250</span>          .setScanMetricsEnabled(true);<a name="line.2250"></a>
+<span class="sourceLineNo">2251</span>      if (opts.addColumns) {<a name="line.2251"></a>
+<span class="sourceLineNo">2252</span>        for (int column = 0; column &lt; opts.columns; column++) {<a name="line.2252"></a>
+<span class="sourceLineNo">2253</span>          byte [] qualifier = column == 0? COLUMN_ZERO: Bytes.toBytes("" + column);<a name="line.2253"></a>
+<span class="sourceLineNo">2254</span>          scan.addColumn(FAMILY_ZERO, qualifier);<a name="line.2254"></a>
+<span class="sourceLineNo">2255</span>        }<a name="line.2255"></a>
+<span class="sourceLineNo">2256</span>      } else {<a name="line.2256"></a>
+<span class="sourceLineNo">2257</span>        scan.addFamily(FAMILY_ZERO);<a name="line.2257"></a>
+<span class="sourceLineNo">2258</span>      }<a name="line.2258"></a>
+<span class="sourceLineNo">2259</span>      scan.setFilter(list);<a name="line.2259"></a>
+<span class="sourceLineNo">2260</span>      return scan;<a name="line.2260"></a>
+<span class="sourceLineNo">2261</span>    }<a name="line.2261"></a>
+<span class="sourceLineNo">2262</span>  }<a name="line.2262"></a>
+<span class="sourceLineNo">2263</span><a name="line.2263"></a>
+<span class="sourceLineNo">2264</span>  /**<a name="line.2264"></a>
+<span class="sourceLineNo">2265</span>   * Compute a throughput rate in MB/s.<a name="line.2265"></a>
+<span class="sourceLineNo">2266</span>   * @param rows Number of records consumed.<a name="line.2266"></a>
+<span class="sourceLineNo">2267</span>   * @param timeMs Time taken in milliseconds.<a name="line.2267"></a>
+<span class="sourceLineNo">2268</span>   * @return String value with label, ie '123.76 MB/s'<a name="line.2268"></a>
+<span class="sourceLineNo">2269</span>   */<a name="line.2269"></a>
+<span class="sourceLineNo">2270</span>  private static String calculateMbps(int rows, long timeMs, final int valueSize, int families, int columns) {<a name="line.2270"></a>
+<span class="sourceLineNo">2271</span>    BigDecimal rowSize = BigDecimal.valueOf(ROW_LENGTH +<a name="line.2271"></a>
+<span class="sourceLineNo">2272</span>      ((valueSize + (FAMILY_NAME_BASE.length()+1) + COLUMN_ZERO.length) * columns) * families);<a name="line.2272"></a>
+<span class="sourceLineNo">2273</span>    BigDecimal mbps = BigDecimal.valueOf(rows).multiply(rowSize, CXT)<a name="line.2273"></a>
+<span class="sourceLineNo">2274</span>      .divide(BigDecimal.valueOf(timeMs), CXT).multiply(MS_PER_SEC, CXT)<a name="line.2274"></a>
+<span class="sourceLineNo">2275</span>      .divide(BYTES_PER_MB, CXT);<a name="line.2275"></a>
+<span class="sourceLineNo">2276</span>    return FMT.format(mbps) + " MB/s";<a name="line.2276"></a>
+<span class="sourceLineNo">2277</span>  }<a name="line.2277"></a>
+<span class="sourceLineNo">2278</span><a name="line.2278"></a>
+<span class="sourceLineNo">2279</span>  /*<a name="line.2279"></a>
+<span class="sourceLineNo">2280</span>   * Format passed integer.<a name="line.2280"></a>
+<span class="sourceLineNo">2281</span>   * @param number<a name="line.2281"></a>
+<span class="sourceLineNo">2282</span>   * @return Returns zero-prefixed ROW_LENGTH-byte wide decimal version of passed<a name="line.2282"></a>
+<span class="sourceLineNo">2283</span>   * number (Does absolute in case number is negative).<a name="line.2283"></a>
+<span class="sourceLineNo">2284</span>   */<a name="line.2284"></a>
+<span class="sourceLineNo">2285</span>  public static byte [] format(final int number) {<a name="line.2285"></a>
+<span class="sourceLineNo">2286</span>    byte [] b = new byte[ROW_LENGTH];<a name="line.2286"></a>
+<span class="sourceLineNo">2287</span>    int d = Math.abs(number);<a name="line.2287"></a>
+<span class="sourceLineNo">2288</span>    for (int i = b.length - 1; i &gt;= 0; i--) {<a name="line.2288"></a>
+<span class="sourceLineNo">2289</span>      b[i] = (byte)((d % 10) + '0');<a name="line.2289"></a>
+<span class="sourceLineNo">2290</span>      d /= 10;<a name="line.2290"></a>
+<span class="sourceLineNo">2291</span>    }<a name="line.2291"></a>
+<span class="sourceLineNo">2292</span>    return b;<a name="line.2292"></a>
+<span class="sourceLineNo">2293</span>  }<a name="line.2293"></a>
+<span class="sourceLineNo">2294</span><a name="line.2294"></a>
+<span class="sourceLineNo">2295</span>  /*<a name="line.2295"></a>
+<span class="sourceLineNo">2296</span>   * This method takes some time and is done inline uploading data.  For<a name="line.2296"></a>
+<span class="sourceLineNo">2297</span>   * example, doing the mapfile test, generation of the key and value<a name="line.2297"></a>
+<span class="sourceLineNo">2298</span>   * consumes about 30% of CPU time.<a name="line.2298"></a>
+<span class="sourceLineNo">2299</span>   * @return Generated random value to insert into a table cell.<a name="line.2299"></a>
+<span class="sourceLineNo">2300</span>   */<a name="line.2300"></a>
+<span class="sourceLineNo">2301</span>  public static byte[] generateData(final Random r, int length) {<a name="line.2301"></a>
+<span class="sourceLineNo">2302</span>    byte [] b = new byte [length];<a name="line.2302"></a>
+<span class="sourceLineNo">2303</span>    int i;<a name="line.2303"></a>
+<span class="sourceLineNo">2304</span><a name="line.2304"></a>
+<span class="sourceLineNo">2305</span>    for(i = 0; i &lt; (length-8); i += 8) {<a name="line.2305"></a>
+<span class="sourceLineNo">2306</span>      b[i] = (byte) (65 + r.nextInt(26));<a name="line.2306"></a>
+<span class="sourceLineNo">2307</span>      b[i+1] = b[i];<a name="line.2307"></a>
+<span class="sourceLineNo">2308</span>      b[i+2] = b[i];<a name="line.2308"></a>
+<span class="sourceLineNo">2309</span>      b[i+3] = b[i];<a name="line.2309"></a>
+<span class="sourceLineNo">2310</span>      b[i+4] = b[i];<a name="line.2310"></a>
+<span class="sourceLineNo">2311</span>      b[i+5] = b[i];<a name="line.2311"></a>
+<span class="sourceLineNo">2312</span>      b[i+6] = b[i];<a name="line.2312"></a>
+<span class="sourceLineNo">2313</span>      b[i+7] = b[i];<a name="line.2313"></a>
+<span class="sourceLineNo">2314</span>    }<a name="line.2314"></a>
+<span class="sourceLineNo">2315</span><a name="line.2315"></a>
+<span class="sourceLineNo">2316</span>    byte a = (byte) (65 + r.nextInt(26));<a name="line.2316"></a>
+<span class="sourceLineNo">2317</span>    for(; i &lt; length; i++) {<a name="line.2317"></a>
+<span class="sourceLineNo">2318</span>      b[i] = a;<a name="line.2318"></a>
+<span class="sourceLineNo">2319</span>    }<a name="line.2319"></a>
+<span class="sourceLineNo">2320</span>    return b;<a name="line.2320"></a>
 <span class="sourceLineNo">2321</span>  }<a name="line.2321"></a>
 <span class="sourceLineNo">2322</span><a name="line.2322"></a>
-<span class="sourceLineNo">2323</span>  static int generateRandomRow(final Random random, final int totalRows) {<a name="line.2323"></a>
-<span class="sourceLineNo">2324</span>    return random.nextInt(Integer.MAX_VALUE) % totalRows;<a name="line.2324"></a>
+<span class="sourceLineNo">2323</span>  static byte [] getRandomRow(final Random random, final int totalRows) {<a name="line.2323"></a>
+<span class="sourceLineNo">2324</span>    return format(generateRandomRow(random, totalRows));<a name="line.2324"></a>
 <span class="sourceLineNo">2325</span>  }<a name="line.2325"></a>
 <span class="sourceLineNo">2326</span><a name="line.2326"></a>
-<span class="sourceLineNo">2327</span>  static RunResult runOneClient(final Class&lt;? extends TestBase&gt; cmd, Configuration conf,<a name="line.2327"></a>
-<span class="sourceLineNo">2328</span>      Connection con, AsyncConnection asyncCon, TestOptions opts, final Status status)<a name="line.2328"></a>
-<span class="sourceLineNo">2329</span>      throws IOException, InterruptedException {<a name="line.2329"></a>
-<span class="sourceLineNo">2330</span>    status.setStatus("Start " + cmd + " at offset " + opts.startRow + " for "<a name="line.2330"></a>
-<span class="sourceLineNo">2331</span>        + opts.perClientRunRows + " rows");<a name="line.2331"></a>
-<span class="sourceLineNo">2332</span>    long totalElapsedTime;<a name="line.2332"></a>
-<span class="sourceLineNo">2333</span><a name="line.2333"></a>
-<span class="sourceLineNo">2334</span>    final TestBase t;<a name="line.2334"></a>
-<span class="sourceLineNo">2335</span>    try {<a name="line.2335"></a>
-<span class="sourceLineNo">2336</span>      if (AsyncTest.class.isAssignableFrom(cmd)) {<a name="line.2336"></a>
-<span class="sourceLineNo">2337</span>        Class&lt;? extends AsyncTest&gt; newCmd = (Class&lt;? extends AsyncTest&gt;) cmd;<a name="line.2337"></a>
-<span class="sourceLineNo">2338</span>        Constructor&lt;? extends AsyncTest&gt; constructor =<a name="line.2338"></a>
-<span class="sourceLineNo">2339</span>            newCmd.getDeclaredConstructor(AsyncConnection.class, TestOptions.class, Status.class);<a name="line.2339"></a>
-<span class="sourceLineNo">2340</span>        t = constructor.newInstance(asyncCon, opts, status);<a name="line.2340"></a>
-<span class="sourceLineNo">2341</span>      } else {<a name="line.2341"></a>
-<span class="sourceLineNo">2342</span>        Class&lt;? extends Test&gt; newCmd = (Class&lt;? extends Test&gt;) cmd;<a name="line.2342"></a>
-<span class="sourceLineNo">2343</span>        Constructor&lt;? extends Test&gt; constructor =<a name="line.2343"></a>
-<span class="sourceLineNo">2344</span>            newCmd.getDeclaredConstructor(Connection.class, TestOptions.class, Status.class);<a name="line.2344"></a>
-<span class="sourceLineNo">2345</span>        t = constructor.newInstance(con, opts, status);<a name="line.2345"></a>
-<span class="sourceLineNo">2346</span>      }<a name="line.2346"></a>
-<span class="sourceLineNo">2347</span>    } catch (NoSuchMethodException e) {<a name="line.2347"></a>
-<span class="sourceLineNo">2348</span>      throw new IllegalArgumentException("Invalid command class: " + cmd.getName()<a name="line.2348"></a>
-<span class="sourceLineNo">2349</span>          + ".  It does not provide a constructor as described by "<a name="line.2349"></a>
-<span class="sourceLineNo">2350</span>          + "the javadoc comment.  Available constructors are: "<a name="line.2350"></a>
-<span class="sourceLineNo">2351</span>          + Arrays.toString(cmd.getConstructors()));<a name="line.2351"></a>
-<span class="sourceLineNo">2352</span>    } catch (Exception e) {<a name="line.2352"></a>
-<span class="sourceLineNo">2353</span>      throw new IllegalStateException("Failed to construct command class", e);<a name="line.2353"></a>
-<span class="sourceLineNo">2354</span>    }<a name="line.2354"></a>
-<span class="sourceLineNo">2355</span>    totalElapsedTime = t.test();<a name="line.2355"></a>
-<span class="sourceLineNo">2356</span><a name="line.2356"></a>
-<span class="sourceLineNo">2357</span>    status.setStatus("Finished " + cmd + " in " + totalElapsedTime +<a name="line.2357"></a>
-<span class="sourceLineNo">2358</span>      "ms at offset " + opts.startRow + " for " + opts.perClientRunRows + " rows" +<a name="line.2358"></a>
-<span class="sourceLineNo">2359</span>      " (" + calculateMbps((int)(opts.perClientRunRows * opts.sampleRate), totalElapsedTime,<a name="line.2359"></a>
-<span class="sourceLineNo">2360</span>          getAverageValueLength(opts), opts.families, opts.columns) + ")");<a name="line.2360"></a>
-<span class="sourceLineNo">2361</span><a name="line.2361"></a>
-<span class="sourceLineNo">2362</span>    return new RunResult(totalElapsedTime, t.getLatencyHistogram());<a name="line.2362"></a>
-<span class="sourceLineNo">2363</span>  }<a name="line.2363"></a>
-<span class="sourceLineNo">2364</span><a name="line.2364"></a>
-<span class="sourceLineNo">2365</span>  private static int getAverageValueLength(final TestOptions opts) {<a name="line.2365"></a>
-<span class="sourceLineNo">2366</span>    return opts.valueRandom? opts.valueSize/2: opts.valueSize;<a name="line.2366"></a>
+<span class="sourceLineNo">2327</span>  static int generateRandomRow(final Random random, final int totalRows) {<a name="line.2327"></a>
+<span class="sourceLineNo">2328</span>    return random.nextInt(Integer.MAX_VALUE) % totalRows;<a name="line.2328"></a>
+<span class="sourceLineNo">2329</span>  }<a name="line.2329"></a>
+<span class="sourceLineNo">2330</span><a name="line.2330"></a>
+<span class="sourceLineNo">2331</span>  static RunResult runOneClient(final Class&lt;? extends TestBase&gt; cmd, Configuration conf,<a name="line.2331"></a>
+<span class="sourceLineNo">2332</span>      Connection con, AsyncConnection asyncCon, TestOptions opts, final Status status)<a name="line.2332"></a>
+<span class="sourceLineNo">2333</span>      throws IOException, InterruptedException {<a name="line.2333"></a>
+<span class="sourceLineNo">2334</span>    status.setStatus("Start " + cmd + " at offset " + opts.startRow + " for "<a name="line.2334"></a>
+<span class="sourceLineNo">2335</span>        + opts.perClientRunRows + " rows");<a name="line.2335"></a>
+<span class="sourceLineNo">2336</span>    long totalElapsedTime;<a name="line.2336"></a>
+<span class="sourceLineNo">2337</span><a name="line.2337"></a>
+<span class="sourceLineNo">2338</span>    final TestBase t;<a name="line.2338"></a>
+<span class="sourceLineNo">2339</span>    try {<a name="line.2339"></a>
+<span class="sourceLineNo">2340</span>      if (AsyncTest.class.isAssignableFrom(cmd)) {<a name="line.2340"></a>
+<span class="sourceLineNo">2341</span>        Class&lt;? extends AsyncTest&gt; newCmd = (Class&lt;? extends AsyncTest&gt;) cmd;<a name="line.2341"></a>
+<span class="sourceLineNo">2342</span>        Constructor&lt;? extends AsyncTest&gt; constructor =<a name="line.2342"></a>
+<span class="sourceLineNo">2343</span>            newCmd.getDeclaredConstructor(AsyncConnection.class, TestOptions.class, Status.class);<a name="line.2343"></a>
+<span class="sourceLineNo">2344</span>        t = constructor.newInstance(asyncCon, opts, status);<a name="line.2344"></a>
+<span class="sourceLineNo">2345</span>      } else {<a name="line.2345"></a>
+<span class="sourceLineNo">2346</span>        Class&lt;? extends Test&gt; newCmd = (Class&lt;? extends Test&gt;) cmd;<a name="line.2346"></a>
+<span class="sourceLineNo">2347</span>        Constructor&lt;? extends Test&gt; constructor =<a name="line.2347"></a>
+<span class="sourceLineNo">2348</span>            newCmd.getDeclaredConstructor(Connection.class, TestOptions.class, Status.class);<a name="line.2348"></a>
+<span class="sourceLineNo">2349</span>        t = constructor.newInstance(con, opts, status);<a name="line.2349"></a>
+<span class="sourceLineNo">2350</span>      }<a name="line.2350"></a>
+<span class="sourceLineNo">2351</span>    } catch (NoSuchMethodException e) {<a name="line.2351"></a>
+<span class="sourceLineNo">2352</span>      throw new IllegalArgumentException("Invalid command class: " + cmd.getName()<a name="line.2352"></a>
+<span class="sourceLineNo">2353</span>          + ".  It does not provide a constructor as described by "<a name="line.2353"></a>
+<span class="sourceLineNo">2354</span>          + "the javadoc comment.  Available constructors are: "<a name="line.2354"></a>
+<span class="sourceLineNo">2355</span>          + Arrays.toString(cmd.getConstructors()));<a name="line.2355"></a>
+<span class="sourceLineNo">2356</span>    } catch (Exception e) {<a name="line.2356"></a>
+<span class="sourceLineNo">2357</span>      throw new IllegalStateException("Failed to construct command class", e);<a name="line.2357"></a>
+<span class="sourceLineNo">2358</span>    }<a name="line.2358"></a>
+<span class="sourceLineNo">2359</span>    totalElapsedTime = t.test();<a name="line.2359"></a>
+<span class="sourceLineNo">2360</span><a name="line.2360"></a>
+<span class="sourceLineNo">2361</span>    status.setStatus("Finished " + cmd + " in " + totalElapsedTime +<a name="line.2361"></a>
+<span class="sourceLineNo">2362</span>      "ms at offset " + opts.startRow + " for " + opts.perClientRunRows + " rows" +<a name="line.2362"></a>
+<span class="sourceLineNo">2363</span>      " (" + calculateMbps((int)(opts.perClientRunRows * opts.sampleRate), totalElapsedTime,<a name="line.2363"></a>
+<span class="sourceLineNo">2364</span>          getAverageValueLength(opts), opts.families, opts.columns) + ")");<a name="line.2364"></a>
+<span class="sourceLineNo">2365</span><a name="line.2365"></a>
+<span class="sourceLineNo">2366</span>    return new RunResult(totalElapsedTime, t.getLatencyHistogram());<a name="line.2366"></a>
 <span class="sourceLineNo">2367</span>  }<a name="line.2367"></a>
 <span class="sourceLineNo">2368</span><a name="line.2368"></a>
-<span class="sourceLineNo">2369</span>  private void runTest(final Class&lt;? extends TestBase&gt; cmd, TestOptions opts) throws IOException,<a name="line.2369"></a>
-<span class="sourceLineNo">2370</span>      InterruptedException, ClassNotFoundException, ExecutionException {<a name="line.2370"></a>
-<span class="sourceLineNo">2371</span>    // Log the configuration we're going to run with. Uses JSON mapper because lazy. It'll do<a name="line.2371"></a>
-<span class="sourceLineNo">2372</span>    // the TestOptions introspection for us and dump the output in a readable format.<a name="line.2372"></a>
-<span class="sourceLineNo">2373</span>    LOG.info(cmd.getSimpleName() + " test run options=" + MAPPER.writeValueAsString(opts));<a name="line.2373"></a>
-<span class="sourceLineNo">2374</span>    Admin admin = null;<a name="line.2374"></a>
-<span class="sourceLineNo">2375</span>    Connection connection = null;<a name="line.2375"></a>
-<span class="sourceLineNo">2376</span>    try {<a name="line.2376"></a>
-<span class="sourceLineNo">2377</span>      connection = ConnectionFactory.createConnection(getConf());<a name="line.2377"></a>
-<span class="sourceLineNo">2378</span>      admin = connection.getAdmin();<a name="line.2378"></a>
-<span class="sourceLineNo">2379</span>      checkTable(admin, opts);<a name="line.2379"></a>
-<span class="sourceLineNo">2380</span>    } finally {<a name="line.2380"></a>
-<span class="sourceLineNo">2381</span>      if (admin != null) admin.close();<a name="line.2381"></a>
-<span class="sourceLineNo">2382</span>      if (connection != null) connection.close();<a name="line.2382"></a>
-<span class="sourceLineNo">2383</span>    }<a name="line.2383"></a>
-<span class="sourceLineNo">2384</span>    if (opts.nomapred) {<a name="line.2384"></a>
-<span class="sourceLineNo">2385</span>      doLocalClients(opts, getConf());<a name="line.2385"></a>
-<span class="sourceLineNo">2386</span>    } else {<a name="line.2386"></a>
-<span class="sourceLineNo">2387</span>      doMapReduce(opts, getConf());<a name="line.2387"></a>
-<span class="sourceLineNo">2388</span>    }<a name="line.2388"></a>
-<span class="sourceLineNo">2389</span>  }<a name="line.2389"></a>
-<span class="sourceLineNo">2390</span><a name="line.2390"></a>
-<span class="sourceLineNo">2391</span>  protected void printUsage() {<a name="line.2391"></a>
-<span class="sourceLineNo">2392</span>    printUsage(PE_COMMAND_SHORTNAME, null);<a name="line.2392"></a>
+<span class="sourceLineNo">2369</span>  private static int getAverageValueLength(final TestOptions opts) {<a name="line.2369"></a>
+<span class="sourceLineNo">2370</span>    return opts.valueRandom? opts.valueSize/2: opts.valueSize;<a name="line.2370"></a>
+<span class="sourceLineNo">2371</span>  }<a name="line.2371"></a>
+<span class="sourceLineNo">2372</span><a name="line.2372"></a>
+<span class="sourceLineNo">2373</span>  private void runTest(final Class&lt;? extends TestBase&gt; cmd, TestOptions opts) throws IOException,<a name="line.2373"></a>
+<span class="sourceLineNo">2374</span>      InterruptedException, ClassNotFoundException, ExecutionException {<a name="line.2374"></a>
+<span class="sourceLineNo">2375</span>    // Log the configuration we're going to run with. Uses JSON mapper because lazy. It'll do<a name="line.2375"></a>
+<span class="sourceLineNo">2376</span>    // the TestOptions introspection for us and dump the output in a readable format.<a name="line.2376"></a>
+<span class="sourceLineNo">2377</span>    LOG.info(cmd.getSimpleName() + " test run options=" + MAPPER.writeValueAsString(opts));<a name="line.2377"></a>
+<span class="sourceLineNo">2378</span>    Admin admin = null;<a name="line.2378"></a>
+<span class="sourceLineNo">2379</span>    Connection connection = null;<a name="line.2379"></a>
+<span class="sourceLineNo">2380</span>    try {<a name="line.2380"></a>
+<span class="sourceLineNo">2381</span>      connection = ConnectionFactory.createConnection(getConf());<a name="line.2381"></a>
+<span class="sourceLineNo">2382</span>      admin = connection.getAdmin();<a name="line.2382"></a>
+<span class="sourceLineNo">2383</span>      checkTable(admin, opts);<a name="line.2383"></a>
+<span class="sourceLineNo">2384</span>    } finally {<a name="line.2384"></a>
+<span class="sourceLineNo">2385</span>      if (admin != null) admin.close();<a name="line.2385"></a>
+<span class="sourceLineNo">2386</span>      if (connection != null) connection.close();<a name="line.2386"></a>
+<span class="sourceLineNo">2387</span>    }<a name="line.2387"></a>
+<span class="sourceLineNo">2388</span>    if (opts.nomapred) {<a name="line.2388"></a>
+<span class="sourceLineNo">2389</span>      doLocalClients(opts, getConf());<a name="line.2389"></a>
+<span class="sourceLineNo">2390</span>    } else {<a name="line.2390"></a>
+<span class="sourceLineNo">2391</span>      doMapReduce(opts, getConf());<a name="line.2391"></a>
+<span class="sourceLineNo">2392</span>    }<a name="line.2392"></a>
 <span class="sourceLineNo">2393</span>  }<a name="line.2393"></a>
 <span class="sourceLineNo">2394</span><a name="line.2394"></a>
-<span class="sourceLineNo">2395</span>  protected static void printUsage(final String message) {<a name="line.2395"></a>
-<span class="sourceLineNo">2396</span>    printUsage(PE_COMMAND_SHORTNAME, message);<a name="line.2396"></a>
+<span class="sourceLineNo">2395</span>  protected void printUsage() {<a name="line.2395"></a>
+<span class="sourceLineNo">2396</span>    printUsage(PE_COMMAND_SHORTNAME, null);<a name="line.2396"></a>
 <span class="sourceLineNo">2397</span>  }<a name="line.2397"></a>
 <span class="sourceLineNo">2398</span><a name="line.2398"></a>
-<span class="sourceLineNo">2399</span>  protected static void printUsageAndExit(final String message, final int exitCode) {<a name="line.2399"></a>
-<span class="sourceLineNo">2400</span>    printUsage(message);<a name="line.2400"></a>
-<span class="sourceLineNo">2401</span>    System.exit(exitCode);<a name="line.2401"></a>
-<span class="sourceLineNo">2402</span>  }<a name="line.2402"></a>
-<span class="sourceLineNo">2403</span><a name="line.2403"></a>
-<span class="sourceLineNo">2404</span>  protected static void printUsage(final String shortName, final String message) {<a name="line.2404"></a>
-<span class="sourceLineNo">2405</span>    if (message != null &amp;&amp; message.length() &gt; 0) {<a name="line.2405"></a>
-<span class="sourceLineNo">2406</span>      System.err.println(message);<a name="line.2406"></a>
-<span class="sourceLineNo">2407</span>    }<a name="line.2407"></a>
-<span class="sourceLineNo">2408</span>    System.err.print("Usage: hbase " + shortName);<a name="line.2408"></a>
-<span class="sourceLineNo">2409</span>    System.err.println("  &lt;OPTIONS&gt; [-D&lt;property=value&gt;]* &lt;command&gt; &lt;nclients&gt;");<a name="line.2409"></a>
-<span class="sourceLineNo">2410</span>    System.err.println();<a name="line.2410"></a>
-<span class="sourceLineNo">2411</span>    System.err.println("General Options:");<a name="line.2411"></a>
-<span class="sourceLineNo">2412</span>    System.err.println(" nomapred        Run multiple clients using threads " +<a name="line.2412"></a>
-<span class="sourceLineNo">2413</span>      "(rather than use mapreduce)");<a name="line.2413"></a>
-<span class="sourceLineNo">2414</span>    System.err.println(" oneCon          all the threads share the same connection. Default: False");<a name="line.2414"></a>
-<span class="sourceLineNo">2415</span>    System.err.println(" connCount          connections all threads share. "<a name="line.2415"></a>
-<span class="sourceLineNo">2416</span>        + "For example, if set to 2, then all thread share 2 connection. "<a name="line.2416"></a>
-<span class="sourceLineNo">2417</span>        + "Default: depend on oneCon parameter. if oneCon set to true, then connCount=1, "<a name="line.2417"></a>
-<span class="sourceLineNo">2418</span>        + "if not, connCount=thread number");<a name="line.2418"></a>
-<span class="sourceLineNo">2419</span><a name="line.2419"></a>
-<span class="sourceLineNo">2420</span>    System.err.println(" sampleRate      Execute test on a sample of total " +<a name="line.2420"></a>
-<span class="sourceLineNo">2421</span>      "rows. Only supported by randomRead. Default: 1.0");<a name="line.2421"></a>
-<span class="sourceLineNo">2422</span>    System.err.println(" period          Report every 'period' rows: " +<a name="line.2422"></a>
-<span class="sourceLineNo">2423</span>      "Default: opts.perClientRunRows / 10 = " + DEFAULT_OPTS.getPerClientRunRows()/10);<a name="line.2423"></a>
-<span class="sourceLineNo">2424</span>    System.err.println(" cycles          How many times to cycle the test. Defaults: 1.");<a name="line.2424"></a>
-<span class="sourceLineNo">2425</span>    System.err.println(" traceRate       Enable HTrace spans. Initiate tracing every N rows. " +<a name="line.2425"></a>
-<span class="sourceLineNo">2426</span>      "Default: 0");<a name="line.2426"></a>
-<span class="sourceLineNo">2427</span>    System.err.println(" latency         Set to report operation latencies. Default: False");<a name="line.2427"></a>
-<span class="sourceLineNo">2428</span>    System.err.println(" measureAfter    Start to measure the latency once 'measureAfter'" +<a name="line.2428"></a>
-<span class="sourceLineNo">2429</span>        " rows have been treated. Default: 0");<a name="line.2429"></a>
-<span class="sourceLineNo">2430</span>    System.err.println(" valueSize       Pass value size to use: Default: "<a name="line.2430"></a>
-<span class="sourceLineNo">2431</span>        + DEFAULT_OPTS.getValueSize());<a name="line.2431"></a>
-<span class="sourceLineNo">2432</span>    System.err.println(" valueRandom     Set if we should vary value size between 0 and " +<a name="line.2432"></a>
-<span class="sourceLineNo">2433</span>        "'valueSize'; set on read for stats on size: Default: Not set.");<a name="line.2433"></a>
-<span class="sourceLineNo">2434</span>    System.err.println(" blockEncoding   Block encoding to use. Value should be one of "<a name="line.2434"></a>
-<span class="sourceLineNo">2435</span>        + Arrays.toString(DataBlockEncoding.values()) + ". Default: NONE");<a name="line.2435"></a>
-<span class="sourceLineNo">2436</span>    System.err.println();<a name="line.2436"></a>
-<span class="sourceLineNo">2437</span>    System.err.println("Table Creation / Write Tests:");<a name="line.2437"></a>
-<span class="sourceLineNo">2438</span>    System.err.println(" table           Alternate table name. Default: 'TestTable'");<a name="line.2438"></a>
-<span class="sourceLineNo">2439</span>    System.err.println(" rows            Rows each client runs. Default: "<a name="line.2439"></a>
-<span class="sourceLineNo">2440</span>        + DEFAULT_OPTS.getPerClientRunRows()<a name="line.2440"></a>
-<span class="sourceLineNo">2441</span>        + ".  In case of randomReads and randomSeekScans this could"<a name="line.2441"></a>
-<span class="sourceLineNo">2442</span>        + " be specified along with --size to specify the number of rows to be scanned within"<a name="line.2442"></a>
-<span class="sourceLineNo">2443</span>        + " the total range specified by the size.");<a name="line.2443"></a>
-<span class="sourceLineNo">2444</span>    System.err.println(<a name="line.2444"></a>
-<span class="sourceLineNo">2445</span>      " size            Total size in GiB. Mutually exclusive with --rows for writes and scans"<a name="line.2445"></a>
-<span class="sourceLineNo">2446</span>          + ". But for randomReads and randomSeekScans when you use size with --rows you could"<a name="line.2446"></a>
-<span class="sourceLineNo">2447</span>          + " use size to specify the end range and --rows"<a name="line.2447"></a>
-<span class="sourceLineNo">2448</span>          + " specifies the number of rows within that range. " + "Default: 1.0.");<a name="line.2448"></a>
-<span class="sourceLineNo">2449</span>    System.err.println(" compress        Compression type to use (GZ, LZO, ...). Default: 'NONE'");<a name="line.2449"></a>
-<span class="sourceLineNo">2450</span>    System.err.println(" flushCommits    Used to determine if the test should flush the table. " +<a name="line.2450"></a>
-<span class="sourceLineNo">2451</span>      "Default: false");<a name="line.2451"></a>
-<span class="sourceLineNo">2452</span>    System.err.println(" valueZipf       Set if we should vary value size between 0 and " +<a name="line.2452"></a>
-<span class="sourceLineNo">2453</span>        "'valueSize' in zipf form: Default: Not set.");<a name="line.2453"></a>
-<span class="sourceLineNo">2454</span>    System.err.println(" writeToWAL      Set writeToWAL on puts. Default: True");<a name="line.2454"></a>
-<span class="sourceLineNo">2455</span>    System.err.println(" autoFlush       Set autoFlush on htable. Default: False");<a name="line.2455"></a>
-<span class="sourceLineNo">2456</span>    System.err.println(" multiPut        Batch puts together into groups of N. Only supported " +<a name="line.2456"></a>
-<span class="sourceLineNo">2457</span>        "by write. If multiPut is bigger than 0, autoFlush need to set to true. Default: 0");<a name="line.2457"></a>
-<span class="sourceLineNo">2458</span>    System.err.println(" presplit        Create presplit table. If a table with same name exists,"<a name="line.2458"></a>
-<span class="sourceLineNo">2459</span>        + " it'll be deleted and recreated (instead of verifying count of its existing regions). "<a name="line.2459"></a>
-<span class="sourceLineNo">2460</span>        + "Recommended for accurate perf analysis (see guide). Default: disabled");<a name="line.2460"></a>
-<span class="sourceLineNo">2461</span>    System.err.println(" usetags         Writes tags along with KVs. Use with HFile V3. " +<a name="line.2461"></a>
-<span class="sourceLineNo">2462</span>      "Default: false");<a name="line.2462"></a>
-<span class="sourceLineNo">2463</span>    System.err.println(" numoftags       Specify the no of tags that would be needed. " +<a name="line.2463"></a>
-<span class="sourceLineNo">2464</span>       "This works only if usetags is true. Default: " + DEFAULT_OPTS.noOfTags);<a name="line.2464"></a>
-<span class="sourceLineNo">2465</span>    System.err.println(" splitPolicy     Specify a custom RegionSplitPolicy for the table.");<a name="line.2465"></a>
-<span class="sourceLineNo">2466</span>    System.err.println(" columns         Columns to write per row. Default: 1");<a name="line.2466"></a>
-<span class="sourceLineNo">2467</span>    System.err.println(" families        Specify number of column families for the table. Default: 1");<a name="line.2467"></a>
-<span class="sourceLineNo">2468</span>    System.err.println();<a name="line.2468"></a>
-<span class="sourceLineNo">2469</span>    System.err.println("Read Tests:");<a name="line.2469"></a>
-<span class="sourceLineNo">2470</span>    System.err.println(" filterAll       Helps to filter out all the rows on the server side"<a name="line.2470"></a>
-<span class="sourceLineNo">2471</span>        + " there by not returning any thing back to the client.  Helps to check the server side"<a name="line.2471"></a>
-<span class="sourceLineNo">2472</span>        + " performance.  Uses FilterAllFilter internally. ");<a name="line.2472"></a>
-<span class="sourceLineNo">2473</span>    System.err.println(" multiGet        Batch gets together into groups of N. Only supported " +<a name="line.2473"></a>
-<span class="sourceLineNo">2474</span>      "by randomRead. Default: disabled");<a name="line.2474"></a>
-<span class="sourceLineNo">2475</span>    System.err.println(" inmemory        Tries to keep the HFiles of the CF " +<a name="line.2475"></a>
-<span class="sourceLineNo">2476</span>      "inmemory as far as possible. Not guaranteed that reads are always served " +<a name="line.2476"></a>
-<span class="sourceLineNo">2477</span>      "from memory.  Default: false");<a name="line.2477"></a>
-<span class="sourceLineNo">2478</span>    System.err.println(" bloomFilter     Bloom filter type, one of "<a name="line.2478"></a>
-<span class="sourceLineNo">2479</span>        + Arrays.toString(BloomType.values()));<a name="line.2479"></a>
-<span class="sourceLineNo">2480</span>    System.err.println(" blockSize       Blocksize to use when writing out hfiles. ");<a name="line.2480"></a>
-<span class="sourceLineNo">2481</span>    System.err.println(" inmemoryCompaction  Makes the column family to do inmemory flushes/compactions. "<a name="line.2481"></a>
-<span class="sourceLineNo">2482</span>        + "Uses the CompactingMemstore");<a name="line.2482"></a>
-<span class="sourceLineNo">2483</span>    System.err.println(" addColumns      Adds columns to scans/gets explicitly. Default: true");<a name="line.2483"></a>
-<span class="sourceLineNo">2484</span>    System.err.println(" replicas        Enable region replica testing. Defaults: 1.");<a name="line.2484"></a>
-<span class="sourceLineNo">2485</span>    System.err.println(" randomSleep     Do a random sleep before each get between 0 and entered value. Defaults: 0");<a name="line.2485"></a>
-<span class="sourceLineNo">2486</span>    System.err.println(" caching         Scan caching to use. Default: 30");<a name="line.2486"></a>
-<span class="sourceLineNo">2487</span>    System.err.println(" asyncPrefetch   Enable asyncPrefetch for scan");<a name="line.2487"></a>
-<span class="sourceLineNo">2488</span>    System.err.println(" cacheBlocks     Set the cacheBlocks option for scan. Default: true");<a name="line.2488"></a>
-<span class="sourceLineNo">2489</span>    System.err.println(" scanReadType    Set the readType option for scan, stream/pread/default. Default: default");<a name="line.2489"></a>
-<span class="sourceLineNo">2490</span>    System.err.println(" bufferSize      Set the value of client side buffering. Default: 2MB");<a name="line.2490"></a>
-<span class="sourceLineNo">2491</span>    System.err.println();<a name="line.2491"></a>
-<span class="sourceLineNo">2492</span>    System.err.println(" Note: -D properties will be applied to the conf used. ");<a name="line.2492"></a>
-<span class="sourceLineNo">2493</span>    System.err.println("  For example: ");<a name="line.2493"></a>
-<span class="sourceLineNo">2494</span>    System.err.println("   -Dmapreduce.output.fileoutputformat.compress=true");<a name="line.2494"></a>
-<span class="sourceLineNo">2495</span>    System.err.println("   -Dmapreduce.task.timeout=60000");<a name="line.2495"></a>
-<span class="sourceLineNo">2496</span>    System.err.println();<a name="line.2496"></a>
-<span class="sourceLineNo">2497</span>    System.err.println("Command:");<a name="line.2497"></a>
-<span class="sourceLineNo">2498</span>    for (CmdDescriptor command : COMMANDS.values()) {<a name="line.2498"></a>
-<span class="sourceLineNo">2499</span>      System.err.println(String.format(" %-20s %s", command.getName(), command.getDescription()));<a name="line.2499"></a>
-<span class="sourceLineNo">2500</span>    }<a name="line.2500"></a>
-<span class="sourceLineNo">2501</span>    System.err.println();<a name="line.2501"></a>
-<span class="sourceLineNo">2502</span>    System.err.println("Args:");<a name="line.2502"></a>
-<span class="sourceLineNo">2503</span>    System.err.println(" nclients        Integer. Required. Total number of clients "<a name="line.2503"></a>
-<span class="sourceLineNo">2504</span>        + "(and HRegionServers) running. 1 &lt;= value &lt;= 500");<a name="line.2504"></a>
-<span class="sourceLineNo">2505</span>    System.err.println("Examples:");<a name="line.2505"></a>
-<span class="sourceLineNo">2506</span>    System.err.println(" To run a single client doing the default 1M sequentialWrites:");<a name="line.2506"></a>
-<span class="sourceLineNo">2507</span>    System.err.println(" $ hbase " + shortName + " sequentialWrite 1");<a name="line.2507"></a>
-<span class="sourceLineNo">2508</span>    System.err.println(" To run 10 clients doing increments over ten rows:");<a name="line.2508"></a>
-<span class="sourceLineNo">2509</span>    System.err.println(" $ hbase " + shortName + " --rows=10 --nomapred increment 10");<a name="line.2509"></a>
-<span class="sourceLineNo">2510</span>  }<a name="line.2510"></a>
-<span class="sourceLineNo">2511</span><a name="line.2511"></a>
-<span class="sourceLineNo">2512</span>  /**<a name="line.2512"></a>
-<span class="sourceLineNo">2513</span>   * Parse options passed in via an arguments array. Assumes that array has been split<a name="line.2513"></a>
-<span class="sourceLineNo">2514</span>   * on white-space and placed into a {@code Queue}. Any unknown arguments will remain<a name="line.2514"></a>
-<span class="sourceLineNo">2515</span>   * in the queue at the conclusion of this method call. It's up to the caller to deal<a name="line.2515"></a>
-<span class="sourceLineNo">2516</span>   * with these unrecognized arguments.<a name="line.2516"></a>
-<span class="sourceLineNo">2517</span>   */<a name="line.2517"></a>
-<span class="sourceLineNo">2518</span>  static TestOptions parseOpts(Queue&lt;String&gt; args) {<a name="line.2518"></a>
-<span class="sourceLineNo">2519</span>    TestOptions opts = new TestOptions();<a name="line.2519"></a>
-<span class="sourceLineNo">2520</span><a name="line.2520"></a>
-<span class="sourceLineNo">2521</span>    String cmd = null;<a name="line.2521"></a>
-<span class="sourceLineNo">2522</span>    while ((cmd = args.poll()) != null) {<a name="line.2522"></a>
-<span class="sourceLineNo">2523</span>      if (cmd.equals("-h") || cmd.startsWith("--h")) {<a name="line.2523"></a>
-<span class="sourceLineNo">2524</span>        // place item back onto queue so that caller knows parsing was incomplete<a name="line.2524"></a>
-<span class="sourceLineNo">2525</span>        args.add(cmd);<a name="line.2525"></a>
-<span class="sourceLineNo">2526</span>        break;<a name="line.2526"></a>
-<span class="sourceLineNo">2527</span>      }<a name="line.2527"></a>
-<span class="sourceLineNo">2528</span><a name="line.2528"></a>
-<span class="sourceLineNo">2529</span>      final String nmr = "--nomapred";<a name="line.2529"></a>
-<span class="sourceLineNo">2530</span>      if (cmd.startsWith(nmr)) {<a name="line.2530"></a>
-<span class="sourceLineNo">2531</span>        opts.nomapred = true;<a name="line.2531"></a>
-<span class="sourceLineNo">2532</span>        continue;<a name="line.2532"></a>
-<span class="sourceLineNo">2533</span>      }<a name="line.2533"></a>
-<span class="sourceLineNo">2534</span><a name="line.2534"></a>
-<span class="sourceLineNo">2535</span>      final String rows = "--rows=";<a name="line.2535"></a>
-<span class="sourceLineNo">2536</span>      if (cmd.startsWith(rows)) {<a name="line.2536"></a>
-<span class="sourceLineNo">2537</span>        opts.perClientRunRows = Integer.parseInt(cmd.substring(rows.length()));<a name="line.2537"></a>
-<span class="sourceLineNo">2538</span>        continue;<a name="line.2538"></a>
-<span class="sourceLineNo">2539</span>      }<a name="line.2539"></a>
-<span class="sourceLineNo">2540</span><a name="line.2540"></a>
-<span class="sourceLineNo">2541</span>      final String cycles = "--cycles=";<a name="line.2541"></a>
-<span class="sourceLineNo">2542</span>      if (cmd.startsWith(cycles)) {<a name="line.2542"></a>
-<span class="sourceLineNo">2543</span>        opts.cycles = Integer.parseInt(cmd.substring(cycles.length()));<a name="line.2543"></a>
-<span class="sourceLineNo">2544</span>        continue;<a name="line.2544"></a>
-<span class="sourceLineNo">2545</span>      }<a name="line.2545"></a>
-<span class="sourceLineNo">2546</span><a name="line.2546"></a>
-<span class="sourceLineNo">2547</span>      final String sampleRate = "--sampleRate=";<a name="line.2547"></a>
-<span class="sourceLineNo">2548</span>      if (cmd.startsWith(sampleRate)) {<a name="line.2548"></a>
-<span class="sourceLineNo">2549</span>        opts.sampleRate = Float.parseFloat(cmd.substring(sampleRate.length()));<a name="line.2549"></a>
-<span class="sourceLineNo">2550</span>        continue;<a name="line.2550"></a>
-<span class="sourceLineNo">2551</span>      }<a name="line.2551"></a>
-<span class="sourceLineNo">2552</span><a name="line.2552"></a>
-<span class="sourceLineNo">2553</span>      final String table = "--table=";<a name="line.2553"></a>
-<span class="sourceLineNo">2554</span>      if (cmd.startsWith(table)) {<a name="line.2554"></a>
-<span class="sourceLineNo">2555</span>        opts.tableName = cmd.substring(table.length());<a name="line.2555"></a>
-<span class="sourceLineNo">2556</span>        continue;<a name="line.2556"></a>
-<span class="sourceLineNo">2557</span>      }<a name="line.2557"></a>
-<span class="sourceLineNo">2558</span><a name="line.2558"></a>
-<span class="sourceLineNo">2559</span>      final String startRow = "--startRow=";<a name="line.2559"></a>
-<span class="sourceLineNo">2560</span>      if (cmd.startsWith(startRow)) {<a name="line.2560"></a>
-<span class="sourceLineNo">2561</span>        opts.startRow = Integer.parseInt(cmd.substring(startRow.length()));<a name="line.2561"></a>
-<span class="sourceLineNo">2562</span>        continue;<a name="line.2562"></a>
-<span class="sourceLineNo">2563</span>      }<a name="line.2563"></a>
-<span class="sourceLineNo">2564</span><a name="line.2564"></a>
-<span class="sourceLineNo">2565</span>      final String compress = "--compress=";<a name="line.2565"></a>
-<span class="sourceLineNo">2566</span>      if (cmd.startsWith(compress)) {<a name="line.2566"></a>
-<span class="sourceLineNo">2567</span>        opts.compression = Compression.Algorithm.valueOf(cmd.substring(compress.length()));<a name="line.2567"></a>
-<span class="sourceLineNo">2568</span>        continue;<a name="line.2568"></a>
-<span class="sourceLineNo">2569</span>      }<a name="line.2569"></a>
-<span class="sourceLineNo">2570</span><a name="line.2570"></a>
-<span class="sourceLineNo">2571</span>      final String traceRate = "--traceRate=";<a name="line.2571"></a>
-<span class="sourceLineNo">2572</span>      if (cmd.startsWith(traceRate)) {<a name="line.2572"></a>
-<span class="sourceLineNo">2573</span>        opts.traceRate = Double.parseDouble(cmd.substring(traceRate.length()));<a name="line.2573"></a>
-<span class="sourceLineNo">2574</span>        continue;<a name="line.2574"></a>
-<span class="sourceLineNo">2575</span>      }<a name="line.2575"></a>
-<span class="sourceLineNo">2576</span><a name="line.2576"></a>
-<span class="sourceLineNo">2577</span>      final String blockEncoding = "--blockEncoding=";<a name="line.2577"></a>
-<span class="sourceLineNo">2578</span>      if (cmd.startsWith(blockEncoding)) {<a name="line.2578"></a>
-<span class="sourceLineNo">2579</span>        opts.blockEncoding = DataBlockEncoding.valueOf(cmd.substring(blockEncoding.length()));<a name="line.2579"></a>
-<span class="sourceLineNo">2580</span>        continue;<a name="line.2580"></a>
-<span class="sourceLineNo">2581</span>      }<a name="line.2581"></a>
-<span class="sourceLineNo">2582</span><a name="line.2582"></a>
-<span class="sourceLineNo">2583</span>      final String flushCommits = "--flushCommits=";<a name="line.2583"></a>
-<span class="sourceLineNo">2584</span>      if (cmd.startsWith(flushCommits)) {<a name="line.2584"></a>
-<span class="sourceLineNo">2585</span>        opts.flushCommits = Boolean.parseBoolean(cmd.substring(flushCommits.length()));<a name="line.2585"></a>
-<span class="sourceLineNo">2586</span>        continue;<a name="line.2586"></a>
-<span class="sourceLineNo">2587</span>      }<a name="line.2587"></a>
-<span class="sourceLineNo">2588</span><a name="line.2588"></a>
-<span class="sourceLineNo">2589</span>      final String writeToWAL = "--writeToWAL=";<a name="line.2589"></a>
-<span class="sourceLineNo">2590</span>      if (cmd.startsWith(writeToWAL)) {<a name="line.2590"></a>
-<span class="sourceLineNo">2591</span>        opts.writeToWAL = Boolean.parseBoolean(cmd.substring(writeToWAL.length()));<a name="line.2591"></a>
-<span class="sourceLineNo">2592</span>        continue;<a name="line.2592"></a>
-<span class="sourceLineNo">2593</span>      }<a name="line.2593"></a>
-<span class="sourceLineNo">2594</span><a name="line.2594"></a>
-<span class="sourceLineNo">2595</span>      final String presplit = "--presplit=";<a name="line.2595"></a>
-<span class="sourceLineNo">2596</span>      if (cmd.startsWith(presplit)) {<a name="line.2596"></a>
-<span class="sourceLineNo">2597</span>        opts.presplitRegions = Integer.parseInt(cmd.substring(presplit.length()));<a name="line.2597"></a>
-<span class="sourceLineNo">2598</span>        continue;<a name="line.2598"></a>
-<span class="sourceLineNo">2599</span>      }<a name="line.2599"></a>
-<span class="sourceLineNo">2600</span><a name="line.2600"></a>
-<span class="sourceLineNo">2601</span>      final String inMemory = "--inmemory=";<a name="line.2601"></a>
-<span class="sourceLineNo">2602</span>      if (cmd.startsWith(inMemory)) {<a name="line.2602"></a>
-<span class="sourceLineNo">2603</span>        opts.inMemoryCF = Boolean.parseBoolean(cmd.substring(inMemory.length()));<a name="line.2603"></a>
-<span class="sourceLineNo">2604</span>        continue;<a name="line.2604"></a>
-<span class="sourceLineNo">2605</span>      }<a name="line.2605"></a>
-<span class="sourceLineNo">2606</span><a name="line.2606"></a>
-<span class="sourceLineNo">2607</span>      final String autoFlush = "--autoFlush=";<a name="line.2607"></a>
-<span class="sourceLineNo">2608</span>      if (cmd.startsWith(autoFlush)) {<a name="line.2608"></a>
-<span class="sourceLineNo">2609</span>        opts.autoFlush = Boolean.parseBoolean(cmd.substring(autoFlush.length()));<a name="line.2609"></a>
-<span class="sourceLineNo">2610</span>        if (!opts.autoFlush &amp;&amp; opts.multiPut &gt; 0) {<a name="line.2610"></a>
-<span class="sourceLineNo">2611</span>          throw new IllegalArgumentException("autoFlush must be true when multiPut is more than 0");<a name="line.2611"></a>
-<span class="sourceLineNo">2612</span>        }<a name="line.2612"></a>
-<span class="sourceLineNo">2613</span>        continue;<a name="line.2613"></a>
-<span class="sourceLineNo">2614</span>      }<a name="line.2614"></a>
-<span class="sourceLineNo">2615</span><a name="line.2615"></a>
-<span class="sourceLineNo">2616</span>      final String onceCon = "--oneCon=";<a name="line.2616"></a>
-<span class="sourceLineNo">2617</span>      if (cmd.startsWith(onceCon)) {<a name="line.2617"></a>
-<span class="sourceLineNo">2618</span>        opts.oneCon = Boolean.parseBoolean(cmd.substring(onceCon.length()));<a name="line.2618"></a>
-<span class="sourceLineNo">2619</span>        if (opts.oneCon &amp;&amp; opts.connCount &gt; 1) {<a name="line.2619"></a>
-<span class="sourceLineNo">2620</span>          throw new IllegalArgumentException("oneCon is set to true, "<a name="line.2620"></a>
-<span class="sourceLineNo">2621</span>              + "connCount should not bigger than 1");<a name="line.2621"></a>
-<span class="sourceLineNo">2622</span>        }<a name="line.2622"></a>
-<span class="sourceLineNo">2623</span>        continue;<a name="line.2623"></a>
-<span class="sourceLineNo">2624</span>      }<a name="line.2624"></a>
-<span class="sourceLineNo">2625</span><a name="line.2625"></a>
-<span class="sourceLineNo">2626</span>      final String connCount = "--connCount=";<a name="line.2626"></a>
-<span class="sourceLineNo">2627</span>      if (cmd.startsWith(connCount)) {<a name="line.2627"></a>
-<span class="sourceLineNo">2628</span>        opts.connCount = Integer.parseInt(cmd.substring(connCount.length()));<a name="line.2628"></a>
-<span class="sourceLineNo">2629</span>        if (opts.oneCon &amp;&amp; opts.connCount &gt; 1) {<a name="line.2629"></a>
-<span class="sourceLineNo">2630</span>          throw new IllegalArgumentException("oneCon is set to true, "<a name="line.2630"></a>
-<span class="sourceLineNo">2631</span>              + "connCount should not bigger than 1");<a name="line.2631"></a>
-<span class="sourceLineNo">2632</span>        }<a name="line.2632"></a>
-<span class="sourceLineNo">2633</span>        continue;<a name="line.2633"></a>
-<span class="sourceLineNo">2634</span>      }<a name="line.2634"></a>
-<span class="sourceLineNo">2635</span><a name="line.2635"></a>
-<span class="sourceLineNo">2636</span>      final String latency = "--latency";<a name="line.2636"></a>
-<span class="sourceLineNo">2637</span>      if (cmd.startsWith(latency)) {<a name="line.2637"></a>
-<span class="sourceLineNo">2638</span>        opts.reportLatency = true;<a name="line.2638"></a>
-<span class="sourceLineNo">2639</span>        continue;<a name="line.2639"></a>
-<span class="sourceLineNo">2640</span>      }<a name="line.2640"></a>
-<span class="sourceLineNo">2641</span><a name="line.2641"></a>
-<span class="sourceLineNo">2642</span>      final String multiGet = "--multiGet=";<a name="line.2642"></a>
-<span class="sourceLineNo">2643</span>      if (cmd.startsWith(multiGet)) {<a name="line.2643"></a>
-<span class="sourceLineNo">2644</span>        opts.multiGet = Integer.parseInt(cmd.substring(multiGet.length()));<a name="line.2644"></a>
-<span class="sourceLineNo">2645</span>        continue;<a name="line.2645"></a>
-<span class="sourceLineNo">2646</span>      }<a name="line.2646"></a>
-<span class="sourceLineNo">2647</span><a name="line.2647"></a>
-<span class="sourceLineNo">2648</span>      final String multiPut = "--multiPut=";<a name="line.2648"></a>
-<span class="sourceLineNo">2649</span>      if (cmd.startsWith(multiPut)) {<a name="line.2649"></a>
-<span class="sourceLineNo">2650</span>        opts.multiPut = Integer.parseInt(cmd.substring(multiPut.length()));<a name="line.2650"></a>
-<span class="sourceLineNo">2651</span>        if (!opts.autoFlush &amp;&amp; opts.multiPut &gt; 0) {<a name="line.2651"></a>
-<span class="sourceLineNo">2652</span>          throw new IllegalArgumentException("autoFlush must be true when multiPut is more than 0");<a name="line.2652"></a>
-<span class="sourceLineNo">2653</span>        }<a name="line.2653"></a>
-<span class="sourceLineNo">2654</span>        continue;<a name="line.2654"></a>
-<span class="sourceLineNo">2655</span>      }<a name="line.2655"></a>
-<span class="sourceLineNo">2656</span><a name="line.2656"></a>
-<span class="sourceLineNo">2657</span>      final String useTags = "--usetags=";<a name="line.2657"></a>
-<span class="sourceLineNo">2658</span>      if (cmd.startsWith(useTags)) {<a name="line.2658"></a>
-<span class="sourceLineNo">2659</span>        opts.useTags = Boolean.parseBoolean(cmd.substring(useTags.length()));<a name="line.2659"></a>
-<span class="sourceLineNo">2660</span>        continue;<a name="line.2660"></a>
-<span class="sourceLineNo">2661</span>      }<a name="line.2661"></a>
-<span class="sourceLineNo">2662</span><a name="line.2662"></a>
-<span class="sourceLineNo">2663</span>      final String noOfTags = "--numoftags=";<a name="line.2663"></a>
-<span class="sourceLineNo">2664</span>      if (cmd.startsWith(noOfTags)) {<a name="line.2664"></a>
-<span class="sourceLineNo">2665</span>        opts.noOfTags = Integer.parseInt(cmd.substring(noOfTags.length()));<a name="line.2665"></a>
-<span class="sourceLineNo">2666</span>        continue;<a name="line.2666"></a>
-<span class="sourceLineNo">2667</span>      }<a name="line.2667"></a>
-<span class="sourceLineNo">2668</span><a name="line.2668"></a>
-<span class="sourceLineNo">2669</span>      final String replicas = "--replicas=";<a name="line.2669"></a>
-<span class="sourceLineNo">2670</span>      if (cmd.startsWith(replicas)) {<a name="line.2670"></a>
-<span class="sourceLineNo">2671</span>        opts.replicas = Integer.parseInt(cmd.substring(replicas.length()));<a name="line.2671"></a>
-<span class="sourceLineNo">2672</span>        continue;<a name="line.2672"></a>
-<span class="sourceLineNo">2673</span>      }<a name="line.2673"></a>
-<span class="sourceLineNo">2674</span><a name="line.2674"></a>
-<span class="sourceLineNo">2675</span>      final String filterOutAll = "--filterAll";<a name="line.2675"></a>
-<span class="sourceLineNo">2676</span>      if (cmd.startsWith(filterOutAll)) {<a name="line.2676"></a>
-<span class="sourceLineNo">2677</span>        opts.filterAll = true;<a name="line.2677"></a>
-<span class="sourceLineNo">2678</span>        continue;<a name="line.2678"></a>
-<span class="sourceLineNo">2679</span>      }<a name="line.2679"></a>
-<span class="sourceLineNo">2680</span><a name="line.2680"></a>
-<span class="sourceLineNo">2681</span>      final String size = "--size=";<a name="line.2681"></a>
-<span class="sourceLineNo">2682</span>      if (cmd.startsWith(size)) {<a name="line.2682"></a>
-<span class="sourceLineNo">2683</span>        opts.size = Float.parseFloat(cmd.substring(size.length()));<a name="line.2683"></a>
-<span class="sourceLineNo">2684</span>        if (opts.size &lt;= 1.0f) throw new IllegalStateException("Size must be &gt; 1; i.e. 1GB");<a name="line.2684"></a>
-<span class="sourceLineNo">2685</span>        continue;<a name="line.2685"></a>
-<span class="sourceLineNo">2686</span>      }<a name="line.2686"></a>
-<span class="sourceLineNo">2687</span><a name="line.2687"></a>
-<span class="sourceLineNo">2688</span>      final String splitPolicy = "--splitPolicy=";<a name="line.2688"></a>
-<span class="sourceLineNo">2689</span>      if (cmd.startsWith(splitPolicy)) {<a name="line.2689"></a>
-<span class="sourceLineNo">2690</span>        opts.splitPolicy = cmd.substring(splitPolicy.length());<a name="line.2690"></a>
-<span class="sourceLineNo">2691</span>        continue;<a name="line.2691"></a>
-<span class="sourceLineNo">2692</span>      }<a name="line.2692"></a>
-<span class="sourceLineNo">2693</span><a name="line.2693"></a>
-<span class="sourceLineNo">2694</span>      final String randomSleep = "--randomSleep=";<a name="line.2694"></a>
-<span class="sourceLineNo">2695</span>      if (cmd.startsWith(randomSleep)) {<a name="line.2695"></a>
-<span class="sourceLineNo">2696</span>        opts.randomSleep = Integer.parseInt(cmd.substring(randomSleep.length()));<a name="line.2696"></a>
-<span class="sourceLineNo">2697</span>        continue;<a name="line.2697"></a>
-<span class="sourceLineNo">2698</span>      }<a name="line.2698"></a>
-<span class="sourceLineNo">2699</span><a name="line.2699"></a>
-<span class="sourceLineNo">2700</span>      final String measureAfter = "--measureAfter=";<a name="line.2700"></a>
-<span class="sourceLineNo">2701</span>      if (cmd.startsWith(measureAfter)) {<a name="line.2701"></a>
-<span class="sourceLineNo">2702</span>        opts.measureAfter = Integer.parseInt(cmd.substring(measureAfter.length()));<a name="line.2702"></a>
-<span class="sourceLineNo">2703</span>        continue;<a name="line.2703"></a>
-<span class="sourceLineNo">2704</span>      }<a name="line.2704"></a>
-<span class="sourceLineNo">2705</span><a name="line.2705"></a>
-<span class="sourceLineNo">2706</span>      final String bloomFilter = "--bloomFilter=";<a name="line.2706"></a>
-<span class="sourceLineNo">2707</span>      if (cmd.startsWith(bloomFilter)) {<a name="line.2707"></a>
-<span class="sourceLineNo">2708</span>        opts.bloomType = BloomType.valueOf(cmd.substring(bloomFilter.length()));<a name="line.2708"></a>
-<span class="sourceLineNo">2709</span>        continue;<a name="line.2709"></a>
-<span class="sourceLineNo">2710</span>      }<a name="line.2710"></a>
-<span class="sourceLineNo">2711</span><a name="line.2711"></a>
-<span class="sourceLineNo">2712</span>      final String blockSize = "--blockSize=";<a name="line.2712"></a>
-<span class="sourceLineNo">2713</span>      if(cmd.startsWith(blockSize) ) {<a name="line.2713"></a>
-<span class="sourceLineNo">2714</span>        opts.blockSize = Integer.parseInt(cmd.substring(blockSize.length()));<a name="line.2714"></a>
-<span class="sourceLineNo">2715</span>      }<a name="line.2715"></a>
-<span class="sourceLineNo">2716</span><a name="line.2716"></a>
-<span class="sourceLineNo">2717</span>      final String valueSize = "--valueSize=";<a name="line.2717"></a>
-<span class="sourceLineNo">2718</span>      if (cmd.startsWith(valueSize)) {<a name="line.2718"></a>
-<span class="sourceLineNo">2719</span>        opts.valueSize = Integer.parseInt(cmd.substring(valueSize.length()));<a name="line.2719"></a>
-<span class="sourceLineNo">2720</span>        continue;<a name="line.2720"></a>
-<span class="sourceLineNo">2721</span>      }<a name="line.2721"></a>
-<span class="sourceLineNo">2722</span><a name="line.2722"></a>
-<span class="sourceLineNo">2723</span>      final String valueRandom = "--valueRandom";<a name="line.2723"></a>
-<span class="sourceLineNo">2724</span>      if (cmd.startsWith(valueRandom)) {<a name="line.2724"></a>
-<span class="sourceLineNo">2725</span>        opts.valueRandom = true;<a name="line.2725"></a>
-<span class="sourceLineNo">2726</span>        if (opts.valueZipf) {<a name="line.2726"></a>
-<span class="sourceLineNo">2727</span>          throw new IllegalStateException("Either valueZipf or valueRandom but not both");<a name="line.2727"></a>
-<span class="sourceLineNo">2728</span>        }<a name="line.2728"></a>
-<span class="sourceLineNo">2729</span>        continue;<a name="line.2729"></a>
-<span class="sourceLineNo">2730</span>      }<a name="line.2730"></a>
-<span class="sourceLineNo">2731</span><a name="line.2731"></a>
-<span class="sourceLineNo">2732</span>      final String valueZipf = "--valueZipf";<a name="line.2732"></a>
-<span class="sourceLineNo">2733</span>      if (cmd.startsWith(valueZipf)) {<a name="line.2733"></a>
-<span class="sourceLineNo">2734</span>        opts.valueZipf = true;<a name="line.2734"></a>
-<span class="sourceLineNo">2735</span>        if (opts.valueRandom) {<a name="line.2735"></a>
-<span class="sourceLineNo">2736</span>          throw new IllegalStateException("Either valueZipf or valueRandom but not both");<a name="line.2736"></a>
-<span class="sourceLineNo">2737</span>        }<a name="line.2737"></a>
-<span class="sourceLineNo">2738</span>        continue;<a name="line.2738"></a>
-<span class="sourceLineNo">2739</span>      }<a name="line.2739"></a>
-<span class="sourceLineNo">2740</span><a name="line.2740"></a>
-<span class="sourceLineNo">2741</span>      final String period = "--period=";<a name="line.2741"></a>
-<span class="sourceLineNo">2742</span>      if (cmd.startsWith(period)) {<a name="line.2742"></a>
-<span class="sourceLineNo">2743</span>        opts.period = Integer.parseInt(cmd.substring(period.length()));<a name="line.2743"></a>
-<span class="sourceLineNo">2744</span>        continue;<a name="line.2744"></a>
-<span class="sourceLineNo">2745</span>      }<a name="line.2745"></a>
-<span class="sourceLineNo">2746</span><a name="line.2746"></a>
-<span class="sourceLineNo">2747</span>      final String addColumns = "--addColumns=";<a name="line.2747"></a>
-<span class="sourceLineNo">2748</span>      if (cmd.startsWith(addColumns)) {<a name="line.2748"></a>
-<span class="sourceLineNo">2749</span>        opts.addColumns = Boolean.parseBoolean(cmd.substring(addColumns.length()));<a name="line.2749"></a>
-<span class="sourceLineNo">2750</span>        continue;<a name="line.2750"></a>
-<span class="sourceLineNo">2751</span>      }<a name="line.2751"></a>
-<span class="sourceLineNo">2752</span><a name="line.2752"></a>
-<span class="sourceLineNo">2753</span>      final String inMemoryCompaction = "--inmemoryCompaction=";<a name="line.2753"></a>
-<span class="sourceLineNo">2754</span>      if (cmd.startsWith(inMemoryCompaction)) {<a name="line.2754"></a>
-<span class="sourceLineNo">2755</span>        opts.inMemoryCompaction =<a name="line.2755"></a>
-<span class="sourceLineNo">2756</span>            MemoryCompactionPolicy.valueOf(cmd.substring(inMemoryCompaction.length()));<a name="line.2756"></a>
-<span class="sourceLineNo">2757</span>        continue;<a name="line.2757"></a>
-<span class="sourceLineNo">2758</span>      }<a name="line.2758"></a>
-<span class="sourceLineNo">2759</span><a name="line.2759"></a>
-<span class="sourceLineNo">2760</span>      final String columns = "--columns=";<a name="line.2760"></a>
-<span class="sourceLineNo">2761</span>      if (cmd.startsWith(columns)) {<a name="line.2761"></a>
-<span class="sourceLineNo">2762</span>        opts.columns = Integer.parseInt(cmd.substring(columns.length()));<a name="line.2762"></a>
-<span class="sourceLineNo">2763</span>        continue;<a name="line.2763"></a>
-<span class="sourceLineNo">2764</span>      }<a name="line.2764"></a>
-<span class="sourceLineNo">2765</span><a name="line.2765"></a>
-<span class="sourceLineNo">2766</span>      final String families = "--families=";<a name="line.2766"></a>
-<span class="sourceLineNo">2767</span>      if (cmd.startsWith(families)) {<a name="line.2767"></a>
-<span class="sourceLineNo">2768</span>        opts.families = Integer.parseInt(cmd.substring(families.length()));<a name="line.2768"></a>
-<span class="sourceLineNo">2769</span>        continue;<a name="line.2769"></a>
-<span class="sourceLineNo">2770</span>      }<a name="line.2770"></a>
-<span class="sourceLineNo">2771</span><a name="line.2771"></a>
-<span class="sourceLineNo">2772</span>      final String caching = "--caching=";<a name="line.2772"></a>
-<span class="sourceLineNo">2773</span>      if (cmd.startsWith(caching)) {<a name="line.2773"></a>
-<span class="sourceLineNo">2774</span>        opts.caching = Integer.parseInt(cmd.substring(caching.length()));<a name="line.2774"></a>
-<span class="sourceLineNo">2775</span>        continue;<a name="line.2775"></a>
-<span class="sourceLineNo">2776</span>      }<a name="line.2776"></a>
-<span class="sourceLineNo">2777</span><a name="line.2777"></a>
-<span class="sourceLineNo">2778</span>      final String asyncPrefetch = "--asyncPrefetch";<a name="line.2778"></a>
-<span class="sourceLineNo">2779</span>      if (cmd.startsWith(asyncPrefetch)) {<a name="line.2779"></a>
-<span class="sourceLineNo">2780</span>        opts.asyncPrefetch = true;<a name="line.2780"></a>
-<span class="sourceLineNo">2781</span>        continue;<a name="line.2781"></a>
-<span class="sourceLineNo">2782</span>      }<a name="line.2782"></a>
-<span class="sourceLineNo">2783</span><a name="line.2783"></a>
-<span class="sourceLineNo">2784</span>      final String cacheBlocks = "--cacheBlocks=";<a name="line.2784"></a>
-<span class="sourceLineNo">2785</span>      if (cmd.startsWith(cacheBlocks)) {<a name="line.2785"></a>
-<span class="sourceLineNo">2786</span>        opts.cacheBlocks = Boolean.parseBoolean(cmd.substring(cacheBlocks.length()));<a name="line.2786"></a>
-<span class="sourceLineNo">2787</span>        continue;<a name="line.2787"></a>
-<span class="sourceLineNo">2788</span>      }<a name="line.2788"></a>
-<span class="sourceLineNo">2789</span><a name="line.2789"></a>
-<span class="sourceLineNo">2790</span>      final String scanReadType = "--scanReadType=";<a name="line.2790"></a>
-<span class="sourceLineNo">2791</span>      if (cmd.startsWith(scanReadType)) {<a name="line.2791"></a>
-<span class="sourceLineNo">2792</span>        opts.scanReadType =<a name="line.2792"></a>
-<span class="sourceLineNo">2793</span>            Scan.ReadType.valueOf(cmd.substring(scanReadType.length()).toUpperCase());<a name="line.2793"></a>
-<span class="sourceLineNo">2794</span>        continue;<a name="line.2794"></a>
-<span class="sourceLineNo">2795</span>      }<a name="line.2795"></a>
-<span class="sourceLineNo">2796</span><a name="line.2796"></a>
-<span class="sourceLineNo">2797</span>      final String bufferSize = "--bufferSize=";<a name="line.2797"></a>
-<span class="sourceLineNo">2798</span>      if (cmd.startsWith(bufferSize)) {<a name="line.2798"></a>
-<span class="sourceLineNo">2799</span>        opts.bufferSize = Long.parseLong(cmd.substring(bufferSize.length()));<a name="line.2799"></a>
-<span class="sourceLineNo">2800</span>        continue;<a name="line.2800"></a>
-<span class="sourceLineNo">2801</span>      }<a name="line.2801"></a>
-<span class="sourceLineNo">2802</span><a name="line.2802"></a>
-<span class="sourceLineNo">2803</span>      if (isCommandClass(cmd)) {<a name="line.2803"></a>
-<span class="sourceLineNo">2804</span>        opts.cmdName = cmd;<a name="line.2804"></a>
-<span class="sourceLineNo">2805</span>        try {<a name="line.2805"></a>
-<span class="sourceLineNo">2806</span>          opts.numClientThreads = Integer.parseInt(args.remove());<a name="line.2806"></a>
-<span class="sourceLineNo">2807</span>        } catch (NoSuchElementException | NumberFormatException e) {<a name="line.2807"></a>
-<span class="sourceLineNo">2808</span>          throw new IllegalArgumentException("Command " + cmd + " does not have threads number", e);<a name="line.2808"></a>
-<span class="sourceLineNo">2809</span>        }<a name="line.2809"></a>
-<span class="sourceLineNo">2810</span>        opts = calculateRowsAndSize(opts);<a name="line.2810"></a>
-<span class="sourceLineNo">2811</span>        break;<a name="line.2811"></a>
-<span class="sourceLineNo">2812</span>      } else {<a name="line.2812"></a>
-<span class="sourceLineNo">2813</span>        printUsageAndExit("ERROR: Unrecognized option/command: " + cmd, -1);<a name="line.2813"></a>
-<span class="sourceLineNo">2814</span>      }<a name="line.2814"></a>
-<span class="sourceLineNo">2815</span><a name="line.2815"></a>
-<span class="sourceLineNo">2816</span>      // Not matching any option or command.<a name="line.2816"></a>
-<span class="sourceLineNo">2817</span>      System.err.println("Error: Wrong option or command: " + cmd);<a name="line.2817"></a>
-<span class="sourceLineNo">2818</span>      args.add(cmd);<a name="line.2818"></a>
-<span class="sourceLineNo">2819</span>      break;<a name="line.2819"></a>
-<span class="sourceLineNo">2820</span>    }<a name="line.2820"></a>
-<span class="sourceLineNo">2821</span>    return opts;<a name="line.2821"></a>
-<span class="sourceLineNo">2822</span>  }<a name="line.2822"></a>
-<span class="sourceLineNo">2823</span><a name="line.2823"></a>
-<span class="sourceLineNo">2824</span>  static TestOptions calculateRowsAndSize(final TestOptions opts) {<a name="line.2824"></a>
-<span class="sourceLineNo">2825</span>    int rowsPerGB = getRowsPerGB(opts);<a name="line.2825"></a>
-<span class="sourceLineNo">2826</span>    if ((opts.getCmdName() != null<a name="line.2826"></a>
-<span class="sourceLineNo">2827</span>        &amp;&amp; (opts.getCmdName().equals(RANDOM_READ) || opts.getCmdName().equals(RANDOM_SEEK_SCAN)))<a name="line.2827"></a>
-<span class="sourceLineNo">2828</span>        &amp;&amp; opts.size != DEFAULT_OPTS.size<a name="line.2828"></a>
-<span class="sourceLineNo">2829</span>        &amp;&amp; opts.perClientRunRows != DEFAULT_OPTS.perClientRunRows) {<a name="line.2829"></a>
-<span class="sourceLineNo">2830</span>      opts.totalRows = (int) opts.size * rowsPerGB;<a name="line.2830"></a>
-<span class="sourceLineNo">2831</span>    } else if (opts.size != DEFAULT_OPTS.size) {<a name="line.2831"></a>
-<span class="sourceLineNo">2832</span>      // total size in GB specified<a name="line.2832"></a>
-<span class="sourceLineNo">2833</span>      opts.totalRows = (int) opts.size * rowsPerGB;<a name="line.2833"></a>
-<span class="sourceLineNo">2834</span>      opts.perClientRunRows = opts.totalRows / opts.numClientThreads;<a name="line.2834"></a>
-<span class="sourceLineNo">2835</span>    } else {<a name="line.2835"></a>
-<span class="sourceLineNo">2836</span>      opts.totalRows = opts.perClientRunRows * opts.numClientThreads;<a name="line.2836"></a>
-<span class="sourceLineNo">2837</span>      opts.size = opts.totalRows / rowsPerGB;<a name="line.2837"></a>
-<span class="sourceLineNo">2838</span>    }<a name="line.2838"></a>
-<span class="sourceLineNo">2839</span>    return opts;<a name="line.2839"></a>
-<span class="sourceLineNo">2840</span>  }<a name="line.2840"></a>
-<span class="sourceLineNo">2841</span><a name="line.2841"></a>
-<span class="sourceLineNo">2842</span>  static int getRowsPerGB(final TestOptions opts) {<a name="line.2842"></a>
-<span class="sourceLineNo">2843</span>    return ONE_GB / ((opts.valueRandom? opts.valueSize/2: opts.valueSize) * opts.getFamilies() *<a name="line.2843"></a>
-<span class="sourceLineNo">2844</span>        opts.getColumns());<a name="line.2844"></a>
-<span class="sourceLineNo">2845</span>  }<a name="line.2845"></a>
-<span class="sourceLineNo">2846</span><a name="line.2846"></a>
-<span class="sourceLineNo">2847</span>  @Override<a name="line.2847"></a>
-<span class="sourceLineNo">2848</span>  public int run(String[] args) throws Exception {<a name="line.2848"></a>
-<span class="sourceLineNo">2849</span>    // Process command-line args. TODO: Better cmd-line processing<a name="line.2849"></a>
-<span class="sourceLineNo">2850</span>    // (but hopefully something not as painful as cli options).<a name="line.2850"></a>
-<span class="sourceLineNo">2851</span>    int errCode = -1;<a name="line.2851"></a>
-<span class="sourceLineNo">2852</span>    if (args.length &lt; 1) {<a name="line.2852"></a>
-<span class="sourceLineNo">2853</span>      printUsage();<a name="line.2853"></a>
-<span class="sourceLineNo">2854</span>      return errCode;<a name="line.2854"></a>
-<span class="sourceLineNo">2855</span>    }<a name="line.2855"></a>
-<span class="sourceLineNo">2856</span><a name="line.2856"></a>
-<span class="sourceLineNo">2857</span>    try {<a name="line.2857"></a>
-<span class="sourceLineNo">2858</span>      LinkedList&lt;String&gt; argv = new LinkedList&lt;&gt;();<a name="line.2858"></a>
-<span class="sourceLineNo">2859</span>      argv.addAll(Arrays.asList(args));<a name="line.2859"></a>
-<span class="sourceLineNo">2860</span>      TestOptions opts = parseOpts(argv);<a name="line.2860"></a>
-<span class="sourceLineNo">2861</span><a name="line.2861"></a>
-<span class="sourceLineNo">2862</span>      // args remaining, print help and exit<a name="line.2862"></a>
-<span class="sourceLineNo">2863</span>      if (!argv.isEmpty()) {<a name="line.2863"></a>
-<span class="sourceLineNo">2864</span>        errCode = 0;<a name="line.2864"></a>
-<span class="sourceLineNo">2865</span>        printUsage();<a name="line.2865"></a>
-<span class="sourceLineNo">2866</span>        return errCode;<a name="line.2866"></a>
-<span class="sourceLineNo">2867</span>      }<a name="line.2867"></a>
-<span class="sourceLineNo">2868</span><a name="line.2868"></a>
-<span class="sourceLineNo">2869</span>      // must run at least 1 client<a name="line.2869"></a>
-<span class="sourceLineNo">2870</span>      if (opts.numClientThreads &lt;= 0) {<a name="line.2870"></a>
-<span class="sourceLineNo">2871</span>        throw new IllegalArgumentException("Number of clients must be &gt; 0");<a name="line.2871"></a>
-<span class="sourceLineNo">2872</span>      }<a name="line.2872"></a>
-<span class="sourceLineNo">2873</span><a name="line.2873"></a>
-<span class="sourceLineNo">2874</span>      // cmdName should not be null, print help and exit<a name="line.2874"></a>
-<span class="sourceLineNo">2875</span>      if (opts.cmdName == null) {<a name="line.2875"></a>
-<span class="sourceLineNo">2876</span>        printUsage();<a name="line.2876"></a>
-<span class="sourceLineNo">2877</span>        return errCode;<a name="line.2877"></a>
-<span class="sourceLineNo">2878</span>      }<a name="line.2878"></a>
-<span class="sourceLineNo">2879</span><a name="line.2879"></a>
-<span class="sourceLineNo">2880</span>      Class&lt;? extends TestBase&gt; cmdClass = determineCommandClass(opts.cmdName);<a name="line.2880"></a>
-<span class="sourceLineNo">2881</span>      if (cmdClass != null) {<a name="line.2881"></a>
-<span class="sourceLineNo">2882</span>        runTest(cmdClass, opts);<a name="line.2882"></a>
-<span class="sourceLineNo">2883</span>        errCode = 0;<a name="line.2883"></a>
-<span class="sourceLineNo">2884</span>      }<a name="line.2884"></a>
-<span class="sourceLineNo">2885</span><a name="line.2885"></a>
-<span class="sourceLineNo">2886</span>    } catch (Exception e) {<a name="line.2886"></a>
-<span class="sourceLineNo">2887</span>      e.printStackTrace();<a name="line.2887"></a>
-<span class="sourceLineNo">2888</span>    }<a name="line.2888"></a>
+<span class="sourceLineNo">2399</span>  protected static void printUsage(final String message) {<a name="line.2399"></a>
+<span class="sourceLineNo">2400</span>    printUsage(PE_COMMAND_SHORTNAME, message);<a name="line.2400"></a>
+<span class="sourceLineNo">2401</span>  }<a name="line.2401"></a>
+<span class="sourceLineNo">2402</span><a name="line.2402"></a>
+<span class="sourceLineNo">2403</span>  protected static void printUsageAndExit(final String message, final int exitCode) {<a name="line.2403"></a>
+<span class="sourceLineNo">2404</span>    printUsage(message);<a name="line.2404"></a>
+<span class="sourceLineNo">2405</span>    System.exit(exitCode);<a name="line.2405"></a>
+<span class="sourceLineNo">2406</span>  }<a name="line.2406"></a>
+<span class="sourceLineNo">2407</span><a name="line.2407"></a>
+<span class="sourceLineNo">2408</span>  protected static void printUsage(final String shortName, final String message) {<a name="line.2408"></a>
+<span class="sourceLineNo">2409</span>    if (message != null &amp;&amp; message.length() &gt; 0) {<a name="line.2409"></a>
+<span class="sourceLineNo">2410</span>      System.err.println(message);<a name="line.2410"></a>
+<span class="sourceLineNo">2411</span>    }<a name="line.2411"></a>
+<span class="sourceLineNo">2412</span>    System.err.print("Usage: hbase " + shortName);<a name="line.2412"></a>
+<span class="sourceLineNo">2413</span>    System.err.println("  &lt;OPTIONS&gt; [-D&lt;property=value&gt;]* &lt;command&gt; &lt;nclients&gt;");<a n

<TRUNCATED>

Mime
View raw message