hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amareshw...@apache.org
Subject [12/23] hive git commit: HIVE-11487 : Adds getNumPartitionsByFilter api in metastore api
Date Mon, 21 Dec 2015 08:46:02 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/ccb30e3e/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 97acb5d..6e90d16 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -1,5 +1,5 @@
 #
-# Autogenerated by Thrift Compiler (0.9.3)
+# Autogenerated by Thrift Compiler (0.9.2)
 #
 # DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
 #
@@ -8,7 +8,6 @@
 
 from thrift.Thrift import TType, TMessageType, TException, TApplicationException
 import fb303.FacebookService
-import logging
 from ttypes import *
 from thrift.Thrift import TProcessor
 from thrift.transport import TTransport
@@ -524,6 +523,15 @@ class Iface(fb303.FacebookService.Iface):
     """
     pass
 
+  def get_num_partitions_by_filter(self, db_name, tbl_name, filter):
+    """
+    Parameters:
+     - db_name
+     - tbl_name
+     - filter
+    """
+    pass
+
   def get_partitions_by_names(self, db_name, tbl_name, names):
     """
     Parameters:
@@ -1119,7 +1127,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "getMetaConf failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "getMetaConf failed: unknown result");
 
   def setMetaConf(self, key, value):
     """
@@ -1222,7 +1230,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_database failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_database failed: unknown result");
 
   def drop_database(self, name, deleteData, cascade):
     """
@@ -1294,7 +1302,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result");
 
   def get_all_databases(self):
     self.send_get_all_databases()
@@ -1322,7 +1330,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_databases failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_databases failed: unknown result");
 
   def alter_database(self, dbname, db):
     """
@@ -1392,7 +1400,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type failed: unknown result");
 
   def create_type(self, type):
     """
@@ -1429,7 +1437,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "create_type failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "create_type failed: unknown result");
 
   def drop_type(self, type):
     """
@@ -1464,7 +1472,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_type failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_type failed: unknown result");
 
   def get_type_all(self, name):
     """
@@ -1497,7 +1505,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type_all failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_type_all failed: unknown result");
 
   def get_fields(self, db_name, table_name):
     """
@@ -1536,7 +1544,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields failed: unknown result");
 
   def get_fields_with_environment_context(self, db_name, table_name, environment_context):
     """
@@ -1577,7 +1585,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_fields_with_environment_context failed: unknown result");
 
   def get_schema(self, db_name, table_name):
     """
@@ -1616,7 +1624,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema failed: unknown result");
 
   def get_schema_with_environment_context(self, db_name, table_name, environment_context):
     """
@@ -1657,7 +1665,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_schema_with_environment_context failed: unknown result");
 
   def create_table(self, tbl):
     """
@@ -1844,7 +1852,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_tables failed: unknown result");
 
   def get_table_meta(self, db_patterns, tbl_patterns, tbl_types):
     """
@@ -1881,7 +1889,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_meta failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_meta failed: unknown result");
 
   def get_all_tables(self, db_name):
     """
@@ -1914,7 +1922,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_tables failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_tables failed: unknown result");
 
   def get_table(self, dbname, tbl_name):
     """
@@ -1951,7 +1959,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table failed: unknown result");
 
   def get_table_objects_by_name(self, dbname, tbl_names):
     """
@@ -1990,7 +1998,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_objects_by_name failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_objects_by_name failed: unknown result");
 
   def get_table_names_by_filter(self, dbname, filter, max_tables):
     """
@@ -2031,7 +2039,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_names_by_filter failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_names_by_filter failed: unknown result");
 
   def alter_table(self, dbname, tbl_name, new_tbl):
     """
@@ -2183,7 +2191,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition failed: unknown result");
 
   def add_partition_with_environment_context(self, new_part, environment_context):
     """
@@ -2222,7 +2230,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partition_with_environment_context failed: unknown result");
 
   def add_partitions(self, new_parts):
     """
@@ -2259,7 +2267,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions failed: unknown result");
 
   def add_partitions_pspec(self, new_parts):
     """
