| <!DOCTYPE HTML> |
| <html lang="en"> |
| <head> |
| <!-- Generated by javadoc (17) --> |
| <title>Source code</title> |
| <meta name="viewport" content="width=device-width, initial-scale=1"> |
| <meta name="description" content="source: package: org.apache.hadoop.hbase.client, class: TestFromClientSide"> |
| <meta name="generator" content="javadoc/SourceToHTMLConverter"> |
| <link rel="stylesheet" type="text/css" href="../../../../../../stylesheet.css" title="Style"> |
| </head> |
| <body class="source-page"> |
| <main role="main"> |
| <div class="source-container"> |
| <pre><span class="source-line-no">001</span><span id="line-1">/*</span> |
| <span class="source-line-no">002</span><span id="line-2"> * Licensed to the Apache Software Foundation (ASF) under one</span> |
| <span class="source-line-no">003</span><span id="line-3"> * or more contributor license agreements. See the NOTICE file</span> |
| <span class="source-line-no">004</span><span id="line-4"> * distributed with this work for additional information</span> |
| <span class="source-line-no">005</span><span id="line-5"> * regarding copyright ownership. The ASF licenses this file</span> |
| <span class="source-line-no">006</span><span id="line-6"> * to you under the Apache License, Version 2.0 (the</span> |
| <span class="source-line-no">007</span><span id="line-7"> * "License"); you may not use this file except in compliance</span> |
| <span class="source-line-no">008</span><span id="line-8"> * with the License. You may obtain a copy of the License at</span> |
| <span class="source-line-no">009</span><span id="line-9"> *</span> |
| <span class="source-line-no">010</span><span id="line-10"> * http://www.apache.org/licenses/LICENSE-2.0</span> |
| <span class="source-line-no">011</span><span id="line-11"> *</span> |
| <span class="source-line-no">012</span><span id="line-12"> * Unless required by applicable law or agreed to in writing, software</span> |
| <span class="source-line-no">013</span><span id="line-13"> * distributed under the License is distributed on an "AS IS" BASIS,</span> |
| <span class="source-line-no">014</span><span id="line-14"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span> |
| <span class="source-line-no">015</span><span id="line-15"> * See the License for the specific language governing permissions and</span> |
| <span class="source-line-no">016</span><span id="line-16"> * limitations under the License.</span> |
| <span class="source-line-no">017</span><span id="line-17"> */</span> |
| <span class="source-line-no">018</span><span id="line-18">package org.apache.hadoop.hbase.client;</span> |
| <span class="source-line-no">019</span><span id="line-19"></span> |
| <span class="source-line-no">020</span><span id="line-20">import static org.apache.hadoop.hbase.HBaseTestingUtil.countRows;</span> |
| <span class="source-line-no">021</span><span id="line-21">import static org.junit.Assert.assertArrayEquals;</span> |
| <span class="source-line-no">022</span><span id="line-22">import static org.junit.Assert.assertEquals;</span> |
| <span class="source-line-no">023</span><span id="line-23">import static org.junit.Assert.assertNull;</span> |
| <span class="source-line-no">024</span><span id="line-24">import static org.junit.Assert.assertSame;</span> |
| <span class="source-line-no">025</span><span id="line-25">import static org.junit.Assert.assertTrue;</span> |
| <span class="source-line-no">026</span><span id="line-26">import static org.junit.Assert.fail;</span> |
| <span class="source-line-no">027</span><span id="line-27"></span> |
| <span class="source-line-no">028</span><span id="line-28">import java.io.IOException;</span> |
| <span class="source-line-no">029</span><span id="line-29">import java.util.ArrayList;</span> |
| <span class="source-line-no">030</span><span id="line-30">import java.util.Arrays;</span> |
| <span class="source-line-no">031</span><span id="line-31">import java.util.Collection;</span> |
| <span class="source-line-no">032</span><span id="line-32">import java.util.Collections;</span> |
| <span class="source-line-no">033</span><span id="line-33">import java.util.HashMap;</span> |
| <span class="source-line-no">034</span><span id="line-34">import java.util.List;</span> |
| <span class="source-line-no">035</span><span id="line-35">import java.util.Map;</span> |
| <span class="source-line-no">036</span><span id="line-36">import org.apache.hadoop.conf.Configuration;</span> |
| <span class="source-line-no">037</span><span id="line-37">import org.apache.hadoop.hbase.Cell;</span> |
| <span class="source-line-no">038</span><span id="line-38">import org.apache.hadoop.hbase.CellUtil;</span> |
| <span class="source-line-no">039</span><span id="line-39">import org.apache.hadoop.hbase.CompareOperator;</span> |
| <span class="source-line-no">040</span><span id="line-40">import org.apache.hadoop.hbase.ExtendedCell;</span> |
| <span class="source-line-no">041</span><span id="line-41">import org.apache.hadoop.hbase.HBaseClassTestRule;</span> |
| <span class="source-line-no">042</span><span id="line-42">import org.apache.hadoop.hbase.HBaseTestingUtil;</span> |
| <span class="source-line-no">043</span><span id="line-43">import org.apache.hadoop.hbase.HConstants;</span> |
| <span class="source-line-no">044</span><span id="line-44">import org.apache.hadoop.hbase.HRegionLocation;</span> |
| <span class="source-line-no">045</span><span id="line-45">import org.apache.hadoop.hbase.KeepDeletedCells;</span> |
| <span class="source-line-no">046</span><span id="line-46">import org.apache.hadoop.hbase.PrivateCellUtil;</span> |
| <span class="source-line-no">047</span><span id="line-47">import org.apache.hadoop.hbase.TableName;</span> |
| <span class="source-line-no">048</span><span id="line-48">import org.apache.hadoop.hbase.TableNameTestRule;</span> |
| <span class="source-line-no">049</span><span id="line-49">import org.apache.hadoop.hbase.coprocessor.MultiRowMutationEndpoint;</span> |
| <span class="source-line-no">050</span><span id="line-50">import org.apache.hadoop.hbase.filter.Filter;</span> |
| <span class="source-line-no">051</span><span id="line-51">import org.apache.hadoop.hbase.filter.KeyOnlyFilter;</span> |
| <span class="source-line-no">052</span><span id="line-52">import org.apache.hadoop.hbase.filter.LongComparator;</span> |
| <span class="source-line-no">053</span><span id="line-53">import org.apache.hadoop.hbase.filter.QualifierFilter;</span> |
| <span class="source-line-no">054</span><span id="line-54">import org.apache.hadoop.hbase.filter.RegexStringComparator;</span> |
| <span class="source-line-no">055</span><span id="line-55">import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;</span> |
| <span class="source-line-no">056</span><span id="line-56">import org.apache.hadoop.hbase.testclassification.ClientTests;</span> |
| <span class="source-line-no">057</span><span id="line-57">import org.apache.hadoop.hbase.testclassification.LargeTests;</span> |
| <span class="source-line-no">058</span><span id="line-58">import org.apache.hadoop.hbase.util.Bytes;</span> |
| <span class="source-line-no">059</span><span id="line-59">import org.apache.hadoop.hbase.util.EnvironmentEdgeManager;</span> |
| <span class="source-line-no">060</span><span id="line-60">import org.junit.AfterClass;</span> |
| <span class="source-line-no">061</span><span id="line-61">import org.junit.ClassRule;</span> |
| <span class="source-line-no">062</span><span id="line-62">import org.junit.Rule;</span> |
| <span class="source-line-no">063</span><span id="line-63">import org.junit.Test;</span> |
| <span class="source-line-no">064</span><span id="line-64">import org.junit.experimental.categories.Category;</span> |
| <span class="source-line-no">065</span><span id="line-65">import org.junit.runner.RunWith;</span> |
| <span class="source-line-no">066</span><span id="line-66">import org.junit.runners.Parameterized;</span> |
| <span class="source-line-no">067</span><span id="line-67">import org.slf4j.Logger;</span> |
| <span class="source-line-no">068</span><span id="line-68">import org.slf4j.LoggerFactory;</span> |
| <span class="source-line-no">069</span><span id="line-69"></span> |
| <span class="source-line-no">070</span><span id="line-70">/**</span> |
| <span class="source-line-no">071</span><span id="line-71"> * Run tests that use the HBase clients; {@link Table}. Sets up the HBase mini cluster once at start</span> |
| <span class="source-line-no">072</span><span id="line-72"> * and runs through all client tests. Each creates a table named for the method and does its stuff</span> |
| <span class="source-line-no">073</span><span id="line-73"> * against that. Parameterized to run with different registry implementations. This class was split</span> |
| <span class="source-line-no">074</span><span id="line-74"> * in three because it got too big when parameterized. Other classes are below.</span> |
| <span class="source-line-no">075</span><span id="line-75"> * @see TestFromClientSide4</span> |
| <span class="source-line-no">076</span><span id="line-76"> * @see TestFromClientSide5</span> |
| <span class="source-line-no">077</span><span id="line-77"> */</span> |
| <span class="source-line-no">078</span><span id="line-78">// NOTE: Increment tests were moved to their own class, TestIncrementsFromClientSide.</span> |
| <span class="source-line-no">079</span><span id="line-79">@Category({ LargeTests.class, ClientTests.class })</span> |
| <span class="source-line-no">080</span><span id="line-80">@SuppressWarnings("deprecation")</span> |
| <span class="source-line-no">081</span><span id="line-81">@RunWith(Parameterized.class)</span> |
| <span class="source-line-no">082</span><span id="line-82">public class TestFromClientSide extends FromClientSideBase {</span> |
| <span class="source-line-no">083</span><span id="line-83"> private static final Logger LOG = LoggerFactory.getLogger(TestFromClientSide.class);</span> |
| <span class="source-line-no">084</span><span id="line-84"></span> |
| <span class="source-line-no">085</span><span id="line-85"> @ClassRule</span> |
| <span class="source-line-no">086</span><span id="line-86"> public static final HBaseClassTestRule CLASS_RULE =</span> |
| <span class="source-line-no">087</span><span id="line-87"> HBaseClassTestRule.forClass(TestFromClientSide.class);</span> |
| <span class="source-line-no">088</span><span id="line-88"> @Rule</span> |
| <span class="source-line-no">089</span><span id="line-89"> public TableNameTestRule name = new TableNameTestRule();</span> |
| <span class="source-line-no">090</span><span id="line-90"></span> |
| <span class="source-line-no">091</span><span id="line-91"> // To keep the child classes happy.</span> |
| <span class="source-line-no">092</span><span id="line-92"> TestFromClientSide() {</span> |
| <span class="source-line-no">093</span><span id="line-93"> }</span> |
| <span class="source-line-no">094</span><span id="line-94"></span> |
| <span class="source-line-no">095</span><span id="line-95"> public TestFromClientSide(Class registry, int numHedgedReqs) throws Exception {</span> |
| <span class="source-line-no">096</span><span id="line-96"> initialize(registry, numHedgedReqs, MultiRowMutationEndpoint.class);</span> |
| <span class="source-line-no">097</span><span id="line-97"> }</span> |
| <span class="source-line-no">098</span><span id="line-98"></span> |
| <span class="source-line-no">099</span><span id="line-99"> @Parameterized.Parameters</span> |
| <span class="source-line-no">100</span><span id="line-100"> public static Collection parameters() {</span> |
| <span class="source-line-no">101</span><span id="line-101"> return Arrays.asList(new Object[][] { { MasterRegistry.class, 1 }, { MasterRegistry.class, 2 },</span> |
| <span class="source-line-no">102</span><span id="line-102"> { ZKConnectionRegistry.class, 1 } });</span> |
| <span class="source-line-no">103</span><span id="line-103"> }</span> |
| <span class="source-line-no">104</span><span id="line-104"></span> |
| <span class="source-line-no">105</span><span id="line-105"> @AfterClass</span> |
| <span class="source-line-no">106</span><span id="line-106"> public static void tearDownAfterClass() throws Exception {</span> |
| <span class="source-line-no">107</span><span id="line-107"> afterClass();</span> |
| <span class="source-line-no">108</span><span id="line-108"> }</span> |
| <span class="source-line-no">109</span><span id="line-109"></span> |
| <span class="source-line-no">110</span><span id="line-110"> /**</span> |
| <span class="source-line-no">111</span><span id="line-111"> * Test append result when there are duplicate rpc request.</span> |
| <span class="source-line-no">112</span><span id="line-112"> */</span> |
| <span class="source-line-no">113</span><span id="line-113"> @Test</span> |
| <span class="source-line-no">114</span><span id="line-114"> public void testDuplicateAppend() throws Exception {</span> |
| <span class="source-line-no">115</span><span id="line-115"> TableDescriptorBuilder builder = TEST_UTIL.createModifyableTableDescriptor(name.getTableName(),</span> |
| <span class="source-line-no">116</span><span id="line-116"> ColumnFamilyDescriptorBuilder.DEFAULT_MIN_VERSIONS, 3, HConstants.FOREVER,</span> |
| <span class="source-line-no">117</span><span id="line-117"> ColumnFamilyDescriptorBuilder.DEFAULT_KEEP_DELETED);</span> |
| <span class="source-line-no">118</span><span id="line-118"> Map<String, String> kvs = new HashMap<>();</span> |
| <span class="source-line-no">119</span><span id="line-119"> kvs.put(SleepAtFirstRpcCall.SLEEP_TIME_CONF_KEY, "2000");</span> |
| <span class="source-line-no">120</span><span id="line-120"> builder.setCoprocessor(CoprocessorDescriptorBuilder</span> |
| <span class="source-line-no">121</span><span id="line-121"> .newBuilder(SleepAtFirstRpcCall.class.getName()).setPriority(1).setProperties(kvs).build());</span> |
| <span class="source-line-no">122</span><span id="line-122"> TEST_UTIL.createTable(builder.build(), new byte[][] { ROW }).close();</span> |
| <span class="source-line-no">123</span><span id="line-123"></span> |
| <span class="source-line-no">124</span><span id="line-124"> Configuration c = new Configuration(TEST_UTIL.getConfiguration());</span> |
| <span class="source-line-no">125</span><span id="line-125"> c.setInt(HConstants.HBASE_CLIENT_PAUSE, 50);</span> |
| <span class="source-line-no">126</span><span id="line-126"> // Client will retry because rpc timeout is small than the sleep time of first rpc call</span> |
| <span class="source-line-no">127</span><span id="line-127"> c.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, 1500);</span> |
| <span class="source-line-no">128</span><span id="line-128"></span> |
| <span class="source-line-no">129</span><span id="line-129"> try (Connection connection = ConnectionFactory.createConnection(c); Table table =</span> |
| <span class="source-line-no">130</span><span id="line-130"> connection.getTableBuilder(name.getTableName(), null).setOperationTimeout(3 * 1000).build()) {</span> |
| <span class="source-line-no">131</span><span id="line-131"> Append append = new Append(ROW);</span> |
| <span class="source-line-no">132</span><span id="line-132"> append.addColumn(HBaseTestingUtil.fam1, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">133</span><span id="line-133"> Result result = table.append(append);</span> |
| <span class="source-line-no">134</span><span id="line-134"></span> |
| <span class="source-line-no">135</span><span id="line-135"> // Verify expected result</span> |
| <span class="source-line-no">136</span><span id="line-136"> Cell[] cells = result.rawCells();</span> |
| <span class="source-line-no">137</span><span id="line-137"> assertEquals(1, cells.length);</span> |
| <span class="source-line-no">138</span><span id="line-138"> assertKey(cells[0], ROW, HBaseTestingUtil.fam1, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">139</span><span id="line-139"></span> |
| <span class="source-line-no">140</span><span id="line-140"> // Verify expected result again</span> |
| <span class="source-line-no">141</span><span id="line-141"> Result readResult = table.get(new Get(ROW));</span> |
| <span class="source-line-no">142</span><span id="line-142"> cells = readResult.rawCells();</span> |
| <span class="source-line-no">143</span><span id="line-143"> assertEquals(1, cells.length);</span> |
| <span class="source-line-no">144</span><span id="line-144"> assertKey(cells[0], ROW, HBaseTestingUtil.fam1, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">145</span><span id="line-145"> }</span> |
| <span class="source-line-no">146</span><span id="line-146"> }</span> |
| <span class="source-line-no">147</span><span id="line-147"></span> |
| <span class="source-line-no">148</span><span id="line-148"> /**</span> |
| <span class="source-line-no">149</span><span id="line-149"> * Test batch append result when there are duplicate rpc request.</span> |
| <span class="source-line-no">150</span><span id="line-150"> */</span> |
| <span class="source-line-no">151</span><span id="line-151"> @Test</span> |
| <span class="source-line-no">152</span><span id="line-152"> public void testDuplicateBatchAppend() throws Exception {</span> |
| <span class="source-line-no">153</span><span id="line-153"> TableDescriptorBuilder builder = TEST_UTIL.createModifyableTableDescriptor(name.getTableName(),</span> |
| <span class="source-line-no">154</span><span id="line-154"> ColumnFamilyDescriptorBuilder.DEFAULT_MIN_VERSIONS, 3, HConstants.FOREVER,</span> |
| <span class="source-line-no">155</span><span id="line-155"> ColumnFamilyDescriptorBuilder.DEFAULT_KEEP_DELETED);</span> |
| <span class="source-line-no">156</span><span id="line-156"> Map<String, String> kvs = new HashMap<>();</span> |
| <span class="source-line-no">157</span><span id="line-157"> kvs.put(SleepAtFirstRpcCall.SLEEP_TIME_CONF_KEY, "2000");</span> |
| <span class="source-line-no">158</span><span id="line-158"> builder.setCoprocessor(CoprocessorDescriptorBuilder</span> |
| <span class="source-line-no">159</span><span id="line-159"> .newBuilder(SleepAtFirstRpcCall.class.getName()).setPriority(1).setProperties(kvs).build());</span> |
| <span class="source-line-no">160</span><span id="line-160"> TEST_UTIL.createTable(builder.build(), new byte[][] { ROW }).close();</span> |
| <span class="source-line-no">161</span><span id="line-161"></span> |
| <span class="source-line-no">162</span><span id="line-162"> Configuration c = new Configuration(TEST_UTIL.getConfiguration());</span> |
| <span class="source-line-no">163</span><span id="line-163"> c.setInt(HConstants.HBASE_CLIENT_PAUSE, 50);</span> |
| <span class="source-line-no">164</span><span id="line-164"> // Client will retry because rpc timeout is small than the sleep time of first rpc call</span> |
| <span class="source-line-no">165</span><span id="line-165"> c.setInt(HConstants.HBASE_RPC_TIMEOUT_KEY, 1500);</span> |
| <span class="source-line-no">166</span><span id="line-166"></span> |
| <span class="source-line-no">167</span><span id="line-167"> try (Connection connection = ConnectionFactory.createConnection(c); Table table =</span> |
| <span class="source-line-no">168</span><span id="line-168"> connection.getTableBuilder(name.getTableName(), null).setOperationTimeout(3 * 1000).build()) {</span> |
| <span class="source-line-no">169</span><span id="line-169"> Append append = new Append(ROW);</span> |
| <span class="source-line-no">170</span><span id="line-170"> append.addColumn(HBaseTestingUtil.fam1, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">171</span><span id="line-171"></span> |
| <span class="source-line-no">172</span><span id="line-172"> // Batch append</span> |
| <span class="source-line-no">173</span><span id="line-173"> Object[] results = new Object[1];</span> |
| <span class="source-line-no">174</span><span id="line-174"> table.batch(Collections.singletonList(append), results);</span> |
| <span class="source-line-no">175</span><span id="line-175"></span> |
| <span class="source-line-no">176</span><span id="line-176"> // Verify expected result</span> |
| <span class="source-line-no">177</span><span id="line-177"> Cell[] cells = ((Result) results[0]).rawCells();</span> |
| <span class="source-line-no">178</span><span id="line-178"> assertEquals(1, cells.length);</span> |
| <span class="source-line-no">179</span><span id="line-179"> assertKey(cells[0], ROW, HBaseTestingUtil.fam1, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">180</span><span id="line-180"></span> |
| <span class="source-line-no">181</span><span id="line-181"> // Verify expected result again</span> |
| <span class="source-line-no">182</span><span id="line-182"> Result readResult = table.get(new Get(ROW));</span> |
| <span class="source-line-no">183</span><span id="line-183"> cells = readResult.rawCells();</span> |
| <span class="source-line-no">184</span><span id="line-184"> assertEquals(1, cells.length);</span> |
| <span class="source-line-no">185</span><span id="line-185"> assertKey(cells[0], ROW, HBaseTestingUtil.fam1, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">186</span><span id="line-186"> }</span> |
| <span class="source-line-no">187</span><span id="line-187"> }</span> |
| <span class="source-line-no">188</span><span id="line-188"></span> |
| <span class="source-line-no">189</span><span id="line-189"> /**</span> |
| <span class="source-line-no">190</span><span id="line-190"> * Basic client side validation of HBASE-4536</span> |
| <span class="source-line-no">191</span><span id="line-191"> */</span> |
| <span class="source-line-no">192</span><span id="line-192"> @Test</span> |
| <span class="source-line-no">193</span><span id="line-193"> public void testKeepDeletedCells() throws Exception {</span> |
| <span class="source-line-no">194</span><span id="line-194"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">195</span><span id="line-195"> final byte[] FAMILY = Bytes.toBytes("family");</span> |
| <span class="source-line-no">196</span><span id="line-196"> final byte[] C0 = Bytes.toBytes("c0");</span> |
| <span class="source-line-no">197</span><span id="line-197"></span> |
| <span class="source-line-no">198</span><span id="line-198"> final byte[] T1 = Bytes.toBytes("T1");</span> |
| <span class="source-line-no">199</span><span id="line-199"> final byte[] T2 = Bytes.toBytes("T2");</span> |
| <span class="source-line-no">200</span><span id="line-200"> final byte[] T3 = Bytes.toBytes("T3");</span> |
| <span class="source-line-no">201</span><span id="line-201"></span> |
| <span class="source-line-no">202</span><span id="line-202"> TableDescriptor tableDescriptor = TableDescriptorBuilder.newBuilder(tableName)</span> |
| <span class="source-line-no">203</span><span id="line-203"> .setColumnFamily(ColumnFamilyDescriptorBuilder.newBuilder(FAMILY)</span> |
| <span class="source-line-no">204</span><span id="line-204"> .setKeepDeletedCells(KeepDeletedCells.TRUE).setMaxVersions(3).build())</span> |
| <span class="source-line-no">205</span><span id="line-205"> .build();</span> |
| <span class="source-line-no">206</span><span id="line-206"> TEST_UTIL.getAdmin().createTable(tableDescriptor);</span> |
| <span class="source-line-no">207</span><span id="line-207"> try (Table h = TEST_UTIL.getConnection().getTable(tableName)) {</span> |
| <span class="source-line-no">208</span><span id="line-208"> long ts = EnvironmentEdgeManager.currentTime();</span> |
| <span class="source-line-no">209</span><span id="line-209"> Put p = new Put(T1, ts);</span> |
| <span class="source-line-no">210</span><span id="line-210"> p.addColumn(FAMILY, C0, T1);</span> |
| <span class="source-line-no">211</span><span id="line-211"> h.put(p);</span> |
| <span class="source-line-no">212</span><span id="line-212"> p = new Put(T1, ts + 2);</span> |
| <span class="source-line-no">213</span><span id="line-213"> p.addColumn(FAMILY, C0, T2);</span> |
| <span class="source-line-no">214</span><span id="line-214"> h.put(p);</span> |
| <span class="source-line-no">215</span><span id="line-215"> p = new Put(T1, ts + 4);</span> |
| <span class="source-line-no">216</span><span id="line-216"> p.addColumn(FAMILY, C0, T3);</span> |
| <span class="source-line-no">217</span><span id="line-217"> h.put(p);</span> |
| <span class="source-line-no">218</span><span id="line-218"></span> |
| <span class="source-line-no">219</span><span id="line-219"> Delete d = new Delete(T1, ts + 3);</span> |
| <span class="source-line-no">220</span><span id="line-220"> h.delete(d);</span> |
| <span class="source-line-no">221</span><span id="line-221"></span> |
| <span class="source-line-no">222</span><span id="line-222"> d = new Delete(T1, ts + 3);</span> |
| <span class="source-line-no">223</span><span id="line-223"> d.addColumns(FAMILY, C0, ts + 3);</span> |
| <span class="source-line-no">224</span><span id="line-224"> h.delete(d);</span> |
| <span class="source-line-no">225</span><span id="line-225"></span> |
| <span class="source-line-no">226</span><span id="line-226"> Get g = new Get(T1);</span> |
| <span class="source-line-no">227</span><span id="line-227"> // does *not* include the delete</span> |
| <span class="source-line-no">228</span><span id="line-228"> g.setTimeRange(0, ts + 3);</span> |
| <span class="source-line-no">229</span><span id="line-229"> Result r = h.get(g);</span> |
| <span class="source-line-no">230</span><span id="line-230"> assertArrayEquals(T2, r.getValue(FAMILY, C0));</span> |
| <span class="source-line-no">231</span><span id="line-231"></span> |
| <span class="source-line-no">232</span><span id="line-232"> Scan s = new Scan().withStartRow(T1);</span> |
| <span class="source-line-no">233</span><span id="line-233"> s.setTimeRange(0, ts + 3);</span> |
| <span class="source-line-no">234</span><span id="line-234"> s.readAllVersions();</span> |
| <span class="source-line-no">235</span><span id="line-235"> ResultScanner scanner = h.getScanner(s);</span> |
| <span class="source-line-no">236</span><span id="line-236"> ExtendedCell[] kvs = scanner.next().rawExtendedCells();</span> |
| <span class="source-line-no">237</span><span id="line-237"> assertArrayEquals(T2, CellUtil.cloneValue(kvs[0]));</span> |
| <span class="source-line-no">238</span><span id="line-238"> assertArrayEquals(T1, CellUtil.cloneValue(kvs[1]));</span> |
| <span class="source-line-no">239</span><span id="line-239"> scanner.close();</span> |
| <span class="source-line-no">240</span><span id="line-240"></span> |
| <span class="source-line-no">241</span><span id="line-241"> s = new Scan().withStartRow(T1);</span> |
| <span class="source-line-no">242</span><span id="line-242"> s.setRaw(true);</span> |
| <span class="source-line-no">243</span><span id="line-243"> s.readAllVersions();</span> |
| <span class="source-line-no">244</span><span id="line-244"> scanner = h.getScanner(s);</span> |
| <span class="source-line-no">245</span><span id="line-245"> kvs = scanner.next().rawExtendedCells();</span> |
| <span class="source-line-no">246</span><span id="line-246"> assertTrue(PrivateCellUtil.isDeleteFamily(kvs[0]));</span> |
| <span class="source-line-no">247</span><span id="line-247"> assertArrayEquals(T3, CellUtil.cloneValue(kvs[1]));</span> |
| <span class="source-line-no">248</span><span id="line-248"> assertTrue(CellUtil.isDelete(kvs[2]));</span> |
| <span class="source-line-no">249</span><span id="line-249"> assertArrayEquals(T2, CellUtil.cloneValue(kvs[3]));</span> |
| <span class="source-line-no">250</span><span id="line-250"> assertArrayEquals(T1, CellUtil.cloneValue(kvs[4]));</span> |
| <span class="source-line-no">251</span><span id="line-251"> scanner.close();</span> |
| <span class="source-line-no">252</span><span id="line-252"> }</span> |
| <span class="source-line-no">253</span><span id="line-253"> }</span> |
| <span class="source-line-no">254</span><span id="line-254"></span> |
| <span class="source-line-no">255</span><span id="line-255"> /**</span> |
| <span class="source-line-no">256</span><span id="line-256"> * Basic client side validation of HBASE-10118</span> |
| <span class="source-line-no">257</span><span id="line-257"> */</span> |
| <span class="source-line-no">258</span><span id="line-258"> @Test</span> |
| <span class="source-line-no">259</span><span id="line-259"> public void testPurgeFutureDeletes() throws Exception {</span> |
| <span class="source-line-no">260</span><span id="line-260"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">261</span><span id="line-261"> final byte[] ROW = Bytes.toBytes("row");</span> |
| <span class="source-line-no">262</span><span id="line-262"> final byte[] FAMILY = Bytes.toBytes("family");</span> |
| <span class="source-line-no">263</span><span id="line-263"> final byte[] COLUMN = Bytes.toBytes("column");</span> |
| <span class="source-line-no">264</span><span id="line-264"> final byte[] VALUE = Bytes.toBytes("value");</span> |
| <span class="source-line-no">265</span><span id="line-265"></span> |
| <span class="source-line-no">266</span><span id="line-266"> try (Table table = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">267</span><span id="line-267"> // future timestamp</span> |
| <span class="source-line-no">268</span><span id="line-268"> long ts = EnvironmentEdgeManager.currentTime() * 2;</span> |
| <span class="source-line-no">269</span><span id="line-269"> Put put = new Put(ROW, ts);</span> |
| <span class="source-line-no">270</span><span id="line-270"> put.addColumn(FAMILY, COLUMN, VALUE);</span> |
| <span class="source-line-no">271</span><span id="line-271"> table.put(put);</span> |
| <span class="source-line-no">272</span><span id="line-272"></span> |
| <span class="source-line-no">273</span><span id="line-273"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">274</span><span id="line-274"> Result result = table.get(get);</span> |
| <span class="source-line-no">275</span><span id="line-275"> assertArrayEquals(VALUE, result.getValue(FAMILY, COLUMN));</span> |
| <span class="source-line-no">276</span><span id="line-276"></span> |
| <span class="source-line-no">277</span><span id="line-277"> Delete del = new Delete(ROW);</span> |
| <span class="source-line-no">278</span><span id="line-278"> del.addColumn(FAMILY, COLUMN, ts);</span> |
| <span class="source-line-no">279</span><span id="line-279"> table.delete(del);</span> |
| <span class="source-line-no">280</span><span id="line-280"></span> |
| <span class="source-line-no">281</span><span id="line-281"> get = new Get(ROW);</span> |
| <span class="source-line-no">282</span><span id="line-282"> result = table.get(get);</span> |
| <span class="source-line-no">283</span><span id="line-283"> assertNull(result.getValue(FAMILY, COLUMN));</span> |
| <span class="source-line-no">284</span><span id="line-284"></span> |
| <span class="source-line-no">285</span><span id="line-285"> // major compaction, purged future deletes</span> |
| <span class="source-line-no">286</span><span id="line-286"> TEST_UTIL.getAdmin().flush(tableName);</span> |
| <span class="source-line-no">287</span><span id="line-287"> TEST_UTIL.getAdmin().majorCompact(tableName);</span> |
| <span class="source-line-no">288</span><span id="line-288"></span> |
| <span class="source-line-no">289</span><span id="line-289"> // waiting for the major compaction to complete</span> |
| <span class="source-line-no">290</span><span id="line-290"> TEST_UTIL.waitFor(6000,</span> |
| <span class="source-line-no">291</span><span id="line-291"> () -> TEST_UTIL.getAdmin().getCompactionState(tableName) == CompactionState.NONE);</span> |
| <span class="source-line-no">292</span><span id="line-292"></span> |
| <span class="source-line-no">293</span><span id="line-293"> put = new Put(ROW, ts);</span> |
| <span class="source-line-no">294</span><span id="line-294"> put.addColumn(FAMILY, COLUMN, VALUE);</span> |
| <span class="source-line-no">295</span><span id="line-295"> table.put(put);</span> |
| <span class="source-line-no">296</span><span id="line-296"></span> |
| <span class="source-line-no">297</span><span id="line-297"> get = new Get(ROW);</span> |
| <span class="source-line-no">298</span><span id="line-298"> result = table.get(get);</span> |
| <span class="source-line-no">299</span><span id="line-299"> assertArrayEquals(VALUE, result.getValue(FAMILY, COLUMN));</span> |
| <span class="source-line-no">300</span><span id="line-300"> }</span> |
| <span class="source-line-no">301</span><span id="line-301"> }</span> |
| <span class="source-line-no">302</span><span id="line-302"></span> |
| <span class="source-line-no">303</span><span id="line-303"> /**</span> |
| <span class="source-line-no">304</span><span id="line-304"> * Verifies that getConfiguration returns the same Configuration object used to create the HTable</span> |
| <span class="source-line-no">305</span><span id="line-305"> * instance.</span> |
| <span class="source-line-no">306</span><span id="line-306"> */</span> |
| <span class="source-line-no">307</span><span id="line-307"> @Test</span> |
| <span class="source-line-no">308</span><span id="line-308"> public void testGetConfiguration() throws Exception {</span> |
| <span class="source-line-no">309</span><span id="line-309"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">310</span><span id="line-310"> byte[][] FAMILIES = new byte[][] { Bytes.toBytes("foo") };</span> |
| <span class="source-line-no">311</span><span id="line-311"> Configuration conf = TEST_UTIL.getConfiguration();</span> |
| <span class="source-line-no">312</span><span id="line-312"> try (Table table = TEST_UTIL.createTable(tableName, FAMILIES)) {</span> |
| <span class="source-line-no">313</span><span id="line-313"> assertSame(conf, table.getConfiguration());</span> |
| <span class="source-line-no">314</span><span id="line-314"> }</span> |
| <span class="source-line-no">315</span><span id="line-315"> }</span> |
| <span class="source-line-no">316</span><span id="line-316"></span> |
| <span class="source-line-no">317</span><span id="line-317"> /**</span> |
| <span class="source-line-no">318</span><span id="line-318"> * Test from client side of an involved filter against a multi family that involves deletes.</span> |
| <span class="source-line-no">319</span><span id="line-319"> */</span> |
| <span class="source-line-no">320</span><span id="line-320"> @Test</span> |
| <span class="source-line-no">321</span><span id="line-321"> public void testWeirdCacheBehaviour() throws Exception {</span> |
| <span class="source-line-no">322</span><span id="line-322"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">323</span><span id="line-323"> byte[][] FAMILIES = new byte[][] { Bytes.toBytes("trans-blob"), Bytes.toBytes("trans-type"),</span> |
| <span class="source-line-no">324</span><span id="line-324"> Bytes.toBytes("trans-date"), Bytes.toBytes("trans-tags"), Bytes.toBytes("trans-group") };</span> |
| <span class="source-line-no">325</span><span id="line-325"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILIES)) {</span> |
| <span class="source-line-no">326</span><span id="line-326"> String value = "this is the value";</span> |
| <span class="source-line-no">327</span><span id="line-327"> String value2 = "this is some other value";</span> |
| <span class="source-line-no">328</span><span id="line-328"> String keyPrefix1 = HBaseTestingUtil.getRandomUUID().toString();</span> |
| <span class="source-line-no">329</span><span id="line-329"> String keyPrefix2 = HBaseTestingUtil.getRandomUUID().toString();</span> |
| <span class="source-line-no">330</span><span id="line-330"> String keyPrefix3 = HBaseTestingUtil.getRandomUUID().toString();</span> |
| <span class="source-line-no">331</span><span id="line-331"> putRows(ht, 3, value, keyPrefix1);</span> |
| <span class="source-line-no">332</span><span id="line-332"> putRows(ht, 3, value, keyPrefix2);</span> |
| <span class="source-line-no">333</span><span id="line-333"> putRows(ht, 3, value, keyPrefix3);</span> |
| <span class="source-line-no">334</span><span id="line-334"> putRows(ht, 3, value2, keyPrefix1);</span> |
| <span class="source-line-no">335</span><span id="line-335"> putRows(ht, 3, value2, keyPrefix2);</span> |
| <span class="source-line-no">336</span><span id="line-336"> putRows(ht, 3, value2, keyPrefix3);</span> |
| <span class="source-line-no">337</span><span id="line-337"> try (Table table = TEST_UTIL.getConnection().getTable(tableName)) {</span> |
| <span class="source-line-no">338</span><span id="line-338"> System.out.println("Checking values for key: " + keyPrefix1);</span> |
| <span class="source-line-no">339</span><span id="line-339"> assertEquals("Got back incorrect number of rows from scan", 3,</span> |
| <span class="source-line-no">340</span><span id="line-340"> getNumberOfRows(keyPrefix1, value2, table));</span> |
| <span class="source-line-no">341</span><span id="line-341"> System.out.println("Checking values for key: " + keyPrefix2);</span> |
| <span class="source-line-no">342</span><span id="line-342"> assertEquals("Got back incorrect number of rows from scan", 3,</span> |
| <span class="source-line-no">343</span><span id="line-343"> getNumberOfRows(keyPrefix2, value2, table));</span> |
| <span class="source-line-no">344</span><span id="line-344"> System.out.println("Checking values for key: " + keyPrefix3);</span> |
| <span class="source-line-no">345</span><span id="line-345"> assertEquals("Got back incorrect number of rows from scan", 3,</span> |
| <span class="source-line-no">346</span><span id="line-346"> getNumberOfRows(keyPrefix3, value2, table));</span> |
| <span class="source-line-no">347</span><span id="line-347"> deleteColumns(ht, value2, keyPrefix1);</span> |
| <span class="source-line-no">348</span><span id="line-348"> deleteColumns(ht, value2, keyPrefix2);</span> |
| <span class="source-line-no">349</span><span id="line-349"> deleteColumns(ht, value2, keyPrefix3);</span> |
| <span class="source-line-no">350</span><span id="line-350"> System.out.println("Starting important checks.....");</span> |
| <span class="source-line-no">351</span><span id="line-351"> assertEquals("Got back incorrect number of rows from scan: " + keyPrefix1, 0,</span> |
| <span class="source-line-no">352</span><span id="line-352"> getNumberOfRows(keyPrefix1, value2, table));</span> |
| <span class="source-line-no">353</span><span id="line-353"> assertEquals("Got back incorrect number of rows from scan: " + keyPrefix2, 0,</span> |
| <span class="source-line-no">354</span><span id="line-354"> getNumberOfRows(keyPrefix2, value2, table));</span> |
| <span class="source-line-no">355</span><span id="line-355"> assertEquals("Got back incorrect number of rows from scan: " + keyPrefix3, 0,</span> |
| <span class="source-line-no">356</span><span id="line-356"> getNumberOfRows(keyPrefix3, value2, table));</span> |
| <span class="source-line-no">357</span><span id="line-357"> }</span> |
| <span class="source-line-no">358</span><span id="line-358"> }</span> |
| <span class="source-line-no">359</span><span id="line-359"> }</span> |
| <span class="source-line-no">360</span><span id="line-360"></span> |
| <span class="source-line-no">361</span><span id="line-361"> /**</span> |
| <span class="source-line-no">362</span><span id="line-362"> * Test filters when multiple regions. It does counts. Needs eye-balling of logs to ensure that</span> |
| <span class="source-line-no">363</span><span id="line-363"> * we're not scanning more regions that we're supposed to. Related to the TestFilterAcrossRegions</span> |
| <span class="source-line-no">364</span><span id="line-364"> * over in the o.a.h.h.filter package.</span> |
| <span class="source-line-no">365</span><span id="line-365"> */</span> |
| <span class="source-line-no">366</span><span id="line-366"> @Test</span> |
| <span class="source-line-no">367</span><span id="line-367"> public void testFilterAcrossMultipleRegions() throws IOException {</span> |
| <span class="source-line-no">368</span><span id="line-368"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">369</span><span id="line-369"> try (Table t = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">370</span><span id="line-370"> int rowCount = TEST_UTIL.loadTable(t, FAMILY, false);</span> |
| <span class="source-line-no">371</span><span id="line-371"> assertRowCount(t, rowCount);</span> |
| <span class="source-line-no">372</span><span id="line-372"> // Split the table. Should split on a reasonable key; 'lqj'</span> |
| <span class="source-line-no">373</span><span id="line-373"> List<HRegionLocation> regions = splitTable(t);</span> |
| <span class="source-line-no">374</span><span id="line-374"> assertRowCount(t, rowCount);</span> |
| <span class="source-line-no">375</span><span id="line-375"> // Get end key of first region.</span> |
| <span class="source-line-no">376</span><span id="line-376"> byte[] endKey = regions.get(0).getRegion().getEndKey();</span> |
| <span class="source-line-no">377</span><span id="line-377"> // Count rows with a filter that stops us before passed 'endKey'.</span> |
| <span class="source-line-no">378</span><span id="line-378"> // Should be count of rows in first region.</span> |
| <span class="source-line-no">379</span><span id="line-379"> int endKeyCount = countRows(t, createScanWithRowFilter(endKey));</span> |
| <span class="source-line-no">380</span><span id="line-380"> assertTrue(endKeyCount < rowCount);</span> |
| <span class="source-line-no">381</span><span id="line-381"></span> |
| <span class="source-line-no">382</span><span id="line-382"> // How do I know I did not got to second region? Thats tough. Can't really</span> |
| <span class="source-line-no">383</span><span id="line-383"> // do that in client-side region test. I verified by tracing in debugger.</span> |
| <span class="source-line-no">384</span><span id="line-384"> // I changed the messages that come out when set to DEBUG so should see</span> |
| <span class="source-line-no">385</span><span id="line-385"> // when scanner is done. Says "Finished with scanning..." with region name.</span> |
| <span class="source-line-no">386</span><span id="line-386"> // Check that its finished in right region.</span> |
| <span class="source-line-no">387</span><span id="line-387"></span> |
| <span class="source-line-no">388</span><span id="line-388"> // New test. Make it so scan goes into next region by one and then two.</span> |
| <span class="source-line-no">389</span><span id="line-389"> // Make sure count comes out right.</span> |
| <span class="source-line-no">390</span><span id="line-390"> byte[] key = new byte[] { endKey[0], endKey[1], (byte) (endKey[2] + 1) };</span> |
| <span class="source-line-no">391</span><span id="line-391"> int plusOneCount = countRows(t, createScanWithRowFilter(key));</span> |
| <span class="source-line-no">392</span><span id="line-392"> assertEquals(endKeyCount + 1, plusOneCount);</span> |
| <span class="source-line-no">393</span><span id="line-393"> key = new byte[] { endKey[0], endKey[1], (byte) (endKey[2] + 2) };</span> |
| <span class="source-line-no">394</span><span id="line-394"> int plusTwoCount = countRows(t, createScanWithRowFilter(key));</span> |
| <span class="source-line-no">395</span><span id="line-395"> assertEquals(endKeyCount + 2, plusTwoCount);</span> |
| <span class="source-line-no">396</span><span id="line-396"></span> |
| <span class="source-line-no">397</span><span id="line-397"> // New test. Make it so I scan one less than endkey.</span> |
| <span class="source-line-no">398</span><span id="line-398"> key = new byte[] { endKey[0], endKey[1], (byte) (endKey[2] - 1) };</span> |
| <span class="source-line-no">399</span><span id="line-399"> int minusOneCount = countRows(t, createScanWithRowFilter(key));</span> |
| <span class="source-line-no">400</span><span id="line-400"> assertEquals(endKeyCount - 1, minusOneCount);</span> |
| <span class="source-line-no">401</span><span id="line-401"> // For above test... study logs. Make sure we do "Finished with scanning.."</span> |
| <span class="source-line-no">402</span><span id="line-402"> // in first region and that we do not fall into the next region.</span> |
| <span class="source-line-no">403</span><span id="line-403"></span> |
| <span class="source-line-no">404</span><span id="line-404"> key = new byte[] { 'a', 'a', 'a' };</span> |
| <span class="source-line-no">405</span><span id="line-405"> int countBBB = countRows(t, createScanWithRowFilter(key, null, CompareOperator.EQUAL));</span> |
| <span class="source-line-no">406</span><span id="line-406"> assertEquals(1, countBBB);</span> |
| <span class="source-line-no">407</span><span id="line-407"></span> |
| <span class="source-line-no">408</span><span id="line-408"> int countGreater =</span> |
| <span class="source-line-no">409</span><span id="line-409"> countRows(t, createScanWithRowFilter(endKey, null, CompareOperator.GREATER_OR_EQUAL));</span> |
| <span class="source-line-no">410</span><span id="line-410"> // Because started at start of table.</span> |
| <span class="source-line-no">411</span><span id="line-411"> assertEquals(0, countGreater);</span> |
| <span class="source-line-no">412</span><span id="line-412"> countGreater =</span> |
| <span class="source-line-no">413</span><span id="line-413"> countRows(t, createScanWithRowFilter(endKey, endKey, CompareOperator.GREATER_OR_EQUAL));</span> |
| <span class="source-line-no">414</span><span id="line-414"> assertEquals(rowCount - endKeyCount, countGreater);</span> |
| <span class="source-line-no">415</span><span id="line-415"> }</span> |
| <span class="source-line-no">416</span><span id="line-416"> }</span> |
| <span class="source-line-no">417</span><span id="line-417"></span> |
| <span class="source-line-no">418</span><span id="line-418"> @Test</span> |
| <span class="source-line-no">419</span><span id="line-419"> public void testSuperSimple() throws Exception {</span> |
| <span class="source-line-no">420</span><span id="line-420"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">421</span><span id="line-421"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">422</span><span id="line-422"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">423</span><span id="line-423"> put.addColumn(FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">424</span><span id="line-424"> ht.put(put);</span> |
| <span class="source-line-no">425</span><span id="line-425"> Scan scan = new Scan();</span> |
| <span class="source-line-no">426</span><span id="line-426"> scan.addColumn(FAMILY, tableName.toBytes());</span> |
| <span class="source-line-no">427</span><span id="line-427"> ResultScanner scanner = ht.getScanner(scan);</span> |
| <span class="source-line-no">428</span><span id="line-428"> Result result = scanner.next();</span> |
| <span class="source-line-no">429</span><span id="line-429"> assertNull("Expected null result", result);</span> |
| <span class="source-line-no">430</span><span id="line-430"> scanner.close();</span> |
| <span class="source-line-no">431</span><span id="line-431"> }</span> |
| <span class="source-line-no">432</span><span id="line-432"> }</span> |
| <span class="source-line-no">433</span><span id="line-433"></span> |
| <span class="source-line-no">434</span><span id="line-434"> @Test</span> |
| <span class="source-line-no">435</span><span id="line-435"> public void testMaxKeyValueSize() throws Exception {</span> |
| <span class="source-line-no">436</span><span id="line-436"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">437</span><span id="line-437"> Configuration conf = TEST_UTIL.getConfiguration();</span> |
| <span class="source-line-no">438</span><span id="line-438"> String oldMaxSize = conf.get(ConnectionConfiguration.MAX_KEYVALUE_SIZE_KEY);</span> |
| <span class="source-line-no">439</span><span id="line-439"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">440</span><span id="line-440"> byte[] value = new byte[4 * 1024 * 1024];</span> |
| <span class="source-line-no">441</span><span id="line-441"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">442</span><span id="line-442"> put.addColumn(FAMILY, QUALIFIER, value);</span> |
| <span class="source-line-no">443</span><span id="line-443"> ht.put(put);</span> |
| <span class="source-line-no">444</span><span id="line-444"></span> |
| <span class="source-line-no">445</span><span id="line-445"> try {</span> |
| <span class="source-line-no">446</span><span id="line-446"> TEST_UTIL.getConfiguration().setInt(ConnectionConfiguration.MAX_KEYVALUE_SIZE_KEY,</span> |
| <span class="source-line-no">447</span><span id="line-447"> 2 * 1024 * 1024);</span> |
| <span class="source-line-no">448</span><span id="line-448"> // Create new table so we pick up the change in Configuration.</span> |
| <span class="source-line-no">449</span><span id="line-449"> try (Connection connection =</span> |
| <span class="source-line-no">450</span><span id="line-450"> ConnectionFactory.createConnection(TEST_UTIL.getConfiguration())) {</span> |
| <span class="source-line-no">451</span><span id="line-451"> try (Table t = connection.getTable(TableName.valueOf(FAMILY))) {</span> |
| <span class="source-line-no">452</span><span id="line-452"> put = new Put(ROW);</span> |
| <span class="source-line-no">453</span><span id="line-453"> put.addColumn(FAMILY, QUALIFIER, value);</span> |
| <span class="source-line-no">454</span><span id="line-454"> t.put(put);</span> |
| <span class="source-line-no">455</span><span id="line-455"> }</span> |
| <span class="source-line-no">456</span><span id="line-456"> }</span> |
| <span class="source-line-no">457</span><span id="line-457"> fail("Inserting a too large KeyValue worked, should throw exception");</span> |
| <span class="source-line-no">458</span><span id="line-458"> } catch (Exception ignored) {</span> |
| <span class="source-line-no">459</span><span id="line-459"> }</span> |
| <span class="source-line-no">460</span><span id="line-460"> }</span> |
| <span class="source-line-no">461</span><span id="line-461"> conf.set(ConnectionConfiguration.MAX_KEYVALUE_SIZE_KEY, oldMaxSize);</span> |
| <span class="source-line-no">462</span><span id="line-462"> }</span> |
| <span class="source-line-no">463</span><span id="line-463"></span> |
| <span class="source-line-no">464</span><span id="line-464"> @Test</span> |
| <span class="source-line-no">465</span><span id="line-465"> public void testFilters() throws Exception {</span> |
| <span class="source-line-no">466</span><span id="line-466"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">467</span><span id="line-467"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">468</span><span id="line-468"> byte[][] ROWS = makeN(ROW, 10);</span> |
| <span class="source-line-no">469</span><span id="line-469"> byte[][] QUALIFIERS =</span> |
| <span class="source-line-no">470</span><span id="line-470"> { Bytes.toBytes("col0-<d2v1>-<d3v2>"), Bytes.toBytes("col1-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">471</span><span id="line-471"> Bytes.toBytes("col2-<d2v1>-<d3v2>"), Bytes.toBytes("col3-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">472</span><span id="line-472"> Bytes.toBytes("col4-<d2v1>-<d3v2>"), Bytes.toBytes("col5-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">473</span><span id="line-473"> Bytes.toBytes("col6-<d2v1>-<d3v2>"), Bytes.toBytes("col7-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">474</span><span id="line-474"> Bytes.toBytes("col8-<d2v1>-<d3v2>"), Bytes.toBytes("col9-<d2v1>-<d3v2>") };</span> |
| <span class="source-line-no">475</span><span id="line-475"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">476</span><span id="line-476"> Put put = new Put(ROWS[i]);</span> |
| <span class="source-line-no">477</span><span id="line-477"> put.setDurability(Durability.SKIP_WAL);</span> |
| <span class="source-line-no">478</span><span id="line-478"> put.addColumn(FAMILY, QUALIFIERS[i], VALUE);</span> |
| <span class="source-line-no">479</span><span id="line-479"> ht.put(put);</span> |
| <span class="source-line-no">480</span><span id="line-480"> }</span> |
| <span class="source-line-no">481</span><span id="line-481"> Scan scan = new Scan();</span> |
| <span class="source-line-no">482</span><span id="line-482"> scan.addFamily(FAMILY);</span> |
| <span class="source-line-no">483</span><span id="line-483"> Filter filter =</span> |
| <span class="source-line-no">484</span><span id="line-484"> new QualifierFilter(CompareOperator.EQUAL, new RegexStringComparator("col[1-5]"));</span> |
| <span class="source-line-no">485</span><span id="line-485"> scan.setFilter(filter);</span> |
| <span class="source-line-no">486</span><span id="line-486"> try (ResultScanner scanner = ht.getScanner(scan)) {</span> |
| <span class="source-line-no">487</span><span id="line-487"> int expectedIndex = 1;</span> |
| <span class="source-line-no">488</span><span id="line-488"> for (Result result : scanner) {</span> |
| <span class="source-line-no">489</span><span id="line-489"> assertEquals(1, result.size());</span> |
| <span class="source-line-no">490</span><span id="line-490"> assertTrue(Bytes.equals(CellUtil.cloneRow(result.rawCells()[0]), ROWS[expectedIndex]));</span> |
| <span class="source-line-no">491</span><span id="line-491"> assertTrue(</span> |
| <span class="source-line-no">492</span><span id="line-492"> Bytes.equals(CellUtil.cloneQualifier(result.rawCells()[0]), QUALIFIERS[expectedIndex]));</span> |
| <span class="source-line-no">493</span><span id="line-493"> expectedIndex++;</span> |
| <span class="source-line-no">494</span><span id="line-494"> }</span> |
| <span class="source-line-no">495</span><span id="line-495"> assertEquals(6, expectedIndex);</span> |
| <span class="source-line-no">496</span><span id="line-496"> }</span> |
| <span class="source-line-no">497</span><span id="line-497"> }</span> |
| <span class="source-line-no">498</span><span id="line-498"> }</span> |
| <span class="source-line-no">499</span><span id="line-499"></span> |
| <span class="source-line-no">500</span><span id="line-500"> @Test</span> |
| <span class="source-line-no">501</span><span id="line-501"> public void testFilterWithLongCompartor() throws Exception {</span> |
| <span class="source-line-no">502</span><span id="line-502"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">503</span><span id="line-503"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">504</span><span id="line-504"> byte[][] ROWS = makeN(ROW, 10);</span> |
| <span class="source-line-no">505</span><span id="line-505"> byte[][] values = new byte[10][];</span> |
| <span class="source-line-no">506</span><span id="line-506"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">507</span><span id="line-507"> values[i] = Bytes.toBytes(100L * i);</span> |
| <span class="source-line-no">508</span><span id="line-508"> }</span> |
| <span class="source-line-no">509</span><span id="line-509"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">510</span><span id="line-510"> Put put = new Put(ROWS[i]);</span> |
| <span class="source-line-no">511</span><span id="line-511"> put.setDurability(Durability.SKIP_WAL);</span> |
| <span class="source-line-no">512</span><span id="line-512"> put.addColumn(FAMILY, QUALIFIER, values[i]);</span> |
| <span class="source-line-no">513</span><span id="line-513"> ht.put(put);</span> |
| <span class="source-line-no">514</span><span id="line-514"> }</span> |
| <span class="source-line-no">515</span><span id="line-515"> Scan scan = new Scan();</span> |
| <span class="source-line-no">516</span><span id="line-516"> scan.addFamily(FAMILY);</span> |
| <span class="source-line-no">517</span><span id="line-517"> Filter filter = new SingleColumnValueFilter(FAMILY, QUALIFIER, CompareOperator.GREATER,</span> |
| <span class="source-line-no">518</span><span id="line-518"> new LongComparator(500));</span> |
| <span class="source-line-no">519</span><span id="line-519"> scan.setFilter(filter);</span> |
| <span class="source-line-no">520</span><span id="line-520"> try (ResultScanner scanner = ht.getScanner(scan)) {</span> |
| <span class="source-line-no">521</span><span id="line-521"> int expectedIndex = 0;</span> |
| <span class="source-line-no">522</span><span id="line-522"> for (Result result : scanner) {</span> |
| <span class="source-line-no">523</span><span id="line-523"> assertEquals(1, result.size());</span> |
| <span class="source-line-no">524</span><span id="line-524"> assertTrue(Bytes.toLong(result.getValue(FAMILY, QUALIFIER)) > 500);</span> |
| <span class="source-line-no">525</span><span id="line-525"> expectedIndex++;</span> |
| <span class="source-line-no">526</span><span id="line-526"> }</span> |
| <span class="source-line-no">527</span><span id="line-527"> assertEquals(4, expectedIndex);</span> |
| <span class="source-line-no">528</span><span id="line-528"> }</span> |
| <span class="source-line-no">529</span><span id="line-529"> }</span> |
| <span class="source-line-no">530</span><span id="line-530"> }</span> |
| <span class="source-line-no">531</span><span id="line-531"></span> |
| <span class="source-line-no">532</span><span id="line-532"> @Test</span> |
| <span class="source-line-no">533</span><span id="line-533"> public void testKeyOnlyFilter() throws Exception {</span> |
| <span class="source-line-no">534</span><span id="line-534"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">535</span><span id="line-535"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">536</span><span id="line-536"> byte[][] ROWS = makeN(ROW, 10);</span> |
| <span class="source-line-no">537</span><span id="line-537"> byte[][] QUALIFIERS =</span> |
| <span class="source-line-no">538</span><span id="line-538"> { Bytes.toBytes("col0-<d2v1>-<d3v2>"), Bytes.toBytes("col1-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">539</span><span id="line-539"> Bytes.toBytes("col2-<d2v1>-<d3v2>"), Bytes.toBytes("col3-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">540</span><span id="line-540"> Bytes.toBytes("col4-<d2v1>-<d3v2>"), Bytes.toBytes("col5-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">541</span><span id="line-541"> Bytes.toBytes("col6-<d2v1>-<d3v2>"), Bytes.toBytes("col7-<d2v1>-<d3v2>"),</span> |
| <span class="source-line-no">542</span><span id="line-542"> Bytes.toBytes("col8-<d2v1>-<d3v2>"), Bytes.toBytes("col9-<d2v1>-<d3v2>") };</span> |
| <span class="source-line-no">543</span><span id="line-543"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">544</span><span id="line-544"> Put put = new Put(ROWS[i]);</span> |
| <span class="source-line-no">545</span><span id="line-545"> put.setDurability(Durability.SKIP_WAL);</span> |
| <span class="source-line-no">546</span><span id="line-546"> put.addColumn(FAMILY, QUALIFIERS[i], VALUE);</span> |
| <span class="source-line-no">547</span><span id="line-547"> ht.put(put);</span> |
| <span class="source-line-no">548</span><span id="line-548"> }</span> |
| <span class="source-line-no">549</span><span id="line-549"> Scan scan = new Scan();</span> |
| <span class="source-line-no">550</span><span id="line-550"> scan.addFamily(FAMILY);</span> |
| <span class="source-line-no">551</span><span id="line-551"> Filter filter = new KeyOnlyFilter(true);</span> |
| <span class="source-line-no">552</span><span id="line-552"> scan.setFilter(filter);</span> |
| <span class="source-line-no">553</span><span id="line-553"> try (ResultScanner scanner = ht.getScanner(scan)) {</span> |
| <span class="source-line-no">554</span><span id="line-554"> int count = 0;</span> |
| <span class="source-line-no">555</span><span id="line-555"> for (Result result : scanner) {</span> |
| <span class="source-line-no">556</span><span id="line-556"> assertEquals(1, result.size());</span> |
| <span class="source-line-no">557</span><span id="line-557"> assertEquals(Bytes.SIZEOF_INT, result.rawCells()[0].getValueLength());</span> |
| <span class="source-line-no">558</span><span id="line-558"> assertEquals(VALUE.length, Bytes.toInt(CellUtil.cloneValue(result.rawCells()[0])));</span> |
| <span class="source-line-no">559</span><span id="line-559"> count++;</span> |
| <span class="source-line-no">560</span><span id="line-560"> }</span> |
| <span class="source-line-no">561</span><span id="line-561"> assertEquals(10, count);</span> |
| <span class="source-line-no">562</span><span id="line-562"> }</span> |
| <span class="source-line-no">563</span><span id="line-563"> }</span> |
| <span class="source-line-no">564</span><span id="line-564"> }</span> |
| <span class="source-line-no">565</span><span id="line-565"></span> |
| <span class="source-line-no">566</span><span id="line-566"> /**</span> |
| <span class="source-line-no">567</span><span id="line-567"> * Test simple table and non-existent row cases.</span> |
| <span class="source-line-no">568</span><span id="line-568"> */</span> |
| <span class="source-line-no">569</span><span id="line-569"> @Test</span> |
| <span class="source-line-no">570</span><span id="line-570"> public void testSimpleMissing() throws Exception {</span> |
| <span class="source-line-no">571</span><span id="line-571"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">572</span><span id="line-572"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">573</span><span id="line-573"> byte[][] ROWS = makeN(ROW, 4);</span> |
| <span class="source-line-no">574</span><span id="line-574"></span> |
| <span class="source-line-no">575</span><span id="line-575"> // Try to get a row on an empty table</span> |
| <span class="source-line-no">576</span><span id="line-576"> Get get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">577</span><span id="line-577"> Result result = ht.get(get);</span> |
| <span class="source-line-no">578</span><span id="line-578"> assertEmptyResult(result);</span> |
| <span class="source-line-no">579</span><span id="line-579"></span> |
| <span class="source-line-no">580</span><span id="line-580"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">581</span><span id="line-581"> get.addFamily(FAMILY);</span> |
| <span class="source-line-no">582</span><span id="line-582"> result = ht.get(get);</span> |
| <span class="source-line-no">583</span><span id="line-583"> assertEmptyResult(result);</span> |
| <span class="source-line-no">584</span><span id="line-584"></span> |
| <span class="source-line-no">585</span><span id="line-585"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">586</span><span id="line-586"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">587</span><span id="line-587"> result = ht.get(get);</span> |
| <span class="source-line-no">588</span><span id="line-588"> assertEmptyResult(result);</span> |
| <span class="source-line-no">589</span><span id="line-589"></span> |
| <span class="source-line-no">590</span><span id="line-590"> Scan scan = new Scan();</span> |
| <span class="source-line-no">591</span><span id="line-591"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">592</span><span id="line-592"> assertNullResult(result);</span> |
| <span class="source-line-no">593</span><span id="line-593"></span> |
| <span class="source-line-no">594</span><span id="line-594"> scan = new Scan().withStartRow(ROWS[0]);</span> |
| <span class="source-line-no">595</span><span id="line-595"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">596</span><span id="line-596"> assertNullResult(result);</span> |
| <span class="source-line-no">597</span><span id="line-597"></span> |
| <span class="source-line-no">598</span><span id="line-598"> scan = new Scan().withStartRow(ROWS[0]).withStopRow(ROWS[1]);</span> |
| <span class="source-line-no">599</span><span id="line-599"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">600</span><span id="line-600"> assertNullResult(result);</span> |
| <span class="source-line-no">601</span><span id="line-601"></span> |
| <span class="source-line-no">602</span><span id="line-602"> scan = new Scan();</span> |
| <span class="source-line-no">603</span><span id="line-603"> scan.addFamily(FAMILY);</span> |
| <span class="source-line-no">604</span><span id="line-604"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">605</span><span id="line-605"> assertNullResult(result);</span> |
| <span class="source-line-no">606</span><span id="line-606"></span> |
| <span class="source-line-no">607</span><span id="line-607"> scan = new Scan();</span> |
| <span class="source-line-no">608</span><span id="line-608"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">609</span><span id="line-609"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">610</span><span id="line-610"> assertNullResult(result);</span> |
| <span class="source-line-no">611</span><span id="line-611"></span> |
| <span class="source-line-no">612</span><span id="line-612"> // Insert a row</span> |
| <span class="source-line-no">613</span><span id="line-613"></span> |
| <span class="source-line-no">614</span><span id="line-614"> Put put = new Put(ROWS[2]);</span> |
| <span class="source-line-no">615</span><span id="line-615"> put.addColumn(FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">616</span><span id="line-616"> ht.put(put);</span> |
| <span class="source-line-no">617</span><span id="line-617"></span> |
| <span class="source-line-no">618</span><span id="line-618"> // Try to get empty rows around it</span> |
| <span class="source-line-no">619</span><span id="line-619"></span> |
| <span class="source-line-no">620</span><span id="line-620"> get = new Get(ROWS[1]);</span> |
| <span class="source-line-no">621</span><span id="line-621"> result = ht.get(get);</span> |
| <span class="source-line-no">622</span><span id="line-622"> assertEmptyResult(result);</span> |
| <span class="source-line-no">623</span><span id="line-623"></span> |
| <span class="source-line-no">624</span><span id="line-624"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">625</span><span id="line-625"> get.addFamily(FAMILY);</span> |
| <span class="source-line-no">626</span><span id="line-626"> result = ht.get(get);</span> |
| <span class="source-line-no">627</span><span id="line-627"> assertEmptyResult(result);</span> |
| <span class="source-line-no">628</span><span id="line-628"></span> |
| <span class="source-line-no">629</span><span id="line-629"> get = new Get(ROWS[3]);</span> |
| <span class="source-line-no">630</span><span id="line-630"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">631</span><span id="line-631"> result = ht.get(get);</span> |
| <span class="source-line-no">632</span><span id="line-632"> assertEmptyResult(result);</span> |
| <span class="source-line-no">633</span><span id="line-633"></span> |
| <span class="source-line-no">634</span><span id="line-634"> // Try to scan empty rows around it</span> |
| <span class="source-line-no">635</span><span id="line-635"></span> |
| <span class="source-line-no">636</span><span id="line-636"> scan = new Scan().withStartRow(ROWS[3]);</span> |
| <span class="source-line-no">637</span><span id="line-637"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">638</span><span id="line-638"> assertNullResult(result);</span> |
| <span class="source-line-no">639</span><span id="line-639"></span> |
| <span class="source-line-no">640</span><span id="line-640"> scan = new Scan().withStartRow(ROWS[0]).withStopRow(ROWS[2]);</span> |
| <span class="source-line-no">641</span><span id="line-641"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">642</span><span id="line-642"> assertNullResult(result);</span> |
| <span class="source-line-no">643</span><span id="line-643"></span> |
| <span class="source-line-no">644</span><span id="line-644"> // Make sure we can actually get the row</span> |
| <span class="source-line-no">645</span><span id="line-645"></span> |
| <span class="source-line-no">646</span><span id="line-646"> get = new Get(ROWS[2]);</span> |
| <span class="source-line-no">647</span><span id="line-647"> result = ht.get(get);</span> |
| <span class="source-line-no">648</span><span id="line-648"> assertSingleResult(result, ROWS[2], FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">649</span><span id="line-649"></span> |
| <span class="source-line-no">650</span><span id="line-650"> get = new Get(ROWS[2]);</span> |
| <span class="source-line-no">651</span><span id="line-651"> get.addFamily(FAMILY);</span> |
| <span class="source-line-no">652</span><span id="line-652"> result = ht.get(get);</span> |
| <span class="source-line-no">653</span><span id="line-653"> assertSingleResult(result, ROWS[2], FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">654</span><span id="line-654"></span> |
| <span class="source-line-no">655</span><span id="line-655"> get = new Get(ROWS[2]);</span> |
| <span class="source-line-no">656</span><span id="line-656"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">657</span><span id="line-657"> result = ht.get(get);</span> |
| <span class="source-line-no">658</span><span id="line-658"> assertSingleResult(result, ROWS[2], FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">659</span><span id="line-659"></span> |
| <span class="source-line-no">660</span><span id="line-660"> // Make sure we can scan the row</span> |
| <span class="source-line-no">661</span><span id="line-661"></span> |
| <span class="source-line-no">662</span><span id="line-662"> scan = new Scan();</span> |
| <span class="source-line-no">663</span><span id="line-663"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">664</span><span id="line-664"> assertSingleResult(result, ROWS[2], FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">665</span><span id="line-665"></span> |
| <span class="source-line-no">666</span><span id="line-666"> scan = new Scan().withStartRow(ROWS[0]).withStopRow(ROWS[3]);</span> |
| <span class="source-line-no">667</span><span id="line-667"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">668</span><span id="line-668"> assertSingleResult(result, ROWS[2], FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">669</span><span id="line-669"></span> |
| <span class="source-line-no">670</span><span id="line-670"> scan = new Scan().withStartRow(ROWS[2]).withStopRow(ROWS[3]);</span> |
| <span class="source-line-no">671</span><span id="line-671"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">672</span><span id="line-672"> assertSingleResult(result, ROWS[2], FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">673</span><span id="line-673"> }</span> |
| <span class="source-line-no">674</span><span id="line-674"> }</span> |
| <span class="source-line-no">675</span><span id="line-675"></span> |
| <span class="source-line-no">676</span><span id="line-676"> /**</span> |
| <span class="source-line-no">677</span><span id="line-677"> * Test basic puts, gets, scans, and deletes for a single row in a multiple family table.</span> |
| <span class="source-line-no">678</span><span id="line-678"> */</span> |
| <span class="source-line-no">679</span><span id="line-679"> @SuppressWarnings("checkstyle:MethodLength")</span> |
| <span class="source-line-no">680</span><span id="line-680"> @Test</span> |
| <span class="source-line-no">681</span><span id="line-681"> public void testSingleRowMultipleFamily() throws Exception {</span> |
| <span class="source-line-no">682</span><span id="line-682"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">683</span><span id="line-683"> byte[][] ROWS = makeN(ROW, 3);</span> |
| <span class="source-line-no">684</span><span id="line-684"> byte[][] FAMILIES = makeNAscii(FAMILY, 10);</span> |
| <span class="source-line-no">685</span><span id="line-685"> byte[][] QUALIFIERS = makeN(QUALIFIER, 10);</span> |
| <span class="source-line-no">686</span><span id="line-686"> byte[][] VALUES = makeN(VALUE, 10);</span> |
| <span class="source-line-no">687</span><span id="line-687"></span> |
| <span class="source-line-no">688</span><span id="line-688"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILIES)) {</span> |
| <span class="source-line-no">689</span><span id="line-689"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">690</span><span id="line-690"> // Insert one column to one family</span> |
| <span class="source-line-no">691</span><span id="line-691"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">692</span><span id="line-692"></span> |
| <span class="source-line-no">693</span><span id="line-693"> Put put = new Put(ROWS[0]);</span> |
| <span class="source-line-no">694</span><span id="line-694"> put.addColumn(FAMILIES[4], QUALIFIERS[0], VALUES[0]);</span> |
| <span class="source-line-no">695</span><span id="line-695"> ht.put(put);</span> |
| <span class="source-line-no">696</span><span id="line-696"></span> |
| <span class="source-line-no">697</span><span id="line-697"> // Get the single column</span> |
| <span class="source-line-no">698</span><span id="line-698"> getVerifySingleColumn(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0, VALUES, 0);</span> |
| <span class="source-line-no">699</span><span id="line-699"></span> |
| <span class="source-line-no">700</span><span id="line-700"> // Scan the single column</span> |
| <span class="source-line-no">701</span><span id="line-701"> scanVerifySingleColumn(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0, VALUES, 0);</span> |
| <span class="source-line-no">702</span><span id="line-702"></span> |
| <span class="source-line-no">703</span><span id="line-703"> // Get empty results around inserted column</span> |
| <span class="source-line-no">704</span><span id="line-704"> getVerifySingleEmpty(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0);</span> |
| <span class="source-line-no">705</span><span id="line-705"></span> |
| <span class="source-line-no">706</span><span id="line-706"> // Scan empty results around inserted column</span> |
| <span class="source-line-no">707</span><span id="line-707"> scanVerifySingleEmpty(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0);</span> |
| <span class="source-line-no">708</span><span id="line-708"></span> |
| <span class="source-line-no">709</span><span id="line-709"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">710</span><span id="line-710"> // Flush memstore and run same tests from storefiles</span> |
| <span class="source-line-no">711</span><span id="line-711"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">712</span><span id="line-712"></span> |
| <span class="source-line-no">713</span><span id="line-713"> TEST_UTIL.flush();</span> |
| <span class="source-line-no">714</span><span id="line-714"></span> |
| <span class="source-line-no">715</span><span id="line-715"> // Redo get and scan tests from storefile</span> |
| <span class="source-line-no">716</span><span id="line-716"> getVerifySingleColumn(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0, VALUES, 0);</span> |
| <span class="source-line-no">717</span><span id="line-717"> scanVerifySingleColumn(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0, VALUES, 0);</span> |
| <span class="source-line-no">718</span><span id="line-718"> getVerifySingleEmpty(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0);</span> |
| <span class="source-line-no">719</span><span id="line-719"> scanVerifySingleEmpty(ht, ROWS, 0, FAMILIES, 4, QUALIFIERS, 0);</span> |
| <span class="source-line-no">720</span><span id="line-720"></span> |
| <span class="source-line-no">721</span><span id="line-721"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">722</span><span id="line-722"> // Now, Test reading from memstore and storefiles at once</span> |
| <span class="source-line-no">723</span><span id="line-723"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">724</span><span id="line-724"></span> |
| <span class="source-line-no">725</span><span id="line-725"> // Insert multiple columns to two other families</span> |
| <span class="source-line-no">726</span><span id="line-726"> put = new Put(ROWS[0]);</span> |
| <span class="source-line-no">727</span><span id="line-727"> put.addColumn(FAMILIES[2], QUALIFIERS[2], VALUES[2]);</span> |
| <span class="source-line-no">728</span><span id="line-728"> put.addColumn(FAMILIES[2], QUALIFIERS[4], VALUES[4]);</span> |
| <span class="source-line-no">729</span><span id="line-729"> put.addColumn(FAMILIES[4], QUALIFIERS[4], VALUES[4]);</span> |
| <span class="source-line-no">730</span><span id="line-730"> put.addColumn(FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">731</span><span id="line-731"> put.addColumn(FAMILIES[6], QUALIFIERS[7], VALUES[7]);</span> |
| <span class="source-line-no">732</span><span id="line-732"> put.addColumn(FAMILIES[7], QUALIFIERS[7], VALUES[7]);</span> |
| <span class="source-line-no">733</span><span id="line-733"> put.addColumn(FAMILIES[9], QUALIFIERS[0], VALUES[0]);</span> |
| <span class="source-line-no">734</span><span id="line-734"> ht.put(put);</span> |
| <span class="source-line-no">735</span><span id="line-735"></span> |
| <span class="source-line-no">736</span><span id="line-736"> // Get multiple columns across multiple families and get empties around it</span> |
| <span class="source-line-no">737</span><span id="line-737"> singleRowGetTest(ht, ROWS, FAMILIES, QUALIFIERS, VALUES);</span> |
| <span class="source-line-no">738</span><span id="line-738"></span> |
| <span class="source-line-no">739</span><span id="line-739"> // Scan multiple columns across multiple families and scan empties around it</span> |
| <span class="source-line-no">740</span><span id="line-740"> singleRowScanTest(ht, ROWS, FAMILIES, QUALIFIERS, VALUES);</span> |
| <span class="source-line-no">741</span><span id="line-741"></span> |
| <span class="source-line-no">742</span><span id="line-742"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">743</span><span id="line-743"> // Flush the table again</span> |
| <span class="source-line-no">744</span><span id="line-744"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">745</span><span id="line-745"></span> |
| <span class="source-line-no">746</span><span id="line-746"> TEST_UTIL.flush();</span> |
| <span class="source-line-no">747</span><span id="line-747"></span> |
| <span class="source-line-no">748</span><span id="line-748"> // Redo tests again</span> |
| <span class="source-line-no">749</span><span id="line-749"> singleRowGetTest(ht, ROWS, FAMILIES, QUALIFIERS, VALUES);</span> |
| <span class="source-line-no">750</span><span id="line-750"> singleRowScanTest(ht, ROWS, FAMILIES, QUALIFIERS, VALUES);</span> |
| <span class="source-line-no">751</span><span id="line-751"></span> |
| <span class="source-line-no">752</span><span id="line-752"> // Insert more data to memstore</span> |
| <span class="source-line-no">753</span><span id="line-753"> put = new Put(ROWS[0]);</span> |
| <span class="source-line-no">754</span><span id="line-754"> put.addColumn(FAMILIES[6], QUALIFIERS[5], VALUES[5]);</span> |
| <span class="source-line-no">755</span><span id="line-755"> put.addColumn(FAMILIES[6], QUALIFIERS[8], VALUES[8]);</span> |
| <span class="source-line-no">756</span><span id="line-756"> put.addColumn(FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">757</span><span id="line-757"> put.addColumn(FAMILIES[4], QUALIFIERS[3], VALUES[3]);</span> |
| <span class="source-line-no">758</span><span id="line-758"> ht.put(put);</span> |
| <span class="source-line-no">759</span><span id="line-759"></span> |
| <span class="source-line-no">760</span><span id="line-760"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">761</span><span id="line-761"> // Delete a storefile column</span> |
| <span class="source-line-no">762</span><span id="line-762"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">763</span><span id="line-763"> Delete delete = new Delete(ROWS[0]);</span> |
| <span class="source-line-no">764</span><span id="line-764"> delete.addColumns(FAMILIES[6], QUALIFIERS[7]);</span> |
| <span class="source-line-no">765</span><span id="line-765"> ht.delete(delete);</span> |
| <span class="source-line-no">766</span><span id="line-766"></span> |
| <span class="source-line-no">767</span><span id="line-767"> // Try to get deleted column</span> |
| <span class="source-line-no">768</span><span id="line-768"> Get get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">769</span><span id="line-769"> get.addColumn(FAMILIES[6], QUALIFIERS[7]);</span> |
| <span class="source-line-no">770</span><span id="line-770"> Result result = ht.get(get);</span> |
| <span class="source-line-no">771</span><span id="line-771"> assertEmptyResult(result);</span> |
| <span class="source-line-no">772</span><span id="line-772"></span> |
| <span class="source-line-no">773</span><span id="line-773"> // Try to scan deleted column</span> |
| <span class="source-line-no">774</span><span id="line-774"> Scan scan = new Scan();</span> |
| <span class="source-line-no">775</span><span id="line-775"> scan.addColumn(FAMILIES[6], QUALIFIERS[7]);</span> |
| <span class="source-line-no">776</span><span id="line-776"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">777</span><span id="line-777"> assertNullResult(result);</span> |
| <span class="source-line-no">778</span><span id="line-778"></span> |
| <span class="source-line-no">779</span><span id="line-779"> // Make sure we can still get a column before it and after it</span> |
| <span class="source-line-no">780</span><span id="line-780"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">781</span><span id="line-781"> get.addColumn(FAMILIES[6], QUALIFIERS[6]);</span> |
| <span class="source-line-no">782</span><span id="line-782"> result = ht.get(get);</span> |
| <span class="source-line-no">783</span><span id="line-783"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">784</span><span id="line-784"></span> |
| <span class="source-line-no">785</span><span id="line-785"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">786</span><span id="line-786"> get.addColumn(FAMILIES[6], QUALIFIERS[8]);</span> |
| <span class="source-line-no">787</span><span id="line-787"> result = ht.get(get);</span> |
| <span class="source-line-no">788</span><span id="line-788"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[8], VALUES[8]);</span> |
| <span class="source-line-no">789</span><span id="line-789"></span> |
| <span class="source-line-no">790</span><span id="line-790"> // Make sure we can still scan a column before it and after it</span> |
| <span class="source-line-no">791</span><span id="line-791"> scan = new Scan();</span> |
| <span class="source-line-no">792</span><span id="line-792"> scan.addColumn(FAMILIES[6], QUALIFIERS[6]);</span> |
| <span class="source-line-no">793</span><span id="line-793"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">794</span><span id="line-794"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">795</span><span id="line-795"></span> |
| <span class="source-line-no">796</span><span id="line-796"> scan = new Scan();</span> |
| <span class="source-line-no">797</span><span id="line-797"> scan.addColumn(FAMILIES[6], QUALIFIERS[8]);</span> |
| <span class="source-line-no">798</span><span id="line-798"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">799</span><span id="line-799"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[8], VALUES[8]);</span> |
| <span class="source-line-no">800</span><span id="line-800"></span> |
| <span class="source-line-no">801</span><span id="line-801"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">802</span><span id="line-802"> // Delete a memstore column</span> |
| <span class="source-line-no">803</span><span id="line-803"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">804</span><span id="line-804"> delete = new Delete(ROWS[0]);</span> |
| <span class="source-line-no">805</span><span id="line-805"> delete.addColumns(FAMILIES[6], QUALIFIERS[8]);</span> |
| <span class="source-line-no">806</span><span id="line-806"> ht.delete(delete);</span> |
| <span class="source-line-no">807</span><span id="line-807"></span> |
| <span class="source-line-no">808</span><span id="line-808"> // Try to get deleted column</span> |
| <span class="source-line-no">809</span><span id="line-809"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">810</span><span id="line-810"> get.addColumn(FAMILIES[6], QUALIFIERS[8]);</span> |
| <span class="source-line-no">811</span><span id="line-811"> result = ht.get(get);</span> |
| <span class="source-line-no">812</span><span id="line-812"> assertEmptyResult(result);</span> |
| <span class="source-line-no">813</span><span id="line-813"></span> |
| <span class="source-line-no">814</span><span id="line-814"> // Try to scan deleted column</span> |
| <span class="source-line-no">815</span><span id="line-815"> scan = new Scan();</span> |
| <span class="source-line-no">816</span><span id="line-816"> scan.addColumn(FAMILIES[6], QUALIFIERS[8]);</span> |
| <span class="source-line-no">817</span><span id="line-817"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">818</span><span id="line-818"> assertNullResult(result);</span> |
| <span class="source-line-no">819</span><span id="line-819"></span> |
| <span class="source-line-no">820</span><span id="line-820"> // Make sure we can still get a column before it and after it</span> |
| <span class="source-line-no">821</span><span id="line-821"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">822</span><span id="line-822"> get.addColumn(FAMILIES[6], QUALIFIERS[6]);</span> |
| <span class="source-line-no">823</span><span id="line-823"> result = ht.get(get);</span> |
| <span class="source-line-no">824</span><span id="line-824"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">825</span><span id="line-825"></span> |
| <span class="source-line-no">826</span><span id="line-826"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">827</span><span id="line-827"> get.addColumn(FAMILIES[6], QUALIFIERS[9]);</span> |
| <span class="source-line-no">828</span><span id="line-828"> result = ht.get(get);</span> |
| <span class="source-line-no">829</span><span id="line-829"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">830</span><span id="line-830"></span> |
| <span class="source-line-no">831</span><span id="line-831"> // Make sure we can still scan a column before it and after it</span> |
| <span class="source-line-no">832</span><span id="line-832"> scan = new Scan();</span> |
| <span class="source-line-no">833</span><span id="line-833"> scan.addColumn(FAMILIES[6], QUALIFIERS[6]);</span> |
| <span class="source-line-no">834</span><span id="line-834"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">835</span><span id="line-835"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">836</span><span id="line-836"></span> |
| <span class="source-line-no">837</span><span id="line-837"> scan = new Scan();</span> |
| <span class="source-line-no">838</span><span id="line-838"> scan.addColumn(FAMILIES[6], QUALIFIERS[9]);</span> |
| <span class="source-line-no">839</span><span id="line-839"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">840</span><span id="line-840"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">841</span><span id="line-841"></span> |
| <span class="source-line-no">842</span><span id="line-842"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">843</span><span id="line-843"> // Delete joint storefile/memstore family</span> |
| <span class="source-line-no">844</span><span id="line-844"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">845</span><span id="line-845"></span> |
| <span class="source-line-no">846</span><span id="line-846"> delete = new Delete(ROWS[0]);</span> |
| <span class="source-line-no">847</span><span id="line-847"> delete.addFamily(FAMILIES[4]);</span> |
| <span class="source-line-no">848</span><span id="line-848"> ht.delete(delete);</span> |
| <span class="source-line-no">849</span><span id="line-849"></span> |
| <span class="source-line-no">850</span><span id="line-850"> // Try to get storefile column in deleted family</span> |
| <span class="source-line-no">851</span><span id="line-851"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">852</span><span id="line-852"> get.addColumn(FAMILIES[4], QUALIFIERS[4]);</span> |
| <span class="source-line-no">853</span><span id="line-853"> result = ht.get(get);</span> |
| <span class="source-line-no">854</span><span id="line-854"> assertEmptyResult(result);</span> |
| <span class="source-line-no">855</span><span id="line-855"></span> |
| <span class="source-line-no">856</span><span id="line-856"> // Try to get memstore column in deleted family</span> |
| <span class="source-line-no">857</span><span id="line-857"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">858</span><span id="line-858"> get.addColumn(FAMILIES[4], QUALIFIERS[3]);</span> |
| <span class="source-line-no">859</span><span id="line-859"> result = ht.get(get);</span> |
| <span class="source-line-no">860</span><span id="line-860"> assertEmptyResult(result);</span> |
| <span class="source-line-no">861</span><span id="line-861"></span> |
| <span class="source-line-no">862</span><span id="line-862"> // Try to get deleted family</span> |
| <span class="source-line-no">863</span><span id="line-863"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">864</span><span id="line-864"> get.addFamily(FAMILIES[4]);</span> |
| <span class="source-line-no">865</span><span id="line-865"> result = ht.get(get);</span> |
| <span class="source-line-no">866</span><span id="line-866"> assertEmptyResult(result);</span> |
| <span class="source-line-no">867</span><span id="line-867"></span> |
| <span class="source-line-no">868</span><span id="line-868"> // Try to scan storefile column in deleted family</span> |
| <span class="source-line-no">869</span><span id="line-869"> scan = new Scan();</span> |
| <span class="source-line-no">870</span><span id="line-870"> scan.addColumn(FAMILIES[4], QUALIFIERS[4]);</span> |
| <span class="source-line-no">871</span><span id="line-871"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">872</span><span id="line-872"> assertNullResult(result);</span> |
| <span class="source-line-no">873</span><span id="line-873"></span> |
| <span class="source-line-no">874</span><span id="line-874"> // Try to scan memstore column in deleted family</span> |
| <span class="source-line-no">875</span><span id="line-875"> scan = new Scan();</span> |
| <span class="source-line-no">876</span><span id="line-876"> scan.addColumn(FAMILIES[4], QUALIFIERS[3]);</span> |
| <span class="source-line-no">877</span><span id="line-877"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">878</span><span id="line-878"> assertNullResult(result);</span> |
| <span class="source-line-no">879</span><span id="line-879"></span> |
| <span class="source-line-no">880</span><span id="line-880"> // Try to scan deleted family</span> |
| <span class="source-line-no">881</span><span id="line-881"> scan = new Scan();</span> |
| <span class="source-line-no">882</span><span id="line-882"> scan.addFamily(FAMILIES[4]);</span> |
| <span class="source-line-no">883</span><span id="line-883"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">884</span><span id="line-884"> assertNullResult(result);</span> |
| <span class="source-line-no">885</span><span id="line-885"></span> |
| <span class="source-line-no">886</span><span id="line-886"> // Make sure we can still get another family</span> |
| <span class="source-line-no">887</span><span id="line-887"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">888</span><span id="line-888"> get.addColumn(FAMILIES[2], QUALIFIERS[2]);</span> |
| <span class="source-line-no">889</span><span id="line-889"> result = ht.get(get);</span> |
| <span class="source-line-no">890</span><span id="line-890"> assertSingleResult(result, ROWS[0], FAMILIES[2], QUALIFIERS[2], VALUES[2]);</span> |
| <span class="source-line-no">891</span><span id="line-891"></span> |
| <span class="source-line-no">892</span><span id="line-892"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">893</span><span id="line-893"> get.addColumn(FAMILIES[6], QUALIFIERS[9]);</span> |
| <span class="source-line-no">894</span><span id="line-894"> result = ht.get(get);</span> |
| <span class="source-line-no">895</span><span id="line-895"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">896</span><span id="line-896"></span> |
| <span class="source-line-no">897</span><span id="line-897"> // Make sure we can still scan another family</span> |
| <span class="source-line-no">898</span><span id="line-898"> scan = new Scan();</span> |
| <span class="source-line-no">899</span><span id="line-899"> scan.addColumn(FAMILIES[6], QUALIFIERS[6]);</span> |
| <span class="source-line-no">900</span><span id="line-900"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">901</span><span id="line-901"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">902</span><span id="line-902"></span> |
| <span class="source-line-no">903</span><span id="line-903"> scan = new Scan();</span> |
| <span class="source-line-no">904</span><span id="line-904"> scan.addColumn(FAMILIES[6], QUALIFIERS[9]);</span> |
| <span class="source-line-no">905</span><span id="line-905"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">906</span><span id="line-906"> assertSingleResult(result, ROWS[0], FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">907</span><span id="line-907"></span> |
| <span class="source-line-no">908</span><span id="line-908"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">909</span><span id="line-909"> // Flush everything and rerun delete tests</span> |
| <span class="source-line-no">910</span><span id="line-910"> ////////////////////////////////////////////////////////////////////////////</span> |
| <span class="source-line-no">911</span><span id="line-911"></span> |
| <span class="source-line-no">912</span><span id="line-912"> TEST_UTIL.flush();</span> |
| <span class="source-line-no">913</span><span id="line-913"></span> |
| <span class="source-line-no">914</span><span id="line-914"> // Try to get storefile column in deleted family</span> |
| <span class="source-line-no">915</span><span id="line-915"> assertEmptyResult(ht.get(new Get(ROWS[0]).addColumn(FAMILIES[4], QUALIFIERS[4])));</span> |
| <span class="source-line-no">916</span><span id="line-916"></span> |
| <span class="source-line-no">917</span><span id="line-917"> // Try to get memstore column in deleted family</span> |
| <span class="source-line-no">918</span><span id="line-918"> assertEmptyResult(ht.get(new Get(ROWS[0]).addColumn(FAMILIES[4], QUALIFIERS[3])));</span> |
| <span class="source-line-no">919</span><span id="line-919"></span> |
| <span class="source-line-no">920</span><span id="line-920"> // Try to get deleted family</span> |
| <span class="source-line-no">921</span><span id="line-921"> assertEmptyResult(ht.get(new Get(ROWS[0]).addFamily(FAMILIES[4])));</span> |
| <span class="source-line-no">922</span><span id="line-922"></span> |
| <span class="source-line-no">923</span><span id="line-923"> // Try to scan storefile column in deleted family</span> |
| <span class="source-line-no">924</span><span id="line-924"> assertNullResult(getSingleScanResult(ht, new Scan().addColumn(FAMILIES[4], QUALIFIERS[4])));</span> |
| <span class="source-line-no">925</span><span id="line-925"></span> |
| <span class="source-line-no">926</span><span id="line-926"> // Try to scan memstore column in deleted family</span> |
| <span class="source-line-no">927</span><span id="line-927"> assertNullResult(getSingleScanResult(ht, new Scan().addColumn(FAMILIES[4], QUALIFIERS[3])));</span> |
| <span class="source-line-no">928</span><span id="line-928"></span> |
| <span class="source-line-no">929</span><span id="line-929"> // Try to scan deleted family</span> |
| <span class="source-line-no">930</span><span id="line-930"> assertNullResult(getSingleScanResult(ht, new Scan().addFamily(FAMILIES[4])));</span> |
| <span class="source-line-no">931</span><span id="line-931"></span> |
| <span class="source-line-no">932</span><span id="line-932"> // Make sure we can still get another family</span> |
| <span class="source-line-no">933</span><span id="line-933"> assertSingleResult(ht.get(new Get(ROWS[0]).addColumn(FAMILIES[2], QUALIFIERS[2])), ROWS[0],</span> |
| <span class="source-line-no">934</span><span id="line-934"> FAMILIES[2], QUALIFIERS[2], VALUES[2]);</span> |
| <span class="source-line-no">935</span><span id="line-935"></span> |
| <span class="source-line-no">936</span><span id="line-936"> assertSingleResult(ht.get(new Get(ROWS[0]).addColumn(FAMILIES[6], QUALIFIERS[9])), ROWS[0],</span> |
| <span class="source-line-no">937</span><span id="line-937"> FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">938</span><span id="line-938"></span> |
| <span class="source-line-no">939</span><span id="line-939"> // Make sure we can still scan another family</span> |
| <span class="source-line-no">940</span><span id="line-940"> assertSingleResult(getSingleScanResult(ht, new Scan().addColumn(FAMILIES[6], QUALIFIERS[6])),</span> |
| <span class="source-line-no">941</span><span id="line-941"> ROWS[0], FAMILIES[6], QUALIFIERS[6], VALUES[6]);</span> |
| <span class="source-line-no">942</span><span id="line-942"></span> |
| <span class="source-line-no">943</span><span id="line-943"> assertSingleResult(getSingleScanResult(ht, new Scan().addColumn(FAMILIES[6], QUALIFIERS[9])),</span> |
| <span class="source-line-no">944</span><span id="line-944"> ROWS[0], FAMILIES[6], QUALIFIERS[9], VALUES[9]);</span> |
| <span class="source-line-no">945</span><span id="line-945"> }</span> |
| <span class="source-line-no">946</span><span id="line-946"> }</span> |
| <span class="source-line-no">947</span><span id="line-947"></span> |
| <span class="source-line-no">948</span><span id="line-948"> @Test(expected = NullPointerException.class)</span> |
| <span class="source-line-no">949</span><span id="line-949"> public void testNullTableName() throws IOException {</span> |
| <span class="source-line-no">950</span><span id="line-950"> // Null table name (should NOT work)</span> |
| <span class="source-line-no">951</span><span id="line-951"> TEST_UTIL.createTable(null, FAMILY);</span> |
| <span class="source-line-no">952</span><span id="line-952"> fail("Creating a table with null name passed, should have failed");</span> |
| <span class="source-line-no">953</span><span id="line-953"> }</span> |
| <span class="source-line-no">954</span><span id="line-954"></span> |
| <span class="source-line-no">955</span><span id="line-955"> @Test(expected = IllegalArgumentException.class)</span> |
| <span class="source-line-no">956</span><span id="line-956"> public void testNullFamilyName() throws IOException {</span> |
| <span class="source-line-no">957</span><span id="line-957"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">958</span><span id="line-958"></span> |
| <span class="source-line-no">959</span><span id="line-959"> // Null family (should NOT work)</span> |
| <span class="source-line-no">960</span><span id="line-960"> TEST_UTIL.createTable(tableName, new byte[][] { null });</span> |
| <span class="source-line-no">961</span><span id="line-961"> fail("Creating a table with a null family passed, should fail");</span> |
| <span class="source-line-no">962</span><span id="line-962"> }</span> |
| <span class="source-line-no">963</span><span id="line-963"></span> |
| <span class="source-line-no">964</span><span id="line-964"> @Test</span> |
| <span class="source-line-no">965</span><span id="line-965"> public void testNullRowAndQualifier() throws Exception {</span> |
| <span class="source-line-no">966</span><span id="line-966"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">967</span><span id="line-967"></span> |
| <span class="source-line-no">968</span><span id="line-968"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">969</span><span id="line-969"></span> |
| <span class="source-line-no">970</span><span id="line-970"> // Null row (should NOT work)</span> |
| <span class="source-line-no">971</span><span id="line-971"> try {</span> |
| <span class="source-line-no">972</span><span id="line-972"> Put put = new Put((byte[]) null);</span> |
| <span class="source-line-no">973</span><span id="line-973"> put.addColumn(FAMILY, QUALIFIER, VALUE);</span> |
| <span class="source-line-no">974</span><span id="line-974"> ht.put(put);</span> |
| <span class="source-line-no">975</span><span id="line-975"> fail("Inserting a null row worked, should throw exception");</span> |
| <span class="source-line-no">976</span><span id="line-976"> } catch (Exception ignored) {</span> |
| <span class="source-line-no">977</span><span id="line-977"> }</span> |
| <span class="source-line-no">978</span><span id="line-978"></span> |
| <span class="source-line-no">979</span><span id="line-979"> // Null qualifier (should work)</span> |
| <span class="source-line-no">980</span><span id="line-980"> {</span> |
| <span class="source-line-no">981</span><span id="line-981"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">982</span><span id="line-982"> put.addColumn(FAMILY, null, VALUE);</span> |
| <span class="source-line-no">983</span><span id="line-983"> ht.put(put);</span> |
| <span class="source-line-no">984</span><span id="line-984"></span> |
| <span class="source-line-no">985</span><span id="line-985"> getTestNull(ht, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">986</span><span id="line-986"></span> |
| <span class="source-line-no">987</span><span id="line-987"> scanTestNull(ht, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">988</span><span id="line-988"></span> |
| <span class="source-line-no">989</span><span id="line-989"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">990</span><span id="line-990"> delete.addColumns(FAMILY, null);</span> |
| <span class="source-line-no">991</span><span id="line-991"> ht.delete(delete);</span> |
| <span class="source-line-no">992</span><span id="line-992"></span> |
| <span class="source-line-no">993</span><span id="line-993"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">994</span><span id="line-994"> Result result = ht.get(get);</span> |
| <span class="source-line-no">995</span><span id="line-995"> assertEmptyResult(result);</span> |
| <span class="source-line-no">996</span><span id="line-996"> }</span> |
| <span class="source-line-no">997</span><span id="line-997"> }</span> |
| <span class="source-line-no">998</span><span id="line-998"> }</span> |
| <span class="source-line-no">999</span><span id="line-999"></span> |
| <span class="source-line-no">1000</span><span id="line-1000"> @Test</span> |
| <span class="source-line-no">1001</span><span id="line-1001"> public void testNullEmptyQualifier() throws Exception {</span> |
| <span class="source-line-no">1002</span><span id="line-1002"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1003</span><span id="line-1003"></span> |
| <span class="source-line-no">1004</span><span id="line-1004"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">1005</span><span id="line-1005"></span> |
| <span class="source-line-no">1006</span><span id="line-1006"> // Empty qualifier, byte[0] instead of null (should work)</span> |
| <span class="source-line-no">1007</span><span id="line-1007"> try {</span> |
| <span class="source-line-no">1008</span><span id="line-1008"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1009</span><span id="line-1009"> put.addColumn(FAMILY, HConstants.EMPTY_BYTE_ARRAY, VALUE);</span> |
| <span class="source-line-no">1010</span><span id="line-1010"> ht.put(put);</span> |
| <span class="source-line-no">1011</span><span id="line-1011"></span> |
| <span class="source-line-no">1012</span><span id="line-1012"> getTestNull(ht, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1013</span><span id="line-1013"></span> |
| <span class="source-line-no">1014</span><span id="line-1014"> scanTestNull(ht, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1015</span><span id="line-1015"></span> |
| <span class="source-line-no">1016</span><span id="line-1016"> // Flush and try again</span> |
| <span class="source-line-no">1017</span><span id="line-1017"></span> |
| <span class="source-line-no">1018</span><span id="line-1018"> TEST_UTIL.flush();</span> |
| <span class="source-line-no">1019</span><span id="line-1019"></span> |
| <span class="source-line-no">1020</span><span id="line-1020"> getTestNull(ht, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1021</span><span id="line-1021"></span> |
| <span class="source-line-no">1022</span><span id="line-1022"> scanTestNull(ht, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1023</span><span id="line-1023"></span> |
| <span class="source-line-no">1024</span><span id="line-1024"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1025</span><span id="line-1025"> delete.addColumns(FAMILY, HConstants.EMPTY_BYTE_ARRAY);</span> |
| <span class="source-line-no">1026</span><span id="line-1026"> ht.delete(delete);</span> |
| <span class="source-line-no">1027</span><span id="line-1027"></span> |
| <span class="source-line-no">1028</span><span id="line-1028"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1029</span><span id="line-1029"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1030</span><span id="line-1030"> assertEmptyResult(result);</span> |
| <span class="source-line-no">1031</span><span id="line-1031"></span> |
| <span class="source-line-no">1032</span><span id="line-1032"> } catch (Exception e) {</span> |
| <span class="source-line-no">1033</span><span id="line-1033"> throw new IOException("Using a row with null qualifier should not throw exception");</span> |
| <span class="source-line-no">1034</span><span id="line-1034"> }</span> |
| <span class="source-line-no">1035</span><span id="line-1035"> }</span> |
| <span class="source-line-no">1036</span><span id="line-1036"> }</span> |
| <span class="source-line-no">1037</span><span id="line-1037"></span> |
| <span class="source-line-no">1038</span><span id="line-1038"> @Test</span> |
| <span class="source-line-no">1039</span><span id="line-1039"> public void testNullValue() throws IOException {</span> |
| <span class="source-line-no">1040</span><span id="line-1040"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1041</span><span id="line-1041"></span> |
| <span class="source-line-no">1042</span><span id="line-1042"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">1043</span><span id="line-1043"> // Null value</span> |
| <span class="source-line-no">1044</span><span id="line-1044"> try {</span> |
| <span class="source-line-no">1045</span><span id="line-1045"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1046</span><span id="line-1046"> put.addColumn(FAMILY, QUALIFIER, null);</span> |
| <span class="source-line-no">1047</span><span id="line-1047"> ht.put(put);</span> |
| <span class="source-line-no">1048</span><span id="line-1048"></span> |
| <span class="source-line-no">1049</span><span id="line-1049"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1050</span><span id="line-1050"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1051</span><span id="line-1051"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1052</span><span id="line-1052"> assertSingleResult(result, ROW, FAMILY, QUALIFIER, null);</span> |
| <span class="source-line-no">1053</span><span id="line-1053"></span> |
| <span class="source-line-no">1054</span><span id="line-1054"> Scan scan = new Scan();</span> |
| <span class="source-line-no">1055</span><span id="line-1055"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1056</span><span id="line-1056"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1057</span><span id="line-1057"> assertSingleResult(result, ROW, FAMILY, QUALIFIER, null);</span> |
| <span class="source-line-no">1058</span><span id="line-1058"></span> |
| <span class="source-line-no">1059</span><span id="line-1059"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1060</span><span id="line-1060"> delete.addColumns(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1061</span><span id="line-1061"> ht.delete(delete);</span> |
| <span class="source-line-no">1062</span><span id="line-1062"></span> |
| <span class="source-line-no">1063</span><span id="line-1063"> get = new Get(ROW);</span> |
| <span class="source-line-no">1064</span><span id="line-1064"> result = ht.get(get);</span> |
| <span class="source-line-no">1065</span><span id="line-1065"> assertEmptyResult(result);</span> |
| <span class="source-line-no">1066</span><span id="line-1066"></span> |
| <span class="source-line-no">1067</span><span id="line-1067"> } catch (Exception e) {</span> |
| <span class="source-line-no">1068</span><span id="line-1068"> throw new IOException("Null values should be allowed, but threw exception");</span> |
| <span class="source-line-no">1069</span><span id="line-1069"> }</span> |
| <span class="source-line-no">1070</span><span id="line-1070"> }</span> |
| <span class="source-line-no">1071</span><span id="line-1071"> }</span> |
| <span class="source-line-no">1072</span><span id="line-1072"></span> |
| <span class="source-line-no">1073</span><span id="line-1073"> @Test</span> |
| <span class="source-line-no">1074</span><span id="line-1074"> public void testNullQualifier() throws Exception {</span> |
| <span class="source-line-no">1075</span><span id="line-1075"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1076</span><span id="line-1076"> try (Table table = TEST_UTIL.createTable(tableName, FAMILY)) {</span> |
| <span class="source-line-no">1077</span><span id="line-1077"></span> |
| <span class="source-line-no">1078</span><span id="line-1078"> // Work for Put</span> |
| <span class="source-line-no">1079</span><span id="line-1079"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1080</span><span id="line-1080"> put.addColumn(FAMILY, null, VALUE);</span> |
| <span class="source-line-no">1081</span><span id="line-1081"> table.put(put);</span> |
| <span class="source-line-no">1082</span><span id="line-1082"></span> |
| <span class="source-line-no">1083</span><span id="line-1083"> // Work for Get, Scan</span> |
| <span class="source-line-no">1084</span><span id="line-1084"> getTestNull(table, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1085</span><span id="line-1085"> scanTestNull(table, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1086</span><span id="line-1086"></span> |
| <span class="source-line-no">1087</span><span id="line-1087"> // Work for Delete</span> |
| <span class="source-line-no">1088</span><span id="line-1088"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1089</span><span id="line-1089"> delete.addColumns(FAMILY, null);</span> |
| <span class="source-line-no">1090</span><span id="line-1090"> table.delete(delete);</span> |
| <span class="source-line-no">1091</span><span id="line-1091"></span> |
| <span class="source-line-no">1092</span><span id="line-1092"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1093</span><span id="line-1093"> Result result = table.get(get);</span> |
| <span class="source-line-no">1094</span><span id="line-1094"> assertEmptyResult(result);</span> |
| <span class="source-line-no">1095</span><span id="line-1095"></span> |
| <span class="source-line-no">1096</span><span id="line-1096"> // Work for Increment/Append</span> |
| <span class="source-line-no">1097</span><span id="line-1097"> Increment increment = new Increment(ROW);</span> |
| <span class="source-line-no">1098</span><span id="line-1098"> increment.addColumn(FAMILY, null, 1L);</span> |
| <span class="source-line-no">1099</span><span id="line-1099"> table.increment(increment);</span> |
| <span class="source-line-no">1100</span><span id="line-1100"> getTestNull(table, ROW, FAMILY, 1L);</span> |
| <span class="source-line-no">1101</span><span id="line-1101"></span> |
| <span class="source-line-no">1102</span><span id="line-1102"> table.incrementColumnValue(ROW, FAMILY, null, 1L);</span> |
| <span class="source-line-no">1103</span><span id="line-1103"> getTestNull(table, ROW, FAMILY, 2L);</span> |
| <span class="source-line-no">1104</span><span id="line-1104"></span> |
| <span class="source-line-no">1105</span><span id="line-1105"> delete = new Delete(ROW);</span> |
| <span class="source-line-no">1106</span><span id="line-1106"> delete.addColumns(FAMILY, null);</span> |
| <span class="source-line-no">1107</span><span id="line-1107"> table.delete(delete);</span> |
| <span class="source-line-no">1108</span><span id="line-1108"></span> |
| <span class="source-line-no">1109</span><span id="line-1109"> Append append = new Append(ROW);</span> |
| <span class="source-line-no">1110</span><span id="line-1110"> append.addColumn(FAMILY, null, VALUE);</span> |
| <span class="source-line-no">1111</span><span id="line-1111"> table.append(append);</span> |
| <span class="source-line-no">1112</span><span id="line-1112"> getTestNull(table, ROW, FAMILY, VALUE);</span> |
| <span class="source-line-no">1113</span><span id="line-1113"></span> |
| <span class="source-line-no">1114</span><span id="line-1114"> // Work for checkAndMutate using thenPut, thenMutate and thenDelete</span> |
| <span class="source-line-no">1115</span><span id="line-1115"> put = new Put(ROW);</span> |
| <span class="source-line-no">1116</span><span id="line-1116"> put.addColumn(FAMILY, null, Bytes.toBytes("checkAndPut"));</span> |
| <span class="source-line-no">1117</span><span id="line-1117"> table.put(put);</span> |
| <span class="source-line-no">1118</span><span id="line-1118"> table.checkAndMutate(ROW, FAMILY).ifEquals(VALUE).thenPut(put);</span> |
| <span class="source-line-no">1119</span><span id="line-1119"></span> |
| <span class="source-line-no">1120</span><span id="line-1120"> RowMutations mutate = new RowMutations(ROW);</span> |
| <span class="source-line-no">1121</span><span id="line-1121"> mutate.add(new Put(ROW).addColumn(FAMILY, null, Bytes.toBytes("checkAndMutate")));</span> |
| <span class="source-line-no">1122</span><span id="line-1122"> table.checkAndMutate(ROW, FAMILY).ifEquals(Bytes.toBytes("checkAndPut")).thenMutate(mutate);</span> |
| <span class="source-line-no">1123</span><span id="line-1123"></span> |
| <span class="source-line-no">1124</span><span id="line-1124"> delete = new Delete(ROW);</span> |
| <span class="source-line-no">1125</span><span id="line-1125"> delete.addColumns(FAMILY, null);</span> |
| <span class="source-line-no">1126</span><span id="line-1126"> table.checkAndMutate(ROW, FAMILY).ifEquals(Bytes.toBytes("checkAndMutate"))</span> |
| <span class="source-line-no">1127</span><span id="line-1127"> .thenDelete(delete);</span> |
| <span class="source-line-no">1128</span><span id="line-1128"> }</span> |
| <span class="source-line-no">1129</span><span id="line-1129"> }</span> |
| <span class="source-line-no">1130</span><span id="line-1130"></span> |
| <span class="source-line-no">1131</span><span id="line-1131"> @Test</span> |
| <span class="source-line-no">1132</span><span id="line-1132"> @SuppressWarnings("checkstyle:MethodLength")</span> |
| <span class="source-line-no">1133</span><span id="line-1133"> public void testVersions() throws Exception {</span> |
| <span class="source-line-no">1134</span><span id="line-1134"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1135</span><span id="line-1135"></span> |
| <span class="source-line-no">1136</span><span id="line-1136"> long[] STAMPS = makeStamps(20);</span> |
| <span class="source-line-no">1137</span><span id="line-1137"> byte[][] VALUES = makeNAscii(VALUE, 20);</span> |
| <span class="source-line-no">1138</span><span id="line-1138"></span> |
| <span class="source-line-no">1139</span><span id="line-1139"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY, 10)) {</span> |
| <span class="source-line-no">1140</span><span id="line-1140"></span> |
| <span class="source-line-no">1141</span><span id="line-1141"> // Insert 4 versions of same column</span> |
| <span class="source-line-no">1142</span><span id="line-1142"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1143</span><span id="line-1143"> put.addColumn(FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1144</span><span id="line-1144"> put.addColumn(FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1145</span><span id="line-1145"> put.addColumn(FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1146</span><span id="line-1146"> put.addColumn(FAMILY, QUALIFIER, STAMPS[5], VALUES[5]);</span> |
| <span class="source-line-no">1147</span><span id="line-1147"> ht.put(put);</span> |
| <span class="source-line-no">1148</span><span id="line-1148"></span> |
| <span class="source-line-no">1149</span><span id="line-1149"> // Verify we can get each one properly</span> |
| <span class="source-line-no">1150</span><span id="line-1150"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1151</span><span id="line-1151"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1152</span><span id="line-1152"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1153</span><span id="line-1153"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[5], VALUES[5]);</span> |
| <span class="source-line-no">1154</span><span id="line-1154"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1155</span><span id="line-1155"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1156</span><span id="line-1156"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1157</span><span id="line-1157"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[5], VALUES[5]);</span> |
| <span class="source-line-no">1158</span><span id="line-1158"></span> |
| <span class="source-line-no">1159</span><span id="line-1159"> // Verify we don't accidentally get others</span> |
| <span class="source-line-no">1160</span><span id="line-1160"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[0]);</span> |
| <span class="source-line-no">1161</span><span id="line-1161"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[3]);</span> |
| <span class="source-line-no">1162</span><span id="line-1162"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[6]);</span> |
| <span class="source-line-no">1163</span><span id="line-1163"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[0]);</span> |
| <span class="source-line-no">1164</span><span id="line-1164"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[3]);</span> |
| <span class="source-line-no">1165</span><span id="line-1165"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[6]);</span> |
| <span class="source-line-no">1166</span><span id="line-1166"></span> |
| <span class="source-line-no">1167</span><span id="line-1167"> // Ensure maxVersions in query is respected</span> |
| <span class="source-line-no">1168</span><span id="line-1168"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1169</span><span id="line-1169"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1170</span><span id="line-1170"> get.readVersions(2);</span> |
| <span class="source-line-no">1171</span><span id="line-1171"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1172</span><span id="line-1172"> assertNResult(result, ROW, FAMILY, QUALIFIER, new long[] { STAMPS[4], STAMPS[5] },</span> |
| <span class="source-line-no">1173</span><span id="line-1173"> new byte[][] { VALUES[4], VALUES[5] }, 0, 1);</span> |
| <span class="source-line-no">1174</span><span id="line-1174"></span> |
| <span class="source-line-no">1175</span><span id="line-1175"> Scan scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1176</span><span id="line-1176"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1177</span><span id="line-1177"> scan.readVersions(2);</span> |
| <span class="source-line-no">1178</span><span id="line-1178"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1179</span><span id="line-1179"> assertNResult(result, ROW, FAMILY, QUALIFIER, new long[] { STAMPS[4], STAMPS[5] },</span> |
| <span class="source-line-no">1180</span><span id="line-1180"> new byte[][] { VALUES[4], VALUES[5] }, 0, 1);</span> |
| <span class="source-line-no">1181</span><span id="line-1181"></span> |
| <span class="source-line-no">1182</span><span id="line-1182"> // Flush and redo</span> |
| <span class="source-line-no">1183</span><span id="line-1183"></span> |
| <span class="source-line-no">1184</span><span id="line-1184"> TEST_UTIL.flush();</span> |
| <span class="source-line-no">1185</span><span id="line-1185"></span> |
| <span class="source-line-no">1186</span><span id="line-1186"> // Verify we can get each one properly</span> |
| <span class="source-line-no">1187</span><span id="line-1187"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1188</span><span id="line-1188"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1189</span><span id="line-1189"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1190</span><span id="line-1190"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[5], VALUES[5]);</span> |
| <span class="source-line-no">1191</span><span id="line-1191"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1192</span><span id="line-1192"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1193</span><span id="line-1193"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1194</span><span id="line-1194"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[5], VALUES[5]);</span> |
| <span class="source-line-no">1195</span><span id="line-1195"></span> |
| <span class="source-line-no">1196</span><span id="line-1196"> // Verify we don't accidentally get others</span> |
| <span class="source-line-no">1197</span><span id="line-1197"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[0]);</span> |
| <span class="source-line-no">1198</span><span id="line-1198"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[3]);</span> |
| <span class="source-line-no">1199</span><span id="line-1199"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[6]);</span> |
| <span class="source-line-no">1200</span><span id="line-1200"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[0]);</span> |
| <span class="source-line-no">1201</span><span id="line-1201"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[3]);</span> |
| <span class="source-line-no">1202</span><span id="line-1202"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[6]);</span> |
| <span class="source-line-no">1203</span><span id="line-1203"></span> |
| <span class="source-line-no">1204</span><span id="line-1204"> // Ensure maxVersions in query is respected</span> |
| <span class="source-line-no">1205</span><span id="line-1205"> get = new Get(ROW);</span> |
| <span class="source-line-no">1206</span><span id="line-1206"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1207</span><span id="line-1207"> get.readVersions(2);</span> |
| <span class="source-line-no">1208</span><span id="line-1208"> result = ht.get(get);</span> |
| <span class="source-line-no">1209</span><span id="line-1209"> assertNResult(result, ROW, FAMILY, QUALIFIER, new long[] { STAMPS[4], STAMPS[5] },</span> |
| <span class="source-line-no">1210</span><span id="line-1210"> new byte[][] { VALUES[4], VALUES[5] }, 0, 1);</span> |
| <span class="source-line-no">1211</span><span id="line-1211"></span> |
| <span class="source-line-no">1212</span><span id="line-1212"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1213</span><span id="line-1213"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1214</span><span id="line-1214"> scan.readVersions(2);</span> |
| <span class="source-line-no">1215</span><span id="line-1215"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1216</span><span id="line-1216"> assertNResult(result, ROW, FAMILY, QUALIFIER, new long[] { STAMPS[4], STAMPS[5] },</span> |
| <span class="source-line-no">1217</span><span id="line-1217"> new byte[][] { VALUES[4], VALUES[5] }, 0, 1);</span> |
| <span class="source-line-no">1218</span><span id="line-1218"></span> |
| <span class="source-line-no">1219</span><span id="line-1219"> // Add some memstore and retest</span> |
| <span class="source-line-no">1220</span><span id="line-1220"></span> |
| <span class="source-line-no">1221</span><span id="line-1221"> // Insert 4 more versions of same column and a dupe</span> |
| <span class="source-line-no">1222</span><span id="line-1222"> put = new Put(ROW);</span> |
| <span class="source-line-no">1223</span><span id="line-1223"> put.addColumn(FAMILY, QUALIFIER, STAMPS[3], VALUES[3]);</span> |
| <span class="source-line-no">1224</span><span id="line-1224"> put.addColumn(FAMILY, QUALIFIER, STAMPS[6], VALUES[6]);</span> |
| <span class="source-line-no">1225</span><span id="line-1225"> put.addColumn(FAMILY, QUALIFIER, STAMPS[7], VALUES[7]);</span> |
| <span class="source-line-no">1226</span><span id="line-1226"> put.addColumn(FAMILY, QUALIFIER, STAMPS[8], VALUES[8]);</span> |
| <span class="source-line-no">1227</span><span id="line-1227"> ht.put(put);</span> |
| <span class="source-line-no">1228</span><span id="line-1228"></span> |
| <span class="source-line-no">1229</span><span id="line-1229"> // Ensure maxVersions in query is respected</span> |
| <span class="source-line-no">1230</span><span id="line-1230"> get = new Get(ROW);</span> |
| <span class="source-line-no">1231</span><span id="line-1231"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1232</span><span id="line-1232"> get.readAllVersions();</span> |
| <span class="source-line-no">1233</span><span id="line-1233"> result = ht.get(get);</span> |
| <span class="source-line-no">1234</span><span id="line-1234"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1235</span><span id="line-1235"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[7],</span> |
| <span class="source-line-no">1236</span><span id="line-1236"> STAMPS[8] },</span> |
| <span class="source-line-no">1237</span><span id="line-1237"> new byte[][] { VALUES[1], VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[7],</span> |
| <span class="source-line-no">1238</span><span id="line-1238"> VALUES[8] },</span> |
| <span class="source-line-no">1239</span><span id="line-1239"> 0, 7);</span> |
| <span class="source-line-no">1240</span><span id="line-1240"></span> |
| <span class="source-line-no">1241</span><span id="line-1241"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1242</span><span id="line-1242"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1243</span><span id="line-1243"> scan.readAllVersions();</span> |
| <span class="source-line-no">1244</span><span id="line-1244"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1245</span><span id="line-1245"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1246</span><span id="line-1246"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[7],</span> |
| <span class="source-line-no">1247</span><span id="line-1247"> STAMPS[8] },</span> |
| <span class="source-line-no">1248</span><span id="line-1248"> new byte[][] { VALUES[1], VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[7],</span> |
| <span class="source-line-no">1249</span><span id="line-1249"> VALUES[8] },</span> |
| <span class="source-line-no">1250</span><span id="line-1250"> 0, 7);</span> |
| <span class="source-line-no">1251</span><span id="line-1251"></span> |
| <span class="source-line-no">1252</span><span id="line-1252"> get = new Get(ROW);</span> |
| <span class="source-line-no">1253</span><span id="line-1253"> get.readAllVersions();</span> |
| <span class="source-line-no">1254</span><span id="line-1254"> result = ht.get(get);</span> |
| <span class="source-line-no">1255</span><span id="line-1255"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1256</span><span id="line-1256"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[7],</span> |
| <span class="source-line-no">1257</span><span id="line-1257"> STAMPS[8] },</span> |
| <span class="source-line-no">1258</span><span id="line-1258"> new byte[][] { VALUES[1], VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[7],</span> |
| <span class="source-line-no">1259</span><span id="line-1259"> VALUES[8] },</span> |
| <span class="source-line-no">1260</span><span id="line-1260"> 0, 7);</span> |
| <span class="source-line-no">1261</span><span id="line-1261"></span> |
| <span class="source-line-no">1262</span><span id="line-1262"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1263</span><span id="line-1263"> scan.readAllVersions();</span> |
| <span class="source-line-no">1264</span><span id="line-1264"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1265</span><span id="line-1265"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1266</span><span id="line-1266"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[7],</span> |
| <span class="source-line-no">1267</span><span id="line-1267"> STAMPS[8] },</span> |
| <span class="source-line-no">1268</span><span id="line-1268"> new byte[][] { VALUES[1], VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[7],</span> |
| <span class="source-line-no">1269</span><span id="line-1269"> VALUES[8] },</span> |
| <span class="source-line-no">1270</span><span id="line-1270"> 0, 7);</span> |
| <span class="source-line-no">1271</span><span id="line-1271"></span> |
| <span class="source-line-no">1272</span><span id="line-1272"> // Verify we can get each one properly</span> |
| <span class="source-line-no">1273</span><span id="line-1273"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1274</span><span id="line-1274"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1275</span><span id="line-1275"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1276</span><span id="line-1276"> getVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[7], VALUES[7]);</span> |
| <span class="source-line-no">1277</span><span id="line-1277"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1278</span><span id="line-1278"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1279</span><span id="line-1279"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1280</span><span id="line-1280"> scanVersionAndVerify(ht, ROW, FAMILY, QUALIFIER, STAMPS[7], VALUES[7]);</span> |
| <span class="source-line-no">1281</span><span id="line-1281"></span> |
| <span class="source-line-no">1282</span><span id="line-1282"> // Verify we don't accidentally get others</span> |
| <span class="source-line-no">1283</span><span id="line-1283"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[0]);</span> |
| <span class="source-line-no">1284</span><span id="line-1284"> getVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[9]);</span> |
| <span class="source-line-no">1285</span><span id="line-1285"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[0]);</span> |
| <span class="source-line-no">1286</span><span id="line-1286"> scanVersionAndVerifyMissing(ht, ROW, FAMILY, QUALIFIER, STAMPS[9]);</span> |
| <span class="source-line-no">1287</span><span id="line-1287"></span> |
| <span class="source-line-no">1288</span><span id="line-1288"> // Ensure maxVersions of table is respected</span> |
| <span class="source-line-no">1289</span><span id="line-1289"></span> |
| <span class="source-line-no">1290</span><span id="line-1290"> TEST_UTIL.flush();</span> |
| <span class="source-line-no">1291</span><span id="line-1291"></span> |
| <span class="source-line-no">1292</span><span id="line-1292"> // Insert 4 more versions of same column and a dupe</span> |
| <span class="source-line-no">1293</span><span id="line-1293"> put = new Put(ROW);</span> |
| <span class="source-line-no">1294</span><span id="line-1294"> put.addColumn(FAMILY, QUALIFIER, STAMPS[9], VALUES[9]);</span> |
| <span class="source-line-no">1295</span><span id="line-1295"> put.addColumn(FAMILY, QUALIFIER, STAMPS[11], VALUES[11]);</span> |
| <span class="source-line-no">1296</span><span id="line-1296"> put.addColumn(FAMILY, QUALIFIER, STAMPS[13], VALUES[13]);</span> |
| <span class="source-line-no">1297</span><span id="line-1297"> put.addColumn(FAMILY, QUALIFIER, STAMPS[15], VALUES[15]);</span> |
| <span class="source-line-no">1298</span><span id="line-1298"> ht.put(put);</span> |
| <span class="source-line-no">1299</span><span id="line-1299"></span> |
| <span class="source-line-no">1300</span><span id="line-1300"> get = new Get(ROW);</span> |
| <span class="source-line-no">1301</span><span id="line-1301"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1302</span><span id="line-1302"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1303</span><span id="line-1303"> result = ht.get(get);</span> |
| <span class="source-line-no">1304</span><span id="line-1304"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1305</span><span id="line-1305"> new long[] { STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[7], STAMPS[8], STAMPS[9],</span> |
| <span class="source-line-no">1306</span><span id="line-1306"> STAMPS[11], STAMPS[13], STAMPS[15] },</span> |
| <span class="source-line-no">1307</span><span id="line-1307"> new byte[][] { VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[7], VALUES[8], VALUES[9],</span> |
| <span class="source-line-no">1308</span><span id="line-1308"> VALUES[11], VALUES[13], VALUES[15] },</span> |
| <span class="source-line-no">1309</span><span id="line-1309"> 0, 9);</span> |
| <span class="source-line-no">1310</span><span id="line-1310"></span> |
| <span class="source-line-no">1311</span><span id="line-1311"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1312</span><span id="line-1312"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1313</span><span id="line-1313"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1314</span><span id="line-1314"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1315</span><span id="line-1315"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1316</span><span id="line-1316"> new long[] { STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[7], STAMPS[8], STAMPS[9],</span> |
| <span class="source-line-no">1317</span><span id="line-1317"> STAMPS[11], STAMPS[13], STAMPS[15] },</span> |
| <span class="source-line-no">1318</span><span id="line-1318"> new byte[][] { VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[7], VALUES[8], VALUES[9],</span> |
| <span class="source-line-no">1319</span><span id="line-1319"> VALUES[11], VALUES[13], VALUES[15] },</span> |
| <span class="source-line-no">1320</span><span id="line-1320"> 0, 9);</span> |
| <span class="source-line-no">1321</span><span id="line-1321"></span> |
| <span class="source-line-no">1322</span><span id="line-1322"> // Delete a version in the memstore and a version in a storefile</span> |
| <span class="source-line-no">1323</span><span id="line-1323"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1324</span><span id="line-1324"> delete.addColumn(FAMILY, QUALIFIER, STAMPS[11]);</span> |
| <span class="source-line-no">1325</span><span id="line-1325"> delete.addColumn(FAMILY, QUALIFIER, STAMPS[7]);</span> |
| <span class="source-line-no">1326</span><span id="line-1326"> ht.delete(delete);</span> |
| <span class="source-line-no">1327</span><span id="line-1327"></span> |
| <span class="source-line-no">1328</span><span id="line-1328"> // Test that it's gone</span> |
| <span class="source-line-no">1329</span><span id="line-1329"> get = new Get(ROW);</span> |
| <span class="source-line-no">1330</span><span id="line-1330"> get.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1331</span><span id="line-1331"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1332</span><span id="line-1332"> result = ht.get(get);</span> |
| <span class="source-line-no">1333</span><span id="line-1333"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1334</span><span id="line-1334"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[8],</span> |
| <span class="source-line-no">1335</span><span id="line-1335"> STAMPS[9], STAMPS[13], STAMPS[15] },</span> |
| <span class="source-line-no">1336</span><span id="line-1336"> new byte[][] { VALUES[1], VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[8],</span> |
| <span class="source-line-no">1337</span><span id="line-1337"> VALUES[9], VALUES[13], VALUES[15] },</span> |
| <span class="source-line-no">1338</span><span id="line-1338"> 0, 9);</span> |
| <span class="source-line-no">1339</span><span id="line-1339"></span> |
| <span class="source-line-no">1340</span><span id="line-1340"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1341</span><span id="line-1341"> scan.addColumn(FAMILY, QUALIFIER);</span> |
| <span class="source-line-no">1342</span><span id="line-1342"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1343</span><span id="line-1343"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1344</span><span id="line-1344"> assertNResult(result, ROW, FAMILY, QUALIFIER,</span> |
| <span class="source-line-no">1345</span><span id="line-1345"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6], STAMPS[8],</span> |
| <span class="source-line-no">1346</span><span id="line-1346"> STAMPS[9], STAMPS[13], STAMPS[15] },</span> |
| <span class="source-line-no">1347</span><span id="line-1347"> new byte[][] { VALUES[1], VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6], VALUES[8],</span> |
| <span class="source-line-no">1348</span><span id="line-1348"> VALUES[9], VALUES[13], VALUES[15] },</span> |
| <span class="source-line-no">1349</span><span id="line-1349"> 0, 9);</span> |
| <span class="source-line-no">1350</span><span id="line-1350"> }</span> |
| <span class="source-line-no">1351</span><span id="line-1351"> }</span> |
| <span class="source-line-no">1352</span><span id="line-1352"></span> |
| <span class="source-line-no">1353</span><span id="line-1353"> @Test</span> |
| <span class="source-line-no">1354</span><span id="line-1354"> @SuppressWarnings("checkstyle:MethodLength")</span> |
| <span class="source-line-no">1355</span><span id="line-1355"> public void testVersionLimits() throws Exception {</span> |
| <span class="source-line-no">1356</span><span id="line-1356"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1357</span><span id="line-1357"> byte[][] FAMILIES = makeNAscii(FAMILY, 3);</span> |
| <span class="source-line-no">1358</span><span id="line-1358"> int[] LIMITS = { 1, 3, 5 };</span> |
| <span class="source-line-no">1359</span><span id="line-1359"> long[] STAMPS = makeStamps(10);</span> |
| <span class="source-line-no">1360</span><span id="line-1360"> byte[][] VALUES = makeNAscii(VALUE, 10);</span> |
| <span class="source-line-no">1361</span><span id="line-1361"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILIES, LIMITS)) {</span> |
| <span class="source-line-no">1362</span><span id="line-1362"></span> |
| <span class="source-line-no">1363</span><span id="line-1363"> // Insert limit + 1 on each family</span> |
| <span class="source-line-no">1364</span><span id="line-1364"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1365</span><span id="line-1365"> put.addColumn(FAMILIES[0], QUALIFIER, STAMPS[0], VALUES[0]);</span> |
| <span class="source-line-no">1366</span><span id="line-1366"> put.addColumn(FAMILIES[0], QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1367</span><span id="line-1367"> put.addColumn(FAMILIES[1], QUALIFIER, STAMPS[0], VALUES[0]);</span> |
| <span class="source-line-no">1368</span><span id="line-1368"> put.addColumn(FAMILIES[1], QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1369</span><span id="line-1369"> put.addColumn(FAMILIES[1], QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1370</span><span id="line-1370"> put.addColumn(FAMILIES[1], QUALIFIER, STAMPS[3], VALUES[3]);</span> |
| <span class="source-line-no">1371</span><span id="line-1371"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[0], VALUES[0]);</span> |
| <span class="source-line-no">1372</span><span id="line-1372"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[1], VALUES[1]);</span> |
| <span class="source-line-no">1373</span><span id="line-1373"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[2], VALUES[2]);</span> |
| <span class="source-line-no">1374</span><span id="line-1374"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[3], VALUES[3]);</span> |
| <span class="source-line-no">1375</span><span id="line-1375"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[4], VALUES[4]);</span> |
| <span class="source-line-no">1376</span><span id="line-1376"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[5], VALUES[5]);</span> |
| <span class="source-line-no">1377</span><span id="line-1377"> put.addColumn(FAMILIES[2], QUALIFIER, STAMPS[6], VALUES[6]);</span> |
| <span class="source-line-no">1378</span><span id="line-1378"> ht.put(put);</span> |
| <span class="source-line-no">1379</span><span id="line-1379"></span> |
| <span class="source-line-no">1380</span><span id="line-1380"> // Verify we only get the right number out of each</span> |
| <span class="source-line-no">1381</span><span id="line-1381"></span> |
| <span class="source-line-no">1382</span><span id="line-1382"> // Family0</span> |
| <span class="source-line-no">1383</span><span id="line-1383"></span> |
| <span class="source-line-no">1384</span><span id="line-1384"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1385</span><span id="line-1385"> get.addColumn(FAMILIES[0], QUALIFIER);</span> |
| <span class="source-line-no">1386</span><span id="line-1386"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1387</span><span id="line-1387"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1388</span><span id="line-1388"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { STAMPS[1] },</span> |
| <span class="source-line-no">1389</span><span id="line-1389"> new byte[][] { VALUES[1] }, 0, 0);</span> |
| <span class="source-line-no">1390</span><span id="line-1390"></span> |
| <span class="source-line-no">1391</span><span id="line-1391"> get = new Get(ROW);</span> |
| <span class="source-line-no">1392</span><span id="line-1392"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1393</span><span id="line-1393"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1394</span><span id="line-1394"> result = ht.get(get);</span> |
| <span class="source-line-no">1395</span><span id="line-1395"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { STAMPS[1] },</span> |
| <span class="source-line-no">1396</span><span id="line-1396"> new byte[][] { VALUES[1] }, 0, 0);</span> |
| <span class="source-line-no">1397</span><span id="line-1397"></span> |
| <span class="source-line-no">1398</span><span id="line-1398"> Scan scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1399</span><span id="line-1399"> scan.addColumn(FAMILIES[0], QUALIFIER);</span> |
| <span class="source-line-no">1400</span><span id="line-1400"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1401</span><span id="line-1401"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1402</span><span id="line-1402"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { STAMPS[1] },</span> |
| <span class="source-line-no">1403</span><span id="line-1403"> new byte[][] { VALUES[1] }, 0, 0);</span> |
| <span class="source-line-no">1404</span><span id="line-1404"></span> |
| <span class="source-line-no">1405</span><span id="line-1405"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1406</span><span id="line-1406"> scan.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1407</span><span id="line-1407"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1408</span><span id="line-1408"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1409</span><span id="line-1409"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { STAMPS[1] },</span> |
| <span class="source-line-no">1410</span><span id="line-1410"> new byte[][] { VALUES[1] }, 0, 0);</span> |
| <span class="source-line-no">1411</span><span id="line-1411"></span> |
| <span class="source-line-no">1412</span><span id="line-1412"> // Family1</span> |
| <span class="source-line-no">1413</span><span id="line-1413"></span> |
| <span class="source-line-no">1414</span><span id="line-1414"> get = new Get(ROW);</span> |
| <span class="source-line-no">1415</span><span id="line-1415"> get.addColumn(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1416</span><span id="line-1416"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1417</span><span id="line-1417"> result = ht.get(get);</span> |
| <span class="source-line-no">1418</span><span id="line-1418"> assertNResult(result, ROW, FAMILIES[1], QUALIFIER,</span> |
| <span class="source-line-no">1419</span><span id="line-1419"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3] },</span> |
| <span class="source-line-no">1420</span><span id="line-1420"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1421</span><span id="line-1421"></span> |
| <span class="source-line-no">1422</span><span id="line-1422"> get = new Get(ROW);</span> |
| <span class="source-line-no">1423</span><span id="line-1423"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1424</span><span id="line-1424"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1425</span><span id="line-1425"> result = ht.get(get);</span> |
| <span class="source-line-no">1426</span><span id="line-1426"> assertNResult(result, ROW, FAMILIES[1], QUALIFIER,</span> |
| <span class="source-line-no">1427</span><span id="line-1427"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3] },</span> |
| <span class="source-line-no">1428</span><span id="line-1428"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1429</span><span id="line-1429"></span> |
| <span class="source-line-no">1430</span><span id="line-1430"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1431</span><span id="line-1431"> scan.addColumn(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1432</span><span id="line-1432"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1433</span><span id="line-1433"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1434</span><span id="line-1434"> assertNResult(result, ROW, FAMILIES[1], QUALIFIER,</span> |
| <span class="source-line-no">1435</span><span id="line-1435"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3] },</span> |
| <span class="source-line-no">1436</span><span id="line-1436"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1437</span><span id="line-1437"></span> |
| <span class="source-line-no">1438</span><span id="line-1438"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1439</span><span id="line-1439"> scan.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1440</span><span id="line-1440"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1441</span><span id="line-1441"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1442</span><span id="line-1442"> assertNResult(result, ROW, FAMILIES[1], QUALIFIER,</span> |
| <span class="source-line-no">1443</span><span id="line-1443"> new long[] { STAMPS[1], STAMPS[2], STAMPS[3] },</span> |
| <span class="source-line-no">1444</span><span id="line-1444"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1445</span><span id="line-1445"></span> |
| <span class="source-line-no">1446</span><span id="line-1446"> // Family2</span> |
| <span class="source-line-no">1447</span><span id="line-1447"></span> |
| <span class="source-line-no">1448</span><span id="line-1448"> get = new Get(ROW);</span> |
| <span class="source-line-no">1449</span><span id="line-1449"> get.addColumn(FAMILIES[2], QUALIFIER);</span> |
| <span class="source-line-no">1450</span><span id="line-1450"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1451</span><span id="line-1451"> result = ht.get(get);</span> |
| <span class="source-line-no">1452</span><span id="line-1452"> assertNResult(result, ROW, FAMILIES[2], QUALIFIER,</span> |
| <span class="source-line-no">1453</span><span id="line-1453"> new long[] { STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6] },</span> |
| <span class="source-line-no">1454</span><span id="line-1454"> new byte[][] { VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6] }, 0, 4);</span> |
| <span class="source-line-no">1455</span><span id="line-1455"></span> |
| <span class="source-line-no">1456</span><span id="line-1456"> get = new Get(ROW);</span> |
| <span class="source-line-no">1457</span><span id="line-1457"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1458</span><span id="line-1458"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1459</span><span id="line-1459"> result = ht.get(get);</span> |
| <span class="source-line-no">1460</span><span id="line-1460"> assertNResult(result, ROW, FAMILIES[2], QUALIFIER,</span> |
| <span class="source-line-no">1461</span><span id="line-1461"> new long[] { STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6] },</span> |
| <span class="source-line-no">1462</span><span id="line-1462"> new byte[][] { VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6] }, 0, 4);</span> |
| <span class="source-line-no">1463</span><span id="line-1463"></span> |
| <span class="source-line-no">1464</span><span id="line-1464"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1465</span><span id="line-1465"> scan.addColumn(FAMILIES[2], QUALIFIER);</span> |
| <span class="source-line-no">1466</span><span id="line-1466"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1467</span><span id="line-1467"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1468</span><span id="line-1468"> assertNResult(result, ROW, FAMILIES[2], QUALIFIER,</span> |
| <span class="source-line-no">1469</span><span id="line-1469"> new long[] { STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6] },</span> |
| <span class="source-line-no">1470</span><span id="line-1470"> new byte[][] { VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6] }, 0, 4);</span> |
| <span class="source-line-no">1471</span><span id="line-1471"></span> |
| <span class="source-line-no">1472</span><span id="line-1472"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1473</span><span id="line-1473"> scan.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1474</span><span id="line-1474"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1475</span><span id="line-1475"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1476</span><span id="line-1476"> assertNResult(result, ROW, FAMILIES[2], QUALIFIER,</span> |
| <span class="source-line-no">1477</span><span id="line-1477"> new long[] { STAMPS[2], STAMPS[3], STAMPS[4], STAMPS[5], STAMPS[6] },</span> |
| <span class="source-line-no">1478</span><span id="line-1478"> new byte[][] { VALUES[2], VALUES[3], VALUES[4], VALUES[5], VALUES[6] }, 0, 4);</span> |
| <span class="source-line-no">1479</span><span id="line-1479"></span> |
| <span class="source-line-no">1480</span><span id="line-1480"> // Try all families</span> |
| <span class="source-line-no">1481</span><span id="line-1481"></span> |
| <span class="source-line-no">1482</span><span id="line-1482"> get = new Get(ROW);</span> |
| <span class="source-line-no">1483</span><span id="line-1483"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1484</span><span id="line-1484"> result = ht.get(get);</span> |
| <span class="source-line-no">1485</span><span id="line-1485"> assertEquals("Expected 9 keys but received " + result.size(), 9, result.size());</span> |
| <span class="source-line-no">1486</span><span id="line-1486"></span> |
| <span class="source-line-no">1487</span><span id="line-1487"> get = new Get(ROW);</span> |
| <span class="source-line-no">1488</span><span id="line-1488"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1489</span><span id="line-1489"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1490</span><span id="line-1490"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1491</span><span id="line-1491"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1492</span><span id="line-1492"> result = ht.get(get);</span> |
| <span class="source-line-no">1493</span><span id="line-1493"> assertEquals("Expected 9 keys but received " + result.size(), 9, result.size());</span> |
| <span class="source-line-no">1494</span><span id="line-1494"></span> |
| <span class="source-line-no">1495</span><span id="line-1495"> get = new Get(ROW);</span> |
| <span class="source-line-no">1496</span><span id="line-1496"> get.addColumn(FAMILIES[0], QUALIFIER);</span> |
| <span class="source-line-no">1497</span><span id="line-1497"> get.addColumn(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1498</span><span id="line-1498"> get.addColumn(FAMILIES[2], QUALIFIER);</span> |
| <span class="source-line-no">1499</span><span id="line-1499"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1500</span><span id="line-1500"> result = ht.get(get);</span> |
| <span class="source-line-no">1501</span><span id="line-1501"> assertEquals("Expected 9 keys but received " + result.size(), 9, result.size());</span> |
| <span class="source-line-no">1502</span><span id="line-1502"></span> |
| <span class="source-line-no">1503</span><span id="line-1503"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1504</span><span id="line-1504"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1505</span><span id="line-1505"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1506</span><span id="line-1506"> assertEquals("Expected 9 keys but received " + result.size(), 9, result.size());</span> |
| <span class="source-line-no">1507</span><span id="line-1507"></span> |
| <span class="source-line-no">1508</span><span id="line-1508"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1509</span><span id="line-1509"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1510</span><span id="line-1510"> scan.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1511</span><span id="line-1511"> scan.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1512</span><span id="line-1512"> scan.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1513</span><span id="line-1513"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1514</span><span id="line-1514"> assertEquals("Expected 9 keys but received " + result.size(), 9, result.size());</span> |
| <span class="source-line-no">1515</span><span id="line-1515"></span> |
| <span class="source-line-no">1516</span><span id="line-1516"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1517</span><span id="line-1517"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1518</span><span id="line-1518"> scan.addColumn(FAMILIES[0], QUALIFIER);</span> |
| <span class="source-line-no">1519</span><span id="line-1519"> scan.addColumn(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1520</span><span id="line-1520"> scan.addColumn(FAMILIES[2], QUALIFIER);</span> |
| <span class="source-line-no">1521</span><span id="line-1521"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1522</span><span id="line-1522"> assertEquals("Expected 9 keys but received " + result.size(), 9, result.size());</span> |
| <span class="source-line-no">1523</span><span id="line-1523"> }</span> |
| <span class="source-line-no">1524</span><span id="line-1524"> }</span> |
| <span class="source-line-no">1525</span><span id="line-1525"></span> |
| <span class="source-line-no">1526</span><span id="line-1526"> @Test</span> |
| <span class="source-line-no">1527</span><span id="line-1527"> public void testDeleteFamilyVersion() throws Exception {</span> |
| <span class="source-line-no">1528</span><span id="line-1528"> try (Admin admin = TEST_UTIL.getAdmin()) {</span> |
| <span class="source-line-no">1529</span><span id="line-1529"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1530</span><span id="line-1530"></span> |
| <span class="source-line-no">1531</span><span id="line-1531"> byte[][] QUALIFIERS = makeNAscii(QUALIFIER, 1);</span> |
| <span class="source-line-no">1532</span><span id="line-1532"> byte[][] VALUES = makeN(VALUE, 5);</span> |
| <span class="source-line-no">1533</span><span id="line-1533"> long[] ts = { 1000, 2000, 3000, 4000, 5000 };</span> |
| <span class="source-line-no">1534</span><span id="line-1534"></span> |
| <span class="source-line-no">1535</span><span id="line-1535"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILY, 5)) {</span> |
| <span class="source-line-no">1536</span><span id="line-1536"></span> |
| <span class="source-line-no">1537</span><span id="line-1537"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1538</span><span id="line-1538"> for (int q = 0; q < 1; q++) {</span> |
| <span class="source-line-no">1539</span><span id="line-1539"> for (int t = 0; t < 5; t++) {</span> |
| <span class="source-line-no">1540</span><span id="line-1540"> put.addColumn(FAMILY, QUALIFIERS[q], ts[t], VALUES[t]);</span> |
| <span class="source-line-no">1541</span><span id="line-1541"> }</span> |
| <span class="source-line-no">1542</span><span id="line-1542"> }</span> |
| <span class="source-line-no">1543</span><span id="line-1543"> ht.put(put);</span> |
| <span class="source-line-no">1544</span><span id="line-1544"> admin.flush(tableName);</span> |
| <span class="source-line-no">1545</span><span id="line-1545"></span> |
| <span class="source-line-no">1546</span><span id="line-1546"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1547</span><span id="line-1547"> delete.addFamilyVersion(FAMILY, ts[1]); // delete version '2000'</span> |
| <span class="source-line-no">1548</span><span id="line-1548"> delete.addFamilyVersion(FAMILY, ts[3]); // delete version '4000'</span> |
| <span class="source-line-no">1549</span><span id="line-1549"> ht.delete(delete);</span> |
| <span class="source-line-no">1550</span><span id="line-1550"> admin.flush(tableName);</span> |
| <span class="source-line-no">1551</span><span id="line-1551"></span> |
| <span class="source-line-no">1552</span><span id="line-1552"> for (int i = 0; i < 1; i++) {</span> |
| <span class="source-line-no">1553</span><span id="line-1553"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1554</span><span id="line-1554"> get.addColumn(FAMILY, QUALIFIERS[i]);</span> |
| <span class="source-line-no">1555</span><span id="line-1555"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1556</span><span id="line-1556"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1557</span><span id="line-1557"> // verify version '1000'/'3000'/'5000' remains for all columns</span> |
| <span class="source-line-no">1558</span><span id="line-1558"> assertNResult(result, ROW, FAMILY, QUALIFIERS[i], new long[] { ts[0], ts[2], ts[4] },</span> |
| <span class="source-line-no">1559</span><span id="line-1559"> new byte[][] { VALUES[0], VALUES[2], VALUES[4] }, 0, 2);</span> |
| <span class="source-line-no">1560</span><span id="line-1560"> }</span> |
| <span class="source-line-no">1561</span><span id="line-1561"> }</span> |
| <span class="source-line-no">1562</span><span id="line-1562"> }</span> |
| <span class="source-line-no">1563</span><span id="line-1563"> }</span> |
| <span class="source-line-no">1564</span><span id="line-1564"></span> |
| <span class="source-line-no">1565</span><span id="line-1565"> @Test</span> |
| <span class="source-line-no">1566</span><span id="line-1566"> public void testDeleteFamilyVersionWithOtherDeletes() throws Exception {</span> |
| <span class="source-line-no">1567</span><span id="line-1567"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1568</span><span id="line-1568"></span> |
| <span class="source-line-no">1569</span><span id="line-1569"> byte[][] QUALIFIERS = makeNAscii(QUALIFIER, 5);</span> |
| <span class="source-line-no">1570</span><span id="line-1570"> byte[][] VALUES = makeN(VALUE, 5);</span> |
| <span class="source-line-no">1571</span><span id="line-1571"> long[] ts = { 1000, 2000, 3000, 4000, 5000 };</span> |
| <span class="source-line-no">1572</span><span id="line-1572"></span> |
| <span class="source-line-no">1573</span><span id="line-1573"> try (Admin admin = TEST_UTIL.getAdmin();</span> |
| <span class="source-line-no">1574</span><span id="line-1574"> Table ht = TEST_UTIL.createTable(tableName, FAMILY, 5)) {</span> |
| <span class="source-line-no">1575</span><span id="line-1575"> Put put;</span> |
| <span class="source-line-no">1576</span><span id="line-1576"> Result result;</span> |
| <span class="source-line-no">1577</span><span id="line-1577"> Get get;</span> |
| <span class="source-line-no">1578</span><span id="line-1578"> Delete delete = null;</span> |
| <span class="source-line-no">1579</span><span id="line-1579"></span> |
| <span class="source-line-no">1580</span><span id="line-1580"> // 1. put on ROW</span> |
| <span class="source-line-no">1581</span><span id="line-1581"> put = new Put(ROW);</span> |
| <span class="source-line-no">1582</span><span id="line-1582"> for (int q = 0; q < 5; q++) {</span> |
| <span class="source-line-no">1583</span><span id="line-1583"> for (int t = 0; t < 5; t++) {</span> |
| <span class="source-line-no">1584</span><span id="line-1584"> put.addColumn(FAMILY, QUALIFIERS[q], ts[t], VALUES[t]);</span> |
| <span class="source-line-no">1585</span><span id="line-1585"> }</span> |
| <span class="source-line-no">1586</span><span id="line-1586"> }</span> |
| <span class="source-line-no">1587</span><span id="line-1587"> ht.put(put);</span> |
| <span class="source-line-no">1588</span><span id="line-1588"> admin.flush(tableName);</span> |
| <span class="source-line-no">1589</span><span id="line-1589"></span> |
| <span class="source-line-no">1590</span><span id="line-1590"> // 2. put on ROWS[0]</span> |
| <span class="source-line-no">1591</span><span id="line-1591"> byte[] ROW2 = Bytes.toBytes("myRowForTest");</span> |
| <span class="source-line-no">1592</span><span id="line-1592"> put = new Put(ROW2);</span> |
| <span class="source-line-no">1593</span><span id="line-1593"> for (int q = 0; q < 5; q++) {</span> |
| <span class="source-line-no">1594</span><span id="line-1594"> for (int t = 0; t < 5; t++) {</span> |
| <span class="source-line-no">1595</span><span id="line-1595"> put.addColumn(FAMILY, QUALIFIERS[q], ts[t], VALUES[t]);</span> |
| <span class="source-line-no">1596</span><span id="line-1596"> }</span> |
| <span class="source-line-no">1597</span><span id="line-1597"> }</span> |
| <span class="source-line-no">1598</span><span id="line-1598"> ht.put(put);</span> |
| <span class="source-line-no">1599</span><span id="line-1599"> admin.flush(tableName);</span> |
| <span class="source-line-no">1600</span><span id="line-1600"></span> |
| <span class="source-line-no">1601</span><span id="line-1601"> // 3. delete on ROW</span> |
| <span class="source-line-no">1602</span><span id="line-1602"> delete = new Delete(ROW);</span> |
| <span class="source-line-no">1603</span><span id="line-1603"> // delete version <= 2000 of all columns</span> |
| <span class="source-line-no">1604</span><span id="line-1604"> // note: addFamily must be the first since it will mask</span> |
| <span class="source-line-no">1605</span><span id="line-1605"> // the subsequent other type deletes!</span> |
| <span class="source-line-no">1606</span><span id="line-1606"> delete.addFamily(FAMILY, ts[1]);</span> |
| <span class="source-line-no">1607</span><span id="line-1607"> // delete version '4000' of all columns</span> |
| <span class="source-line-no">1608</span><span id="line-1608"> delete.addFamilyVersion(FAMILY, ts[3]);</span> |
| <span class="source-line-no">1609</span><span id="line-1609"> // delete version <= 3000 of column 0</span> |
| <span class="source-line-no">1610</span><span id="line-1610"> delete.addColumns(FAMILY, QUALIFIERS[0], ts[2]);</span> |
| <span class="source-line-no">1611</span><span id="line-1611"> // delete version <= 5000 of column 2</span> |
| <span class="source-line-no">1612</span><span id="line-1612"> delete.addColumns(FAMILY, QUALIFIERS[2], ts[4]);</span> |
| <span class="source-line-no">1613</span><span id="line-1613"> // delete version 5000 of column 4</span> |
| <span class="source-line-no">1614</span><span id="line-1614"> delete.addColumn(FAMILY, QUALIFIERS[4], ts[4]);</span> |
| <span class="source-line-no">1615</span><span id="line-1615"> ht.delete(delete);</span> |
| <span class="source-line-no">1616</span><span id="line-1616"> admin.flush(tableName);</span> |
| <span class="source-line-no">1617</span><span id="line-1617"></span> |
| <span class="source-line-no">1618</span><span id="line-1618"> // 4. delete on ROWS[0]</span> |
| <span class="source-line-no">1619</span><span id="line-1619"> delete = new Delete(ROW2);</span> |
| <span class="source-line-no">1620</span><span id="line-1620"> delete.addFamilyVersion(FAMILY, ts[1]); // delete version '2000'</span> |
| <span class="source-line-no">1621</span><span id="line-1621"> delete.addFamilyVersion(FAMILY, ts[3]); // delete version '4000'</span> |
| <span class="source-line-no">1622</span><span id="line-1622"> ht.delete(delete);</span> |
| <span class="source-line-no">1623</span><span id="line-1623"> admin.flush(tableName);</span> |
| <span class="source-line-no">1624</span><span id="line-1624"></span> |
| <span class="source-line-no">1625</span><span id="line-1625"> // 5. check ROW</span> |
| <span class="source-line-no">1626</span><span id="line-1626"> get = new Get(ROW);</span> |
| <span class="source-line-no">1627</span><span id="line-1627"> get.addColumn(FAMILY, QUALIFIERS[0]);</span> |
| <span class="source-line-no">1628</span><span id="line-1628"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1629</span><span id="line-1629"> result = ht.get(get);</span> |
| <span class="source-line-no">1630</span><span id="line-1630"> assertNResult(result, ROW, FAMILY, QUALIFIERS[0], new long[] { ts[4] },</span> |
| <span class="source-line-no">1631</span><span id="line-1631"> new byte[][] { VALUES[4] }, 0, 0);</span> |
| <span class="source-line-no">1632</span><span id="line-1632"></span> |
| <span class="source-line-no">1633</span><span id="line-1633"> get = new Get(ROW);</span> |
| <span class="source-line-no">1634</span><span id="line-1634"> get.addColumn(FAMILY, QUALIFIERS[1]);</span> |
| <span class="source-line-no">1635</span><span id="line-1635"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1636</span><span id="line-1636"> result = ht.get(get);</span> |
| <span class="source-line-no">1637</span><span id="line-1637"> assertNResult(result, ROW, FAMILY, QUALIFIERS[1], new long[] { ts[2], ts[4] },</span> |
| <span class="source-line-no">1638</span><span id="line-1638"> new byte[][] { VALUES[2], VALUES[4] }, 0, 1);</span> |
| <span class="source-line-no">1639</span><span id="line-1639"></span> |
| <span class="source-line-no">1640</span><span id="line-1640"> get = new Get(ROW);</span> |
| <span class="source-line-no">1641</span><span id="line-1641"> get.addColumn(FAMILY, QUALIFIERS[2]);</span> |
| <span class="source-line-no">1642</span><span id="line-1642"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1643</span><span id="line-1643"> result = ht.get(get);</span> |
| <span class="source-line-no">1644</span><span id="line-1644"> assertEquals(0, result.size());</span> |
| <span class="source-line-no">1645</span><span id="line-1645"></span> |
| <span class="source-line-no">1646</span><span id="line-1646"> get = new Get(ROW);</span> |
| <span class="source-line-no">1647</span><span id="line-1647"> get.addColumn(FAMILY, QUALIFIERS[3]);</span> |
| <span class="source-line-no">1648</span><span id="line-1648"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1649</span><span id="line-1649"> result = ht.get(get);</span> |
| <span class="source-line-no">1650</span><span id="line-1650"> assertNResult(result, ROW, FAMILY, QUALIFIERS[3], new long[] { ts[2], ts[4] },</span> |
| <span class="source-line-no">1651</span><span id="line-1651"> new byte[][] { VALUES[2], VALUES[4] }, 0, 1);</span> |
| <span class="source-line-no">1652</span><span id="line-1652"></span> |
| <span class="source-line-no">1653</span><span id="line-1653"> get = new Get(ROW);</span> |
| <span class="source-line-no">1654</span><span id="line-1654"> get.addColumn(FAMILY, QUALIFIERS[4]);</span> |
| <span class="source-line-no">1655</span><span id="line-1655"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1656</span><span id="line-1656"> result = ht.get(get);</span> |
| <span class="source-line-no">1657</span><span id="line-1657"> assertNResult(result, ROW, FAMILY, QUALIFIERS[4], new long[] { ts[2] },</span> |
| <span class="source-line-no">1658</span><span id="line-1658"> new byte[][] { VALUES[2] }, 0, 0);</span> |
| <span class="source-line-no">1659</span><span id="line-1659"></span> |
| <span class="source-line-no">1660</span><span id="line-1660"> // 6. check ROWS[0]</span> |
| <span class="source-line-no">1661</span><span id="line-1661"> for (int i = 0; i < 5; i++) {</span> |
| <span class="source-line-no">1662</span><span id="line-1662"> get = new Get(ROW2);</span> |
| <span class="source-line-no">1663</span><span id="line-1663"> get.addColumn(FAMILY, QUALIFIERS[i]);</span> |
| <span class="source-line-no">1664</span><span id="line-1664"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1665</span><span id="line-1665"> result = ht.get(get);</span> |
| <span class="source-line-no">1666</span><span id="line-1666"> // verify version '1000'/'3000'/'5000' remains for all columns</span> |
| <span class="source-line-no">1667</span><span id="line-1667"> assertNResult(result, ROW2, FAMILY, QUALIFIERS[i], new long[] { ts[0], ts[2], ts[4] },</span> |
| <span class="source-line-no">1668</span><span id="line-1668"> new byte[][] { VALUES[0], VALUES[2], VALUES[4] }, 0, 2);</span> |
| <span class="source-line-no">1669</span><span id="line-1669"> }</span> |
| <span class="source-line-no">1670</span><span id="line-1670"> }</span> |
| <span class="source-line-no">1671</span><span id="line-1671"> }</span> |
| <span class="source-line-no">1672</span><span id="line-1672"></span> |
| <span class="source-line-no">1673</span><span id="line-1673"> @Test</span> |
| <span class="source-line-no">1674</span><span id="line-1674"> public void testDeleteWithFailed() throws Exception {</span> |
| <span class="source-line-no">1675</span><span id="line-1675"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1676</span><span id="line-1676"></span> |
| <span class="source-line-no">1677</span><span id="line-1677"> byte[][] FAMILIES = makeNAscii(FAMILY, 3);</span> |
| <span class="source-line-no">1678</span><span id="line-1678"> byte[][] VALUES = makeN(VALUE, 5);</span> |
| <span class="source-line-no">1679</span><span id="line-1679"> long[] ts = { 1000, 2000, 3000, 4000, 5000 };</span> |
| <span class="source-line-no">1680</span><span id="line-1680"></span> |
| <span class="source-line-no">1681</span><span id="line-1681"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILIES, 3)) {</span> |
| <span class="source-line-no">1682</span><span id="line-1682"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1683</span><span id="line-1683"> put.addColumn(FAMILIES[0], QUALIFIER, ts[0], VALUES[0]);</span> |
| <span class="source-line-no">1684</span><span id="line-1684"> ht.put(put);</span> |
| <span class="source-line-no">1685</span><span id="line-1685"></span> |
| <span class="source-line-no">1686</span><span id="line-1686"> // delete wrong family</span> |
| <span class="source-line-no">1687</span><span id="line-1687"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1688</span><span id="line-1688"> delete.addFamily(FAMILIES[1], ts[0]);</span> |
| <span class="source-line-no">1689</span><span id="line-1689"> ht.delete(delete);</span> |
| <span class="source-line-no">1690</span><span id="line-1690"></span> |
| <span class="source-line-no">1691</span><span id="line-1691"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1692</span><span id="line-1692"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1693</span><span id="line-1693"> get.readAllVersions();</span> |
| <span class="source-line-no">1694</span><span id="line-1694"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1695</span><span id="line-1695"> assertTrue(Bytes.equals(result.getValue(FAMILIES[0], QUALIFIER), VALUES[0]));</span> |
| <span class="source-line-no">1696</span><span id="line-1696"> }</span> |
| <span class="source-line-no">1697</span><span id="line-1697"> }</span> |
| <span class="source-line-no">1698</span><span id="line-1698"></span> |
| <span class="source-line-no">1699</span><span id="line-1699"> @Test</span> |
| <span class="source-line-no">1700</span><span id="line-1700"> @SuppressWarnings("checkstyle:MethodLength")</span> |
| <span class="source-line-no">1701</span><span id="line-1701"> public void testDeletes() throws Exception {</span> |
| <span class="source-line-no">1702</span><span id="line-1702"> final TableName tableName = name.getTableName();</span> |
| <span class="source-line-no">1703</span><span id="line-1703"></span> |
| <span class="source-line-no">1704</span><span id="line-1704"> byte[][] ROWS = makeNAscii(ROW, 6);</span> |
| <span class="source-line-no">1705</span><span id="line-1705"> byte[][] FAMILIES = makeNAscii(FAMILY, 3);</span> |
| <span class="source-line-no">1706</span><span id="line-1706"> byte[][] VALUES = makeN(VALUE, 5);</span> |
| <span class="source-line-no">1707</span><span id="line-1707"> long[] ts = { 1000, 2000, 3000, 4000, 5000 };</span> |
| <span class="source-line-no">1708</span><span id="line-1708"></span> |
| <span class="source-line-no">1709</span><span id="line-1709"> try (Table ht = TEST_UTIL.createTable(tableName, FAMILIES, 3)) {</span> |
| <span class="source-line-no">1710</span><span id="line-1710"></span> |
| <span class="source-line-no">1711</span><span id="line-1711"> Put put = new Put(ROW);</span> |
| <span class="source-line-no">1712</span><span id="line-1712"> put.addColumn(FAMILIES[0], QUALIFIER, ts[0], VALUES[0]);</span> |
| <span class="source-line-no">1713</span><span id="line-1713"> put.addColumn(FAMILIES[0], QUALIFIER, ts[1], VALUES[1]);</span> |
| <span class="source-line-no">1714</span><span id="line-1714"> ht.put(put);</span> |
| <span class="source-line-no">1715</span><span id="line-1715"></span> |
| <span class="source-line-no">1716</span><span id="line-1716"> Delete delete = new Delete(ROW);</span> |
| <span class="source-line-no">1717</span><span id="line-1717"> delete.addFamily(FAMILIES[0], ts[0]);</span> |
| <span class="source-line-no">1718</span><span id="line-1718"> ht.delete(delete);</span> |
| <span class="source-line-no">1719</span><span id="line-1719"></span> |
| <span class="source-line-no">1720</span><span id="line-1720"> Get get = new Get(ROW);</span> |
| <span class="source-line-no">1721</span><span id="line-1721"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1722</span><span id="line-1722"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1723</span><span id="line-1723"> Result result = ht.get(get);</span> |
| <span class="source-line-no">1724</span><span id="line-1724"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { ts[1] },</span> |
| <span class="source-line-no">1725</span><span id="line-1725"> new byte[][] { VALUES[1] }, 0, 0);</span> |
| <span class="source-line-no">1726</span><span id="line-1726"></span> |
| <span class="source-line-no">1727</span><span id="line-1727"> Scan scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1728</span><span id="line-1728"> scan.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1729</span><span id="line-1729"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1730</span><span id="line-1730"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1731</span><span id="line-1731"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { ts[1] },</span> |
| <span class="source-line-no">1732</span><span id="line-1732"> new byte[][] { VALUES[1] }, 0, 0);</span> |
| <span class="source-line-no">1733</span><span id="line-1733"></span> |
| <span class="source-line-no">1734</span><span id="line-1734"> // Test delete latest version</span> |
| <span class="source-line-no">1735</span><span id="line-1735"> put = new Put(ROW);</span> |
| <span class="source-line-no">1736</span><span id="line-1736"> put.addColumn(FAMILIES[0], QUALIFIER, ts[4], VALUES[4]);</span> |
| <span class="source-line-no">1737</span><span id="line-1737"> put.addColumn(FAMILIES[0], QUALIFIER, ts[2], VALUES[2]);</span> |
| <span class="source-line-no">1738</span><span id="line-1738"> put.addColumn(FAMILIES[0], QUALIFIER, ts[3], VALUES[3]);</span> |
| <span class="source-line-no">1739</span><span id="line-1739"> put.addColumn(FAMILIES[0], null, ts[4], VALUES[4]);</span> |
| <span class="source-line-no">1740</span><span id="line-1740"> put.addColumn(FAMILIES[0], null, ts[2], VALUES[2]);</span> |
| <span class="source-line-no">1741</span><span id="line-1741"> put.addColumn(FAMILIES[0], null, ts[3], VALUES[3]);</span> |
| <span class="source-line-no">1742</span><span id="line-1742"> ht.put(put);</span> |
| <span class="source-line-no">1743</span><span id="line-1743"></span> |
| <span class="source-line-no">1744</span><span id="line-1744"> delete = new Delete(ROW);</span> |
| <span class="source-line-no">1745</span><span id="line-1745"> delete.addColumn(FAMILIES[0], QUALIFIER); // ts[4]</span> |
| <span class="source-line-no">1746</span><span id="line-1746"> ht.delete(delete);</span> |
| <span class="source-line-no">1747</span><span id="line-1747"></span> |
| <span class="source-line-no">1748</span><span id="line-1748"> get = new Get(ROW);</span> |
| <span class="source-line-no">1749</span><span id="line-1749"> get.addColumn(FAMILIES[0], QUALIFIER);</span> |
| <span class="source-line-no">1750</span><span id="line-1750"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1751</span><span id="line-1751"> result = ht.get(get);</span> |
| <span class="source-line-no">1752</span><span id="line-1752"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { ts[1], ts[2], ts[3] },</span> |
| <span class="source-line-no">1753</span><span id="line-1753"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1754</span><span id="line-1754"></span> |
| <span class="source-line-no">1755</span><span id="line-1755"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1756</span><span id="line-1756"> scan.addColumn(FAMILIES[0], QUALIFIER);</span> |
| <span class="source-line-no">1757</span><span id="line-1757"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1758</span><span id="line-1758"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1759</span><span id="line-1759"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { ts[1], ts[2], ts[3] },</span> |
| <span class="source-line-no">1760</span><span id="line-1760"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1761</span><span id="line-1761"></span> |
| <span class="source-line-no">1762</span><span id="line-1762"> // Test for HBASE-1847</span> |
| <span class="source-line-no">1763</span><span id="line-1763"> delete = new Delete(ROW);</span> |
| <span class="source-line-no">1764</span><span id="line-1764"> delete.addColumn(FAMILIES[0], null);</span> |
| <span class="source-line-no">1765</span><span id="line-1765"> ht.delete(delete);</span> |
| <span class="source-line-no">1766</span><span id="line-1766"></span> |
| <span class="source-line-no">1767</span><span id="line-1767"> // Cleanup null qualifier</span> |
| <span class="source-line-no">1768</span><span id="line-1768"> delete = new Delete(ROW);</span> |
| <span class="source-line-no">1769</span><span id="line-1769"> delete.addColumns(FAMILIES[0], null);</span> |
| <span class="source-line-no">1770</span><span id="line-1770"> ht.delete(delete);</span> |
| <span class="source-line-no">1771</span><span id="line-1771"></span> |
| <span class="source-line-no">1772</span><span id="line-1772"> // Expected client behavior might be that you can re-put deleted values</span> |
| <span class="source-line-no">1773</span><span id="line-1773"> // But alas, this is not to be. We can't put them back in either case.</span> |
| <span class="source-line-no">1774</span><span id="line-1774"></span> |
| <span class="source-line-no">1775</span><span id="line-1775"> put = new Put(ROW);</span> |
| <span class="source-line-no">1776</span><span id="line-1776"> put.addColumn(FAMILIES[0], QUALIFIER, ts[0], VALUES[0]); // 1000</span> |
| <span class="source-line-no">1777</span><span id="line-1777"> put.addColumn(FAMILIES[0], QUALIFIER, ts[4], VALUES[4]); // 5000</span> |
| <span class="source-line-no">1778</span><span id="line-1778"> ht.put(put);</span> |
| <span class="source-line-no">1779</span><span id="line-1779"></span> |
| <span class="source-line-no">1780</span><span id="line-1780"> // It used to be due to the internal implementation of Get, that</span> |
| <span class="source-line-no">1781</span><span id="line-1781"> // the Get() call would return ts[4] UNLIKE the Scan below. With</span> |
| <span class="source-line-no">1782</span><span id="line-1782"> // the switch to using Scan for Get this is no longer the case.</span> |
| <span class="source-line-no">1783</span><span id="line-1783"> get = new Get(ROW);</span> |
| <span class="source-line-no">1784</span><span id="line-1784"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1785</span><span id="line-1785"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1786</span><span id="line-1786"> result = ht.get(get);</span> |
| <span class="source-line-no">1787</span><span id="line-1787"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { ts[1], ts[2], ts[3] },</span> |
| <span class="source-line-no">1788</span><span id="line-1788"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1789</span><span id="line-1789"></span> |
| <span class="source-line-no">1790</span><span id="line-1790"> // The Scanner returns the previous values, the expected-naive-unexpected behavior</span> |
| <span class="source-line-no">1791</span><span id="line-1791"></span> |
| <span class="source-line-no">1792</span><span id="line-1792"> scan = new Scan().withStartRow(ROW);</span> |
| <span class="source-line-no">1793</span><span id="line-1793"> scan.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1794</span><span id="line-1794"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1795</span><span id="line-1795"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1796</span><span id="line-1796"> assertNResult(result, ROW, FAMILIES[0], QUALIFIER, new long[] { ts[1], ts[2], ts[3] },</span> |
| <span class="source-line-no">1797</span><span id="line-1797"> new byte[][] { VALUES[1], VALUES[2], VALUES[3] }, 0, 2);</span> |
| <span class="source-line-no">1798</span><span id="line-1798"></span> |
| <span class="source-line-no">1799</span><span id="line-1799"> // Test deleting an entire family from one row but not the other various ways</span> |
| <span class="source-line-no">1800</span><span id="line-1800"></span> |
| <span class="source-line-no">1801</span><span id="line-1801"> put = new Put(ROWS[0]);</span> |
| <span class="source-line-no">1802</span><span id="line-1802"> put.addColumn(FAMILIES[1], QUALIFIER, ts[0], VALUES[0]);</span> |
| <span class="source-line-no">1803</span><span id="line-1803"> put.addColumn(FAMILIES[1], QUALIFIER, ts[1], VALUES[1]);</span> |
| <span class="source-line-no">1804</span><span id="line-1804"> put.addColumn(FAMILIES[2], QUALIFIER, ts[2], VALUES[2]);</span> |
| <span class="source-line-no">1805</span><span id="line-1805"> put.addColumn(FAMILIES[2], QUALIFIER, ts[3], VALUES[3]);</span> |
| <span class="source-line-no">1806</span><span id="line-1806"> ht.put(put);</span> |
| <span class="source-line-no">1807</span><span id="line-1807"></span> |
| <span class="source-line-no">1808</span><span id="line-1808"> put = new Put(ROWS[1]);</span> |
| <span class="source-line-no">1809</span><span id="line-1809"> put.addColumn(FAMILIES[1], QUALIFIER, ts[0], VALUES[0]);</span> |
| <span class="source-line-no">1810</span><span id="line-1810"> put.addColumn(FAMILIES[1], QUALIFIER, ts[1], VALUES[1]);</span> |
| <span class="source-line-no">1811</span><span id="line-1811"> put.addColumn(FAMILIES[2], QUALIFIER, ts[2], VALUES[2]);</span> |
| <span class="source-line-no">1812</span><span id="line-1812"> put.addColumn(FAMILIES[2], QUALIFIER, ts[3], VALUES[3]);</span> |
| <span class="source-line-no">1813</span><span id="line-1813"> ht.put(put);</span> |
| <span class="source-line-no">1814</span><span id="line-1814"></span> |
| <span class="source-line-no">1815</span><span id="line-1815"> put = new Put(ROWS[2]);</span> |
| <span class="source-line-no">1816</span><span id="line-1816"> put.addColumn(FAMILIES[1], QUALIFIER, ts[0], VALUES[0]);</span> |
| <span class="source-line-no">1817</span><span id="line-1817"> put.addColumn(FAMILIES[1], QUALIFIER, ts[1], VALUES[1]);</span> |
| <span class="source-line-no">1818</span><span id="line-1818"> put.addColumn(FAMILIES[2], QUALIFIER, ts[2], VALUES[2]);</span> |
| <span class="source-line-no">1819</span><span id="line-1819"> put.addColumn(FAMILIES[2], QUALIFIER, ts[3], VALUES[3]);</span> |
| <span class="source-line-no">1820</span><span id="line-1820"> ht.put(put);</span> |
| <span class="source-line-no">1821</span><span id="line-1821"></span> |
| <span class="source-line-no">1822</span><span id="line-1822"> // Assert that above went in.</span> |
| <span class="source-line-no">1823</span><span id="line-1823"> get = new Get(ROWS[2]);</span> |
| <span class="source-line-no">1824</span><span id="line-1824"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1825</span><span id="line-1825"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1826</span><span id="line-1826"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1827</span><span id="line-1827"> result = ht.get(get);</span> |
| <span class="source-line-no">1828</span><span id="line-1828"> assertEquals("Expected 4 key but received " + result.size() + ": " + result, 4,</span> |
| <span class="source-line-no">1829</span><span id="line-1829"> result.size());</span> |
| <span class="source-line-no">1830</span><span id="line-1830"></span> |
| <span class="source-line-no">1831</span><span id="line-1831"> delete = new Delete(ROWS[0]);</span> |
| <span class="source-line-no">1832</span><span id="line-1832"> delete.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1833</span><span id="line-1833"> ht.delete(delete);</span> |
| <span class="source-line-no">1834</span><span id="line-1834"></span> |
| <span class="source-line-no">1835</span><span id="line-1835"> delete = new Delete(ROWS[1]);</span> |
| <span class="source-line-no">1836</span><span id="line-1836"> delete.addColumns(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1837</span><span id="line-1837"> ht.delete(delete);</span> |
| <span class="source-line-no">1838</span><span id="line-1838"></span> |
| <span class="source-line-no">1839</span><span id="line-1839"> delete = new Delete(ROWS[2]);</span> |
| <span class="source-line-no">1840</span><span id="line-1840"> delete.addColumn(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1841</span><span id="line-1841"> delete.addColumn(FAMILIES[1], QUALIFIER);</span> |
| <span class="source-line-no">1842</span><span id="line-1842"> delete.addColumn(FAMILIES[2], QUALIFIER);</span> |
| <span class="source-line-no">1843</span><span id="line-1843"> ht.delete(delete);</span> |
| <span class="source-line-no">1844</span><span id="line-1844"></span> |
| <span class="source-line-no">1845</span><span id="line-1845"> get = new Get(ROWS[0]);</span> |
| <span class="source-line-no">1846</span><span id="line-1846"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1847</span><span id="line-1847"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1848</span><span id="line-1848"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1849</span><span id="line-1849"> result = ht.get(get);</span> |
| <span class="source-line-no">1850</span><span id="line-1850"> assertEquals("Expected 2 keys but received " + result.size(), 2, result.size());</span> |
| <span class="source-line-no">1851</span><span id="line-1851"> assertNResult(result, ROWS[0], FAMILIES[1], QUALIFIER, new long[] { ts[0], ts[1] },</span> |
| <span class="source-line-no">1852</span><span id="line-1852"> new byte[][] { VALUES[0], VALUES[1] }, 0, 1);</span> |
| <span class="source-line-no">1853</span><span id="line-1853"></span> |
| <span class="source-line-no">1854</span><span id="line-1854"> scan = new Scan().withStartRow(ROWS[0]);</span> |
| <span class="source-line-no">1855</span><span id="line-1855"> scan.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1856</span><span id="line-1856"> scan.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1857</span><span id="line-1857"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1858</span><span id="line-1858"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1859</span><span id="line-1859"> assertEquals("Expected 2 keys but received " + result.size(), 2, result.size());</span> |
| <span class="source-line-no">1860</span><span id="line-1860"> assertNResult(result, ROWS[0], FAMILIES[1], QUALIFIER, new long[] { ts[0], ts[1] },</span> |
| <span class="source-line-no">1861</span><span id="line-1861"> new byte[][] { VALUES[0], VALUES[1] }, 0, 1);</span> |
| <span class="source-line-no">1862</span><span id="line-1862"></span> |
| <span class="source-line-no">1863</span><span id="line-1863"> get = new Get(ROWS[1]);</span> |
| <span class="source-line-no">1864</span><span id="line-1864"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1865</span><span id="line-1865"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1866</span><span id="line-1866"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1867</span><span id="line-1867"> result = ht.get(get);</span> |
| <span class="source-line-no">1868</span><span id="line-1868"> assertEquals("Expected 2 keys but received " + result.size(), 2, result.size());</span> |
| <span class="source-line-no">1869</span><span id="line-1869"></span> |
| <span class="source-line-no">1870</span><span id="line-1870"> scan = new Scan().withStartRow(ROWS[1]);</span> |
| <span class="source-line-no">1871</span><span id="line-1871"> scan.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1872</span><span id="line-1872"> scan.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1873</span><span id="line-1873"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1874</span><span id="line-1874"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1875</span><span id="line-1875"> assertEquals("Expected 2 keys but received " + result.size(), 2, result.size());</span> |
| <span class="source-line-no">1876</span><span id="line-1876"></span> |
| <span class="source-line-no">1877</span><span id="line-1877"> get = new Get(ROWS[2]);</span> |
| <span class="source-line-no">1878</span><span id="line-1878"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1879</span><span id="line-1879"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1880</span><span id="line-1880"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1881</span><span id="line-1881"> result = ht.get(get);</span> |
| <span class="source-line-no">1882</span><span id="line-1882"> assertEquals(1, result.size());</span> |
| <span class="source-line-no">1883</span><span id="line-1883"> assertNResult(result, ROWS[2], FAMILIES[2], QUALIFIER, new long[] { ts[2] },</span> |
| <span class="source-line-no">1884</span><span id="line-1884"> new byte[][] { VALUES[2] }, 0, 0);</span> |
| <span class="source-line-no">1885</span><span id="line-1885"></span> |
| <span class="source-line-no">1886</span><span id="line-1886"> scan = new Scan().withStartRow(ROWS[2]);</span> |
| <span class="source-line-no">1887</span><span id="line-1887"> scan.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1888</span><span id="line-1888"> scan.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1889</span><span id="line-1889"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1890</span><span id="line-1890"> result = getSingleScanResult(ht, scan);</span> |
| <span class="source-line-no">1891</span><span id="line-1891"> assertEquals(1, result.size());</span> |
| <span class="source-line-no">1892</span><span id="line-1892"> assertNResult(result, ROWS[2], FAMILIES[2], QUALIFIER, new long[] { ts[2] },</span> |
| <span class="source-line-no">1893</span><span id="line-1893"> new byte[][] { VALUES[2] }, 0, 0);</span> |
| <span class="source-line-no">1894</span><span id="line-1894"></span> |
| <span class="source-line-no">1895</span><span id="line-1895"> // Test if we delete the family first in one row (HBASE-1541)</span> |
| <span class="source-line-no">1896</span><span id="line-1896"></span> |
| <span class="source-line-no">1897</span><span id="line-1897"> delete = new Delete(ROWS[3]);</span> |
| <span class="source-line-no">1898</span><span id="line-1898"> delete.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1899</span><span id="line-1899"> ht.delete(delete);</span> |
| <span class="source-line-no">1900</span><span id="line-1900"></span> |
| <span class="source-line-no">1901</span><span id="line-1901"> put = new Put(ROWS[3]);</span> |
| <span class="source-line-no">1902</span><span id="line-1902"> put.addColumn(FAMILIES[2], QUALIFIER, VALUES[0]);</span> |
| <span class="source-line-no">1903</span><span id="line-1903"> ht.put(put);</span> |
| <span class="source-line-no">1904</span><span id="line-1904"></span> |
| <span class="source-line-no">1905</span><span id="line-1905"> put = new Put(ROWS[4]);</span> |
| <span class="source-line-no">1906</span><span id="line-1906"> put.addColumn(FAMILIES[1], QUALIFIER, VALUES[1]);</span> |
| <span class="source-line-no">1907</span><span id="line-1907"> put.addColumn(FAMILIES[2], QUALIFIER, VALUES[2]);</span> |
| <span class="source-line-no">1908</span><span id="line-1908"> ht.put(put);</span> |
| <span class="source-line-no">1909</span><span id="line-1909"></span> |
| <span class="source-line-no">1910</span><span id="line-1910"> get = new Get(ROWS[3]);</span> |
| <span class="source-line-no">1911</span><span id="line-1911"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1912</span><span id="line-1912"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1913</span><span id="line-1913"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1914</span><span id="line-1914"> result = ht.get(get);</span> |
| <span class="source-line-no">1915</span><span id="line-1915"> assertEquals("Expected 1 key but received " + result.size(), 1, result.size());</span> |
| <span class="source-line-no">1916</span><span id="line-1916"></span> |
| <span class="source-line-no">1917</span><span id="line-1917"> get = new Get(ROWS[4]);</span> |
| <span class="source-line-no">1918</span><span id="line-1918"> get.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1919</span><span id="line-1919"> get.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1920</span><span id="line-1920"> get.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1921</span><span id="line-1921"> result = ht.get(get);</span> |
| <span class="source-line-no">1922</span><span id="line-1922"> assertEquals("Expected 2 keys but received " + result.size(), 2, result.size());</span> |
| <span class="source-line-no">1923</span><span id="line-1923"></span> |
| <span class="source-line-no">1924</span><span id="line-1924"> scan = new Scan().withStartRow(ROWS[3]);</span> |
| <span class="source-line-no">1925</span><span id="line-1925"> scan.addFamily(FAMILIES[1]);</span> |
| <span class="source-line-no">1926</span><span id="line-1926"> scan.addFamily(FAMILIES[2]);</span> |
| <span class="source-line-no">1927</span><span id="line-1927"> scan.readVersions(Integer.MAX_VALUE);</span> |
| <span class="source-line-no">1928</span><span id="line-1928"> ResultScanner scanner = ht.getScanner(scan);</span> |
| <span class="source-line-no">1929</span><span id="line-1929"> result = scanner.next();</span> |
| <span class="source-line-no">1930</span><span id="line-1930"> assertEquals("Expected 1 key but received " + result.size(), 1, result.size());</span> |
| <span class="source-line-no">1931</span><span id="line-1931"> assertTrue(Bytes.equals(CellUtil.cloneRow(result.rawCells()[0]), ROWS[3]));</span> |
| <span class="source-line-no">1932</span><span id="line-1932"> assertTrue(Bytes.equals(CellUtil.cloneValue(result.rawCells()[0]), VALUES[0]));</span> |
| <span class="source-line-no">1933</span><span id="line-1933"> result = scanner.next();</span> |
| <span class="source-line-no">1934</span><span id="line-1934"> assertEquals("Expected 2 keys but received " + result.size(), 2, result.size());</span> |
| <span class="source-line-no">1935</span><span id="line-1935"> assertTrue(Bytes.equals(CellUtil.cloneRow(result.rawCells()[0]), ROWS[4]));</span> |
| <span class="source-line-no">1936</span><span id="line-1936"> assertTrue(Bytes.equals(CellUtil.cloneRow(result.rawCells()[1]), ROWS[4]));</span> |
| <span class="source-line-no">1937</span><span id="line-1937"> assertTrue(Bytes.equals(CellUtil.cloneValue(result.rawCells()[0]), VALUES[1]));</span> |
| <span class="source-line-no">1938</span><span id="line-1938"> assertTrue(Bytes.equals(CellUtil.cloneValue(result.rawCells()[1]), VALUES[2]));</span> |
| <span class="source-line-no">1939</span><span id="line-1939"> scanner.close();</span> |
| <span class="source-line-no">1940</span><span id="line-1940"></span> |
| <span class="source-line-no">1941</span><span id="line-1941"> // Add test of bulk deleting.</span> |
| <span class="source-line-no">1942</span><span id="line-1942"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">1943</span><span id="line-1943"> byte[] bytes = Bytes.toBytes(i);</span> |
| <span class="source-line-no">1944</span><span id="line-1944"> put = new Put(bytes);</span> |
| <span class="source-line-no">1945</span><span id="line-1945"> put.setDurability(Durability.SKIP_WAL);</span> |
| <span class="source-line-no">1946</span><span id="line-1946"> put.addColumn(FAMILIES[0], QUALIFIER, bytes);</span> |
| <span class="source-line-no">1947</span><span id="line-1947"> ht.put(put);</span> |
| <span class="source-line-no">1948</span><span id="line-1948"> }</span> |
| <span class="source-line-no">1949</span><span id="line-1949"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">1950</span><span id="line-1950"> byte[] bytes = Bytes.toBytes(i);</span> |
| <span class="source-line-no">1951</span><span id="line-1951"> get = new Get(bytes);</span> |
| <span class="source-line-no">1952</span><span id="line-1952"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1953</span><span id="line-1953"> result = ht.get(get);</span> |
| <span class="source-line-no">1954</span><span id="line-1954"> assertEquals(1, result.size());</span> |
| <span class="source-line-no">1955</span><span id="line-1955"> }</span> |
| <span class="source-line-no">1956</span><span id="line-1956"> ArrayList<Delete> deletes = new ArrayList<>();</span> |
| <span class="source-line-no">1957</span><span id="line-1957"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">1958</span><span id="line-1958"> byte[] bytes = Bytes.toBytes(i);</span> |
| <span class="source-line-no">1959</span><span id="line-1959"> delete = new Delete(bytes);</span> |
| <span class="source-line-no">1960</span><span id="line-1960"> delete.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1961</span><span id="line-1961"> deletes.add(delete);</span> |
| <span class="source-line-no">1962</span><span id="line-1962"> }</span> |
| <span class="source-line-no">1963</span><span id="line-1963"> ht.delete(deletes);</span> |
| <span class="source-line-no">1964</span><span id="line-1964"> for (int i = 0; i < 10; i++) {</span> |
| <span class="source-line-no">1965</span><span id="line-1965"> byte[] bytes = Bytes.toBytes(i);</span> |
| <span class="source-line-no">1966</span><span id="line-1966"> get = new Get(bytes);</span> |
| <span class="source-line-no">1967</span><span id="line-1967"> get.addFamily(FAMILIES[0]);</span> |
| <span class="source-line-no">1968</span><span id="line-1968"> result = ht.get(get);</span> |
| <span class="source-line-no">1969</span><span id="line-1969"> assertTrue(result.isEmpty());</span> |
| <span class="source-line-no">1970</span><span id="line-1970"> }</span> |
| <span class="source-line-no">1971</span><span id="line-1971"> }</span> |
| <span class="source-line-no">1972</span><span id="line-1972"> }</span> |
| <span class="source-line-no">1973</span><span id="line-1973">}</span> |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| |
| </pre> |
| </div> |
| </main> |
| </body> |
| </html> |
