Author: stack
Date: Fri Jul 24 04:45:54 2009
New Revision: 797322
URL: http://svn.apache.org/viewvc?rev=797322&view=rev
Log:
HBASE-1670 transactions / indexing fixes: trx deletes not handeled, index scan
can't specify stopRow; forgot to add a file
Added:
hadoop/hbase/trunk/src/contrib/transactional/src/java/org/apache/hadoop/hbase/client/transactional/TransactionalRPC.java
Added:
hadoop/hbase/trunk/src/contrib/transactional/src/java/org/apache/hadoop/hbase/client/transactional/TransactionalRPC.java
URL:
http://svn.apache.org/viewvc/hadoop/hbase/trunk/src/contrib/transactional/src/java/org/apache/hadoop/hbase/client/transactional/TransactionalRPC.java?rev=797322&view=auto
==============================================================================
---
hadoop/hbase/trunk/src/contrib/transactional/src/java/org/apache/hadoop/hbase/client/transactional/TransactionalRPC.java
(added)
+++
hadoop/hbase/trunk/src/contrib/transactional/src/java/org/apache/hadoop/hbase/client/transactional/TransactionalRPC.java
Fri Jul 24 04:45:54 2009
@@ -0,0 +1,27 @@
+package org.apache.hadoop.hbase.client.transactional;
+
+import org.apache.hadoop.hbase.ipc.HBaseRPC;
+import org.apache.hadoop.hbase.ipc.TransactionalRegionInterface;
+
+/** Simple class for registering the transactional RPC codes.
+ *
+ */
+public final class TransactionalRPC {
+
+ private static final byte RPC_CODE = 100;
+
+ private static boolean initialized = false;
+
+ public synchronized static void initialize() {
+ if (initialized) {
+ return;
+ }
+ HBaseRPC.addToMap(TransactionalRegionInterface.class, RPC_CODE);
+ initialized = true;
+ }
+
+ private TransactionalRPC() {
+ // Static helper class;
+ }
+
+}