@@ -2296,7 +2304,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_pspec failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_pspec failed: unknown result");
 
   def append_partition(self, db_name, tbl_name, part_vals):
     """
@@ -2337,7 +2345,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition failed: unknown result");
 
   def add_partitions_req(self, request):
     """
@@ -2374,7 +2382,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_req failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_partitions_req failed: unknown result");
 
   def append_partition_with_environment_context(self, db_name, tbl_name, part_vals, environment_context):
     """
@@ -2417,7 +2425,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_with_environment_context failed: unknown result");
 
   def append_partition_by_name(self, db_name, tbl_name, part_name):
     """
@@ -2458,7 +2466,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name failed: unknown result");
 
   def append_partition_by_name_with_environment_context(self, db_name, tbl_name, part_name, environment_context):
     """
@@ -2501,7 +2509,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "append_partition_by_name_with_environment_context failed: unknown result");
 
   def drop_partition(self, db_name, tbl_name, part_vals, deleteData):
     """
@@ -2542,7 +2550,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition failed: unknown result");
 
   def drop_partition_with_environment_context(self, db_name, tbl_name, part_vals, deleteData, environment_context):
     """
@@ -2585,7 +2593,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_with_environment_context failed: unknown result");
 
   def drop_partition_by_name(self, db_name, tbl_name, part_name, deleteData):
     """
@@ -2626,7 +2634,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name failed: unknown result");
 
   def drop_partition_by_name_with_environment_context(self, db_name, tbl_name, part_name, deleteData, environment_context):
     """
@@ -2669,7 +2677,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name_with_environment_context failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name_with_environment_context failed: unknown result");
 
   def drop_partitions_req(self, req):
     """
@@ -2704,7 +2712,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partitions_req failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partitions_req failed: unknown result");
 
   def get_partition(self, db_name, tbl_name, part_vals):
     """
@@ -2743,7 +2751,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition failed: unknown result");
 
   def exchange_partition(self, partitionSpecs, source_db, source_table_name, dest_db, dest_table_name):
     """
@@ -2790,7 +2798,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "exchange_partition failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "exchange_partition failed: unknown result");
 
   def exchange_partitions(self, partitionSpecs, source_db, source_table_name, dest_db, dest_table_name):
     """
@@ -2837,7 +2845,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "exchange_partitions failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "exchange_partitions failed: unknown result");
 
   def get_partition_with_auth(self, db_name, tbl_name, part_vals, user_name, group_names):
     """
@@ -2880,7 +2888,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_with_auth failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_with_auth failed: unknown result");
 
   def get_partition_by_name(self, db_name, tbl_name, part_name):
     """
@@ -2919,7 +2927,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_by_name failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_by_name failed: unknown result");
 
   def get_partitions(self, db_name, tbl_name, max_parts):
     """
@@ -2958,7 +2966,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions failed: unknown result");
 
   def get_partitions_with_auth(self, db_name, tbl_name, max_parts, user_name, group_names):
     """
@@ -3001,7 +3009,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_with_auth failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_with_auth failed: unknown result");
 
   def get_partitions_pspec(self, db_name, tbl_name, max_parts):
     """
@@ -3040,7 +3048,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_pspec failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_pspec failed: unknown result");
 
   def get_partition_names(self, db_name, tbl_name, max_parts):
     """
@@ -3077,7 +3085,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names failed: unknown result");
 
   def get_partitions_ps(self, db_name, tbl_name, part_vals, max_parts):
     """
@@ -3118,7 +3126,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps failed: unknown result");
 
   def get_partitions_ps_with_auth(self, db_name, tbl_name, part_vals, max_parts, user_name, group_names):
     """
@@ -3163,7 +3171,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps_with_auth failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_ps_with_auth failed: unknown result");
 
   def get_partition_names_ps(self, db_name, tbl_name, part_vals, max_parts):
     """
@@ -3204,7 +3212,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names_ps failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_names_ps failed: unknown result");
 
   def get_partitions_by_filter(self, db_name, tbl_name, filter, max_parts):
     """
@@ -3245,7 +3253,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_filter failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_filter failed: unknown result");
 
   def get_part_specs_by_filter(self, db_name, tbl_name, filter, max_parts):
     """
