Adding tableExists

mjrusso · May 28, 2010 · 84337cc · 84337cc
1 parent 95d8eda
commit 84337cc
Show file tree

Hide file tree

Showing 4 changed files with 22 additions and 6 deletions.
diff --git a/examples/pyhbase-cli b/examples/pyhbase-cli
@@ -14,18 +14,16 @@ if __name__=="__main__":
       describe_table table
       describe_family table family
       is_table_enabled table
+      table_exists table
 
       create_table table [family1 [family2 ...]]
       enable_table table
       disable_table table
 
-      get table row [family1[:qualifier1] [family2[:qualifier2] ...]]
-
       put table row family1:qualifier1 value1 [family2:qualifier2 value2 ...]
-
-      scan table number_of_rows
-
+      get table row [family1[:qualifier1] [family2[:qualifier2] ...]]
       delete table row [family1[:qualifier1] [family2[:qualifier2] ...]]
+      scan table number_of_rows
   """ % sys.argv[0]
 
   if len(sys.argv) <= 1 or sys.argv[1] == '--help':
@@ -68,6 +66,11 @@ if __name__=="__main__":
       usage()
       sys.exit(1)
     print connection.is_table_enabled(*args)
+  elif cmd == 'table_exists':
+    if len(args) != 1:
+      usage()
+      sys.exit(1)
+    print connection.table_exists(*args)
   elif cmd == 'create_table':
     if len(args) < 1:
       usage()

diff --git a/pyhbase/connection.py b/pyhbase/connection.py
@@ -73,6 +73,11 @@ def is_table_enabled(self, table):
     """Determine if a table is enabled."""
     return self.requestor.request("isTableEnabled", {"table": table})
 
+  @retry_wrapper
+  def table_exists(self, table):
+    """Determine if a table exists."""
+    return self.requestor.request("tableExists", {"table": table})
+
   #
   # Administrative Operations
   #

diff --git a/pyhbase/schema/hbase.avpr b/pyhbase/schema/hbase.avpr
@@ -264,6 +264,14 @@
       "response" : "boolean",
       "errors" : [ "AIOError" ]
     },
+    "tableExists" : {
+      "request" : [ {
+        "name" : "table",
+        "type" : "bytes"
+      } ],
+      "response" : "boolean",
+      "errors" : [ "AIOError" ]
+    },
     "listTables" : {
       "request" : [ ],
       "response" : {

diff --git a/setup.py b/setup.py
@@ -1,7 +1,7 @@
 from setuptools import setup, find_packages
 
 setup(name="PyHBase",
-      version='0.0.6',
+      version='0.0.7',
       description="High-level Python interface to HBase",
       url="http://github.com/hammer/pyhbase/",
       packages=['pyhbase'],