http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestHBaseTransactionManager.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestHBaseTransactionManager.html b/xref-test/org/apache/omid/transaction/TestHBaseTransactionManager.html index 5472783..58f473a 100644 --- a/xref-test/org/apache/omid/transaction/TestHBaseTransactionManager.html +++ b/xref-test/org/apache/omid/transaction/TestHBaseTransactionManager.html @@ -8,23 +8,23 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestHBaseTransactionManager.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> <a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.client.TSOClient;
http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestMultiplePut.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestMultiplePut.html b/xref-test/org/apache/omid/transaction/TestMultiplePut.html index b222d6a..adbe467 100644 --- a/xref-test/org/apache/omid/transaction/TestMultiplePut.html +++ b/xref-test/org/apache/omid/transaction/TestMultiplePut.html @@ -8,23 +8,23 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestMultiplePut.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> <a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Get; http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestReadPath.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestReadPath.html b/xref-test/org/apache/omid/transaction/TestReadPath.html index 34b8445..ab3049b 100644 --- a/xref-test/org/apache/omid/transaction/TestReadPath.html +++ b/xref-test/org/apache/omid/transaction/TestReadPath.html @@ -8,23 +8,23 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestReadPath.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> <a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.Cell; @@ -40,9 +40,9 @@ <a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> java.util.Arrays; <a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> java.util.List; <a class="jxr_linenumber" name="32" href="#32">32</a> -<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.AssertJUnit.assertFalse; -<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.AssertJUnit.assertNotNull; -<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.AssertJUnit.assertTrue; +<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertFalse; +<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertNotNull; +<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertTrue; <a class="jxr_linenumber" name="36" href="#36">36</a> <a class="jxr_linenumber" name="37" href="#37">37</a> @Test(groups = <span class="jxr_string">"sharedHBase"</span>) <a class="jxr_linenumber" name="38" href="#38">38</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/omid/transaction/TestReadPath.html">TestReadPath</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../org/apache/omid/transaction/OmidTestBase.html">OmidTestBase</a> { @@ -53,7 +53,7 @@ <a class="jxr_linenumber" name="43" href="#43">43</a> <strong class="jxr_keyword">final</strong> byte[] data = Bytes.toBytes(<span class="jxr_string">"data"</span>); <a class="jxr_linenumber" name="44" href="#44">44</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> byte[] uncommitted = Bytes.toBytes(<span class="jxr_string">"uncommitted"</span>); <a class="jxr_linenumber" name="45" href="#45">45</a> -<a class="jxr_linenumber" name="46" href="#46">46</a> @Test +<a class="jxr_linenumber" name="46" href="#46">46</a> @Test(timeOut = 10_000) <a class="jxr_linenumber" name="47" href="#47">47</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testReadInterleaved(ITestContext context) <strong class="jxr_keyword">throws</strong> Exception { <a class="jxr_linenumber" name="48" href="#48">48</a> TransactionManager tm = newTransactionManager(context); <a class="jxr_linenumber" name="49" href="#49">49</a> TTable table = <strong class="jxr_keyword">new</strong> TTable(hbaseConf, TEST_TABLE); @@ -69,10 +69,10 @@ <a class="jxr_linenumber" name="59" href="#59">59</a> <a class="jxr_linenumber" name="60" href="#60">60</a> Get get = <strong class="jxr_keyword">new</strong> Get(row); <a class="jxr_linenumber" name="61" href="#61">61</a> Result result = table.get(t2, get); -<a class="jxr_linenumber" name="62" href="#62">62</a> assertFalse(<span class="jxr_string">"Should be unable to read column"</span>, result.containsColumn(family, col)); +<a class="jxr_linenumber" name="62" href="#62">62</a> assertFalse(result.containsColumn(family, col), <span class="jxr_string">"Should be unable to read column"</span>); <a class="jxr_linenumber" name="63" href="#63">63</a> } <a class="jxr_linenumber" name="64" href="#64">64</a> -<a class="jxr_linenumber" name="65" href="#65">65</a> @Test +<a class="jxr_linenumber" name="65" href="#65">65</a> @Test(timeOut = 10_000) <a class="jxr_linenumber" name="66" href="#66">66</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testReadWithSeveralUncommitted(ITestContext context) <strong class="jxr_keyword">throws</strong> Exception { <a class="jxr_linenumber" name="67" href="#67">67</a> TransactionManager tm = newTransactionManager(context); <a class="jxr_linenumber" name="68" href="#68">68</a> TTable table = <strong class="jxr_keyword">new</strong> TTable(hbaseConf, TEST_TABLE); @@ -99,9 +99,9 @@ <a class="jxr_linenumber" name="89" href="#89">89</a> Get get = <strong class="jxr_keyword">new</strong> Get(row); <a class="jxr_linenumber" name="90" href="#90">90</a> Result result = table.get(t, get); <a class="jxr_linenumber" name="91" href="#91">91</a> Cell cell = result.getColumnLatestCell(family, col); -<a class="jxr_linenumber" name="92" href="#92">92</a> assertNotNull(<span class="jxr_string">"KeyValue is null"</span>, cell); +<a class="jxr_linenumber" name="92" href="#92">92</a> assertNotNull(cell, <span class="jxr_string">"KeyValue is null"</span>); <a class="jxr_linenumber" name="93" href="#93">93</a> byte[] value = CellUtil.cloneValue(cell); -<a class="jxr_linenumber" name="94" href="#94">94</a> assertTrue(<span class="jxr_string">"Read data doesn't match"</span>, Arrays.equals(data, value)); +<a class="jxr_linenumber" name="94" href="#94">94</a> assertTrue(Arrays.equals(data, value), <span class="jxr_string">"Read data doesn't match"</span>); <a class="jxr_linenumber" name="95" href="#95">95</a> tm.commit(t); <a class="jxr_linenumber" name="96" href="#96">96</a> <a class="jxr_linenumber" name="97" href="#97">97</a> table.close(); http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestShadowCells.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestShadowCells.html b/xref-test/org/apache/omid/transaction/TestShadowCells.html index 55172db..7a88640 100644 --- a/xref-test/org/apache/omid/transaction/TestShadowCells.html +++ b/xref-test/org/apache/omid/transaction/TestShadowCells.html @@ -8,23 +8,23 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestShadowCells.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> <a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> com.google.common.base.Charsets; @@ -408,7 +408,7 @@ <a class="jxr_linenumber" name="398" href="#398">398</a> <em class="jxr_javadoccomment">/**</em> <a class="jxr_linenumber" name="399" href="#399">399</a> <em class="jxr_javadoccomment"> * Test that the new client can read shadow cells written by the old client.</em> <a class="jxr_linenumber" name="400" href="#400">400</a> <em class="jxr_javadoccomment"> */</em> -<a class="jxr_linenumber" name="401" href="#401">401</a> @Test +<a class="jxr_linenumber" name="401" href="#401">401</a> @Test(timeOut = 60_000) <a class="jxr_linenumber" name="402" href="#402">402</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testGetOldShadowCells(ITestContext context) <strong class="jxr_keyword">throws</strong> Exception { <a class="jxr_linenumber" name="403" href="#403">403</a> <a class="jxr_linenumber" name="404" href="#404">404</a> TransactionManager tm = newTransactionManager(context); http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestSingleColumnFamily.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestSingleColumnFamily.html b/xref-test/org/apache/omid/transaction/TestSingleColumnFamily.html index 176ca75..61676e6 100644 --- a/xref-test/org/apache/omid/transaction/TestSingleColumnFamily.html +++ b/xref-test/org/apache/omid/transaction/TestSingleColumnFamily.html @@ -8,23 +8,23 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestSingleColumnFamily.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> <a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Put; @@ -37,14 +37,14 @@ <a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.testng.ITestContext; <a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.Test; <a class="jxr_linenumber" name="29" href="#29">29</a> -<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.AssertJUnit.assertTrue; +<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertTrue; <a class="jxr_linenumber" name="31" href="#31">31</a> <a class="jxr_linenumber" name="32" href="#32">32</a> @Test(groups = <span class="jxr_string">"sharedHBase"</span>) <a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/omid/transaction/TestSingleColumnFamily.html">TestSingleColumnFamily</a> <strong class="jxr_keyword">extends</strong> <a href="../../../../org/apache/omid/transaction/OmidTestBase.html">OmidTestBase</a> { -<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> Logger LOG = LoggerFactory.getLogger(TestSingleColumnFamily.<strong class="jxr_keyword">class</strong>); -<a class="jxr_linenumber" name="35" href="#35">35</a> +<a class="jxr_linenumber" name="34" href="#34">34</a> +<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> Logger LOG = LoggerFactory.getLogger(TestSingleColumnFamily.<strong class="jxr_keyword">class</strong>); <a class="jxr_linenumber" name="36" href="#36">36</a> -<a class="jxr_linenumber" name="37" href="#37">37</a> @Test +<a class="jxr_linenumber" name="37" href="#37">37</a> @Test(timeOut = 10_000) <a class="jxr_linenumber" name="38" href="#38">38</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testSingleColumnFamily(ITestContext context) <strong class="jxr_keyword">throws</strong> Exception { <a class="jxr_linenumber" name="39" href="#39">39</a> TransactionManager tm = newTransactionManager(context); <a class="jxr_linenumber" name="40" href="#40">40</a> TTable table1 = <strong class="jxr_keyword">new</strong> TTable(hbaseConf, TEST_TABLE); @@ -69,53 +69,48 @@ <a class="jxr_linenumber" name="59" href="#59">59</a> LOG.info(<span class="jxr_string">"RES:"</span> + tmp1 + <span class="jxr_string">";"</span> + tmp2); <a class="jxr_linenumber" name="60" href="#60">60</a> count++; <a class="jxr_linenumber" name="61" href="#61">61</a> } -<a class="jxr_linenumber" name="62" href="#62">62</a> assertTrue(<span class="jxr_string">"Can't see puts. I should see "</span> -<a class="jxr_linenumber" name="63" href="#63">63</a> + num + <span class="jxr_string">" but I see "</span> + count -<a class="jxr_linenumber" name="64" href="#64">64</a> , num == count); -<a class="jxr_linenumber" name="65" href="#65">65</a> -<a class="jxr_linenumber" name="66" href="#66">66</a> tm.commit(t); -<a class="jxr_linenumber" name="67" href="#67">67</a> t = tm.begin(); -<a class="jxr_linenumber" name="68" href="#68">68</a> -<a class="jxr_linenumber" name="69" href="#69">69</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> j = 0; j < num / 2; j++) { -<a class="jxr_linenumber" name="70" href="#70">70</a> byte[] data = Bytes.toBytes(j); -<a class="jxr_linenumber" name="71" href="#71">71</a> byte[] ndata = Bytes.toBytes(j * 10); -<a class="jxr_linenumber" name="72" href="#72">72</a> Put put = <strong class="jxr_keyword">new</strong> Put(data); -<a class="jxr_linenumber" name="73" href="#73">73</a> put.add(Bytes.toBytes(TEST_FAMILY), Bytes.toBytes(<span class="jxr_string">"value2"</span>), ndata); -<a class="jxr_linenumber" name="74" href="#74">74</a> table1.put(t, put); -<a class="jxr_linenumber" name="75" href="#75">75</a> } -<a class="jxr_linenumber" name="76" href="#76">76</a> tm.commit(t); -<a class="jxr_linenumber" name="77" href="#77">77</a> t = tm.begin(); -<a class="jxr_linenumber" name="78" href="#78">78</a> s = <strong class="jxr_keyword">new</strong> Scan(); -<a class="jxr_linenumber" name="79" href="#79">79</a> res = table1.getScanner(t, s); -<a class="jxr_linenumber" name="80" href="#80">80</a> count = 0; -<a class="jxr_linenumber" name="81" href="#81">81</a> <strong class="jxr_keyword">int</strong> modified = 0, notmodified = 0; -<a class="jxr_linenumber" name="82" href="#82">82</a> <strong class="jxr_keyword">while</strong> ((rr = res.next()) != <strong class="jxr_keyword">null</strong>) { -<a class="jxr_linenumber" name="83" href="#83">83</a> <strong class="jxr_keyword">int</strong> tmp1 = Bytes.toInt(rr.getValue(Bytes.toBytes(TEST_FAMILY), Bytes.toBytes(<span class="jxr_string">"value1"</span>))); -<a class="jxr_linenumber" name="84" href="#84">84</a> <strong class="jxr_keyword">int</strong> tmp2 = Bytes.toInt(rr.getValue(Bytes.toBytes(TEST_FAMILY), Bytes.toBytes(<span class="jxr_string">"value2"</span>))); -<a class="jxr_linenumber" name="85" href="#85">85</a> LOG.info(<span class="jxr_string">"RES:"</span> + tmp1 + <span class="jxr_string">";"</span> + tmp2); -<a class="jxr_linenumber" name="86" href="#86">86</a> count++; -<a class="jxr_linenumber" name="87" href="#87">87</a> -<a class="jxr_linenumber" name="88" href="#88">88</a> <strong class="jxr_keyword">if</strong> (tmp2 == Bytes.toInt(rr.getRow()) * 10) { -<a class="jxr_linenumber" name="89" href="#89">89</a> modified++; -<a class="jxr_linenumber" name="90" href="#90">90</a> } <strong class="jxr_keyword">else</strong> { -<a class="jxr_linenumber" name="91" href="#91">91</a> notmodified++; -<a class="jxr_linenumber" name="92" href="#92">92</a> } -<a class="jxr_linenumber" name="93" href="#93">93</a> <strong class="jxr_keyword">if</strong> (count == 8) { -<a class="jxr_linenumber" name="94" href="#94">94</a> LOG.debug(<span class="jxr_string">"stop"</span>); -<a class="jxr_linenumber" name="95" href="#95">95</a> } -<a class="jxr_linenumber" name="96" href="#96">96</a> } -<a class="jxr_linenumber" name="97" href="#97">97</a> assertTrue(<span class="jxr_string">"Can't see puts. I should see "</span> -<a class="jxr_linenumber" name="98" href="#98">98</a> + num + <span class="jxr_string">" but I see "</span> + count -<a class="jxr_linenumber" name="99" href="#99">99</a> , num == count); -<a class="jxr_linenumber" name="100" href="#100">100</a> assertTrue(<span class="jxr_string">"Half of rows should equal row id, half not ("</span> -<a class="jxr_linenumber" name="101" href="#101">101</a> + modified + <span class="jxr_string">", "</span> + notmodified + <span class="jxr_string">")"</span> -<a class="jxr_linenumber" name="102" href="#102">102</a> , modified == notmodified && notmodified == (num / 2)); -<a class="jxr_linenumber" name="103" href="#103">103</a> -<a class="jxr_linenumber" name="104" href="#104">104</a> tm.commit(t); -<a class="jxr_linenumber" name="105" href="#105">105</a> LOG.info(<span class="jxr_string">"End commiting"</span>); -<a class="jxr_linenumber" name="106" href="#106">106</a> table1.close(); -<a class="jxr_linenumber" name="107" href="#107">107</a> } -<a class="jxr_linenumber" name="108" href="#108">108</a> } +<a class="jxr_linenumber" name="62" href="#62">62</a> assertTrue(num == count, <span class="jxr_string">"Can't see puts. I should see "</span> + num + <span class="jxr_string">" but I see "</span> + count); +<a class="jxr_linenumber" name="63" href="#63">63</a> +<a class="jxr_linenumber" name="64" href="#64">64</a> tm.commit(t); +<a class="jxr_linenumber" name="65" href="#65">65</a> t = tm.begin(); +<a class="jxr_linenumber" name="66" href="#66">66</a> +<a class="jxr_linenumber" name="67" href="#67">67</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> j = 0; j < num / 2; j++) { +<a class="jxr_linenumber" name="68" href="#68">68</a> byte[] data = Bytes.toBytes(j); +<a class="jxr_linenumber" name="69" href="#69">69</a> byte[] ndata = Bytes.toBytes(j * 10); +<a class="jxr_linenumber" name="70" href="#70">70</a> Put put = <strong class="jxr_keyword">new</strong> Put(data); +<a class="jxr_linenumber" name="71" href="#71">71</a> put.add(Bytes.toBytes(TEST_FAMILY), Bytes.toBytes(<span class="jxr_string">"value2"</span>), ndata); +<a class="jxr_linenumber" name="72" href="#72">72</a> table1.put(t, put); +<a class="jxr_linenumber" name="73" href="#73">73</a> } +<a class="jxr_linenumber" name="74" href="#74">74</a> tm.commit(t); +<a class="jxr_linenumber" name="75" href="#75">75</a> t = tm.begin(); +<a class="jxr_linenumber" name="76" href="#76">76</a> s = <strong class="jxr_keyword">new</strong> Scan(); +<a class="jxr_linenumber" name="77" href="#77">77</a> res = table1.getScanner(t, s); +<a class="jxr_linenumber" name="78" href="#78">78</a> count = 0; +<a class="jxr_linenumber" name="79" href="#79">79</a> <strong class="jxr_keyword">int</strong> modified = 0, notmodified = 0; +<a class="jxr_linenumber" name="80" href="#80">80</a> <strong class="jxr_keyword">while</strong> ((rr = res.next()) != <strong class="jxr_keyword">null</strong>) { +<a class="jxr_linenumber" name="81" href="#81">81</a> <strong class="jxr_keyword">int</strong> tmp1 = Bytes.toInt(rr.getValue(Bytes.toBytes(TEST_FAMILY), Bytes.toBytes(<span class="jxr_string">"value1"</span>))); +<a class="jxr_linenumber" name="82" href="#82">82</a> <strong class="jxr_keyword">int</strong> tmp2 = Bytes.toInt(rr.getValue(Bytes.toBytes(TEST_FAMILY), Bytes.toBytes(<span class="jxr_string">"value2"</span>))); +<a class="jxr_linenumber" name="83" href="#83">83</a> LOG.info(<span class="jxr_string">"RES:"</span> + tmp1 + <span class="jxr_string">";"</span> + tmp2); +<a class="jxr_linenumber" name="84" href="#84">84</a> count++; +<a class="jxr_linenumber" name="85" href="#85">85</a> +<a class="jxr_linenumber" name="86" href="#86">86</a> <strong class="jxr_keyword">if</strong> (tmp2 == Bytes.toInt(rr.getRow()) * 10) { +<a class="jxr_linenumber" name="87" href="#87">87</a> modified++; +<a class="jxr_linenumber" name="88" href="#88">88</a> } <strong class="jxr_keyword">else</strong> { +<a class="jxr_linenumber" name="89" href="#89">89</a> notmodified++; +<a class="jxr_linenumber" name="90" href="#90">90</a> } +<a class="jxr_linenumber" name="91" href="#91">91</a> <strong class="jxr_keyword">if</strong> (count == 8) { +<a class="jxr_linenumber" name="92" href="#92">92</a> LOG.debug(<span class="jxr_string">"stop"</span>); +<a class="jxr_linenumber" name="93" href="#93">93</a> } +<a class="jxr_linenumber" name="94" href="#94">94</a> } +<a class="jxr_linenumber" name="95" href="#95">95</a> assertTrue(num == count, <span class="jxr_string">"Can't see puts. I should see "</span> + num + <span class="jxr_string">" but I see "</span> + count); +<a class="jxr_linenumber" name="96" href="#96">96</a> assertTrue(modified == notmodified && notmodified == (num / 2), +<a class="jxr_linenumber" name="97" href="#97">97</a> <span class="jxr_string">"Half of rows should equal row id, half not ("</span> + modified + <span class="jxr_string">", "</span> + notmodified + <span class="jxr_string">")"</span>); +<a class="jxr_linenumber" name="98" href="#98">98</a> +<a class="jxr_linenumber" name="99" href="#99">99</a> tm.commit(t); +<a class="jxr_linenumber" name="100" href="#100">100</a> LOG.info(<span class="jxr_string">"End commiting"</span>); +<a class="jxr_linenumber" name="101" href="#101">101</a> table1.close(); +<a class="jxr_linenumber" name="102" href="#102">102</a> } +<a class="jxr_linenumber" name="103" href="#103">103</a> } </pre> <hr/><div id="footer">This page was automatically generated by <a href="http://maven.apache.org/";>Maven</a></div></body> </html> http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestTSOModule.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestTSOModule.html b/xref-test/org/apache/omid/transaction/TestTSOModule.html index 8383241..887af6b 100644 --- a/xref-test/org/apache/omid/transaction/TestTSOModule.html +++ b/xref-test/org/apache/omid/transaction/TestTSOModule.html @@ -8,104 +8,122 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestTSOModule.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> -<a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> com.google.inject.AbstractModule; -<a class="jxr_linenumber" name="21" href="#21">21</a> <strong class="jxr_keyword">import</strong> com.google.inject.Provides; -<a class="jxr_linenumber" name="22" href="#22">22</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable; -<a class="jxr_linenumber" name="23" href="#23">23</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.hbase.HBaseCommitTable; -<a class="jxr_linenumber" name="24" href="#24">24</a> <strong class="jxr_keyword">import</strong> org.apache.omid.metrics.MetricsRegistry; -<a class="jxr_linenumber" name="25" href="#25">25</a> <strong class="jxr_keyword">import</strong> org.apache.omid.metrics.NullMetricsProvider; -<a class="jxr_linenumber" name="26" href="#26">26</a> <strong class="jxr_keyword">import</strong> org.apache.omid.timestamp.storage.HBaseTimestampStorage; -<a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.apache.omid.timestamp.storage.TimestampStorage; -<a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.DisruptorModule; -<a class="jxr_linenumber" name="29" href="#29">29</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.MockPanicker; -<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.NetworkInterfaceUtils; -<a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.Panicker; -<a class="jxr_linenumber" name="32" href="#32">32</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.PausableTimestampOracle; -<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOChannelHandler; -<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOServerConfig; -<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOStateManager; -<a class="jxr_linenumber" name="36" href="#36">36</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOStateManagerImpl; -<a class="jxr_linenumber" name="37" href="#37">37</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TimestampOracle; -<a class="jxr_linenumber" name="38" href="#38">38</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.conf.Configuration; -<a class="jxr_linenumber" name="39" href="#39">39</a> -<a class="jxr_linenumber" name="40" href="#40">40</a> <strong class="jxr_keyword">import</strong> javax.inject.Named; -<a class="jxr_linenumber" name="41" href="#41">41</a> <strong class="jxr_keyword">import</strong> javax.inject.Singleton; -<a class="jxr_linenumber" name="42" href="#42">42</a> <strong class="jxr_keyword">import</strong> java.net.SocketException; -<a class="jxr_linenumber" name="43" href="#43">43</a> <strong class="jxr_keyword">import</strong> java.net.UnknownHostException; +<a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> com.google.common.base.Preconditions; +<a class="jxr_linenumber" name="21" href="#21">21</a> <strong class="jxr_keyword">import</strong> com.google.inject.AbstractModule; +<a class="jxr_linenumber" name="22" href="#22">22</a> <strong class="jxr_keyword">import</strong> com.google.inject.Provider; +<a class="jxr_linenumber" name="23" href="#23">23</a> <strong class="jxr_keyword">import</strong> com.google.inject.Provides; +<a class="jxr_linenumber" name="24" href="#24">24</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable; +<a class="jxr_linenumber" name="25" href="#25">25</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.hbase.HBaseCommitTable; +<a class="jxr_linenumber" name="26" href="#26">26</a> <strong class="jxr_keyword">import</strong> org.apache.omid.metrics.MetricsRegistry; +<a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.apache.omid.metrics.NullMetricsProvider; +<a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.apache.omid.timestamp.storage.HBaseTimestampStorage; +<a class="jxr_linenumber" name="29" href="#29">29</a> <strong class="jxr_keyword">import</strong> org.apache.omid.timestamp.storage.TimestampStorage; +<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.BatchPoolModule; +<a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.DisruptorModule; +<a class="jxr_linenumber" name="32" href="#32">32</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.RuntimeExceptionPanicker; +<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.NetworkInterfaceUtils; +<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.Panicker; +<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.PausableTimestampOracle; +<a class="jxr_linenumber" name="36" href="#36">36</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.PersistenceProcessorHandler; +<a class="jxr_linenumber" name="37" href="#37">37</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOChannelHandler; +<a class="jxr_linenumber" name="38" href="#38">38</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOServerConfig; +<a class="jxr_linenumber" name="39" href="#39">39</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOStateManager; +<a class="jxr_linenumber" name="40" href="#40">40</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TSOStateManagerImpl; +<a class="jxr_linenumber" name="41" href="#41">41</a> <strong class="jxr_keyword">import</strong> org.apache.omid.tso.TimestampOracle; +<a class="jxr_linenumber" name="42" href="#42">42</a> +<a class="jxr_linenumber" name="43" href="#43">43</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.conf.Configuration; <a class="jxr_linenumber" name="44" href="#44">44</a> -<a class="jxr_linenumber" name="45" href="#45">45</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.apache.omid.tso.TSOServer.TSO_HOST_AND_PORT_KEY; -<a class="jxr_linenumber" name="46" href="#46">46</a> -<a class="jxr_linenumber" name="47" href="#47">47</a> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/omid/transaction/TestTSOModule.html">TestTSOModule</a> <strong class="jxr_keyword">extends</strong> AbstractModule { -<a class="jxr_linenumber" name="48" href="#48">48</a> -<a class="jxr_linenumber" name="49" href="#49">49</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Configuration hBaseConfig; -<a class="jxr_linenumber" name="50" href="#50">50</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> TSOServerConfig config; -<a class="jxr_linenumber" name="51" href="#51">51</a> -<a class="jxr_linenumber" name="52" href="#52">52</a> <a href="../../../../org/apache/omid/transaction/TestTSOModule.html">TestTSOModule</a>(Configuration hBaseConfig, TSOServerConfig config) { -<a class="jxr_linenumber" name="53" href="#53">53</a> <strong class="jxr_keyword">this</strong>.hBaseConfig = hBaseConfig; -<a class="jxr_linenumber" name="54" href="#54">54</a> <strong class="jxr_keyword">this</strong>.config = config; -<a class="jxr_linenumber" name="55" href="#55">55</a> } -<a class="jxr_linenumber" name="56" href="#56">56</a> -<a class="jxr_linenumber" name="57" href="#57">57</a> @Override -<a class="jxr_linenumber" name="58" href="#58">58</a> <strong class="jxr_keyword">protected</strong> <strong class="jxr_keyword">void</strong> configure() { -<a class="jxr_linenumber" name="59" href="#59">59</a> -<a class="jxr_linenumber" name="60" href="#60">60</a> bind(TSOChannelHandler.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); -<a class="jxr_linenumber" name="61" href="#61">61</a> -<a class="jxr_linenumber" name="62" href="#62">62</a> bind(TSOStateManager.<strong class="jxr_keyword">class</strong>).to(TSOStateManagerImpl.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); +<a class="jxr_linenumber" name="45" href="#45">45</a> <strong class="jxr_keyword">import</strong> javax.inject.Named; +<a class="jxr_linenumber" name="46" href="#46">46</a> <strong class="jxr_keyword">import</strong> javax.inject.Singleton; +<a class="jxr_linenumber" name="47" href="#47">47</a> +<a class="jxr_linenumber" name="48" href="#48">48</a> <strong class="jxr_keyword">import</strong> java.net.SocketException; +<a class="jxr_linenumber" name="49" href="#49">49</a> <strong class="jxr_keyword">import</strong> java.net.UnknownHostException; +<a class="jxr_linenumber" name="50" href="#50">50</a> +<a class="jxr_linenumber" name="51" href="#51">51</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.apache.omid.tso.TSOServer.TSO_HOST_AND_PORT_KEY; +<a class="jxr_linenumber" name="52" href="#52">52</a> +<a class="jxr_linenumber" name="53" href="#53">53</a> <strong class="jxr_keyword">class</strong> <a href="../../../../org/apache/omid/transaction/TestTSOModule.html">TestTSOModule</a> <strong class="jxr_keyword">extends</strong> AbstractModule { +<a class="jxr_linenumber" name="54" href="#54">54</a> +<a class="jxr_linenumber" name="55" href="#55">55</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> Configuration hBaseConfig; +<a class="jxr_linenumber" name="56" href="#56">56</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">final</strong> TSOServerConfig config; +<a class="jxr_linenumber" name="57" href="#57">57</a> +<a class="jxr_linenumber" name="58" href="#58">58</a> <a href="../../../../org/apache/omid/transaction/TestTSOModule.html">TestTSOModule</a>(Configuration hBaseConfig, TSOServerConfig config) { +<a class="jxr_linenumber" name="59" href="#59">59</a> Preconditions.checkArgument(config.getNumConcurrentCTWriters() >= 2, <span class="jxr_string">"# of Commit Table writers must be >= 2"</span>); +<a class="jxr_linenumber" name="60" href="#60">60</a> <strong class="jxr_keyword">this</strong>.hBaseConfig = hBaseConfig; +<a class="jxr_linenumber" name="61" href="#61">61</a> <strong class="jxr_keyword">this</strong>.config = config; +<a class="jxr_linenumber" name="62" href="#62">62</a> } <a class="jxr_linenumber" name="63" href="#63">63</a> -<a class="jxr_linenumber" name="64" href="#64">64</a> bind(CommitTable.<strong class="jxr_keyword">class</strong>).to(HBaseCommitTable.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); -<a class="jxr_linenumber" name="65" href="#65">65</a> bind(TimestampStorage.<strong class="jxr_keyword">class</strong>).to(HBaseTimestampStorage.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); -<a class="jxr_linenumber" name="66" href="#66">66</a> bind(TimestampOracle.<strong class="jxr_keyword">class</strong>).to(PausableTimestampOracle.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); -<a class="jxr_linenumber" name="67" href="#67">67</a> bind(Panicker.<strong class="jxr_keyword">class</strong>).to(MockPanicker.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); +<a class="jxr_linenumber" name="64" href="#64">64</a> @Override +<a class="jxr_linenumber" name="65" href="#65">65</a> <strong class="jxr_keyword">protected</strong> <strong class="jxr_keyword">void</strong> configure() { +<a class="jxr_linenumber" name="66" href="#66">66</a> +<a class="jxr_linenumber" name="67" href="#67">67</a> bind(TSOChannelHandler.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); <a class="jxr_linenumber" name="68" href="#68">68</a> -<a class="jxr_linenumber" name="69" href="#69">69</a> <em class="jxr_comment">// Disruptor setup</em> -<a class="jxr_linenumber" name="70" href="#70">70</a> install(<strong class="jxr_keyword">new</strong> DisruptorModule()); -<a class="jxr_linenumber" name="71" href="#71">71</a> -<a class="jxr_linenumber" name="72" href="#72">72</a> <em class="jxr_comment">// LeaseManagement setup</em> -<a class="jxr_linenumber" name="73" href="#73">73</a> install(config.getLeaseModule()); -<a class="jxr_linenumber" name="74" href="#74">74</a> } +<a class="jxr_linenumber" name="69" href="#69">69</a> bind(TSOStateManager.<strong class="jxr_keyword">class</strong>).to(TSOStateManagerImpl.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); +<a class="jxr_linenumber" name="70" href="#70">70</a> +<a class="jxr_linenumber" name="71" href="#71">71</a> bind(CommitTable.<strong class="jxr_keyword">class</strong>).to(HBaseCommitTable.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); +<a class="jxr_linenumber" name="72" href="#72">72</a> bind(TimestampStorage.<strong class="jxr_keyword">class</strong>).to(HBaseTimestampStorage.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); +<a class="jxr_linenumber" name="73" href="#73">73</a> bind(TimestampOracle.<strong class="jxr_keyword">class</strong>).to(PausableTimestampOracle.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); +<a class="jxr_linenumber" name="74" href="#74">74</a> bind(Panicker.<strong class="jxr_keyword">class</strong>).to(RuntimeExceptionPanicker.<strong class="jxr_keyword">class</strong>).in(Singleton.<strong class="jxr_keyword">class</strong>); <a class="jxr_linenumber" name="75" href="#75">75</a> -<a class="jxr_linenumber" name="76" href="#76">76</a> @Provides -<a class="jxr_linenumber" name="77" href="#77">77</a> Configuration provideHBaseConfig() { -<a class="jxr_linenumber" name="78" href="#78">78</a> <strong class="jxr_keyword">return</strong> hBaseConfig; -<a class="jxr_linenumber" name="79" href="#79">79</a> } +<a class="jxr_linenumber" name="76" href="#76">76</a> install(<strong class="jxr_keyword">new</strong> BatchPoolModule(config)); +<a class="jxr_linenumber" name="77" href="#77">77</a> +<a class="jxr_linenumber" name="78" href="#78">78</a> <em class="jxr_comment">// Disruptor setup</em> +<a class="jxr_linenumber" name="79" href="#79">79</a> install(<strong class="jxr_keyword">new</strong> DisruptorModule()); <a class="jxr_linenumber" name="80" href="#80">80</a> -<a class="jxr_linenumber" name="81" href="#81">81</a> @Provides -<a class="jxr_linenumber" name="82" href="#82">82</a> TSOServerConfig provideTSOServerConfig() { -<a class="jxr_linenumber" name="83" href="#83">83</a> <strong class="jxr_keyword">return</strong> config; -<a class="jxr_linenumber" name="84" href="#84">84</a> } -<a class="jxr_linenumber" name="85" href="#85">85</a> -<a class="jxr_linenumber" name="86" href="#86">86</a> @Provides -<a class="jxr_linenumber" name="87" href="#87">87</a> @Singleton -<a class="jxr_linenumber" name="88" href="#88">88</a> MetricsRegistry provideMetricsRegistry() { -<a class="jxr_linenumber" name="89" href="#89">89</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">new</strong> NullMetricsProvider(); -<a class="jxr_linenumber" name="90" href="#90">90</a> } -<a class="jxr_linenumber" name="91" href="#91">91</a> -<a class="jxr_linenumber" name="92" href="#92">92</a> @Provides -<a class="jxr_linenumber" name="93" href="#93">93</a> @Named(TSO_HOST_AND_PORT_KEY) -<a class="jxr_linenumber" name="94" href="#94">94</a> String provideTSOHostAndPort() <strong class="jxr_keyword">throws</strong> SocketException, UnknownHostException { -<a class="jxr_linenumber" name="95" href="#95">95</a> <strong class="jxr_keyword">return</strong> NetworkInterfaceUtils.getTSOHostAndPort(config); -<a class="jxr_linenumber" name="96" href="#96">96</a> } -<a class="jxr_linenumber" name="97" href="#97">97</a> -<a class="jxr_linenumber" name="98" href="#98">98</a> } +<a class="jxr_linenumber" name="81" href="#81">81</a> <em class="jxr_comment">// LeaseManagement setup</em> +<a class="jxr_linenumber" name="82" href="#82">82</a> install(config.getLeaseModule()); +<a class="jxr_linenumber" name="83" href="#83">83</a> } +<a class="jxr_linenumber" name="84" href="#84">84</a> +<a class="jxr_linenumber" name="85" href="#85">85</a> @Provides +<a class="jxr_linenumber" name="86" href="#86">86</a> Configuration provideHBaseConfig() { +<a class="jxr_linenumber" name="87" href="#87">87</a> <strong class="jxr_keyword">return</strong> hBaseConfig; +<a class="jxr_linenumber" name="88" href="#88">88</a> } +<a class="jxr_linenumber" name="89" href="#89">89</a> +<a class="jxr_linenumber" name="90" href="#90">90</a> @Provides +<a class="jxr_linenumber" name="91" href="#91">91</a> TSOServerConfig provideTSOServerConfig() { +<a class="jxr_linenumber" name="92" href="#92">92</a> <strong class="jxr_keyword">return</strong> config; +<a class="jxr_linenumber" name="93" href="#93">93</a> } +<a class="jxr_linenumber" name="94" href="#94">94</a> +<a class="jxr_linenumber" name="95" href="#95">95</a> @Provides +<a class="jxr_linenumber" name="96" href="#96">96</a> @Singleton +<a class="jxr_linenumber" name="97" href="#97">97</a> MetricsRegistry provideMetricsRegistry() { +<a class="jxr_linenumber" name="98" href="#98">98</a> <strong class="jxr_keyword">return</strong> <strong class="jxr_keyword">new</strong> NullMetricsProvider(); +<a class="jxr_linenumber" name="99" href="#99">99</a> } +<a class="jxr_linenumber" name="100" href="#100">100</a> +<a class="jxr_linenumber" name="101" href="#101">101</a> @Provides +<a class="jxr_linenumber" name="102" href="#102">102</a> @Named(TSO_HOST_AND_PORT_KEY) +<a class="jxr_linenumber" name="103" href="#103">103</a> String provideTSOHostAndPort() <strong class="jxr_keyword">throws</strong> SocketException, UnknownHostException { +<a class="jxr_linenumber" name="104" href="#104">104</a> <strong class="jxr_keyword">return</strong> NetworkInterfaceUtils.getTSOHostAndPort(config); +<a class="jxr_linenumber" name="105" href="#105">105</a> } +<a class="jxr_linenumber" name="106" href="#106">106</a> +<a class="jxr_linenumber" name="107" href="#107">107</a> @Provides +<a class="jxr_linenumber" name="108" href="#108">108</a> PersistenceProcessorHandler[] getPersistenceProcessorHandler(Provider<PersistenceProcessorHandler> provider) { +<a class="jxr_linenumber" name="109" href="#109">109</a> PersistenceProcessorHandler[] persistenceProcessorHandlers = <strong class="jxr_keyword">new</strong> PersistenceProcessorHandler[config.getNumConcurrentCTWriters()]; +<a class="jxr_linenumber" name="110" href="#110">110</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> i = 0; i < persistenceProcessorHandlers.length; i++) { +<a class="jxr_linenumber" name="111" href="#111">111</a> persistenceProcessorHandlers[i] = provider.get(); +<a class="jxr_linenumber" name="112" href="#112">112</a> } +<a class="jxr_linenumber" name="113" href="#113">113</a> <strong class="jxr_keyword">return</strong> persistenceProcessorHandlers; +<a class="jxr_linenumber" name="114" href="#114">114</a> } +<a class="jxr_linenumber" name="115" href="#115">115</a> +<a class="jxr_linenumber" name="116" href="#116">116</a> } </pre> <hr/><div id="footer">This page was automatically generated by <a href="http://maven.apache.org/";>Maven</a></div></body> </html> http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/3a40a657/xref-test/org/apache/omid/transaction/TestTTableBehaviour.html ---------------------------------------------------------------------- diff --git a/xref-test/org/apache/omid/transaction/TestTTableBehaviour.html b/xref-test/org/apache/omid/transaction/TestTTableBehaviour.html index b9c61ee..dd07395 100644 --- a/xref-test/org/apache/omid/transaction/TestTTableBehaviour.html +++ b/xref-test/org/apache/omid/transaction/TestTTableBehaviour.html @@ -8,23 +8,23 @@ <body> <div id="overview"><a href="../../../../../../target/site/testapidocs/org/apache/omid/transaction/TestTTableBehaviour.html">View Javadoc</a></div><pre> -<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_javadoccomment">/**</em> -<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_javadoccomment"> * Licensed to the Apache Software Foundation (ASF) under one</em> -<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_javadoccomment"> * or more contributor license agreements. See the NOTICE file</em> -<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_javadoccomment"> * distributed with this work for additional information</em> -<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_javadoccomment"> * regarding copyright ownership. The ASF licenses this file</em> -<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_javadoccomment"> * to you under the Apache License, Version 2.0 (the</em> -<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_javadoccomment"> * "License"); you may not use this file except in compliance</em> -<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_javadoccomment"> * with the License. You may obtain a copy of the License at</em> -<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_javadoccomment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> -<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_javadoccomment"> *</em> -<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_javadoccomment"> * Unless required by applicable law or agreed to in writing, software</em> -<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_javadoccomment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> -<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_javadoccomment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> -<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_javadoccomment"> * See the License for the specific language governing permissions and</em> -<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_javadoccomment"> * limitations under the License.</em> -<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_javadoccomment"> */</em> +<a class="jxr_linenumber" name="1" href="#1">1</a> <em class="jxr_comment">/*</em> +<a class="jxr_linenumber" name="2" href="#2">2</a> <em class="jxr_comment"> * Licensed to the Apache Software Foundation (ASF) under one</em> +<a class="jxr_linenumber" name="3" href="#3">3</a> <em class="jxr_comment"> * or more contributor license agreements. See the NOTICE file</em> +<a class="jxr_linenumber" name="4" href="#4">4</a> <em class="jxr_comment"> * distributed with this work for additional information</em> +<a class="jxr_linenumber" name="5" href="#5">5</a> <em class="jxr_comment"> * regarding copyright ownership. The ASF licenses this file</em> +<a class="jxr_linenumber" name="6" href="#6">6</a> <em class="jxr_comment"> * to you under the Apache License, Version 2.0 (the</em> +<a class="jxr_linenumber" name="7" href="#7">7</a> <em class="jxr_comment"> * "License"); you may not use this file except in compliance</em> +<a class="jxr_linenumber" name="8" href="#8">8</a> <em class="jxr_comment"> * with the License. You may obtain a copy of the License at</em> +<a class="jxr_linenumber" name="9" href="#9">9</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="10" href="#10">10</a> <em class="jxr_comment"> * <a href="http://www.apache.org/licenses/LICENSE-2.0"; target="alexandria_uri">http://www.apache.org/licenses/LICENSE-2.0</a></em> +<a class="jxr_linenumber" name="11" href="#11">11</a> <em class="jxr_comment"> *</em> +<a class="jxr_linenumber" name="12" href="#12">12</a> <em class="jxr_comment"> * Unless required by applicable law or agreed to in writing, software</em> +<a class="jxr_linenumber" name="13" href="#13">13</a> <em class="jxr_comment"> * distributed under the License is distributed on an "AS IS" BASIS,</em> +<a class="jxr_linenumber" name="14" href="#14">14</a> <em class="jxr_comment"> * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</em> +<a class="jxr_linenumber" name="15" href="#15">15</a> <em class="jxr_comment"> * See the License for the specific language governing permissions and</em> +<a class="jxr_linenumber" name="16" href="#16">16</a> <em class="jxr_comment"> * limitations under the License.</em> +<a class="jxr_linenumber" name="17" href="#17">17</a> <em class="jxr_comment"> */</em> <a class="jxr_linenumber" name="18" href="#18">18</a> <strong class="jxr_keyword">package</strong> org.apache.omid.transaction; <a class="jxr_linenumber" name="19" href="#19">19</a> <a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> com.google.common.base.Charsets;