@@ -3286,7 +3294,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_part_specs_by_filter failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_part_specs_by_filter failed: unknown result");
 
   def get_partitions_by_expr(self, req):
     """
@@ -3321,7 +3329,46 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_expr failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_expr failed: unknown result");
+
+  def get_num_partitions_by_filter(self, db_name, tbl_name, filter):
+    """
+    Parameters:
+     - db_name
+     - tbl_name
+     - filter
+    """
+    self.send_get_num_partitions_by_filter(db_name, tbl_name, filter)
+    return self.recv_get_num_partitions_by_filter()
+
+  def send_get_num_partitions_by_filter(self, db_name, tbl_name, filter):
+    self._oprot.writeMessageBegin('get_num_partitions_by_filter', TMessageType.CALL, self._seqid)
+    args = get_num_partitions_by_filter_args()
+    args.db_name = db_name
+    args.tbl_name = tbl_name
+    args.filter = filter
+    args.write(self._oprot)
+    self._oprot.writeMessageEnd()
+    self._oprot.trans.flush()
+
+  def recv_get_num_partitions_by_filter(self):
+    iprot = self._iprot
+    (fname, mtype, rseqid) = iprot.readMessageBegin()
+    if mtype == TMessageType.EXCEPTION:
+      x = TApplicationException()
+      x.read(iprot)
+      iprot.readMessageEnd()
+      raise x
+    result = get_num_partitions_by_filter_result()
+    result.read(iprot)
+    iprot.readMessageEnd()
+    if result.success is not None:
+      return result.success
+    if result.o1 is not None:
+      raise result.o1
+    if result.o2 is not None:
+      raise result.o2
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_num_partitions_by_filter failed: unknown result");
 
   def get_partitions_by_names(self, db_name, tbl_name, names):
     """
@@ -3360,7 +3407,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_by_names failed: unknown result");
 
   def alter_partition(self, db_name, tbl_name, new_part):
     """
@@ -3547,7 +3594,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_has_valid_characters failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_has_valid_characters failed: unknown result");
 
   def get_config_value(self, name, defaultValue):
     """
@@ -3582,7 +3629,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_config_value failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_config_value failed: unknown result");
 
   def partition_name_to_vals(self, part_name):
     """
@@ -3615,7 +3662,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_vals failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_vals failed: unknown result");
 
   def partition_name_to_spec(self, part_name):
     """
@@ -3648,7 +3695,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_spec failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "partition_name_to_spec failed: unknown result");
 
   def markPartitionForEvent(self, db_name, tbl_name, part_vals, eventType):
     """
@@ -3744,7 +3791,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o5
     if result.o6 is not None:
       raise result.o6
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result");
 
   def add_index(self, new_index, index_table):
     """
@@ -3783,7 +3830,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_index failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "add_index failed: unknown result");
 
   def alter_index(self, dbname, base_tbl_name, idx_name, new_idx):
     """
@@ -3863,7 +3910,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_index_by_name failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_index_by_name failed: unknown result");
 
   def get_index_by_name(self, db_name, tbl_name, index_name):
     """
@@ -3902,7 +3949,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_by_name failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_by_name failed: unknown result");
 
   def get_indexes(self, db_name, tbl_name, max_indexes):
     """
@@ -3941,7 +3988,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_indexes failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_indexes failed: unknown result");
 
   def get_index_names(self, db_name, tbl_name, max_indexes):
     """
@@ -3978,7 +4025,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result");
 
   def update_table_column_statistics(self, stats_obj):
     """
@@ -4017,7 +4064,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "update_table_column_statistics failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "update_table_column_statistics failed: unknown result");
 
   def update_partition_column_statistics(self, stats_obj):
     """
