You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@omid.apache.org by yo...@apache.org on 2018/09/26 09:03:42 UTC
[43/56] incubator-omid-site git commit: [wagon-git] commit to branch
asf-site 9/25/18 12:09 PM
http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/077788dd/team.html
----------------------------------------------------------------------
diff --git a/team.html b/team.html
new file mode 100644
index 0000000..d9a56ed
--- /dev/null
+++ b/team.html
@@ -0,0 +1,292 @@
+<!DOCTYPE html>
+<!--
+ | Generated by Apache Maven Doxia Site Renderer 1.8.1 at 2018-09-25
+ | Rendered using Apache Maven Fluido Skin 1.5
+-->
+<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
+ <head>
+ <meta charset="UTF-8" />
+ <meta name="viewport" content="width=device-width, initial-scale=1.0" />
+ <meta name="Date-Revision-yyyymmdd" content="20180925" />
+ <meta http-equiv="Content-Language" content="en" />
+ <title>Apache Omid – Project Team</title>
+ <link rel="stylesheet" href="./css/apache-maven-fluido-1.5.min.css" />
+ <link rel="stylesheet" href="./css/site.css" />
+ <link rel="stylesheet" href="./css/print.css" media="print" />
+
+
+ <script type="text/javascript" src="./js/apache-maven-fluido-1.5.min.js"></script>
+
+ </head>
+ <body class="topBarEnabled">
+
+
+
+
+
+ <div id="topbar" class="navbar navbar-fixed-top ">
+ <div class="navbar-inner">
+ <div class="container" style="width: 100%;"><div class="nav-collapse">
+
+
+ <ul class="nav">
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Home <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="index.html" title="Overview">Overview</a>
+</li>
+
+ <li> <a href="license.html" title="License">License</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Download <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="https://github.com/apache/incubator-omid" title="Omid Sources">Omid Sources</a>
+</li>
+
+ <li> <a href="https://dist.apache.org/repos/dist/release/incubator/omid/" title="Apache Version Repository">Apache Version Repository</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">User Guide & API <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="quickstart.html" title="Quickstart">Quickstart</a>
+</li>
+
+ <li> <a href="basic-examples.html" title="API and Code Examples">API and Code Examples</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Technical Docs <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="basic-concepts.html" title="Basic Concepts">Basic Concepts</a>
+</li>
+
+ <li> <a href="omid-components.html" title="Omid Components">Omid Components</a>
+</li>
+
+ <li> <a href="basic-algorithm.html" title="Basic Algorithm">Basic Algorithm</a>
+</li>
+
+ <li> <a href="client-failure-management.html" title="Management of Client Failures">Management of Client Failures</a>
+</li>
+
+ <li> <a href="http://yahoohadoop.tumblr.com/tagged/HBase" title="Blog Entries">Blog Entries</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Contribute <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li> <a href="https://git-wip-us.apache.org/repos/asf/incubator-omid.git" title="Source Code">Source Code</a>
+</li>
+
+ <li> <a href="https://issues.apache.org/jira/browse/Omid" title="JIRA">JIRA</a>
+</li>
+
+ <li> <a href="mailing-lists.html" title="Mailing Lists">Mailing Lists</a>
+</li>
+
+ <li> <a href="coding-guide-and-style.html" title="Coding Guide and Style">Coding Guide and Style</a>
+</li>
+ </ul>
+ </li>
+ <li class="dropdown">
+ <a href="#" class="dropdown-toggle" data-toggle="dropdown">Project Reports <b class="caret"></b></a>
+ <ul class="dropdown-menu">
+
+ <li class="dropdown-submenu">
+ <a href="project-info.html" title="Project Information">Project Information</a>
+ <ul class="dropdown-menu">
+ <li> <a href="dependency-convergence.html" title="Dependency Convergence">Dependency Convergence</a>
+</li>
+ <li> <a href="dependency-info.html" title="Dependency Information">Dependency Information</a>
+</li>
+ <li> <a href="dependency-management.html" title="Dependency Management">Dependency Management</a>
+</li>
+ <li> <a href="distribution-management.html" title="Distribution Management">Distribution Management</a>
+</li>
+ <li> <a href="index.html" title="About">About</a>
+</li>
+ <li> <a href="licenses.html" title="Licenses">Licenses</a>
+</li>
+ <li> <a href="modules.html" title="Project Modules">Project Modules</a>
+</li>
+ <li> <a href="plugin-management.html" title="Plugin Management">Plugin Management</a>
+</li>
+ <li> <a href="plugins.html" title="Plugins">Plugins</a>
+</li>
+ <li> <a href="scm.html" title="Source Code Management">Source Code Management</a>
+</li>
+ <li> <a href="summary.html" title="Summary">Summary</a>
+</li>
+ <li> <a href="team.html" title="Team">Team</a>
+</li>
+ </ul>
+ </li>
+
+ <li class="dropdown-submenu">
+ <a href="project-reports.html" title="Project Reports">Project Reports</a>
+ <ul class="dropdown-menu">
+ <li> <a href="xref/index.html" title="Source Xref">Source Xref</a>
+</li>
+ <li> <a href="xref-test/index.html" title="Test Source Xref">Test Source Xref</a>
+</li>
+ <li> <a href="checkstyle-aggregate.html" title="Checkstyle">Checkstyle</a>
+</li>
+ <li> <a href="cpd.html" title="CPD">CPD</a>
+</li>
+ <li> <a href="pmd.html" title="PMD">PMD</a>
+</li>
+ </ul>
+ </li>
+ </ul>
+ </li>
+ </ul>
+
+ <form id="search-form" action="https://www.google.com/search" method="get" class="navbar-search pull-right" >
+
+ <input value="omid.incubator.apache.org" name="sitesearch" type="hidden"/>
+ <input class="search-query" name="q" id="query" type="text" />
+</form>
+<script type="text/javascript" src="https://cse.google.com/brand?form=search-form"></script>
+
+
+
+
+ <ul class="nav pull-right"><li>
+
+ <a href="https://twitter.com/apacheomid" class="twitter-follow-button" data-show-count="true" data-align="right" data-size="large" data-show-screen-name="true" data-lang="en">Follow apacheomid</a>
+ <script type="text/javascript">!function(d,s,id){var js,fjs=d.getElementsByTagName(s)[0];if(!d.getElementById(id)){js=d.createElement(s);js.id=id;js.src="//platform.twitter.com/widgets.js";fjs.parentNode.insertBefore(js,fjs);}}(document,"script","twitter-wjs");</script>
+
+ </li></ul>
+
+
+ </div>
+
+ </div>
+ </div>
+ </div>
+
+ <div class="container">
+ <div id="banner">
+ <div class="pull-left">
+ <a href="./" id="bannerLeft">
+ <img src="images/omid-logo.png" alt="Omid" width="200"/>
+ </a>
+ </div>
+ <div class="pull-right"> <a href="http://incubator.apache.org/" id="bannerRight">
+ <img src="http://incubator.apache.org/images/egg-logo2.png" alt="Apache Incubator" width="200"/>
+ </a>
+ </div>
+ <div class="clear"><hr/></div>
+ </div>
+
+ <div id="breadcrumbs">
+ <ul class="breadcrumb">
+
+ <li id="projectVersion">Version: 0.8.2.11-SNAPSHOT
+ </li>
+
+
+ <li id="publishDate" class="pull-right">Last Published: 2018-09-25</li>
+
+ </ul>
+ </div>
+
+
+
+ <div id="bodyColumn" >
+
+ <div class="section">
+<h2><a name="Project_Team"></a>Project Team</h2><a name="Project_Team"></a>
+<p>A successful project requires many people to play many roles. Some members write code or documentation, while others are valuable as testers, submitting patches and suggestions.</p>
+<p>The project team is comprised of Members and Contributors. Members have direct access to the source of a project and actively evolve the code-base. Contributors improve the project through submission of patches and suggestions to the Members. The number of Contributors to the project is unbounded. Get involved today. All contributions to the project are greatly appreciated.</p>
+<div class="section">
+<h3><a name="Members"></a>Members</h3><a name="Members"></a>
+<p>The following is a list of developers with commit privileges that have directly contributed to the project in one way or another.</p>
+<table border="0" class="table table-striped">
+<tr class="a">
+<th>Image</th>
+<th>Id</th>
+<th>Name</th>
+<th>Email</th>
+<th>Organization</th>
+<th>Organization URL</th>
+<th>Time Zone</th></tr>
+<tr class="b">
+<td><img src="http://www.gravatar.com/avatar/4bf5a0c9e1543f477177cd847bbb3820?d=mm&s=60" alt="" /></td>
+<td><a name="daijy"></a>daijy</td>
+<td>Daniel Dai</td>
+<td><a href="daijy@apache.org">daijy@apache.org</a></td>
+<td>Hortonworks</td>
+<td><a class="externalLink" href="http://www.hortonworks.com">http://www.hortonworks.com</a></td>
+<td>-8</td></tr>
+<tr class="a">
+<td><img src="http://www.gravatar.com/avatar/e5cbd7c2ae43f34a1107a1a126c66282?d=mm&s=60" alt="" /></td>
+<td><a name="fperezsorrosal"></a>fperezsorrosal</td>
+<td>Francisco Perez-Sorrosal</td>
+<td><a href="fperezsorrosal@apache.org">fperezsorrosal@apache.org</a></td>
+<td>Yahoo Inc.</td>
+<td><a class="externalLink" href="http://www.yahoo.com">http://www.yahoo.com</a></td>
+<td>-8</td></tr>
+<tr class="b">
+<td><img src="http://www.gravatar.com/avatar/0fe8efbb69c8f9b9232dc951ead23412?d=mm&s=60" alt="" /></td>
+<td><a name="ikatkov"></a>ikatkov</td>
+<td>Igor Katkov</td>
+<td><a href="ikatkov@apache.org">ikatkov@apache.org</a></td>
+<td>Yahoo Inc.</td>
+<td><a class="externalLink" href="http://www.yahoo.com">http://www.yahoo.com</a></td>
+<td>-8</td></tr>
+<tr class="a">
+<td><img src="http://www.gravatar.com/avatar/0068140030946c5ac8831cf4b38d1914?d=mm&s=60" alt="" /></td>
+<td><a name="ohads"></a>ohads</td>
+<td>Ohad Shacham</td>
+<td><a href="ohads@apache.org">ohads@apache.org</a></td>
+<td>Yahoo Inc.</td>
+<td><a class="externalLink" href="http://www.yahoo.com">http://www.yahoo.com</a></td>
+<td>+2</td></tr>
+<tr class="b">
+<td><img src="http://www.gravatar.com/avatar/190d84722ad887f8e99394e79dc19d9d?d=mm&s=60" alt="" /></td>
+<td><a name="sameerp"></a>sameerp</td>
+<td>Sameer Paranjpye</td>
+<td><a href="sameerp@apache.org">sameerp@apache.org</a></td>
+<td>Arimo</td>
+<td><a class="externalLink" href="https://www.arimo.com">https://www.arimo.com</a></td>
+<td>-8</td></tr></table></div>
+<div class="section">
+<h3><a name="Contributors"></a>Contributors</h3><a name="Contributors"></a>
+<p>There are no contributors listed for this project. Please check back again later.</p></div></div>
+ </div>
+ </div>
+
+ <hr/>
+
+ <footer>
+ <div class="container">
+ <div class="row">
+ <p >Copyright © 2011–2018
+ <a href="http://www.apache.org">Apache Software Foundation</a>.
+ All rights reserved.
+ </p>
+ </div>
+
+ <p id="poweredBy" class="pull-right">
+ <a href="http://maven.apache.org/" title="Maven" class="builtBy">
+ <img class="builtBy" alt="Maven" src="http://maven.apache.org/images/logos/maven-feather.png" />
+ </a>
+ </p>
+
+ </div>
+ </footer>
+ </body>
+</html>
http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/077788dd/xref-test/allclasses-frame.html
----------------------------------------------------------------------
diff --git a/xref-test/allclasses-frame.html b/xref-test/allclasses-frame.html
index 03736aa..608b7da 100644
--- a/xref-test/allclasses-frame.html
+++ b/xref-test/allclasses-frame.html
@@ -69,6 +69,9 @@
<a href="org/apache/omid/transaction/TSOForHBaseCompactorTestModule.html" target="classFrame">TSOForHBaseCompactorTestModule</a>
</li>
<li>
+ <a href="org/apache/omid/transaction/TSOForSnapshotFilterTestModule.html" target="classFrame">TSOForSnapshotFilterTestModule</a>
+ </li>
+ <li>
<a href="org/apache/omid/tso/TSOMockModule.html" target="classFrame">TSOMockModule</a>
</li>
<li>
@@ -90,13 +93,10 @@
<a href="org/apache/omid/tso/TestBatch.html" target="classFrame">TestBatch</a>
</li>
<li>
- <a href="org/apache/omid/tso/TestBatchPool.html" target="classFrame">TestBatchPool</a>
- </li>
- <li>
<a href="org/apache/omid/transaction/TestCellUtils.html" target="classFrame">TestCellUtils</a>
</li>
<li>
- <a href="org/apache/omid/TestReflectionHelper.html" target="classFrame">TestClass</a>
+ <a href="org/apache/omid/transaction/TestCheckpoint.html" target="classFrame">TestCheckpoint</a>
</li>
<li>
<a href="org/apache/omid/transaction/TestColumnIterator.html" target="classFrame">TestColumnIterator</a>
@@ -150,6 +150,9 @@
<a href="org/apache/omid/tso/TestLongCache.html" target="classFrame">TestLongCache</a>
</li>
<li>
+ <a href="org/apache/omid/transaction/TestMarkPutAsCommitted.html" target="classFrame">TestMarkPutAsCommitted</a>
+ </li>
+ <li>
<a href="org/apache/omid/tso/client/TestMockTSOClient.html" target="classFrame">TestMockTSOClient</a>
</li>
<li>
@@ -174,9 +177,6 @@
<a href="org/apache/omid/transaction/TestReadPath.html" target="classFrame">TestReadPath</a>
</li>
<li>
- <a href="org/apache/omid/TestReflectionHelper.html" target="classFrame">TestReflectionHelper</a>
- </li>
- <li>
<a href="org/apache/omid/tso/TestReplyProcessor.html" target="classFrame">TestReplyProcessor</a>
</li>
<li>
@@ -192,6 +192,9 @@
<a href="org/apache/omid/transaction/TestSingleColumnFamily.html" target="classFrame">TestSingleColumnFamily</a>
</li>
<li>
+ <a href="org/apache/omid/transaction/TestSnapshotFilter.html" target="classFrame">TestSnapshotFilter</a>
+ </li>
+ <li>
<a href="org/apache/statemachine/TestStateMachine.html" target="classFrame">TestStateMachine</a>
</li>
<li>
@@ -207,6 +210,9 @@
<a href="org/apache/omid/tso/client/TestTSOClientResponseHandling.html" target="classFrame">TestTSOClientResponseHandling</a>
</li>
<li>
+ <a href="org/apache/omid/tso/client/TestTSOClientRowAndCellLevelConflict.html" target="classFrame">TestTSOClientRowAndCellLevelConflict</a>
+ </li>
+ <li>
<a href="org/apache/omid/transaction/TestTSOModule.html" target="classFrame">TestTSOModule</a>
</li>
<li>
@@ -237,6 +243,9 @@
<a href="org/apache/omid/TestUtils.html" target="classFrame">TestUtils</a>
</li>
<li>
+ <a href="org/apache/omid/tso/TestWorldTimeOracle.html" target="classFrame">TestWorldTimeOracle</a>
+ </li>
+ <li>
<a href="org/apache/omid/timestamp/storage/TestZKTimestampStorage.html" target="classFrame">TestZKTimestampStorage</a>
</li>
<li>
http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/077788dd/xref-test/index.html
----------------------------------------------------------------------
diff --git a/xref-test/index.html b/xref-test/index.html
index 3d49b33..2834caf 100644
--- a/xref-test/index.html
+++ b/xref-test/index.html
@@ -3,7 +3,7 @@
<html xml:lang="en" lang="en">
<head>
<meta http-equiv="content-type" content="text/html; charset=UTF-8" />
- <title>Omid 0.9.0.0 Reference</title>
+ <title>Omid 0.8.2.11-SNAPSHOT Reference</title>
</head>
<frameset cols="20%,80%">
<frameset rows="30%,70%">
http://git-wip-us.apache.org/repos/asf/incubator-omid-site/blob/077788dd/xref-test/org/apache/omid/committable/hbase/TestHBaseCommitTable.html
----------------------------------------------------------------------
diff --git a/xref-test/org/apache/omid/committable/hbase/TestHBaseCommitTable.html b/xref-test/org/apache/omid/committable/hbase/TestHBaseCommitTable.html
index b17d32c..8b2c6e2 100644
--- a/xref-test/org/apache/omid/committable/hbase/TestHBaseCommitTable.html
+++ b/xref-test/org/apache/omid/committable/hbase/TestHBaseCommitTable.html
@@ -27,285 +27,296 @@
<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.committable.hbase;
<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.Optional;
-<a class="jxr_linenumber" name="21" href="#21">21</a> <strong class="jxr_keyword">import</strong> com.google.common.util.concurrent.ListenableFuture;
-<a class="jxr_linenumber" name="22" href="#22">22</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.conf.Configuration;
-<a class="jxr_linenumber" name="23" href="#23">23</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HBaseConfiguration;
-<a class="jxr_linenumber" name="24" href="#24">24</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HBaseTestingUtility;
-<a class="jxr_linenumber" name="25" href="#25">25</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HColumnDescriptor;
-<a class="jxr_linenumber" name="26" href="#26">26</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HTableDescriptor;
-<a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.MiniHBaseCluster;
-<a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.TableName;
-<a class="jxr_linenumber" name="29" href="#29">29</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.HBaseAdmin;
-<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Scan;
-<a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.coprocessor.AggregationClient;
-<a class="jxr_linenumber" name="32" href="#32">32</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.coprocessor.LongColumnInterpreter;
-<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable;
-<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable.Client;
-<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable.CommitTimestamp;
-<a class="jxr_linenumber" name="36" href="#36">36</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable.Writer;
-<a class="jxr_linenumber" name="37" href="#37">37</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.hbase.HBaseCommitTable.HBaseClient;
-<a class="jxr_linenumber" name="38" href="#38">38</a> <strong class="jxr_keyword">import</strong> org.slf4j.Logger;
-<a class="jxr_linenumber" name="39" href="#39">39</a> <strong class="jxr_keyword">import</strong> org.slf4j.LoggerFactory;
-<a class="jxr_linenumber" name="40" href="#40">40</a> <strong class="jxr_keyword">import</strong> org.testng.Assert;
-<a class="jxr_linenumber" name="41" href="#41">41</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.AfterClass;
-<a class="jxr_linenumber" name="42" href="#42">42</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.AfterMethod;
-<a class="jxr_linenumber" name="43" href="#43">43</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.BeforeClass;
-<a class="jxr_linenumber" name="44" href="#44">44</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.BeforeMethod;
-<a class="jxr_linenumber" name="45" href="#45">45</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.Test;
-<a class="jxr_linenumber" name="46" href="#46">46</a>
-<a class="jxr_linenumber" name="47" href="#47">47</a> <strong class="jxr_keyword">import</strong> java.util.concurrent.ExecutionException;
-<a class="jxr_linenumber" name="48" href="#48">48</a> <strong class="jxr_keyword">import</strong> java.util.concurrent.Future;
-<a class="jxr_linenumber" name="49" href="#49">49</a>
-<a class="jxr_linenumber" name="50" href="#50">50</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertEquals;
-<a class="jxr_linenumber" name="51" href="#51">51</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertFalse;
-<a class="jxr_linenumber" name="52" href="#52">52</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertTrue;
+<a class="jxr_linenumber" name="20" href="#20">20</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertEquals;
+<a class="jxr_linenumber" name="21" href="#21">21</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertFalse;
+<a class="jxr_linenumber" name="22" href="#22">22</a> <strong class="jxr_keyword">import</strong> <strong class="jxr_keyword">static</strong> org.testng.Assert.assertTrue;
+<a class="jxr_linenumber" name="23" href="#23">23</a>
+<a class="jxr_linenumber" name="24" href="#24">24</a> <strong class="jxr_keyword">import</strong> java.util.concurrent.ExecutionException;
+<a class="jxr_linenumber" name="25" href="#25">25</a> <strong class="jxr_keyword">import</strong> java.util.concurrent.Future;
+<a class="jxr_linenumber" name="26" href="#26">26</a>
+<a class="jxr_linenumber" name="27" href="#27">27</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.conf.Configuration;
+<a class="jxr_linenumber" name="28" href="#28">28</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HBaseConfiguration;
+<a class="jxr_linenumber" name="29" href="#29">29</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HBaseTestingUtility;
+<a class="jxr_linenumber" name="30" href="#30">30</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HColumnDescriptor;
+<a class="jxr_linenumber" name="31" href="#31">31</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.HTableDescriptor;
+<a class="jxr_linenumber" name="32" href="#32">32</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.MiniHBaseCluster;
+<a class="jxr_linenumber" name="33" href="#33">33</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.TableName;
+<a class="jxr_linenumber" name="34" href="#34">34</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Admin;
+<a class="jxr_linenumber" name="35" href="#35">35</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Connection;
+<a class="jxr_linenumber" name="36" href="#36">36</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.ConnectionFactory;
+<a class="jxr_linenumber" name="37" href="#37">37</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.ResultScanner;
+<a class="jxr_linenumber" name="38" href="#38">38</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Scan;
+<a class="jxr_linenumber" name="39" href="#39">39</a> <strong class="jxr_keyword">import</strong> org.apache.hadoop.hbase.client.Table;
+<a class="jxr_linenumber" name="40" href="#40">40</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable;
+<a class="jxr_linenumber" name="41" href="#41">41</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable.Client;
+<a class="jxr_linenumber" name="42" href="#42">42</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable.CommitTimestamp;
+<a class="jxr_linenumber" name="43" href="#43">43</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.CommitTable.Writer;
+<a class="jxr_linenumber" name="44" href="#44">44</a> <strong class="jxr_keyword">import</strong> org.apache.omid.committable.hbase.HBaseCommitTable.HBaseClient;
+<a class="jxr_linenumber" name="45" href="#45">45</a> <strong class="jxr_keyword">import</strong> org.slf4j.Logger;
+<a class="jxr_linenumber" name="46" href="#46">46</a> <strong class="jxr_keyword">import</strong> org.slf4j.LoggerFactory;
+<a class="jxr_linenumber" name="47" href="#47">47</a> <strong class="jxr_keyword">import</strong> org.testng.Assert;
+<a class="jxr_linenumber" name="48" href="#48">48</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.AfterClass;
+<a class="jxr_linenumber" name="49" href="#49">49</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.AfterMethod;
+<a class="jxr_linenumber" name="50" href="#50">50</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.BeforeClass;
+<a class="jxr_linenumber" name="51" href="#51">51</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.BeforeMethod;
+<a class="jxr_linenumber" name="52" href="#52">52</a> <strong class="jxr_keyword">import</strong> org.testng.annotations.Test;
<a class="jxr_linenumber" name="53" href="#53">53</a>
-<a class="jxr_linenumber" name="54" href="#54">54</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/omid/committable/hbase/TestHBaseCommitTable.html">TestHBaseCommitTable</a> {
-<a class="jxr_linenumber" name="55" href="#55">55</a>
-<a class="jxr_linenumber" name="56" href="#56">56</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> Logger LOG = LoggerFactory.getLogger(TestHBaseCommitTable.<strong class="jxr_keyword">class</strong>);
-<a class="jxr_linenumber" name="57" href="#57">57</a>
-<a class="jxr_linenumber" name="58" href="#58">58</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> String TEST_TABLE = <span class="jxr_string">"TEST"</span>;
-<a class="jxr_linenumber" name="59" href="#59">59</a>
-<a class="jxr_linenumber" name="60" href="#60">60</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> TableName TABLE_NAME = TableName.valueOf(TEST_TABLE);
-<a class="jxr_linenumber" name="61" href="#61">61</a>
-<a class="jxr_linenumber" name="62" href="#62">62</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> HBaseTestingUtility testutil;
-<a class="jxr_linenumber" name="63" href="#63">63</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> MiniHBaseCluster hbasecluster;
-<a class="jxr_linenumber" name="64" href="#64">64</a> <strong class="jxr_keyword">protected</strong> <strong class="jxr_keyword">static</strong> Configuration hbaseConf;
-<a class="jxr_linenumber" name="65" href="#65">65</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> AggregationClient aggregationClient;
-<a class="jxr_linenumber" name="66" href="#66">66</a> <strong class="jxr_keyword">private</strong> byte[] commitTableFamily;
-<a class="jxr_linenumber" name="67" href="#67">67</a> <strong class="jxr_keyword">private</strong> byte[] lowWatermarkFamily;
-<a class="jxr_linenumber" name="68" href="#68">68</a>
-<a class="jxr_linenumber" name="69" href="#69">69</a>
-<a class="jxr_linenumber" name="70" href="#70">70</a> @BeforeClass
-<a class="jxr_linenumber" name="71" href="#71">71</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setUpClass() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="72" href="#72">72</a> <em class="jxr_comment">// HBase setup</em>
-<a class="jxr_linenumber" name="73" href="#73">73</a> hbaseConf = HBaseConfiguration.create();
-<a class="jxr_linenumber" name="74" href="#74">74</a> DefaultHBaseCommitTableStorageModule module = <strong class="jxr_keyword">new</strong> DefaultHBaseCommitTableStorageModule();
-<a class="jxr_linenumber" name="75" href="#75">75</a> commitTableFamily = module.getFamilyName().getBytes();
-<a class="jxr_linenumber" name="76" href="#76">76</a> lowWatermarkFamily = module.getLowWatermarkFamily().getBytes();
-<a class="jxr_linenumber" name="77" href="#77">77</a> LOG.info(<span class="jxr_string">"Create hbase"</span>);
-<a class="jxr_linenumber" name="78" href="#78">78</a> testutil = <strong class="jxr_keyword">new</strong> HBaseTestingUtility(hbaseConf);
-<a class="jxr_linenumber" name="79" href="#79">79</a> hbasecluster = testutil.startMiniCluster(1);
-<a class="jxr_linenumber" name="80" href="#80">80</a> aggregationClient = <strong class="jxr_keyword">new</strong> AggregationClient(hbaseConf);
-<a class="jxr_linenumber" name="81" href="#81">81</a>
-<a class="jxr_linenumber" name="82" href="#82">82</a> }
-<a class="jxr_linenumber" name="83" href="#83">83</a>
-<a class="jxr_linenumber" name="84" href="#84">84</a> @AfterClass
-<a class="jxr_linenumber" name="85" href="#85">85</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> tearDownClass() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="86" href="#86">86</a> <strong class="jxr_keyword">if</strong> (hbasecluster != <strong class="jxr_keyword">null</strong>) {
-<a class="jxr_linenumber" name="87" href="#87">87</a> testutil.shutdownMiniCluster();
-<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>
-<a class="jxr_linenumber" name="91" href="#91">91</a> @BeforeMethod
-<a class="jxr_linenumber" name="92" href="#92">92</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setUp() <strong class="jxr_keyword">throws</strong> Exception {
-<a class="jxr_linenumber" name="93" href="#93">93</a> HBaseAdmin admin = testutil.getHBaseAdmin();
-<a class="jxr_linenumber" name="94" href="#94">94</a>
-<a class="jxr_linenumber" name="95" href="#95">95</a> <strong class="jxr_keyword">if</strong> (!admin.tableExists(TEST_TABLE)) {
-<a class="jxr_linenumber" name="96" href="#96">96</a> HTableDescriptor desc = <strong class="jxr_keyword">new</strong> HTableDescriptor(TABLE_NAME);
+<a class="jxr_linenumber" name="54" href="#54">54</a> <strong class="jxr_keyword">import</strong> com.google.common.base.Optional;
+<a class="jxr_linenumber" name="55" href="#55">55</a> <strong class="jxr_keyword">import</strong> com.google.common.util.concurrent.ListenableFuture;
+<a class="jxr_linenumber" name="56" href="#56">56</a>
+<a class="jxr_linenumber" name="57" href="#57">57</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">class</strong> <a href="../../../../../org/apache/omid/committable/hbase/TestHBaseCommitTable.html">TestHBaseCommitTable</a> {
+<a class="jxr_linenumber" name="58" href="#58">58</a>
+<a class="jxr_linenumber" name="59" href="#59">59</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> Logger LOG = LoggerFactory.getLogger(TestHBaseCommitTable.<strong class="jxr_keyword">class</strong>);
+<a class="jxr_linenumber" name="60" href="#60">60</a>
+<a class="jxr_linenumber" name="61" href="#61">61</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> String TEST_TABLE = <span class="jxr_string">"TEST"</span>;
+<a class="jxr_linenumber" name="62" href="#62">62</a>
+<a class="jxr_linenumber" name="63" href="#63">63</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">final</strong> TableName TABLE_NAME = TableName.valueOf(TEST_TABLE);
+<a class="jxr_linenumber" name="64" href="#64">64</a>
+<a class="jxr_linenumber" name="65" href="#65">65</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> HBaseTestingUtility testutil;
+<a class="jxr_linenumber" name="66" href="#66">66</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> MiniHBaseCluster hbasecluster;
+<a class="jxr_linenumber" name="67" href="#67">67</a> <strong class="jxr_keyword">protected</strong> <strong class="jxr_keyword">static</strong> Configuration hbaseConf;
+<a class="jxr_linenumber" name="68" href="#68">68</a> <strong class="jxr_keyword">protected</strong> <strong class="jxr_keyword">static</strong> Connection connection;
+<a class="jxr_linenumber" name="69" href="#69">69</a> <strong class="jxr_keyword">private</strong> byte[] commitTableFamily;
+<a class="jxr_linenumber" name="70" href="#70">70</a> <strong class="jxr_keyword">private</strong> byte[] lowWatermarkFamily;
+<a class="jxr_linenumber" name="71" href="#71">71</a>
+<a class="jxr_linenumber" name="72" href="#72">72</a>
+<a class="jxr_linenumber" name="73" href="#73">73</a> @BeforeClass
+<a class="jxr_linenumber" name="74" href="#74">74</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setUpClass() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="75" href="#75">75</a> <em class="jxr_comment">// HBase setup</em>
+<a class="jxr_linenumber" name="76" href="#76">76</a> hbaseConf = HBaseConfiguration.create();
+<a class="jxr_linenumber" name="77" href="#77">77</a> hbaseConf.setBoolean(<span class="jxr_string">"hbase.localcluster.assign.random.ports"</span>,<strong class="jxr_keyword">true</strong>);
+<a class="jxr_linenumber" name="78" href="#78">78</a> DefaultHBaseCommitTableStorageModule module = <strong class="jxr_keyword">new</strong> DefaultHBaseCommitTableStorageModule();
+<a class="jxr_linenumber" name="79" href="#79">79</a> commitTableFamily = module.getFamilyName().getBytes();
+<a class="jxr_linenumber" name="80" href="#80">80</a> lowWatermarkFamily = module.getLowWatermarkFamily().getBytes();
+<a class="jxr_linenumber" name="81" href="#81">81</a> LOG.info(<span class="jxr_string">"Create hbase"</span>);
+<a class="jxr_linenumber" name="82" href="#82">82</a> testutil = <strong class="jxr_keyword">new</strong> HBaseTestingUtility(hbaseConf);
+<a class="jxr_linenumber" name="83" href="#83">83</a> hbasecluster = testutil.startMiniCluster(1);
+<a class="jxr_linenumber" name="84" href="#84">84</a> connection = ConnectionFactory.createConnection(hbaseConf);
+<a class="jxr_linenumber" name="85" href="#85">85</a> }
+<a class="jxr_linenumber" name="86" href="#86">86</a>
+<a class="jxr_linenumber" name="87" href="#87">87</a> @AfterClass
+<a class="jxr_linenumber" name="88" href="#88">88</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> tearDownClass() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="89" href="#89">89</a> <strong class="jxr_keyword">if</strong> (hbasecluster != <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="90" href="#90">90</a> testutil.shutdownMiniCluster();
+<a class="jxr_linenumber" name="91" href="#91">91</a> }
+<a class="jxr_linenumber" name="92" href="#92">92</a> }
+<a class="jxr_linenumber" name="93" href="#93">93</a>
+<a class="jxr_linenumber" name="94" href="#94">94</a> @BeforeMethod
+<a class="jxr_linenumber" name="95" href="#95">95</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> setUp() <strong class="jxr_keyword">throws</strong> Exception {
+<a class="jxr_linenumber" name="96" href="#96">96</a> Admin admin = testutil.getHBaseAdmin();
<a class="jxr_linenumber" name="97" href="#97">97</a>
-<a class="jxr_linenumber" name="98" href="#98">98</a> HColumnDescriptor datafam = <strong class="jxr_keyword">new</strong> HColumnDescriptor(commitTableFamily);
-<a class="jxr_linenumber" name="99" href="#99">99</a> datafam.setMaxVersions(Integer.MAX_VALUE);
-<a class="jxr_linenumber" name="100" href="#100">100</a> desc.addFamily(datafam);
-<a class="jxr_linenumber" name="101" href="#101">101</a>
-<a class="jxr_linenumber" name="102" href="#102">102</a> HColumnDescriptor lowWatermarkFam = <strong class="jxr_keyword">new</strong> HColumnDescriptor(lowWatermarkFamily);
-<a class="jxr_linenumber" name="103" href="#103">103</a> lowWatermarkFam.setMaxVersions(Integer.MAX_VALUE);
-<a class="jxr_linenumber" name="104" href="#104">104</a> desc.addFamily(lowWatermarkFam);
-<a class="jxr_linenumber" name="105" href="#105">105</a>
-<a class="jxr_linenumber" name="106" href="#106">106</a> desc.addCoprocessor(<span class="jxr_string">"org.apache.hadoop.hbase.coprocessor.AggregateImplementation"</span>);
-<a class="jxr_linenumber" name="107" href="#107">107</a> admin.createTable(desc);
-<a class="jxr_linenumber" name="108" href="#108">108</a> }
-<a class="jxr_linenumber" name="109" href="#109">109</a>
-<a class="jxr_linenumber" name="110" href="#110">110</a> <strong class="jxr_keyword">if</strong> (admin.isTableDisabled(TEST_TABLE)) {
-<a class="jxr_linenumber" name="111" href="#111">111</a> admin.enableTable(TEST_TABLE);
+<a class="jxr_linenumber" name="98" href="#98">98</a> <strong class="jxr_keyword">if</strong> (!admin.tableExists(TableName.valueOf(TEST_TABLE))) {
+<a class="jxr_linenumber" name="99" href="#99">99</a> HTableDescriptor desc = <strong class="jxr_keyword">new</strong> HTableDescriptor(TABLE_NAME);
+<a class="jxr_linenumber" name="100" href="#100">100</a>
+<a class="jxr_linenumber" name="101" href="#101">101</a> HColumnDescriptor datafam = <strong class="jxr_keyword">new</strong> HColumnDescriptor(commitTableFamily);
+<a class="jxr_linenumber" name="102" href="#102">102</a> datafam.setMaxVersions(Integer.MAX_VALUE);
+<a class="jxr_linenumber" name="103" href="#103">103</a> desc.addFamily(datafam);
+<a class="jxr_linenumber" name="104" href="#104">104</a>
+<a class="jxr_linenumber" name="105" href="#105">105</a> HColumnDescriptor lowWatermarkFam = <strong class="jxr_keyword">new</strong> HColumnDescriptor(lowWatermarkFamily);
+<a class="jxr_linenumber" name="106" href="#106">106</a> lowWatermarkFam.setMaxVersions(Integer.MAX_VALUE);
+<a class="jxr_linenumber" name="107" href="#107">107</a> desc.addFamily(lowWatermarkFam);
+<a class="jxr_linenumber" name="108" href="#108">108</a>
+<a class="jxr_linenumber" name="109" href="#109">109</a> <em class="jxr_comment">// Move to HBaseSims for 2.0 support</em>
+<a class="jxr_linenumber" name="110" href="#110">110</a> <em class="jxr_comment">// For 2.0, use TableDescriptorBuilder to build TableDescriptor</em>
+<a class="jxr_linenumber" name="111" href="#111">111</a> admin.createTable(desc);
<a class="jxr_linenumber" name="112" href="#112">112</a> }
-<a class="jxr_linenumber" name="113" href="#113">113</a> HTableDescriptor[] tables = admin.listTables();
-<a class="jxr_linenumber" name="114" href="#114">114</a> <strong class="jxr_keyword">for</strong> (HTableDescriptor t : tables) {
-<a class="jxr_linenumber" name="115" href="#115">115</a> LOG.info(t.getNameAsString());
+<a class="jxr_linenumber" name="113" href="#113">113</a>
+<a class="jxr_linenumber" name="114" href="#114">114</a> <strong class="jxr_keyword">if</strong> (admin.isTableDisabled(TableName.valueOf(TEST_TABLE))) {
+<a class="jxr_linenumber" name="115" href="#115">115</a> admin.enableTable(TableName.valueOf(TEST_TABLE));
<a class="jxr_linenumber" name="116" href="#116">116</a> }
-<a class="jxr_linenumber" name="117" href="#117">117</a> }
-<a class="jxr_linenumber" name="118" href="#118">118</a>
-<a class="jxr_linenumber" name="119" href="#119">119</a> @AfterMethod
-<a class="jxr_linenumber" name="120" href="#120">120</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> tearDown() {
-<a class="jxr_linenumber" name="121" href="#121">121</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="122" href="#122">122</a> LOG.info(<span class="jxr_string">"tearing Down"</span>);
-<a class="jxr_linenumber" name="123" href="#123">123</a> HBaseAdmin admin = testutil.getHBaseAdmin();
-<a class="jxr_linenumber" name="124" href="#124">124</a> admin.disableTable(TEST_TABLE);
-<a class="jxr_linenumber" name="125" href="#125">125</a> admin.deleteTable(TEST_TABLE);
-<a class="jxr_linenumber" name="126" href="#126">126</a>
-<a class="jxr_linenumber" name="127" href="#127">127</a> } <strong class="jxr_keyword">catch</strong> (Exception e) {
-<a class="jxr_linenumber" name="128" href="#128">128</a> LOG.error(<span class="jxr_string">"Error tearing down"</span>, e);
-<a class="jxr_linenumber" name="129" href="#129">129</a> }
-<a class="jxr_linenumber" name="130" href="#130">130</a> }
-<a class="jxr_linenumber" name="131" href="#131">131</a>
-<a class="jxr_linenumber" name="132" href="#132">132</a> @Test(timeOut = 30_000)
-<a class="jxr_linenumber" name="133" href="#133">133</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testBasicBehaviour() <strong class="jxr_keyword">throws</strong> Throwable {
-<a class="jxr_linenumber" name="134" href="#134">134</a> HBaseCommitTableConfig config = <strong class="jxr_keyword">new</strong> HBaseCommitTableConfig();
-<a class="jxr_linenumber" name="135" href="#135">135</a> config.setTableName(TEST_TABLE);
-<a class="jxr_linenumber" name="136" href="#136">136</a> HBaseCommitTable commitTable = <strong class="jxr_keyword">new</strong> HBaseCommitTable(hbaseConf, config);
-<a class="jxr_linenumber" name="137" href="#137">137</a>
-<a class="jxr_linenumber" name="138" href="#138">138</a> Writer writer = commitTable.getWriter();
-<a class="jxr_linenumber" name="139" href="#139">139</a> Client client = commitTable.getClient();
-<a class="jxr_linenumber" name="140" href="#140">140</a>
-<a class="jxr_linenumber" name="141" href="#141">141</a> <em class="jxr_comment">// Test that the first time the table is empty</em>
-<a class="jxr_linenumber" name="142" href="#142">142</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
-<a class="jxr_linenumber" name="143" href="#143">143</a>
-<a class="jxr_linenumber" name="144" href="#144">144</a> <em class="jxr_comment">// Test the successful creation of 1000 txs in the table</em>
-<a class="jxr_linenumber" name="145" href="#145">145</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> i = 0; i < 1000; i++) {
-<a class="jxr_linenumber" name="146" href="#146">146</a> writer.addCommittedTransaction(i, i + 1);
-<a class="jxr_linenumber" name="147" href="#147">147</a> }
-<a class="jxr_linenumber" name="148" href="#148">148</a> writer.flush();
-<a class="jxr_linenumber" name="149" href="#149">149</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 1000, <span class="jxr_string">"Rows should be 1000!"</span>);
-<a class="jxr_linenumber" name="150" href="#150">150</a>
-<a class="jxr_linenumber" name="151" href="#151">151</a> <em class="jxr_comment">// Test the we get the right commit timestamps for each previously inserted tx</em>
-<a class="jxr_linenumber" name="152" href="#152">152</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">long</strong> i = 0; i < 1000; i++) {
-<a class="jxr_linenumber" name="153" href="#153">153</a> Optional<CommitTimestamp> commitTimestamp = client.getCommitTimestamp(i).get();
-<a class="jxr_linenumber" name="154" href="#154">154</a> assertTrue(commitTimestamp.isPresent());
-<a class="jxr_linenumber" name="155" href="#155">155</a> assertTrue(commitTimestamp.get().isValid());
-<a class="jxr_linenumber" name="156" href="#156">156</a> <strong class="jxr_keyword">long</strong> ct = commitTimestamp.get().getValue();
-<a class="jxr_linenumber" name="157" href="#157">157</a> assertEquals(ct, (i + 1), <span class="jxr_string">"Commit timestamp should be "</span> + (i + 1));
-<a class="jxr_linenumber" name="158" href="#158">158</a> }
-<a class="jxr_linenumber" name="159" href="#159">159</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 1000, <span class="jxr_string">"Rows should be 1000!"</span>);
-<a class="jxr_linenumber" name="160" href="#160">160</a>
-<a class="jxr_linenumber" name="161" href="#161">161</a> <em class="jxr_comment">// Test the successful deletion of the 1000 txs</em>
-<a class="jxr_linenumber" name="162" href="#162">162</a> Future<Void> f;
-<a class="jxr_linenumber" name="163" href="#163">163</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">long</strong> i = 0; i < 1000; i++) {
-<a class="jxr_linenumber" name="164" href="#164">164</a> f = client.completeTransaction(i);
-<a class="jxr_linenumber" name="165" href="#165">165</a> f.get();
-<a class="jxr_linenumber" name="166" href="#166">166</a> }
-<a class="jxr_linenumber" name="167" href="#167">167</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
-<a class="jxr_linenumber" name="168" href="#168">168</a>
-<a class="jxr_linenumber" name="169" href="#169">169</a> <em class="jxr_comment">// Test we don't get a commit timestamp for a non-existent transaction id in the table</em>
-<a class="jxr_linenumber" name="170" href="#170">170</a> Optional<CommitTimestamp> commitTimestamp = client.getCommitTimestamp(0).get();
-<a class="jxr_linenumber" name="171" href="#171">171</a> assertFalse(commitTimestamp.isPresent(), <span class="jxr_string">"Commit timestamp should not be present"</span>);
+<a class="jxr_linenumber" name="117" href="#117">117</a> HTableDescriptor[] tables = admin.listTables();
+<a class="jxr_linenumber" name="118" href="#118">118</a> <strong class="jxr_keyword">for</strong> (HTableDescriptor t : tables) {
+<a class="jxr_linenumber" name="119" href="#119">119</a> LOG.info(t.getNameAsString());
+<a class="jxr_linenumber" name="120" href="#120">120</a> }
+<a class="jxr_linenumber" name="121" href="#121">121</a> }
+<a class="jxr_linenumber" name="122" href="#122">122</a>
+<a class="jxr_linenumber" name="123" href="#123">123</a> @AfterMethod
+<a class="jxr_linenumber" name="124" href="#124">124</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> tearDown() {
+<a class="jxr_linenumber" name="125" href="#125">125</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="126" href="#126">126</a> LOG.info(<span class="jxr_string">"tearing Down"</span>);
+<a class="jxr_linenumber" name="127" href="#127">127</a> Admin admin = testutil.getHBaseAdmin();
+<a class="jxr_linenumber" name="128" href="#128">128</a> admin.disableTable(TableName.valueOf(TEST_TABLE));
+<a class="jxr_linenumber" name="129" href="#129">129</a> admin.deleteTable(TableName.valueOf(TEST_TABLE));
+<a class="jxr_linenumber" name="130" href="#130">130</a>
+<a class="jxr_linenumber" name="131" href="#131">131</a> } <strong class="jxr_keyword">catch</strong> (Exception e) {
+<a class="jxr_linenumber" name="132" href="#132">132</a> LOG.error(<span class="jxr_string">"Error tearing down"</span>, e);
+<a class="jxr_linenumber" name="133" href="#133">133</a> }
+<a class="jxr_linenumber" name="134" href="#134">134</a> }
+<a class="jxr_linenumber" name="135" href="#135">135</a>
+<a class="jxr_linenumber" name="136" href="#136">136</a> @Test(timeOut = 30_000)
+<a class="jxr_linenumber" name="137" href="#137">137</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testBasicBehaviour() <strong class="jxr_keyword">throws</strong> Throwable {
+<a class="jxr_linenumber" name="138" href="#138">138</a> HBaseCommitTableConfig config = <strong class="jxr_keyword">new</strong> HBaseCommitTableConfig();
+<a class="jxr_linenumber" name="139" href="#139">139</a> config.setTableName(TEST_TABLE);
+<a class="jxr_linenumber" name="140" href="#140">140</a> HBaseCommitTable commitTable = <strong class="jxr_keyword">new</strong> HBaseCommitTable(hbaseConf, config);
+<a class="jxr_linenumber" name="141" href="#141">141</a>
+<a class="jxr_linenumber" name="142" href="#142">142</a> Writer writer = commitTable.getWriter();
+<a class="jxr_linenumber" name="143" href="#143">143</a> Client client = commitTable.getClient();
+<a class="jxr_linenumber" name="144" href="#144">144</a>
+<a class="jxr_linenumber" name="145" href="#145">145</a> <em class="jxr_comment">// Test that the first time the table is empty</em>
+<a class="jxr_linenumber" name="146" href="#146">146</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
+<a class="jxr_linenumber" name="147" href="#147">147</a>
+<a class="jxr_linenumber" name="148" href="#148">148</a> <em class="jxr_comment">// Test the successful creation of 1000 txs in the table</em>
+<a class="jxr_linenumber" name="149" href="#149">149</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> i = 0; i < 1000; i++) {
+<a class="jxr_linenumber" name="150" href="#150">150</a> writer.addCommittedTransaction(i, i + 1);
+<a class="jxr_linenumber" name="151" href="#151">151</a> }
+<a class="jxr_linenumber" name="152" href="#152">152</a> writer.flush();
+<a class="jxr_linenumber" name="153" href="#153">153</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 1000, <span class="jxr_string">"Rows should be 1000!"</span>);
+<a class="jxr_linenumber" name="154" href="#154">154</a>
+<a class="jxr_linenumber" name="155" href="#155">155</a> <em class="jxr_comment">// Test the we get the right commit timestamps for each previously inserted tx</em>
+<a class="jxr_linenumber" name="156" href="#156">156</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">long</strong> i = 0; i < 1000; i++) {
+<a class="jxr_linenumber" name="157" href="#157">157</a> Optional<CommitTimestamp> commitTimestamp = client.getCommitTimestamp(i).get();
+<a class="jxr_linenumber" name="158" href="#158">158</a> assertTrue(commitTimestamp.isPresent());
+<a class="jxr_linenumber" name="159" href="#159">159</a> assertTrue(commitTimestamp.get().isValid());
+<a class="jxr_linenumber" name="160" href="#160">160</a> <strong class="jxr_keyword">long</strong> ct = commitTimestamp.get().getValue();
+<a class="jxr_linenumber" name="161" href="#161">161</a> assertEquals(ct, (i + 1), <span class="jxr_string">"Commit timestamp should be "</span> + (i + 1));
+<a class="jxr_linenumber" name="162" href="#162">162</a> }
+<a class="jxr_linenumber" name="163" href="#163">163</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 1000, <span class="jxr_string">"Rows should be 1000!"</span>);
+<a class="jxr_linenumber" name="164" href="#164">164</a>
+<a class="jxr_linenumber" name="165" href="#165">165</a> <em class="jxr_comment">// Test the successful deletion of the 1000 txs</em>
+<a class="jxr_linenumber" name="166" href="#166">166</a> Future<Void> f;
+<a class="jxr_linenumber" name="167" href="#167">167</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">long</strong> i = 0; i < 1000; i++) {
+<a class="jxr_linenumber" name="168" href="#168">168</a> f = client.completeTransaction(i);
+<a class="jxr_linenumber" name="169" href="#169">169</a> f.get();
+<a class="jxr_linenumber" name="170" href="#170">170</a> }
+<a class="jxr_linenumber" name="171" href="#171">171</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
<a class="jxr_linenumber" name="172" href="#172">172</a>
-<a class="jxr_linenumber" name="173" href="#173">173</a> <em class="jxr_comment">// Test that the first time, the low watermark family in table is empty</em>
-<a class="jxr_linenumber" name="174" href="#174">174</a> assertEquals(rowCount(TABLE_NAME, lowWatermarkFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
-<a class="jxr_linenumber" name="175" href="#175">175</a>
-<a class="jxr_linenumber" name="176" href="#176">176</a> <em class="jxr_comment">// Test the unsuccessful read of the low watermark the first time</em>
-<a class="jxr_linenumber" name="177" href="#177">177</a> ListenableFuture<Long> lowWatermarkFuture = client.readLowWatermark();
-<a class="jxr_linenumber" name="178" href="#178">178</a> assertEquals(lowWatermarkFuture.get(), Long.valueOf(0), <span class="jxr_string">"Low watermark should be 0"</span>);
+<a class="jxr_linenumber" name="173" href="#173">173</a> <em class="jxr_comment">// Test we don't get a commit timestamp for a non-existent transaction id in the table</em>
+<a class="jxr_linenumber" name="174" href="#174">174</a> Optional<CommitTimestamp> commitTimestamp = client.getCommitTimestamp(0).get();
+<a class="jxr_linenumber" name="175" href="#175">175</a> assertFalse(commitTimestamp.isPresent(), <span class="jxr_string">"Commit timestamp should not be present"</span>);
+<a class="jxr_linenumber" name="176" href="#176">176</a>
+<a class="jxr_linenumber" name="177" href="#177">177</a> <em class="jxr_comment">// Test that the first time, the low watermark family in table is empty</em>
+<a class="jxr_linenumber" name="178" href="#178">178</a> assertEquals(rowCount(TABLE_NAME, lowWatermarkFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
<a class="jxr_linenumber" name="179" href="#179">179</a>
-<a class="jxr_linenumber" name="180" href="#180">180</a> <em class="jxr_comment">// Test the successful update of the low watermark</em>
-<a class="jxr_linenumber" name="181" href="#181">181</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> lowWatermark = 0; lowWatermark < 1000; lowWatermark++) {
-<a class="jxr_linenumber" name="182" href="#182">182</a> writer.updateLowWatermark(lowWatermark);
-<a class="jxr_linenumber" name="183" href="#183">183</a> }
-<a class="jxr_linenumber" name="184" href="#184">184</a> writer.flush();
-<a class="jxr_linenumber" name="185" href="#185">185</a> assertEquals(rowCount(TABLE_NAME, lowWatermarkFamily), 1, <span class="jxr_string">"Should there be only one row!"</span>);
-<a class="jxr_linenumber" name="186" href="#186">186</a>
-<a class="jxr_linenumber" name="187" href="#187">187</a> <em class="jxr_comment">// Test the successful read of the low watermark</em>
-<a class="jxr_linenumber" name="188" href="#188">188</a> lowWatermarkFuture = client.readLowWatermark();
-<a class="jxr_linenumber" name="189" href="#189">189</a> <strong class="jxr_keyword">long</strong> lowWatermark = lowWatermarkFuture.get();
-<a class="jxr_linenumber" name="190" href="#190">190</a> assertEquals(lowWatermark, 999, <span class="jxr_string">"Low watermark should be 999"</span>);
-<a class="jxr_linenumber" name="191" href="#191">191</a> assertEquals(rowCount(TABLE_NAME, lowWatermarkFamily), 1, <span class="jxr_string">"Should there be only one row!"</span>);
-<a class="jxr_linenumber" name="192" href="#192">192</a>
-<a class="jxr_linenumber" name="193" href="#193">193</a> }
-<a class="jxr_linenumber" name="194" href="#194">194</a>
-<a class="jxr_linenumber" name="195" href="#195">195</a> @Test(timeOut = 30_000)
-<a class="jxr_linenumber" name="196" href="#196">196</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testTransactionInvalidation() <strong class="jxr_keyword">throws</strong> Throwable {
-<a class="jxr_linenumber" name="197" href="#197">197</a>
-<a class="jxr_linenumber" name="198" href="#198">198</a> <em class="jxr_comment">// Prepare test</em>
-<a class="jxr_linenumber" name="199" href="#199">199</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX1_ST = 1;
-<a class="jxr_linenumber" name="200" href="#200">200</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX1_CT = 2;
-<a class="jxr_linenumber" name="201" href="#201">201</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX2_ST = 11;
-<a class="jxr_linenumber" name="202" href="#202">202</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX2_CT = 12;
-<a class="jxr_linenumber" name="203" href="#203">203</a>
-<a class="jxr_linenumber" name="204" href="#204">204</a> HBaseCommitTableConfig config = <strong class="jxr_keyword">new</strong> HBaseCommitTableConfig();
-<a class="jxr_linenumber" name="205" href="#205">205</a> config.setTableName(TEST_TABLE);
-<a class="jxr_linenumber" name="206" href="#206">206</a> HBaseCommitTable commitTable = <strong class="jxr_keyword">new</strong> HBaseCommitTable(hbaseConf, config);
+<a class="jxr_linenumber" name="180" href="#180">180</a> <em class="jxr_comment">// Test the unsuccessful read of the low watermark the first time</em>
+<a class="jxr_linenumber" name="181" href="#181">181</a> ListenableFuture<Long> lowWatermarkFuture = client.readLowWatermark();
+<a class="jxr_linenumber" name="182" href="#182">182</a> assertEquals(lowWatermarkFuture.get(), Long.valueOf(0), <span class="jxr_string">"Low watermark should be 0"</span>);
+<a class="jxr_linenumber" name="183" href="#183">183</a>
+<a class="jxr_linenumber" name="184" href="#184">184</a> <em class="jxr_comment">// Test the successful update of the low watermark</em>
+<a class="jxr_linenumber" name="185" href="#185">185</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> lowWatermark = 0; lowWatermark < 1000; lowWatermark++) {
+<a class="jxr_linenumber" name="186" href="#186">186</a> writer.updateLowWatermark(lowWatermark);
+<a class="jxr_linenumber" name="187" href="#187">187</a> }
+<a class="jxr_linenumber" name="188" href="#188">188</a> writer.flush();
+<a class="jxr_linenumber" name="189" href="#189">189</a> assertEquals(rowCount(TABLE_NAME, lowWatermarkFamily), 1, <span class="jxr_string">"Should there be only one row!"</span>);
+<a class="jxr_linenumber" name="190" href="#190">190</a>
+<a class="jxr_linenumber" name="191" href="#191">191</a> <em class="jxr_comment">// Test the successful read of the low watermark</em>
+<a class="jxr_linenumber" name="192" href="#192">192</a> lowWatermarkFuture = client.readLowWatermark();
+<a class="jxr_linenumber" name="193" href="#193">193</a> <strong class="jxr_keyword">long</strong> lowWatermark = lowWatermarkFuture.get();
+<a class="jxr_linenumber" name="194" href="#194">194</a> assertEquals(lowWatermark, 999, <span class="jxr_string">"Low watermark should be 999"</span>);
+<a class="jxr_linenumber" name="195" href="#195">195</a> assertEquals(rowCount(TABLE_NAME, lowWatermarkFamily), 1, <span class="jxr_string">"Should there be only one row!"</span>);
+<a class="jxr_linenumber" name="196" href="#196">196</a>
+<a class="jxr_linenumber" name="197" href="#197">197</a> }
+<a class="jxr_linenumber" name="198" href="#198">198</a>
+<a class="jxr_linenumber" name="199" href="#199">199</a> @Test(timeOut = 30_000)
+<a class="jxr_linenumber" name="200" href="#200">200</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testTransactionInvalidation() <strong class="jxr_keyword">throws</strong> Throwable {
+<a class="jxr_linenumber" name="201" href="#201">201</a>
+<a class="jxr_linenumber" name="202" href="#202">202</a> <em class="jxr_comment">// Prepare test</em>
+<a class="jxr_linenumber" name="203" href="#203">203</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX1_ST = 1;
+<a class="jxr_linenumber" name="204" href="#204">204</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX1_CT = 2;
+<a class="jxr_linenumber" name="205" href="#205">205</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX2_ST = 11;
+<a class="jxr_linenumber" name="206" href="#206">206</a> <strong class="jxr_keyword">final</strong> <strong class="jxr_keyword">int</strong> TX2_CT = 12;
<a class="jxr_linenumber" name="207" href="#207">207</a>
-<a class="jxr_linenumber" name="208" href="#208">208</a> <em class="jxr_comment">// Components under test</em>
-<a class="jxr_linenumber" name="209" href="#209">209</a> Writer writer = commitTable.getWriter();
-<a class="jxr_linenumber" name="210" href="#210">210</a> Client client = commitTable.getClient();
+<a class="jxr_linenumber" name="208" href="#208">208</a> HBaseCommitTableConfig config = <strong class="jxr_keyword">new</strong> HBaseCommitTableConfig();
+<a class="jxr_linenumber" name="209" href="#209">209</a> config.setTableName(TEST_TABLE);
+<a class="jxr_linenumber" name="210" href="#210">210</a> HBaseCommitTable commitTable = <strong class="jxr_keyword">new</strong> HBaseCommitTable(hbaseConf, config);
<a class="jxr_linenumber" name="211" href="#211">211</a>
-<a class="jxr_linenumber" name="212" href="#212">212</a> <em class="jxr_comment">// Test that initially the table is empty</em>
-<a class="jxr_linenumber" name="213" href="#213">213</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
-<a class="jxr_linenumber" name="214" href="#214">214</a>
-<a class="jxr_linenumber" name="215" href="#215">215</a> <em class="jxr_comment">// Test that a transaction can be added properly to the commit table</em>
-<a class="jxr_linenumber" name="216" href="#216">216</a> writer.addCommittedTransaction(TX1_ST, TX1_CT);
-<a class="jxr_linenumber" name="217" href="#217">217</a> writer.flush();
-<a class="jxr_linenumber" name="218" href="#218">218</a> Optional<CommitTimestamp> commitTimestamp = client.getCommitTimestamp(TX1_ST).get();
-<a class="jxr_linenumber" name="219" href="#219">219</a> assertTrue(commitTimestamp.isPresent());
-<a class="jxr_linenumber" name="220" href="#220">220</a> assertTrue(commitTimestamp.get().isValid());
-<a class="jxr_linenumber" name="221" href="#221">221</a> <strong class="jxr_keyword">long</strong> ct = commitTimestamp.get().getValue();
-<a class="jxr_linenumber" name="222" href="#222">222</a> assertEquals(ct, TX1_CT, <span class="jxr_string">"Commit timestamp should be "</span> + TX1_CT);
-<a class="jxr_linenumber" name="223" href="#223">223</a>
-<a class="jxr_linenumber" name="224" href="#224">224</a> <em class="jxr_comment">// Test that a committed transaction cannot be invalidated and</em>
-<a class="jxr_linenumber" name="225" href="#225">225</a> <em class="jxr_comment">// preserves its commit timestamp after that</em>
-<a class="jxr_linenumber" name="226" href="#226">226</a> <strong class="jxr_keyword">boolean</strong> wasInvalidated = client.tryInvalidateTransaction(TX1_ST).get();
-<a class="jxr_linenumber" name="227" href="#227">227</a> assertFalse(wasInvalidated, <span class="jxr_string">"Transaction should not be invalidated"</span>);
-<a class="jxr_linenumber" name="228" href="#228">228</a>
-<a class="jxr_linenumber" name="229" href="#229">229</a> commitTimestamp = client.getCommitTimestamp(TX1_ST).get();
-<a class="jxr_linenumber" name="230" href="#230">230</a> assertTrue(commitTimestamp.isPresent());
-<a class="jxr_linenumber" name="231" href="#231">231</a> assertTrue(commitTimestamp.get().isValid());
-<a class="jxr_linenumber" name="232" href="#232">232</a> ct = commitTimestamp.get().getValue();
-<a class="jxr_linenumber" name="233" href="#233">233</a> assertEquals(ct, TX1_CT, <span class="jxr_string">"Commit timestamp should be "</span> + TX1_CT);
-<a class="jxr_linenumber" name="234" href="#234">234</a>
-<a class="jxr_linenumber" name="235" href="#235">235</a> <em class="jxr_comment">// Test that a non-committed transaction can be invalidated...</em>
-<a class="jxr_linenumber" name="236" href="#236">236</a> wasInvalidated = client.tryInvalidateTransaction(TX2_ST).get();
-<a class="jxr_linenumber" name="237" href="#237">237</a> assertTrue(wasInvalidated, <span class="jxr_string">"Transaction should be invalidated"</span>);
-<a class="jxr_linenumber" name="238" href="#238">238</a> commitTimestamp = client.getCommitTimestamp(TX2_ST).get();
-<a class="jxr_linenumber" name="239" href="#239">239</a> assertTrue(commitTimestamp.isPresent());
-<a class="jxr_linenumber" name="240" href="#240">240</a> assertFalse(commitTimestamp.get().isValid());
-<a class="jxr_linenumber" name="241" href="#241">241</a> ct = commitTimestamp.get().getValue();
-<a class="jxr_linenumber" name="242" href="#242">242</a> assertEquals(ct, CommitTable.INVALID_TRANSACTION_MARKER,
-<a class="jxr_linenumber" name="243" href="#243">243</a> <span class="jxr_string">"Commit timestamp should be "</span> + CommitTable.INVALID_TRANSACTION_MARKER);
-<a class="jxr_linenumber" name="244" href="#244">244</a> <em class="jxr_comment">// ...and that if it has been already invalidated, it remains</em>
-<a class="jxr_linenumber" name="245" href="#245">245</a> <em class="jxr_comment">// invalidated when someone tries to commit it</em>
-<a class="jxr_linenumber" name="246" href="#246">246</a> writer.addCommittedTransaction(TX2_ST, TX2_CT);
-<a class="jxr_linenumber" name="247" href="#247">247</a> writer.flush();
-<a class="jxr_linenumber" name="248" href="#248">248</a> commitTimestamp = client.getCommitTimestamp(TX2_ST).get();
-<a class="jxr_linenumber" name="249" href="#249">249</a> assertTrue(commitTimestamp.isPresent());
-<a class="jxr_linenumber" name="250" href="#250">250</a> assertFalse(commitTimestamp.get().isValid());
-<a class="jxr_linenumber" name="251" href="#251">251</a> ct = commitTimestamp.get().getValue();
-<a class="jxr_linenumber" name="252" href="#252">252</a> assertEquals(ct, CommitTable.INVALID_TRANSACTION_MARKER,
-<a class="jxr_linenumber" name="253" href="#253">253</a> <span class="jxr_string">"Commit timestamp should be "</span> + CommitTable.INVALID_TRANSACTION_MARKER);
-<a class="jxr_linenumber" name="254" href="#254">254</a>
-<a class="jxr_linenumber" name="255" href="#255">255</a> <em class="jxr_comment">// Test that at the end of the test, the commit table contains 2</em>
-<a class="jxr_linenumber" name="256" href="#256">256</a> <em class="jxr_comment">// elements, which correspond to the two rows added in the test</em>
-<a class="jxr_linenumber" name="257" href="#257">257</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 2, <span class="jxr_string">"Rows should be 2!"</span>);
+<a class="jxr_linenumber" name="212" href="#212">212</a> <em class="jxr_comment">// Components under test</em>
+<a class="jxr_linenumber" name="213" href="#213">213</a> Writer writer = commitTable.getWriter();
+<a class="jxr_linenumber" name="214" href="#214">214</a> Client client = commitTable.getClient();
+<a class="jxr_linenumber" name="215" href="#215">215</a>
+<a class="jxr_linenumber" name="216" href="#216">216</a> <em class="jxr_comment">// Test that initially the table is empty</em>
+<a class="jxr_linenumber" name="217" href="#217">217</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 0, <span class="jxr_string">"Rows should be 0!"</span>);
+<a class="jxr_linenumber" name="218" href="#218">218</a>
+<a class="jxr_linenumber" name="219" href="#219">219</a> <em class="jxr_comment">// Test that a transaction can be added properly to the commit table</em>
+<a class="jxr_linenumber" name="220" href="#220">220</a> writer.addCommittedTransaction(TX1_ST, TX1_CT);
+<a class="jxr_linenumber" name="221" href="#221">221</a> writer.flush();
+<a class="jxr_linenumber" name="222" href="#222">222</a> Optional<CommitTimestamp> commitTimestamp = client.getCommitTimestamp(TX1_ST).get();
+<a class="jxr_linenumber" name="223" href="#223">223</a> assertTrue(commitTimestamp.isPresent());
+<a class="jxr_linenumber" name="224" href="#224">224</a> assertTrue(commitTimestamp.get().isValid());
+<a class="jxr_linenumber" name="225" href="#225">225</a> <strong class="jxr_keyword">long</strong> ct = commitTimestamp.get().getValue();
+<a class="jxr_linenumber" name="226" href="#226">226</a> assertEquals(ct, TX1_CT, <span class="jxr_string">"Commit timestamp should be "</span> + TX1_CT);
+<a class="jxr_linenumber" name="227" href="#227">227</a>
+<a class="jxr_linenumber" name="228" href="#228">228</a> <em class="jxr_comment">// Test that a committed transaction cannot be invalidated and</em>
+<a class="jxr_linenumber" name="229" href="#229">229</a> <em class="jxr_comment">// preserves its commit timestamp after that</em>
+<a class="jxr_linenumber" name="230" href="#230">230</a> <strong class="jxr_keyword">boolean</strong> wasInvalidated = client.tryInvalidateTransaction(TX1_ST).get();
+<a class="jxr_linenumber" name="231" href="#231">231</a> assertFalse(wasInvalidated, <span class="jxr_string">"Transaction should not be invalidated"</span>);
+<a class="jxr_linenumber" name="232" href="#232">232</a>
+<a class="jxr_linenumber" name="233" href="#233">233</a> commitTimestamp = client.getCommitTimestamp(TX1_ST).get();
+<a class="jxr_linenumber" name="234" href="#234">234</a> assertTrue(commitTimestamp.isPresent());
+<a class="jxr_linenumber" name="235" href="#235">235</a> assertTrue(commitTimestamp.get().isValid());
+<a class="jxr_linenumber" name="236" href="#236">236</a> ct = commitTimestamp.get().getValue();
+<a class="jxr_linenumber" name="237" href="#237">237</a> assertEquals(ct, TX1_CT, <span class="jxr_string">"Commit timestamp should be "</span> + TX1_CT);
+<a class="jxr_linenumber" name="238" href="#238">238</a>
+<a class="jxr_linenumber" name="239" href="#239">239</a> <em class="jxr_comment">// Test that a non-committed transaction can be invalidated...</em>
+<a class="jxr_linenumber" name="240" href="#240">240</a> wasInvalidated = client.tryInvalidateTransaction(TX2_ST).get();
+<a class="jxr_linenumber" name="241" href="#241">241</a> assertTrue(wasInvalidated, <span class="jxr_string">"Transaction should be invalidated"</span>);
+<a class="jxr_linenumber" name="242" href="#242">242</a> commitTimestamp = client.getCommitTimestamp(TX2_ST).get();
+<a class="jxr_linenumber" name="243" href="#243">243</a> assertTrue(commitTimestamp.isPresent());
+<a class="jxr_linenumber" name="244" href="#244">244</a> assertFalse(commitTimestamp.get().isValid());
+<a class="jxr_linenumber" name="245" href="#245">245</a> ct = commitTimestamp.get().getValue();
+<a class="jxr_linenumber" name="246" href="#246">246</a> assertEquals(ct, CommitTable.INVALID_TRANSACTION_MARKER,
+<a class="jxr_linenumber" name="247" href="#247">247</a> <span class="jxr_string">"Commit timestamp should be "</span> + CommitTable.INVALID_TRANSACTION_MARKER);
+<a class="jxr_linenumber" name="248" href="#248">248</a> <em class="jxr_comment">// ...and that if it has been already invalidated, it remains</em>
+<a class="jxr_linenumber" name="249" href="#249">249</a> <em class="jxr_comment">// invalidated when someone tries to commit it</em>
+<a class="jxr_linenumber" name="250" href="#250">250</a> writer.addCommittedTransaction(TX2_ST, TX2_CT);
+<a class="jxr_linenumber" name="251" href="#251">251</a> writer.flush();
+<a class="jxr_linenumber" name="252" href="#252">252</a> commitTimestamp = client.getCommitTimestamp(TX2_ST).get();
+<a class="jxr_linenumber" name="253" href="#253">253</a> assertTrue(commitTimestamp.isPresent());
+<a class="jxr_linenumber" name="254" href="#254">254</a> assertFalse(commitTimestamp.get().isValid());
+<a class="jxr_linenumber" name="255" href="#255">255</a> ct = commitTimestamp.get().getValue();
+<a class="jxr_linenumber" name="256" href="#256">256</a> assertEquals(ct, CommitTable.INVALID_TRANSACTION_MARKER,
+<a class="jxr_linenumber" name="257" href="#257">257</a> <span class="jxr_string">"Commit timestamp should be "</span> + CommitTable.INVALID_TRANSACTION_MARKER);
<a class="jxr_linenumber" name="258" href="#258">258</a>
-<a class="jxr_linenumber" name="259" href="#259">259</a> }
-<a class="jxr_linenumber" name="260" href="#260">260</a>
-<a class="jxr_linenumber" name="261" href="#261">261</a> @Test(timeOut = 30_000)
-<a class="jxr_linenumber" name="262" href="#262">262</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testClosingClientEmptyQueuesProperly() <strong class="jxr_keyword">throws</strong> Throwable {
-<a class="jxr_linenumber" name="263" href="#263">263</a> HBaseCommitTableConfig config = <strong class="jxr_keyword">new</strong> HBaseCommitTableConfig();
-<a class="jxr_linenumber" name="264" href="#264">264</a> config.setTableName(TEST_TABLE);
-<a class="jxr_linenumber" name="265" href="#265">265</a> HBaseCommitTable commitTable = <strong class="jxr_keyword">new</strong> HBaseCommitTable(hbaseConf, config);
-<a class="jxr_linenumber" name="266" href="#266">266</a>
-<a class="jxr_linenumber" name="267" href="#267">267</a> Writer writer = commitTable.getWriter();
-<a class="jxr_linenumber" name="268" href="#268">268</a> HBaseCommitTable.HBaseClient client = (HBaseClient) commitTable.getClient();
-<a class="jxr_linenumber" name="269" href="#269">269</a>
-<a class="jxr_linenumber" name="270" href="#270">270</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> i = 0; i < 1000; i++) {
-<a class="jxr_linenumber" name="271" href="#271">271</a> writer.addCommittedTransaction(i, i + 1);
-<a class="jxr_linenumber" name="272" href="#272">272</a> }
-<a class="jxr_linenumber" name="273" href="#273">273</a> writer.flush();
-<a class="jxr_linenumber" name="274" href="#274">274</a>
-<a class="jxr_linenumber" name="275" href="#275">275</a> <em class="jxr_comment">// Completing first transaction should be fine</em>
-<a class="jxr_linenumber" name="276" href="#276">276</a> client.completeTransaction(0).get();
-<a class="jxr_linenumber" name="277" href="#277">277</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 999, <span class="jxr_string">"Rows should be 999!"</span>);
+<a class="jxr_linenumber" name="259" href="#259">259</a> <em class="jxr_comment">// Test that at the end of the test, the commit table contains 2</em>
+<a class="jxr_linenumber" name="260" href="#260">260</a> <em class="jxr_comment">// elements, which correspond to the two rows added in the test</em>
+<a class="jxr_linenumber" name="261" href="#261">261</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 2, <span class="jxr_string">"Rows should be 2!"</span>);
+<a class="jxr_linenumber" name="262" href="#262">262</a>
+<a class="jxr_linenumber" name="263" href="#263">263</a> }
+<a class="jxr_linenumber" name="264" href="#264">264</a>
+<a class="jxr_linenumber" name="265" href="#265">265</a> @Test(timeOut = 30_000)
+<a class="jxr_linenumber" name="266" href="#266">266</a> <strong class="jxr_keyword">public</strong> <strong class="jxr_keyword">void</strong> testClosingClientEmptyQueuesProperly() <strong class="jxr_keyword">throws</strong> Throwable {
+<a class="jxr_linenumber" name="267" href="#267">267</a> HBaseCommitTableConfig config = <strong class="jxr_keyword">new</strong> HBaseCommitTableConfig();
+<a class="jxr_linenumber" name="268" href="#268">268</a> config.setTableName(TEST_TABLE);
+<a class="jxr_linenumber" name="269" href="#269">269</a> HBaseCommitTable commitTable = <strong class="jxr_keyword">new</strong> HBaseCommitTable(hbaseConf, config);
+<a class="jxr_linenumber" name="270" href="#270">270</a>
+<a class="jxr_linenumber" name="271" href="#271">271</a> Writer writer = commitTable.getWriter();
+<a class="jxr_linenumber" name="272" href="#272">272</a> HBaseCommitTable.HBaseClient client = (HBaseClient) commitTable.getClient();
+<a class="jxr_linenumber" name="273" href="#273">273</a>
+<a class="jxr_linenumber" name="274" href="#274">274</a> <strong class="jxr_keyword">for</strong> (<strong class="jxr_keyword">int</strong> i = 0; i < 1000; i++) {
+<a class="jxr_linenumber" name="275" href="#275">275</a> writer.addCommittedTransaction(i, i + 1);
+<a class="jxr_linenumber" name="276" href="#276">276</a> }
+<a class="jxr_linenumber" name="277" href="#277">277</a> writer.flush();
<a class="jxr_linenumber" name="278" href="#278">278</a>
-<a class="jxr_linenumber" name="279" href="#279">279</a> <em class="jxr_comment">// When closing, removing a transaction should throw an EE with an IOException</em>
-<a class="jxr_linenumber" name="280" href="#280">280</a> client.close();
-<a class="jxr_linenumber" name="281" href="#281">281</a> <strong class="jxr_keyword">try</strong> {
-<a class="jxr_linenumber" name="282" href="#282">282</a> client.completeTransaction(1).get();
-<a class="jxr_linenumber" name="283" href="#283">283</a> Assert.fail();
-<a class="jxr_linenumber" name="284" href="#284">284</a> } <strong class="jxr_keyword">catch</strong> (ExecutionException e) {
-<a class="jxr_linenumber" name="285" href="#285">285</a> <em class="jxr_comment">// Expected</em>
-<a class="jxr_linenumber" name="286" href="#286">286</a> }
-<a class="jxr_linenumber" name="287" href="#287">287</a> assertEquals(client.deleteQueue.size(), 0, <span class="jxr_string">"Delete queue size should be 0!"</span>);
-<a class="jxr_linenumber" name="288" href="#288">288</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 999, <span class="jxr_string">"Rows should be 999!"</span>);
-<a class="jxr_linenumber" name="289" href="#289">289</a>
-<a class="jxr_linenumber" name="290" href="#290">290</a> }
-<a class="jxr_linenumber" name="291" href="#291">291</a>
-<a class="jxr_linenumber" name="292" href="#292">292</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">long</strong> rowCount(TableName table, byte[] family) <strong class="jxr_keyword">throws</strong> Throwable {
-<a class="jxr_linenumber" name="293" href="#293">293</a> Scan scan = <strong class="jxr_keyword">new</strong> Scan();
-<a class="jxr_linenumber" name="294" href="#294">294</a> scan.addFamily(family);
-<a class="jxr_linenumber" name="295" href="#295">295</a> <strong class="jxr_keyword">return</strong> aggregationClient.rowCount(table, <strong class="jxr_keyword">new</strong> LongColumnInterpreter(), scan);
-<a class="jxr_linenumber" name="296" href="#296">296</a> }
-<a class="jxr_linenumber" name="297" href="#297">297</a>
-<a class="jxr_linenumber" name="298" href="#298">298</a> }
+<a class="jxr_linenumber" name="279" href="#279">279</a> <em class="jxr_comment">// Completing first transaction should be fine</em>
+<a class="jxr_linenumber" name="280" href="#280">280</a> client.completeTransaction(0).get();
+<a class="jxr_linenumber" name="281" href="#281">281</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 999, <span class="jxr_string">"Rows should be 999!"</span>);
+<a class="jxr_linenumber" name="282" href="#282">282</a>
+<a class="jxr_linenumber" name="283" href="#283">283</a> <em class="jxr_comment">// When closing, removing a transaction should throw an EE with an IOException</em>
+<a class="jxr_linenumber" name="284" href="#284">284</a> client.close();
+<a class="jxr_linenumber" name="285" href="#285">285</a> <strong class="jxr_keyword">try</strong> {
+<a class="jxr_linenumber" name="286" href="#286">286</a> client.completeTransaction(1).get();
+<a class="jxr_linenumber" name="287" href="#287">287</a> Assert.fail();
+<a class="jxr_linenumber" name="288" href="#288">288</a> } <strong class="jxr_keyword">catch</strong> (ExecutionException e) {
+<a class="jxr_linenumber" name="289" href="#289">289</a> <em class="jxr_comment">// Expected</em>
+<a class="jxr_linenumber" name="290" href="#290">290</a> }
+<a class="jxr_linenumber" name="291" href="#291">291</a> assertEquals(client.deleteQueue.size(), 0, <span class="jxr_string">"Delete queue size should be 0!"</span>);
+<a class="jxr_linenumber" name="292" href="#292">292</a> assertEquals(rowCount(TABLE_NAME, commitTableFamily), 999, <span class="jxr_string">"Rows should be 999!"</span>);
+<a class="jxr_linenumber" name="293" href="#293">293</a>
+<a class="jxr_linenumber" name="294" href="#294">294</a> }
+<a class="jxr_linenumber" name="295" href="#295">295</a>
+<a class="jxr_linenumber" name="296" href="#296">296</a> <strong class="jxr_keyword">private</strong> <strong class="jxr_keyword">static</strong> <strong class="jxr_keyword">long</strong> rowCount(TableName tableName, byte[] family) <strong class="jxr_keyword">throws</strong> Throwable {
+<a class="jxr_linenumber" name="297" href="#297">297</a> Scan scan = <strong class="jxr_keyword">new</strong> Scan();
+<a class="jxr_linenumber" name="298" href="#298">298</a> scan.addFamily(family);
+<a class="jxr_linenumber" name="299" href="#299">299</a> Table table = connection.getTable(tableName);
+<a class="jxr_linenumber" name="300" href="#300">300</a> <strong class="jxr_keyword">try</strong> (ResultScanner scanner = table.getScanner(scan)) {
+<a class="jxr_linenumber" name="301" href="#301">301</a> <strong class="jxr_keyword">int</strong> count = 0;
+<a class="jxr_linenumber" name="302" href="#302">302</a> <strong class="jxr_keyword">while</strong> (scanner.next() != <strong class="jxr_keyword">null</strong>) {
+<a class="jxr_linenumber" name="303" href="#303">303</a> count++;
+<a class="jxr_linenumber" name="304" href="#304">304</a> }
+<a class="jxr_linenumber" name="305" href="#305">305</a> <strong class="jxr_keyword">return</strong> count;
+<a class="jxr_linenumber" name="306" href="#306">306</a> }
+<a class="jxr_linenumber" name="307" href="#307">307</a> }
+<a class="jxr_linenumber" name="308" href="#308">308</a>
+<a class="jxr_linenumber" name="309" href="#309">309</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/077788dd/xref-test/org/apache/omid/committable/hbase/package-frame.html
----------------------------------------------------------------------
diff --git a/xref-test/org/apache/omid/committable/hbase/package-frame.html b/xref-test/org/apache/omid/committable/hbase/package-frame.html
index be026b6..71b5192 100644
--- a/xref-test/org/apache/omid/committable/hbase/package-frame.html
+++ b/xref-test/org/apache/omid/committable/hbase/package-frame.html
@@ -3,7 +3,7 @@
<html xml:lang="en" lang="en">
<head>
<meta http-equiv="content-type" content="text/html; charset=UTF-8" />
- <title>Omid 0.9.0.0 Reference Package org.apache.omid.committable.hbase</title>
+ <title>Omid 0.8.2.11-SNAPSHOT Reference Package org.apache.omid.committable.hbase</title>
<link rel="stylesheet" type="text/css" href="../../../../../stylesheet.css" title="style" />
</head>
<body>