You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by st...@apache.org on 2013/04/06 08:06:09 UTC
svn commit: r1465198 [11/41] - in /hbase/hbase.apache.org/trunk: ./ css/
hbase-assembly/ images/ xref-test/ xref-test/org/apache/hadoop/hbase/
xref-test/org/apache/hadoop/hbase/client/
xref-test/org/apache/hadoop/hbase/client/replication/ xref-test/org...
Modified: hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/mapreduce/TestLoadIncrementalHFiles.html
URL: http://svn.apache.org/viewvc/hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/mapreduce/TestLoadIncrementalHFiles.html?rev=1465198&r1=1465197&r2=1465198&view=diff
==============================================================================
--- hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/mapreduce/TestLoadIncrementalHFiles.html (original)
+++ hbase/hbase.apache.org/trunk/xref-test/org/apache/hadoop/hbase/mapreduce/TestLoadIncrementalHFiles.html Sat Apr 6 06:06:07 2013
@@ -170,194 +170,237 @@
<a class="jxr_linenumber" name="160" href="#160">160</a> assertEquals(expectedRows, util.countRows(table));
<a class="jxr_linenumber" name="161" href="#161">161</a> }
<a class="jxr_linenumber" name="162" href="#162">162</a>
-<a class="jxr_linenumber" name="163" href="#163">163</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">void</strong> verifyAssignedSequenceNumber(String testName,
-<a class="jxr_linenumber" name="164" href="#164">164</a> byte[][][] hfileRanges, <strong class="jxr_keyword">boolean</strong> nonZero) <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="165" href="#165">165</a> Path dir = util.getDataTestDir(testName);
-<a class="jxr_linenumber" name="166" href="#166">166</a> FileSystem fs = util.getTestFileSystem();
-<a class="jxr_linenumber" name="167" href="#167">167</a> dir = dir.makeQualified(fs);
-<a class="jxr_linenumber" name="168" href="#168">168</a> Path familyDir = <strong class="jxr_keyword">new</strong> Path(dir, Bytes.toString(FAMILY));
-<a class="jxr_linenumber" name="169" href="#169">169</a>
-<a class="jxr_linenumber" name="170" href="#170">170</a> <strong class="jxr_keyword">int</strong> hfileIdx = 0;
-<a class="jxr_linenumber" name="171" href="#171">171</a> <strong class="jxr_keyword">for</strong> (byte[][] range : hfileRanges) {
-<a class="jxr_linenumber" name="172" href="#172">172</a> byte[] from = range[0];
-<a class="jxr_linenumber" name="173" href="#173">173</a> byte[] to = range[1];
-<a class="jxr_linenumber" name="174" href="#174">174</a> createHFile(util.getConfiguration(), fs, <strong class="jxr_keyword">new</strong> Path(familyDir, <span class="jxr_string">"hfile_"</span>
-<a class="jxr_linenumber" name="175" href="#175">175</a> + hfileIdx++), FAMILY, QUALIFIER, from, to, 1000);
-<a class="jxr_linenumber" name="176" href="#176">176</a> }
-<a class="jxr_linenumber" name="177" href="#177">177</a>
-<a class="jxr_linenumber" name="178" href="#178">178</a> <strong class="jxr_keyword">final</strong> byte[] TABLE = Bytes.toBytes(<span class="jxr_string">"mytable_"</span>+testName);
-<a class="jxr_linenumber" name="179" href="#179">179</a>
-<a class="jxr_linenumber" name="180" href="#180">180</a> HBaseAdmin admin = <strong class="jxr_keyword">new</strong> HBaseAdmin(util.getConfiguration());
-<a class="jxr_linenumber" name="181" href="#181">181</a> HTableDescriptor htd = <strong class="jxr_keyword">new</strong> HTableDescriptor(TABLE);
-<a class="jxr_linenumber" name="182" href="#182">182</a> HColumnDescriptor familyDesc = <strong class="jxr_keyword">new</strong> HColumnDescriptor(FAMILY);
-<a class="jxr_linenumber" name="183" href="#183">183</a> htd.addFamily(familyDesc);
-<a class="jxr_linenumber" name="184" href="#184">184</a> admin.createTable(htd, SPLIT_KEYS);
-<a class="jxr_linenumber" name="185" href="#185">185</a>
-<a class="jxr_linenumber" name="186" href="#186">186</a> HTable table = <strong class="jxr_keyword">new</strong> HTable(util.getConfiguration(), TABLE);
-<a class="jxr_linenumber" name="187" href="#187">187</a> util.waitTableEnabled(TABLE);
-<a class="jxr_linenumber" name="188" href="#188">188</a> LoadIncrementalHFiles loader = <strong class="jxr_keyword">new</strong> LoadIncrementalHFiles(
-<a class="jxr_linenumber" name="189" href="#189">189</a> util.getConfiguration());
-<a class="jxr_linenumber" name="190" href="#190">190</a>
-<a class="jxr_linenumber" name="191" href="#191">191</a> <em class="jxr_comment">// Do a dummy put to increase the hlog sequence number</em>
-<a class="jxr_linenumber" name="192" href="#192">192</a> Put put = <strong class="jxr_keyword">new</strong> Put(Bytes.toBytes(<span class="jxr_string">"row"</span>));
-<a class="jxr_linenumber" name="193" href="#193">193</a> put.add(FAMILY, QUALIFIER, Bytes.toBytes(<span class="jxr_string">"value"</span>));
-<a class="jxr_linenumber" name="194" href="#194">194</a> table.put(put);
-<a class="jxr_linenumber" name="195" href="#195">195</a>
-<a class="jxr_linenumber" name="196" href="#196">196</a> loader.doBulkLoad(dir, table);
-<a class="jxr_linenumber" name="197" href="#197">197</a>
-<a class="jxr_linenumber" name="198" href="#198">198</a> <em class="jxr_comment">// Get the store files</em>
-<a class="jxr_linenumber" name="199" href="#199">199</a> Collection<StoreFile> files = util.getHBaseCluster().
-<a class="jxr_linenumber" name="200" href="#200">200</a> getRegions(TABLE).get(0).getStore(FAMILY).getStorefiles();
-<a class="jxr_linenumber" name="201" href="#201">201</a> <strong class="jxr_keyword">for</strong> (StoreFile file: files) {
-<a class="jxr_linenumber" name="202" href="#202">202</a> <em class="jxr_comment">// the sequenceId gets initialized during createReader</em>
-<a class="jxr_linenumber" name="203" href="#203">203</a> file.createReader();
-<a class="jxr_linenumber" name="204" href="#204">204</a>
-<a class="jxr_linenumber" name="205" href="#205">205</a> <strong class="jxr_keyword">if</strong> (nonZero)
-<a class="jxr_linenumber" name="206" href="#206">206</a> assertTrue(file.getMaxSequenceId() > 0);
-<a class="jxr_linenumber" name="207" href="#207">207</a> <strong class="jxr_keyword">else</strong>
-<a class="jxr_linenumber" name="208" href="#208">208</a> assertTrue(file.getMaxSequenceId() == -1);
-<a class="jxr_linenumber" name="209" href="#209">209</a> }
-<a class="jxr_linenumber" name="210" href="#210">210</a> }
-<a class="jxr_linenumber" name="211" href="#211">211</a>
-<a class="jxr_linenumber" name="212" href="#212">212</a> @Test
-<a class="jxr_linenumber" name="213" href="#213">213</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testSplitStoreFile() <strong class="jxr_keyword">throws</strong> IOException {
-<a class="jxr_linenumber" name="214" href="#214">214</a> Path dir = util.getDataTestDirOnTestFS(<span class="jxr_string">"testSplitHFile"</span>);
-<a class="jxr_linenumber" name="215" href="#215">215</a> FileSystem fs = util.getTestFileSystem();
-<a class="jxr_linenumber" name="216" href="#216">216</a> Path testIn = <strong class="jxr_keyword">new</strong> Path(dir, <span class="jxr_string">"testhfile"</span>);
-<a class="jxr_linenumber" name="217" href="#217">217</a> HColumnDescriptor familyDesc = <strong class="jxr_keyword">new</strong> HColumnDescriptor(FAMILY);
-<a class="jxr_linenumber" name="218" href="#218">218</a> createHFile(util.getConfiguration(), fs, testIn, FAMILY, QUALIFIER,
-<a class="jxr_linenumber" name="219" href="#219">219</a> Bytes.toBytes(<span class="jxr_string">"aaa"</span>), Bytes.toBytes(<span class="jxr_string">"zzz"</span>), 1000);
+<a class="jxr_linenumber" name="163" href="#163">163</a> <em class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="164" href="#164">164</a> <em class="jxr_javadoccomment"> * Test loading into a column family that does not exist.</em>
+<a class="jxr_linenumber" name="165" href="#165">165</a> <em class="jxr_javadoccomment"> */</em>
+<a class="jxr_linenumber" name="166" href="#166">166</a> @Test
+<a class="jxr_linenumber" name="167" href="#167">167</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testNonexistentColumnFamilyLoad() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="168" href="#168">168</a> String testName = <span class="jxr_string">"testNonexistentColumnFamilyLoad"</span>;
+<a class="jxr_linenumber" name="169" href="#169">169</a> byte[][][] hfileRanges = <strong class="jxr_keyword">new</strong> byte[][][] {
+<a class="jxr_linenumber" name="170" href="#170">170</a> <strong class="jxr_keyword">new</strong> byte[][]{ Bytes.toBytes(<span class="jxr_string">"aaa"</span>), Bytes.toBytes(<span class="jxr_string">"ccc"</span>) },
+<a class="jxr_linenumber" name="171" href="#171">171</a> <strong class="jxr_keyword">new</strong> byte[][]{ Bytes.toBytes(<span class="jxr_string">"ddd"</span>), Bytes.toBytes(<span class="jxr_string">"ooo"</span>) },
+<a class="jxr_linenumber" name="172" href="#172">172</a> };
+<a class="jxr_linenumber" name="173" href="#173">173</a>
+<a class="jxr_linenumber" name="174" href="#174">174</a> Path dir = util.getDataTestDirOnTestFS(testName);
+<a class="jxr_linenumber" name="175" href="#175">175</a> FileSystem fs = util.getTestFileSystem();
+<a class="jxr_linenumber" name="176" href="#176">176</a> dir = dir.makeQualified(fs);
+<a class="jxr_linenumber" name="177" href="#177">177</a> Path familyDir = <strong class="jxr_keyword">new</strong> Path(dir, Bytes.toString(FAMILY));
+<a class="jxr_linenumber" name="178" href="#178">178</a>
+<a class="jxr_linenumber" name="179" href="#179">179</a> <strong class="jxr_keyword">int</strong> hfileIdx = 0;
+<a class="jxr_linenumber" name="180" href="#180">180</a> <strong class="jxr_keyword">for</strong> (byte[][] range : hfileRanges) {
+<a class="jxr_linenumber" name="181" href="#181">181</a> byte[] from = range[0];
+<a class="jxr_linenumber" name="182" href="#182">182</a> byte[] to = range[1];
+<a class="jxr_linenumber" name="183" href="#183">183</a> createHFile(util.getConfiguration(), fs, <strong class="jxr_keyword">new</strong> Path(familyDir, <span class="jxr_string">"hfile_"</span>
+<a class="jxr_linenumber" name="184" href="#184">184</a> + hfileIdx++), FAMILY, QUALIFIER, from, to, 1000);
+<a class="jxr_linenumber" name="185" href="#185">185</a> }
+<a class="jxr_linenumber" name="186" href="#186">186</a>
+<a class="jxr_linenumber" name="187" href="#187">187</a> <strong class="jxr_keyword">final</strong> byte[] TABLE = Bytes.toBytes(<span class="jxr_string">"mytable_"</span>+testName);
+<a class="jxr_linenumber" name="188" href="#188">188</a>
+<a class="jxr_linenumber" name="189" href="#189">189</a> HBaseAdmin admin = <strong class="jxr_keyword">new</strong> HBaseAdmin(util.getConfiguration());
+<a class="jxr_linenumber" name="190" href="#190">190</a> HTableDescriptor htd = <strong class="jxr_keyword">new</strong> HTableDescriptor(TABLE);
+<a class="jxr_linenumber" name="191" href="#191">191</a> admin.createTable(htd, SPLIT_KEYS);
+<a class="jxr_linenumber" name="192" href="#192">192</a>
+<a class="jxr_linenumber" name="193" href="#193">193</a> HTable table = <strong class="jxr_keyword">new</strong> HTable(util.getConfiguration(), TABLE);
+<a class="jxr_linenumber" name="194" href="#194">194</a> util.waitTableEnabled(TABLE);
+<a class="jxr_linenumber" name="195" href="#195">195</a> LoadIncrementalHFiles loader = <strong class="jxr_keyword">new</strong> LoadIncrementalHFiles(util.getConfiguration(), false);
+<a class="jxr_linenumber" name="196" href="#196">196</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="197" href="#197">197</a> loader.doBulkLoad(dir, table);
+<a class="jxr_linenumber" name="198" href="#198">198</a> assertTrue(<span class="jxr_string">"Loading into table with non-existent family should have failed"</span>, false);
+<a class="jxr_linenumber" name="199" href="#199">199</a> } <strong class="jxr_keyword">catch</strong> (Exception e) {
+<a class="jxr_linenumber" name="200" href="#200">200</a> assertTrue(<span class="jxr_string">"IOException expected"</span>, e instanceof IOException);
+<a class="jxr_linenumber" name="201" href="#201">201</a> }
+<a class="jxr_linenumber" name="202" href="#202">202</a> table.close();
+<a class="jxr_linenumber" name="203" href="#203">203</a> admin.close();
+<a class="jxr_linenumber" name="204" href="#204">204</a> }
+<a class="jxr_linenumber" name="205" href="#205">205</a>
+<a class="jxr_linenumber" name="206" href="#206">206</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">void</strong> verifyAssignedSequenceNumber(String testName,
+<a class="jxr_linenumber" name="207" href="#207">207</a> byte[][][] hfileRanges, <strong class="jxr_keyword">boolean</strong> nonZero) <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="208" href="#208">208</a> Path dir = util.getDataTestDir(testName);
+<a class="jxr_linenumber" name="209" href="#209">209</a> FileSystem fs = util.getTestFileSystem();
+<a class="jxr_linenumber" name="210" href="#210">210</a> dir = dir.makeQualified(fs);
+<a class="jxr_linenumber" name="211" href="#211">211</a> Path familyDir = <strong class="jxr_keyword">new</strong> Path(dir, Bytes.toString(FAMILY));
+<a class="jxr_linenumber" name="212" href="#212">212</a>
+<a class="jxr_linenumber" name="213" href="#213">213</a> <strong class="jxr_keyword">int</strong> hfileIdx = 0;
+<a class="jxr_linenumber" name="214" href="#214">214</a> <strong class="jxr_keyword">for</strong> (byte[][] range : hfileRanges) {
+<a class="jxr_linenumber" name="215" href="#215">215</a> byte[] from = range[0];
+<a class="jxr_linenumber" name="216" href="#216">216</a> byte[] to = range[1];
+<a class="jxr_linenumber" name="217" href="#217">217</a> createHFile(util.getConfiguration(), fs, <strong class="jxr_keyword">new</strong> Path(familyDir, <span class="jxr_string">"hfile_"</span>
+<a class="jxr_linenumber" name="218" href="#218">218</a> + hfileIdx++), FAMILY, QUALIFIER, from, to, 1000);
+<a class="jxr_linenumber" name="219" href="#219">219</a> }
<a class="jxr_linenumber" name="220" href="#220">220</a>
-<a class="jxr_linenumber" name="221" href="#221">221</a> Path bottomOut = <strong class="jxr_keyword">new</strong> Path(dir, <span class="jxr_string">"bottom.out"</span>);
-<a class="jxr_linenumber" name="222" href="#222">222</a> Path topOut = <strong class="jxr_keyword">new</strong> Path(dir, <span class="jxr_string">"top.out"</span>);
-<a class="jxr_linenumber" name="223" href="#223">223</a>
-<a class="jxr_linenumber" name="224" href="#224">224</a> LoadIncrementalHFiles.splitStoreFile(
-<a class="jxr_linenumber" name="225" href="#225">225</a> util.getConfiguration(), testIn,
-<a class="jxr_linenumber" name="226" href="#226">226</a> familyDesc, Bytes.toBytes(<span class="jxr_string">"ggg"</span>),
-<a class="jxr_linenumber" name="227" href="#227">227</a> bottomOut,
-<a class="jxr_linenumber" name="228" href="#228">228</a> topOut);
-<a class="jxr_linenumber" name="229" href="#229">229</a>
-<a class="jxr_linenumber" name="230" href="#230">230</a> <strong class="jxr_keyword">int</strong> rowCount = verifyHFile(bottomOut);
-<a class="jxr_linenumber" name="231" href="#231">231</a> rowCount += verifyHFile(topOut);
-<a class="jxr_linenumber" name="232" href="#232">232</a> assertEquals(1000, rowCount);
-<a class="jxr_linenumber" name="233" href="#233">233</a> }
-<a class="jxr_linenumber" name="234" href="#234">234</a>
-<a class="jxr_linenumber" name="235" href="#235">235</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">int</strong> verifyHFile(Path p) <strong class="jxr_keyword">throws</strong> IOException {
-<a class="jxr_linenumber" name="236" href="#236">236</a> Configuration conf = util.getConfiguration();
-<a class="jxr_linenumber" name="237" href="#237">237</a> HFile.Reader reader = HFile.createReader(
-<a class="jxr_linenumber" name="238" href="#238">238</a> p.getFileSystem(conf), p, <strong class="jxr_keyword">new</strong> CacheConfig(conf));
-<a class="jxr_linenumber" name="239" href="#239">239</a> reader.loadFileInfo();
-<a class="jxr_linenumber" name="240" href="#240">240</a> HFileScanner scanner = reader.getScanner(false, false);
-<a class="jxr_linenumber" name="241" href="#241">241</a> scanner.seekTo();
-<a class="jxr_linenumber" name="242" href="#242">242</a> <strong class="jxr_keyword">int</strong> count = 0;
-<a class="jxr_linenumber" name="243" href="#243">243</a> <strong class="jxr_keyword">do</strong> {
-<a class="jxr_linenumber" name="244" href="#244">244</a> count++;
-<a class="jxr_linenumber" name="245" href="#245">245</a> } <strong class="jxr_keyword">while</strong> (scanner.next());
-<a class="jxr_linenumber" name="246" href="#246">246</a> assertTrue(count > 0);
-<a class="jxr_linenumber" name="247" href="#247">247</a> reader.close();
-<a class="jxr_linenumber" name="248" href="#248">248</a> <strong class="jxr_keyword">return</strong> count;
-<a class="jxr_linenumber" name="249" href="#249">249</a> }
-<a class="jxr_linenumber" name="250" href="#250">250</a>
-<a class="jxr_linenumber" name="251" href="#251">251</a>
-<a class="jxr_linenumber" name="252" href="#252">252</a> <em class="jxr_javadoccomment">/**</em>
-<a class="jxr_linenumber" name="253" href="#253">253</a> <em class="jxr_javadoccomment"> * Create an HFile with the given number of rows between a given</em>
-<a class="jxr_linenumber" name="254" href="#254">254</a> <em class="jxr_javadoccomment"> * start key and end key.</em>
-<a class="jxr_linenumber" name="255" href="#255">255</a> <em class="jxr_javadoccomment"> * TODO put me in an HFileTestUtil or something?</em>
-<a class="jxr_linenumber" name="256" href="#256">256</a> <em class="jxr_javadoccomment"> */</em>
-<a class="jxr_linenumber" name="257" href="#257">257</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">void</strong> createHFile(
-<a class="jxr_linenumber" name="258" href="#258">258</a> Configuration conf,
-<a class="jxr_linenumber" name="259" href="#259">259</a> FileSystem fs, Path path,
-<a class="jxr_linenumber" name="260" href="#260">260</a> byte[] family, byte[] qualifier,
-<a class="jxr_linenumber" name="261" href="#261">261</a> byte[] startKey, byte[] endKey, <strong class="jxr_keyword">int</strong> numRows) <strong class="jxr_keyword">throws</strong> IOException
-<a class="jxr_linenumber" name="262" href="#262">262</a> {
-<a class="jxr_linenumber" name="263" href="#263">263</a> HFile.Writer writer = HFile.getWriterFactory(conf, <strong class="jxr_keyword">new</strong> CacheConfig(conf))
-<a class="jxr_linenumber" name="264" href="#264">264</a> .withPath(fs, path)
-<a class="jxr_linenumber" name="265" href="#265">265</a> .withBlockSize(BLOCKSIZE)
-<a class="jxr_linenumber" name="266" href="#266">266</a> .withCompression(COMPRESSION)
-<a class="jxr_linenumber" name="267" href="#267">267</a> .withComparator(KeyValue.KEY_COMPARATOR)
-<a class="jxr_linenumber" name="268" href="#268">268</a> .create();
-<a class="jxr_linenumber" name="269" href="#269">269</a> <strong class="jxr_keyword">long</strong> now = System.currentTimeMillis();
-<a class="jxr_linenumber" name="270" href="#270">270</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="271" href="#271">271</a> <em class="jxr_comment">// subtract 2 since iterateOnSplits doesn't include boundary keys</em>
-<a class="jxr_linenumber" name="272" href="#272">272</a> <strong class="jxr_keyword">for</strong> (byte[] key : Bytes.iterateOnSplits(startKey, endKey, numRows-2)) {
-<a class="jxr_linenumber" name="273" href="#273">273</a> KeyValue kv = <strong class="jxr_keyword">new</strong> KeyValue(key, family, qualifier, now, key);
-<a class="jxr_linenumber" name="274" href="#274">274</a> writer.append(kv);
-<a class="jxr_linenumber" name="275" href="#275">275</a> }
-<a class="jxr_linenumber" name="276" href="#276">276</a> } <strong class="jxr_keyword">finally</strong> {
-<a class="jxr_linenumber" name="277" href="#277">277</a> writer.appendFileInfo(StoreFile.BULKLOAD_TIME_KEY,
-<a class="jxr_linenumber" name="278" href="#278">278</a> Bytes.toBytes(System.currentTimeMillis()));
-<a class="jxr_linenumber" name="279" href="#279">279</a> writer.close();
-<a class="jxr_linenumber" name="280" href="#280">280</a> }
-<a class="jxr_linenumber" name="281" href="#281">281</a> }
-<a class="jxr_linenumber" name="282" href="#282">282</a>
-<a class="jxr_linenumber" name="283" href="#283">283</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">void</strong> addStartEndKeysForTest(TreeMap<byte[], Integer> map, byte[] first, byte[] last) {
-<a class="jxr_linenumber" name="284" href="#284">284</a> Integer value = map.containsKey(first)?(Integer)map.get(first):0;
-<a class="jxr_linenumber" name="285" href="#285">285</a> map.put(first, value+1);
-<a class="jxr_linenumber" name="286" href="#286">286</a>
-<a class="jxr_linenumber" name="287" href="#287">287</a> value = map.containsKey(last)?(Integer)map.get(last):0;
-<a class="jxr_linenumber" name="288" href="#288">288</a> map.put(last, value-1);
-<a class="jxr_linenumber" name="289" href="#289">289</a> }
-<a class="jxr_linenumber" name="290" href="#290">290</a>
-<a class="jxr_linenumber" name="291" href="#291">291</a> @Test
-<a class="jxr_linenumber" name="292" href="#292">292</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testInferBoundaries() {
-<a class="jxr_linenumber" name="293" href="#293">293</a> TreeMap<byte[], Integer> map = <strong class="jxr_keyword">new</strong> TreeMap<byte[], Integer>(Bytes.BYTES_COMPARATOR);
+<a class="jxr_linenumber" name="221" href="#221">221</a> <strong class="jxr_keyword">final</strong> byte[] TABLE = Bytes.toBytes(<span class="jxr_string">"mytable_"</span>+testName);
+<a class="jxr_linenumber" name="222" href="#222">222</a>
+<a class="jxr_linenumber" name="223" href="#223">223</a> HBaseAdmin admin = <strong class="jxr_keyword">new</strong> HBaseAdmin(util.getConfiguration());
+<a class="jxr_linenumber" name="224" href="#224">224</a> HTableDescriptor htd = <strong class="jxr_keyword">new</strong> HTableDescriptor(TABLE);
+<a class="jxr_linenumber" name="225" href="#225">225</a> HColumnDescriptor familyDesc = <strong class="jxr_keyword">new</strong> HColumnDescriptor(FAMILY);
+<a class="jxr_linenumber" name="226" href="#226">226</a> htd.addFamily(familyDesc);
+<a class="jxr_linenumber" name="227" href="#227">227</a> admin.createTable(htd, SPLIT_KEYS);
+<a class="jxr_linenumber" name="228" href="#228">228</a>
+<a class="jxr_linenumber" name="229" href="#229">229</a> HTable table = <strong class="jxr_keyword">new</strong> HTable(util.getConfiguration(), TABLE);
+<a class="jxr_linenumber" name="230" href="#230">230</a> util.waitTableEnabled(TABLE);
+<a class="jxr_linenumber" name="231" href="#231">231</a> LoadIncrementalHFiles loader = <strong class="jxr_keyword">new</strong> LoadIncrementalHFiles(
+<a class="jxr_linenumber" name="232" href="#232">232</a> util.getConfiguration());
+<a class="jxr_linenumber" name="233" href="#233">233</a>
+<a class="jxr_linenumber" name="234" href="#234">234</a> <em class="jxr_comment">// Do a dummy put to increase the hlog sequence number</em>
+<a class="jxr_linenumber" name="235" href="#235">235</a> Put put = <strong class="jxr_keyword">new</strong> Put(Bytes.toBytes(<span class="jxr_string">"row"</span>));
+<a class="jxr_linenumber" name="236" href="#236">236</a> put.add(FAMILY, QUALIFIER, Bytes.toBytes(<span class="jxr_string">"value"</span>));
+<a class="jxr_linenumber" name="237" href="#237">237</a> table.put(put);
+<a class="jxr_linenumber" name="238" href="#238">238</a>
+<a class="jxr_linenumber" name="239" href="#239">239</a> loader.doBulkLoad(dir, table);
+<a class="jxr_linenumber" name="240" href="#240">240</a>
+<a class="jxr_linenumber" name="241" href="#241">241</a> <em class="jxr_comment">// Get the store files</em>
+<a class="jxr_linenumber" name="242" href="#242">242</a> Collection<StoreFile> files = util.getHBaseCluster().
+<a class="jxr_linenumber" name="243" href="#243">243</a> getRegions(TABLE).get(0).getStore(FAMILY).getStorefiles();
+<a class="jxr_linenumber" name="244" href="#244">244</a> <strong class="jxr_keyword">for</strong> (StoreFile file: files) {
+<a class="jxr_linenumber" name="245" href="#245">245</a> <em class="jxr_comment">// the sequenceId gets initialized during createReader</em>
+<a class="jxr_linenumber" name="246" href="#246">246</a> file.createReader();
+<a class="jxr_linenumber" name="247" href="#247">247</a>
+<a class="jxr_linenumber" name="248" href="#248">248</a> <strong class="jxr_keyword">if</strong> (nonZero)
+<a class="jxr_linenumber" name="249" href="#249">249</a> assertTrue(file.getMaxSequenceId() > 0);
+<a class="jxr_linenumber" name="250" href="#250">250</a> <strong class="jxr_keyword">else</strong>
+<a class="jxr_linenumber" name="251" href="#251">251</a> assertTrue(file.getMaxSequenceId() == -1);
+<a class="jxr_linenumber" name="252" href="#252">252</a> }
+<a class="jxr_linenumber" name="253" href="#253">253</a> }
+<a class="jxr_linenumber" name="254" href="#254">254</a>
+<a class="jxr_linenumber" name="255" href="#255">255</a> @Test
+<a class="jxr_linenumber" name="256" href="#256">256</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testSplitStoreFile() <strong class="jxr_keyword">throws</strong> IOException {
+<a class="jxr_linenumber" name="257" href="#257">257</a> Path dir = util.getDataTestDirOnTestFS(<span class="jxr_string">"testSplitHFile"</span>);
+<a class="jxr_linenumber" name="258" href="#258">258</a> FileSystem fs = util.getTestFileSystem();
+<a class="jxr_linenumber" name="259" href="#259">259</a> Path testIn = <strong class="jxr_keyword">new</strong> Path(dir, <span class="jxr_string">"testhfile"</span>);
+<a class="jxr_linenumber" name="260" href="#260">260</a> HColumnDescriptor familyDesc = <strong class="jxr_keyword">new</strong> HColumnDescriptor(FAMILY);
+<a class="jxr_linenumber" name="261" href="#261">261</a> createHFile(util.getConfiguration(), fs, testIn, FAMILY, QUALIFIER,
+<a class="jxr_linenumber" name="262" href="#262">262</a> Bytes.toBytes(<span class="jxr_string">"aaa"</span>), Bytes.toBytes(<span class="jxr_string">"zzz"</span>), 1000);
+<a class="jxr_linenumber" name="263" href="#263">263</a>
+<a class="jxr_linenumber" name="264" href="#264">264</a> Path bottomOut = <strong class="jxr_keyword">new</strong> Path(dir, <span class="jxr_string">"bottom.out"</span>);
+<a class="jxr_linenumber" name="265" href="#265">265</a> Path topOut = <strong class="jxr_keyword">new</strong> Path(dir, <span class="jxr_string">"top.out"</span>);
+<a class="jxr_linenumber" name="266" href="#266">266</a>
+<a class="jxr_linenumber" name="267" href="#267">267</a> LoadIncrementalHFiles.splitStoreFile(
+<a class="jxr_linenumber" name="268" href="#268">268</a> util.getConfiguration(), testIn,
+<a class="jxr_linenumber" name="269" href="#269">269</a> familyDesc, Bytes.toBytes(<span class="jxr_string">"ggg"</span>),
+<a class="jxr_linenumber" name="270" href="#270">270</a> bottomOut,
+<a class="jxr_linenumber" name="271" href="#271">271</a> topOut);
+<a class="jxr_linenumber" name="272" href="#272">272</a>
+<a class="jxr_linenumber" name="273" href="#273">273</a> <strong class="jxr_keyword">int</strong> rowCount = verifyHFile(bottomOut);
+<a class="jxr_linenumber" name="274" href="#274">274</a> rowCount += verifyHFile(topOut);
+<a class="jxr_linenumber" name="275" href="#275">275</a> assertEquals(1000, rowCount);
+<a class="jxr_linenumber" name="276" href="#276">276</a> }
+<a class="jxr_linenumber" name="277" href="#277">277</a>
+<a class="jxr_linenumber" name="278" href="#278">278</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">int</strong> verifyHFile(Path p) <strong class="jxr_keyword">throws</strong> IOException {
+<a class="jxr_linenumber" name="279" href="#279">279</a> Configuration conf = util.getConfiguration();
+<a class="jxr_linenumber" name="280" href="#280">280</a> HFile.Reader reader = HFile.createReader(
+<a class="jxr_linenumber" name="281" href="#281">281</a> p.getFileSystem(conf), p, <strong class="jxr_keyword">new</strong> CacheConfig(conf));
+<a class="jxr_linenumber" name="282" href="#282">282</a> reader.loadFileInfo();
+<a class="jxr_linenumber" name="283" href="#283">283</a> HFileScanner scanner = reader.getScanner(false, false);
+<a class="jxr_linenumber" name="284" href="#284">284</a> scanner.seekTo();
+<a class="jxr_linenumber" name="285" href="#285">285</a> <strong class="jxr_keyword">int</strong> count = 0;
+<a class="jxr_linenumber" name="286" href="#286">286</a> <strong class="jxr_keyword">do</strong> {
+<a class="jxr_linenumber" name="287" href="#287">287</a> count++;
+<a class="jxr_linenumber" name="288" href="#288">288</a> } <strong class="jxr_keyword">while</strong> (scanner.next());
+<a class="jxr_linenumber" name="289" href="#289">289</a> assertTrue(count > 0);
+<a class="jxr_linenumber" name="290" href="#290">290</a> reader.close();
+<a class="jxr_linenumber" name="291" href="#291">291</a> <strong class="jxr_keyword">return</strong> count;
+<a class="jxr_linenumber" name="292" href="#292">292</a> }
+<a class="jxr_linenumber" name="293" href="#293">293</a>
<a class="jxr_linenumber" name="294" href="#294">294</a>
-<a class="jxr_linenumber" name="295" href="#295">295</a> <em class="jxr_comment">/*<em class="jxr_comment"> Toy example</em></em>
-<a class="jxr_linenumber" name="296" href="#296">296</a> <em class="jxr_comment"> * c---------i o------p s---------t v------x</em>
-<a class="jxr_linenumber" name="297" href="#297">297</a> <em class="jxr_comment"> * a------e g-----k m-------------q r----s u----w</em>
-<a class="jxr_linenumber" name="298" href="#298">298</a> <em class="jxr_comment"> *</em>
-<a class="jxr_linenumber" name="299" href="#299">299</a> <em class="jxr_comment"> * Should be inferred as:</em>
-<a class="jxr_linenumber" name="300" href="#300">300</a> <em class="jxr_comment"> * a-----------------k m-------------q r--------------t u---------x</em>
-<a class="jxr_linenumber" name="301" href="#301">301</a> <em class="jxr_comment"> * </em>
-<a class="jxr_linenumber" name="302" href="#302">302</a> <em class="jxr_comment"> * The output should be (m,r,u) </em>
-<a class="jxr_linenumber" name="303" href="#303">303</a> <em class="jxr_comment"> */</em>
-<a class="jxr_linenumber" name="304" href="#304">304</a>
-<a class="jxr_linenumber" name="305" href="#305">305</a> String first;
-<a class="jxr_linenumber" name="306" href="#306">306</a> String last;
-<a class="jxr_linenumber" name="307" href="#307">307</a>
-<a class="jxr_linenumber" name="308" href="#308">308</a> first = <span class="jxr_string">"a"</span>; last = <span class="jxr_string">"e"</span>;
-<a class="jxr_linenumber" name="309" href="#309">309</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="310" href="#310">310</a>
-<a class="jxr_linenumber" name="311" href="#311">311</a> first = <span class="jxr_string">"r"</span>; last = <span class="jxr_string">"s"</span>;
-<a class="jxr_linenumber" name="312" href="#312">312</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="313" href="#313">313</a>
-<a class="jxr_linenumber" name="314" href="#314">314</a> first = <span class="jxr_string">"o"</span>; last = <span class="jxr_string">"p"</span>;
-<a class="jxr_linenumber" name="315" href="#315">315</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="316" href="#316">316</a>
-<a class="jxr_linenumber" name="317" href="#317">317</a> first = <span class="jxr_string">"g"</span>; last = <span class="jxr_string">"k"</span>;
-<a class="jxr_linenumber" name="318" href="#318">318</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="319" href="#319">319</a>
-<a class="jxr_linenumber" name="320" href="#320">320</a> first = <span class="jxr_string">"v"</span>; last = <span class="jxr_string">"x"</span>;
-<a class="jxr_linenumber" name="321" href="#321">321</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="322" href="#322">322</a>
-<a class="jxr_linenumber" name="323" href="#323">323</a> first = <span class="jxr_string">"c"</span>; last = <span class="jxr_string">"i"</span>;
-<a class="jxr_linenumber" name="324" href="#324">324</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="295" href="#295">295</a> <em class="jxr_javadoccomment">/**</em>
+<a class="jxr_linenumber" name="296" href="#296">296</a> <em class="jxr_javadoccomment"> * Create an HFile with the given number of rows between a given</em>
+<a class="jxr_linenumber" name="297" href="#297">297</a> <em class="jxr_javadoccomment"> * start key and end key.</em>
+<a class="jxr_linenumber" name="298" href="#298">298</a> <em class="jxr_javadoccomment"> * TODO put me in an HFileTestUtil or something?</em>
+<a class="jxr_linenumber" name="299" href="#299">299</a> <em class="jxr_javadoccomment"> */</em>
+<a class="jxr_linenumber" name="300" href="#300">300</a> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">void</strong> createHFile(
+<a class="jxr_linenumber" name="301" href="#301">301</a> Configuration conf,
+<a class="jxr_linenumber" name="302" href="#302">302</a> FileSystem fs, Path path,
+<a class="jxr_linenumber" name="303" href="#303">303</a> byte[] family, byte[] qualifier,
+<a class="jxr_linenumber" name="304" href="#304">304</a> byte[] startKey, byte[] endKey, <strong class="jxr_keyword">int</strong> numRows) <strong class="jxr_keyword">throws</strong> IOException
+<a class="jxr_linenumber" name="305" href="#305">305</a> {
+<a class="jxr_linenumber" name="306" href="#306">306</a> HFile.Writer writer = HFile.getWriterFactory(conf, <strong class="jxr_keyword">new</strong> CacheConfig(conf))
+<a class="jxr_linenumber" name="307" href="#307">307</a> .withPath(fs, path)
+<a class="jxr_linenumber" name="308" href="#308">308</a> .withBlockSize(BLOCKSIZE)
+<a class="jxr_linenumber" name="309" href="#309">309</a> .withCompression(COMPRESSION)
+<a class="jxr_linenumber" name="310" href="#310">310</a> .withComparator(KeyValue.KEY_COMPARATOR)
+<a class="jxr_linenumber" name="311" href="#311">311</a> .create();
+<a class="jxr_linenumber" name="312" href="#312">312</a> <strong class="jxr_keyword">long</strong> now = System.currentTimeMillis();
+<a class="jxr_linenumber" name="313" href="#313">313</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="314" href="#314">314</a> <em class="jxr_comment">// subtract 2 since iterateOnSplits doesn't include boundary keys</em>
+<a class="jxr_linenumber" name="315" href="#315">315</a> <strong class="jxr_keyword">for</strong> (byte[] key : Bytes.iterateOnSplits(startKey, endKey, numRows-2)) {
+<a class="jxr_linenumber" name="316" href="#316">316</a> KeyValue kv = <strong class="jxr_keyword">new</strong> KeyValue(key, family, qualifier, now, key);
+<a class="jxr_linenumber" name="317" href="#317">317</a> writer.append(kv);
+<a class="jxr_linenumber" name="318" href="#318">318</a> }
+<a class="jxr_linenumber" name="319" href="#319">319</a> } <strong class="jxr_keyword">finally</strong> {
+<a class="jxr_linenumber" name="320" href="#320">320</a> writer.appendFileInfo(StoreFile.BULKLOAD_TIME_KEY,
+<a class="jxr_linenumber" name="321" href="#321">321</a> Bytes.toBytes(System.currentTimeMillis()));
+<a class="jxr_linenumber" name="322" href="#322">322</a> writer.close();
+<a class="jxr_linenumber" name="323" href="#323">323</a> }
+<a class="jxr_linenumber" name="324" href="#324">324</a> }
<a class="jxr_linenumber" name="325" href="#325">325</a>
-<a class="jxr_linenumber" name="326" href="#326">326</a> first = <span class="jxr_string">"m"</span>; last = <span class="jxr_string">"q"</span>;
-<a class="jxr_linenumber" name="327" href="#327">327</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="328" href="#328">328</a>
-<a class="jxr_linenumber" name="329" href="#329">329</a> first = <span class="jxr_string">"s"</span>; last = <span class="jxr_string">"t"</span>;
-<a class="jxr_linenumber" name="330" href="#330">330</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="331" href="#331">331</a>
-<a class="jxr_linenumber" name="332" href="#332">332</a> first = <span class="jxr_string">"u"</span>; last = <span class="jxr_string">"w"</span>;
-<a class="jxr_linenumber" name="333" href="#333">333</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
-<a class="jxr_linenumber" name="334" href="#334">334</a>
-<a class="jxr_linenumber" name="335" href="#335">335</a> byte[][] keysArray = LoadIncrementalHFiles.inferBoundaries(map);
-<a class="jxr_linenumber" name="336" href="#336">336</a> byte[][] compare = <strong class="jxr_keyword">new</strong> byte[3][];
-<a class="jxr_linenumber" name="337" href="#337">337</a> compare[0] = <span class="jxr_string">"m"</span>.getBytes();
-<a class="jxr_linenumber" name="338" href="#338">338</a> compare[1] = <span class="jxr_string">"r"</span>.getBytes();
-<a class="jxr_linenumber" name="339" href="#339">339</a> compare[2] = <span class="jxr_string">"u"</span>.getBytes();
-<a class="jxr_linenumber" name="340" href="#340">340</a>
-<a class="jxr_linenumber" name="341" href="#341">341</a> assertEquals(keysArray.length, 3);
-<a class="jxr_linenumber" name="342" href="#342">342</a>
-<a class="jxr_linenumber" name="343" href="#343">343</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> row = 0; row<keysArray.length; row++){
-<a class="jxr_linenumber" name="344" href="#344">344</a> assertArrayEquals(keysArray[row], compare[row]);
-<a class="jxr_linenumber" name="345" href="#345">345</a> }
-<a class="jxr_linenumber" name="346" href="#346">346</a> }
+<a class="jxr_linenumber" name="326" href="#326">326</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">void</strong> addStartEndKeysForTest(TreeMap<byte[], Integer> map, byte[] first, byte[] last) {
+<a class="jxr_linenumber" name="327" href="#327">327</a> Integer value = map.containsKey(first)?(Integer)map.get(first):0;
+<a class="jxr_linenumber" name="328" href="#328">328</a> map.put(first, value+1);
+<a class="jxr_linenumber" name="329" href="#329">329</a>
+<a class="jxr_linenumber" name="330" href="#330">330</a> value = map.containsKey(last)?(Integer)map.get(last):0;
+<a class="jxr_linenumber" name="331" href="#331">331</a> map.put(last, value-1);
+<a class="jxr_linenumber" name="332" href="#332">332</a> }
+<a class="jxr_linenumber" name="333" href="#333">333</a>
+<a class="jxr_linenumber" name="334" href="#334">334</a> @Test
+<a class="jxr_linenumber" name="335" href="#335">335</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testInferBoundaries() {
+<a class="jxr_linenumber" name="336" href="#336">336</a> TreeMap<byte[], Integer> map = <strong class="jxr_keyword">new</strong> TreeMap<byte[], Integer>(Bytes.BYTES_COMPARATOR);
+<a class="jxr_linenumber" name="337" href="#337">337</a>
+<a class="jxr_linenumber" name="338" href="#338">338</a> <em class="jxr_comment">/*<em class="jxr_comment"> Toy example</em></em>
+<a class="jxr_linenumber" name="339" href="#339">339</a> <em class="jxr_comment"> * c---------i o------p s---------t v------x</em>
+<a class="jxr_linenumber" name="340" href="#340">340</a> <em class="jxr_comment"> * a------e g-----k m-------------q r----s u----w</em>
+<a class="jxr_linenumber" name="341" href="#341">341</a> <em class="jxr_comment"> *</em>
+<a class="jxr_linenumber" name="342" href="#342">342</a> <em class="jxr_comment"> * Should be inferred as:</em>
+<a class="jxr_linenumber" name="343" href="#343">343</a> <em class="jxr_comment"> * a-----------------k m-------------q r--------------t u---------x</em>
+<a class="jxr_linenumber" name="344" href="#344">344</a> <em class="jxr_comment"> * </em>
+<a class="jxr_linenumber" name="345" href="#345">345</a> <em class="jxr_comment"> * The output should be (m,r,u) </em>
+<a class="jxr_linenumber" name="346" href="#346">346</a> <em class="jxr_comment"> */</em>
<a class="jxr_linenumber" name="347" href="#347">347</a>
-<a class="jxr_linenumber" name="348" href="#348">348</a>
-<a class="jxr_linenumber" name="349" href="#349">349</a> }
+<a class="jxr_linenumber" name="348" href="#348">348</a> String first;
+<a class="jxr_linenumber" name="349" href="#349">349</a> String last;
<a class="jxr_linenumber" name="350" href="#350">350</a>
+<a class="jxr_linenumber" name="351" href="#351">351</a> first = <span class="jxr_string">"a"</span>; last = <span class="jxr_string">"e"</span>;
+<a class="jxr_linenumber" name="352" href="#352">352</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="353" href="#353">353</a>
+<a class="jxr_linenumber" name="354" href="#354">354</a> first = <span class="jxr_string">"r"</span>; last = <span class="jxr_string">"s"</span>;
+<a class="jxr_linenumber" name="355" href="#355">355</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="356" href="#356">356</a>
+<a class="jxr_linenumber" name="357" href="#357">357</a> first = <span class="jxr_string">"o"</span>; last = <span class="jxr_string">"p"</span>;
+<a class="jxr_linenumber" name="358" href="#358">358</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="359" href="#359">359</a>
+<a class="jxr_linenumber" name="360" href="#360">360</a> first = <span class="jxr_string">"g"</span>; last = <span class="jxr_string">"k"</span>;
+<a class="jxr_linenumber" name="361" href="#361">361</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="362" href="#362">362</a>
+<a class="jxr_linenumber" name="363" href="#363">363</a> first = <span class="jxr_string">"v"</span>; last = <span class="jxr_string">"x"</span>;
+<a class="jxr_linenumber" name="364" href="#364">364</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="365" href="#365">365</a>
+<a class="jxr_linenumber" name="366" href="#366">366</a> first = <span class="jxr_string">"c"</span>; last = <span class="jxr_string">"i"</span>;
+<a class="jxr_linenumber" name="367" href="#367">367</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="368" href="#368">368</a>
+<a class="jxr_linenumber" name="369" href="#369">369</a> first = <span class="jxr_string">"m"</span>; last = <span class="jxr_string">"q"</span>;
+<a class="jxr_linenumber" name="370" href="#370">370</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="371" href="#371">371</a>
+<a class="jxr_linenumber" name="372" href="#372">372</a> first = <span class="jxr_string">"s"</span>; last = <span class="jxr_string">"t"</span>;
+<a class="jxr_linenumber" name="373" href="#373">373</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="374" href="#374">374</a>
+<a class="jxr_linenumber" name="375" href="#375">375</a> first = <span class="jxr_string">"u"</span>; last = <span class="jxr_string">"w"</span>;
+<a class="jxr_linenumber" name="376" href="#376">376</a> addStartEndKeysForTest(map, first.getBytes(), last.getBytes());
+<a class="jxr_linenumber" name="377" href="#377">377</a>
+<a class="jxr_linenumber" name="378" href="#378">378</a> byte[][] keysArray = LoadIncrementalHFiles.inferBoundaries(map);
+<a class="jxr_linenumber" name="379" href="#379">379</a> byte[][] compare = <strong class="jxr_keyword">new</strong> byte[3][];
+<a class="jxr_linenumber" name="380" href="#380">380</a> compare[0] = <span class="jxr_string">"m"</span>.getBytes();
+<a class="jxr_linenumber" name="381" href="#381">381</a> compare[1] = <span class="jxr_string">"r"</span>.getBytes();
+<a class="jxr_linenumber" name="382" href="#382">382</a> compare[2] = <span class="jxr_string">"u"</span>.getBytes();
+<a class="jxr_linenumber" name="383" href="#383">383</a>
+<a class="jxr_linenumber" name="384" href="#384">384</a> assertEquals(keysArray.length, 3);
+<a class="jxr_linenumber" name="385" href="#385">385</a>
+<a class="jxr_linenumber" name="386" href="#386">386</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> row = 0; row<keysArray.length; row++){
+<a class="jxr_linenumber" name="387" href="#387">387</a> assertArrayEquals(keysArray[row], compare[row]);
+<a class="jxr_linenumber" name="388" href="#388">388</a> }
+<a class="jxr_linenumber" name="389" href="#389">389</a> }
+<a class="jxr_linenumber" name="390" href="#390">390</a>
+<a class="jxr_linenumber" name="391" href="#391">391</a>
+<a class="jxr_linenumber" name="392" href="#392">392</a> }
+<a class="jxr_linenumber" name="393" href="#393">393</a>
</pre>
<hr/><div id="footer">This page was automatically generated by <a href="http://maven.apache.org/">Maven</a></div></body>
</html>