@@ -4056,7 +4103,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "update_partition_column_statistics failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "update_partition_column_statistics failed: unknown result");
 
   def get_table_column_statistics(self, db_name, tbl_name, col_name):
     """
@@ -4099,7 +4146,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_column_statistics failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_column_statistics failed: unknown result");
 
   def get_partition_column_statistics(self, db_name, tbl_name, part_name, col_name):
     """
@@ -4144,7 +4191,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_column_statistics failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partition_column_statistics failed: unknown result");
 
   def get_table_statistics_req(self, request):
     """
@@ -4179,7 +4226,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_statistics_req failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_statistics_req failed: unknown result");
 
   def get_partitions_statistics_req(self, request):
     """
@@ -4214,7 +4261,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_statistics_req failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_partitions_statistics_req failed: unknown result");
 
   def get_aggr_stats_for(self, request):
     """
@@ -4249,7 +4296,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result");
 
   def set_aggr_stats_for(self, request):
     """
@@ -4288,7 +4335,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "set_aggr_stats_for failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "set_aggr_stats_for failed: unknown result");
 
   def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name):
     """
@@ -4333,7 +4380,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_partition_column_statistics failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_partition_column_statistics failed: unknown result");
 
   def delete_table_column_statistics(self, db_name, tbl_name, col_name):
     """
@@ -4376,7 +4423,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o3
     if result.o4 is not None:
       raise result.o4
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_table_column_statistics failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "delete_table_column_statistics failed: unknown result");
 
   def create_function(self, func):
     """
@@ -4520,7 +4567,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_functions failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_functions failed: unknown result");
 
   def get_function(self, dbName, funcName):
     """
@@ -4557,7 +4604,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_function failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_function failed: unknown result");
 
   def get_all_functions(self):
     self.send_get_all_functions()
@@ -4585,7 +4632,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_functions failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_all_functions failed: unknown result");
 
   def create_role(self, role):
     """
@@ -4618,7 +4665,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "create_role failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "create_role failed: unknown result");
 
   def drop_role(self, role_name):
     """
@@ -4651,7 +4698,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_role failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_role failed: unknown result");
 
   def get_role_names(self):
     self.send_get_role_names()
@@ -4679,7 +4726,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_names failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_names failed: unknown result");
 
   def grant_role(self, role_name, principal_name, principal_type, grantor, grantorType, grant_option):
     """
@@ -4722,7 +4769,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_role failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_role failed: unknown result");
 
   def revoke_role(self, role_name, principal_name, principal_type):
     """
@@ -4759,7 +4806,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_role failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_role failed: unknown result");
 
   def list_roles(self, principal_name, principal_type):
     """
@@ -4794,7 +4841,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "list_roles failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "list_roles failed: unknown result");
 
   def grant_revoke_role(self, request):
     """
@@ -4827,7 +4874,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_role failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_role failed: unknown result");
 
   def get_principals_in_role(self, request):
     """
@@ -4860,7 +4907,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_principals_in_role failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_principals_in_role failed: unknown result");
 
   def get_role_grants_for_principal(self, request):
     """
@@ -4893,7 +4940,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_grants_for_principal failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_role_grants_for_principal failed: unknown result");
 
   def get_privilege_set(self, hiveObject, user_name, group_names):
     """
@@ -4930,7 +4977,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_privilege_set failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_privilege_set failed: unknown result");
 
   def list_privileges(self, principal_name, principal_type, hiveObject):
     """
@@ -4967,7 +5014,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "list_privileges failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "list_privileges failed: unknown result");
 
   def grant_privileges(self, privileges):
     """
@@ -5000,7 +5047,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_privileges failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_privileges failed: unknown result");
 
   def revoke_privileges(self, privileges):
     """
@@ -5033,7 +5080,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_privileges failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "revoke_privileges failed: unknown result");
 
   def grant_revoke_privileges(self, request):
     """
@@ -5066,7 +5113,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_privileges failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "grant_revoke_privileges failed: unknown result");
 
   def set_ugi(self, user_name, group_names):
     """
@@ -5101,7 +5148,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "set_ugi failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "set_ugi failed: unknown result");
 
   def get_delegation_token(self, token_owner, renewer_kerberos_principal_name):
     """
@@ -5136,7 +5183,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_delegation_token failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_delegation_token failed: unknown result");
 
   def renew_delegation_token(self, token_str_form):
     """
@@ -5169,7 +5216,7 @@ class Client(fb303.FacebookService.Client, Iface):
       return result.success
     if result.o1 is not None:
       raise result.o1
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "renew_delegation_token failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "renew_delegation_token failed: unknown result");
 
   def cancel_delegation_token(self, token_str_form):
     """
@@ -5226,7 +5273,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns failed: unknown result");
 
   def get_open_txns_info(self):
     self.send_get_open_txns_info()
@@ -5252,7 +5299,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns_info failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_open_txns_info failed: unknown result");
 
   def open_txns(self, rqst):
     """
@@ -5283,7 +5330,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "open_txns failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "open_txns failed: unknown result");
 
   def abort_txn(self, rqst):
     """
@@ -5382,7 +5429,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o1
     if result.o2 is not None:
       raise result.o2
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "lock failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "lock failed: unknown result");
 
   def check_lock(self, rqst):
     """
@@ -5419,7 +5466,7 @@ class Client(fb303.FacebookService.Client, Iface):
       raise result.o2
     if result.o3 is not None:
       raise result.o3
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "check_lock failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "check_lock failed: unknown result");
 
   def unlock(self, rqst):
     """
@@ -5483,7 +5530,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "show_locks failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "show_locks failed: unknown result");
 
   def heartbeat(self, ids):
     """
@@ -5549,7 +5596,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "heartbeat_txn_range failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "heartbeat_txn_range failed: unknown result");
 
   def compact(self, rqst):
     """
@@ -5609,7 +5656,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result");
 
   def add_dynamic_partitions(self, rqst):
     """
@@ -5673,7 +5720,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result");
 
   def get_current_notificationEventId(self):
     self.send_get_current_notificationEventId()
@@ -5699,7 +5746,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result");
 
   def fire_listener_event(self, rqst):
     """
@@ -5730,7 +5777,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "fire_listener_event failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "fire_listener_event failed: unknown result");
 
   def flushCache(self):
     self.send_flushCache()
@@ -5785,7 +5832,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata_by_expr failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata_by_expr failed: unknown result");
 
   def get_file_metadata(self, req):
     """
@@ -5816,7 +5863,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "get_file_metadata failed: unknown result");
 
   def put_file_metadata(self, req):
     """
@@ -5847,7 +5894,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "put_file_metadata failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "put_file_metadata failed: unknown result");
 
   def clear_file_metadata(self, req):
     """
@@ -5878,7 +5925,7 @@ class Client(fb303.FacebookService.Client, Iface):
     iprot.readMessageEnd()
     if result.success is not None:
       return result.success
-    raise TApplicationException(TApplicationException.MISSING_RESULT, "clear_file_metadata failed: unknown result")
+    raise TApplicationException(TApplicationException.MISSING_RESULT, "clear_file_metadata failed: unknown result");
 
   def cache_file_metadata(self, req):
     """
@@ -5973,6 +6020,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     self._processMap["get_partitions_by_filter"] = Processor.process_get_partitions_by_filter
     self._processMap["get_part_specs_by_filter"] = Processor.process_get_part_specs_by_filter
     self._processMap["get_partitions_by_expr"] = Processor.process_get_partitions_by_expr
+    self._processMap["get_num_partitions_by_filter"] = Processor.process_get_num_partitions_by_filter
     self._processMap["get_partitions_by_names"] = Processor.process_get_partitions_by_names
     self._processMap["alter_partition"] = Processor.process_alter_partition
     self._processMap["alter_partitions"] = Processor.process_alter_partitions
@@ -6070,17 +6118,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = getMetaConf_result()
     try:
       result.success = self._handler.getMetaConf(args.key)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("getMetaConf", msg_type, seqid)
+    oprot.writeMessageBegin("getMetaConf", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6092,17 +6132,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = setMetaConf_result()
     try:
       self._handler.setMetaConf(args.key, args.value)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("setMetaConf", msg_type, seqid)
+    oprot.writeMessageBegin("setMetaConf", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6114,23 +6146,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = create_database_result()
     try:
       self._handler.create_database(args.database)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except AlreadyExistsException as o1:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o1:
       result.o1 = o1
-    except InvalidObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("create_database", msg_type, seqid)
+    oprot.writeMessageBegin("create_database", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6142,20 +6164,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_database_result()
     try:
       result.success = self._handler.get_database(args.name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except NoSuchObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o1:
       result.o1 = o1
-    except MetaException as o2:
-      msg_type = TMessageType.REPLY
+    except MetaException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_database", msg_type, seqid)
+    oprot.writeMessageBegin("get_database", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6167,23 +6180,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = drop_database_result()
     try:
       self._handler.drop_database(args.name, args.deleteData, args.cascade)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except NoSuchObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o1:
       result.o1 = o1
-    except InvalidOperationException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidOperationException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("drop_database", msg_type, seqid)
+    oprot.writeMessageBegin("drop_database", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6195,17 +6198,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_databases_result()
     try:
       result.success = self._handler.get_databases(args.pattern)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_databases", msg_type, seqid)
+    oprot.writeMessageBegin("get_databases", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6217,17 +6212,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_all_databases_result()
     try:
       result.success = self._handler.get_all_databases()
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_all_databases", msg_type, seqid)
+    oprot.writeMessageBegin("get_all_databases", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6239,20 +6226,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = alter_database_result()
     try:
       self._handler.alter_database(args.dbname, args.db)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except NoSuchObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("alter_database", msg_type, seqid)
+    oprot.writeMessageBegin("alter_database", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6264,20 +6242,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_type_result()
     try:
       result.success = self._handler.get_type(args.name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except NoSuchObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_type", msg_type, seqid)
+    oprot.writeMessageBegin("get_type", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6289,23 +6258,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = create_type_result()
     try:
       result.success = self._handler.create_type(args.type)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except AlreadyExistsException as o1:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o1:
       result.o1 = o1
-    except InvalidObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("create_type", msg_type, seqid)
+    oprot.writeMessageBegin("create_type", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6317,20 +6276,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = drop_type_result()
     try:
       result.success = self._handler.drop_type(args.type)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except NoSuchObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("drop_type", msg_type, seqid)
+    oprot.writeMessageBegin("drop_type", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6342,17 +6292,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_type_all_result()
     try:
       result.success = self._handler.get_type_all(args.name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o2:
-      msg_type = TMessageType.REPLY
+    except MetaException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_type_all", msg_type, seqid)
+    oprot.writeMessageBegin("get_type_all", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6364,23 +6306,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_fields_result()
     try:
       result.success = self._handler.get_fields(args.db_name, args.table_name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except UnknownTableException as o2:
-      msg_type = TMessageType.REPLY
+    except UnknownTableException, o2:
       result.o2 = o2
-    except UnknownDBException as o3:
-      msg_type = TMessageType.REPLY
+    except UnknownDBException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_fields", msg_type, seqid)
+    oprot.writeMessageBegin("get_fields", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6392,23 +6324,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_fields_with_environment_context_result()
     try:
       result.success = self._handler.get_fields_with_environment_context(args.db_name, args.table_name, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except UnknownTableException as o2:
-      msg_type = TMessageType.REPLY
+    except UnknownTableException, o2:
       result.o2 = o2
-    except UnknownDBException as o3:
-      msg_type = TMessageType.REPLY
+    except UnknownDBException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_fields_with_environment_context", msg_type, seqid)
+    oprot.writeMessageBegin("get_fields_with_environment_context", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6420,23 +6342,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_schema_result()
     try:
       result.success = self._handler.get_schema(args.db_name, args.table_name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except UnknownTableException as o2:
-      msg_type = TMessageType.REPLY
+    except UnknownTableException, o2:
       result.o2 = o2
-    except UnknownDBException as o3:
-      msg_type = TMessageType.REPLY
+    except UnknownDBException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_schema", msg_type, seqid)
+    oprot.writeMessageBegin("get_schema", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6448,23 +6360,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_schema_with_environment_context_result()
     try:
       result.success = self._handler.get_schema_with_environment_context(args.db_name, args.table_name, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except UnknownTableException as o2:
-      msg_type = TMessageType.REPLY
+    except UnknownTableException, o2:
       result.o2 = o2
-    except UnknownDBException as o3:
-      msg_type = TMessageType.REPLY
+    except UnknownDBException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_schema_with_environment_context", msg_type, seqid)
+    oprot.writeMessageBegin("get_schema_with_environment_context", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6476,26 +6378,15 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = create_table_result()
     try:
       self._handler.create_table(args.tbl)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except AlreadyExistsException as o1:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o1:
       result.o1 = o1
-    except InvalidObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except NoSuchObjectException as o4:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o4:
       result.o4 = o4
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("create_table", msg_type, seqid)
+    oprot.writeMessageBegin("create_table", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6507,26 +6398,15 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = create_table_with_environment_context_result()
     try:
       self._handler.create_table_with_environment_context(args.tbl, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except AlreadyExistsException as o1:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o1:
       result.o1 = o1
-    except InvalidObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except NoSuchObjectException as o4:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o4:
       result.o4 = o4
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("create_table_with_environment_context", msg_type, seqid)
+    oprot.writeMessageBegin("create_table_with_environment_context", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6538,20 +6418,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = drop_table_result()
     try:
       self._handler.drop_table(args.dbname, args.name, args.deleteData)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except NoSuchObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o1:
       result.o1 = o1
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("drop_table", msg_type, seqid)
+    oprot.writeMessageBegin("drop_table", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6563,20 +6434,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = drop_table_with_environment_context_result()
     try:
       self._handler.drop_table_with_environment_context(args.dbname, args.name, args.deleteData, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except NoSuchObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o1:
       result.o1 = o1
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("drop_table_with_environment_context", msg_type, seqid)
+    oprot.writeMessageBegin("drop_table_with_environment_context", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6588,17 +6450,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_tables_result()
     try:
       result.success = self._handler.get_tables(args.db_name, args.pattern)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_tables", msg_type, seqid)
+    oprot.writeMessageBegin("get_tables", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6610,17 +6464,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_table_meta_result()
     try:
       result.success = self._handler.get_table_meta(args.db_patterns, args.tbl_patterns, args.tbl_types)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_table_meta", msg_type, seqid)
+    oprot.writeMessageBegin("get_table_meta", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6632,17 +6478,9 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_all_tables_result()
     try:
       result.success = self._handler.get_all_tables(args.db_name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_all_tables", msg_type, seqid)
+    oprot.writeMessageBegin("get_all_tables", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6654,20 +6492,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_table_result()
     try:
       result.success = self._handler.get_table(args.dbname, args.tbl_name)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except NoSuchObjectException as o2:
-      msg_type = TMessageType.REPLY
+    except NoSuchObjectException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_table", msg_type, seqid)
+    oprot.writeMessageBegin("get_table", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6679,23 +6508,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_table_objects_by_name_result()
     try:
       result.success = self._handler.get_table_objects_by_name(args.dbname, args.tbl_names)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except InvalidOperationException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidOperationException, o2:
       result.o2 = o2
-    except UnknownDBException as o3:
-      msg_type = TMessageType.REPLY
+    except UnknownDBException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_table_objects_by_name", msg_type, seqid)
+    oprot.writeMessageBegin("get_table_objects_by_name", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6707,23 +6526,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = get_table_names_by_filter_result()
     try:
       result.success = self._handler.get_table_names_by_filter(args.dbname, args.filter, args.max_tables)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except MetaException as o1:
-      msg_type = TMessageType.REPLY
+    except MetaException, o1:
       result.o1 = o1
-    except InvalidOperationException as o2:
-      msg_type = TMessageType.REPLY
+    except InvalidOperationException, o2:
       result.o2 = o2
-    except UnknownDBException as o3:
-      msg_type = TMessageType.REPLY
+    except UnknownDBException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("get_table_names_by_filter", msg_type, seqid)
+    oprot.writeMessageBegin("get_table_names_by_filter", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6735,20 +6544,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = alter_table_result()
     try:
       self._handler.alter_table(args.dbname, args.tbl_name, args.new_tbl)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidOperationException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidOperationException, o1:
       result.o1 = o1
-    except MetaException as o2:
-      msg_type = TMessageType.REPLY
+    except MetaException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("alter_table", msg_type, seqid)
+    oprot.writeMessageBegin("alter_table", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6760,20 +6560,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = alter_table_with_environment_context_result()
     try:
       self._handler.alter_table_with_environment_context(args.dbname, args.tbl_name, args.new_tbl, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidOperationException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidOperationException, o1:
       result.o1 = o1
-    except MetaException as o2:
-      msg_type = TMessageType.REPLY
+    except MetaException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("alter_table_with_environment_context", msg_type, seqid)
+    oprot.writeMessageBegin("alter_table_with_environment_context", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6785,20 +6576,11 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = alter_table_with_cascade_result()
     try:
       self._handler.alter_table_with_cascade(args.dbname, args.tbl_name, args.new_tbl, args.cascade)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidOperationException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidOperationException, o1:
       result.o1 = o1
-    except MetaException as o2:
-      msg_type = TMessageType.REPLY
+    except MetaException, o2:
       result.o2 = o2
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("alter_table_with_cascade", msg_type, seqid)
+    oprot.writeMessageBegin("alter_table_with_cascade", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6810,23 +6592,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = add_partition_result()
     try:
       result.success = self._handler.add_partition(args.new_part)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("add_partition", msg_type, seqid)
+    oprot.writeMessageBegin("add_partition", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6838,23 +6610,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = add_partition_with_environment_context_result()
     try:
       result.success = self._handler.add_partition_with_environment_context(args.new_part, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("add_partition_with_environment_context", msg_type, seqid)
+    oprot.writeMessageBegin("add_partition_with_environment_context", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6866,23 +6628,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = add_partitions_result()
     try:
       result.success = self._handler.add_partitions(args.new_parts)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("add_partitions", msg_type, seqid)
+    oprot.writeMessageBegin("add_partitions", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6894,23 +6646,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = add_partitions_pspec_result()
     try:
       result.success = self._handler.add_partitions_pspec(args.new_parts)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("add_partitions_pspec", msg_type, seqid)
+    oprot.writeMessageBegin("add_partitions_pspec", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6922,23 +6664,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = append_partition_result()
     try:
       result.success = self._handler.append_partition(args.db_name, args.tbl_name, args.part_vals)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("append_partition", msg_type, seqid)
+    oprot.writeMessageBegin("append_partition", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6950,23 +6682,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = add_partitions_req_result()
     try:
       result.success = self._handler.add_partitions_req(args.request)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessageBegin("add_partitions_req", msg_type, seqid)
+    oprot.writeMessageBegin("add_partitions_req", TMessageType.REPLY, seqid)
     result.write(oprot)
     oprot.writeMessageEnd()
     oprot.trans.flush()
@@ -6978,23 +6700,13 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
     result = append_partition_with_environment_context_result()
     try:
       result.success = self._handler.append_partition_with_environment_context(args.db_name, args.tbl_name, args.part_vals, args.environment_context)
-      msg_type = TMessageType.REPLY
-    except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
-      raise
-    except InvalidObjectException as o1:
-      msg_type = TMessageType.REPLY
+    except InvalidObjectException, o1:
       result.o1 = o1
-    except AlreadyExistsException as o2:
-      msg_type = TMessageType.REPLY
+    except AlreadyExistsException, o2:
       result.o2 = o2
-    except MetaException as o3:
-      msg_type = TMessageType.REPLY
+    except MetaException, o3:
       result.o3 = o3
-    except Exception as ex:
-      msg_type = TMessageType.EXCEPTION
-      logging.exception(ex)
-      result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
-    oprot.writeMessa

<TRUNCATED>

Mime
View raw message