You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by xu...@apache.org on 2015/08/02 05:59:14 UTC
[29/50] hive git commit: HIVE-9152 - Dynamic Partition Pruning [Spark
Branch] (Chao Sun, reviewed by Xuefu Zhang and Chengxiang Li)
http://git-wip-us.apache.org/repos/asf/hive/blob/d7413e4b/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 4cc54e8..e299906 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.0)
+# Autogenerated by Thrift Compiler (0.9.2)
#
# DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
#
@@ -67,7 +67,7 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def get_all_databases(self, ):
+ def get_all_databases(self):
pass
def alter_database(self, dbname, db):
@@ -789,7 +789,7 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def get_role_names(self, ):
+ def get_role_names(self):
pass
def grant_role(self, role_name, principal_name, principal_type, grantor, grantorType, grant_option):
@@ -911,10 +911,10 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def get_open_txns(self, ):
+ def get_open_txns(self):
pass
- def get_open_txns_info(self, ):
+ def get_open_txns_info(self):
pass
def open_txns(self, rqst):
@@ -1008,7 +1008,7 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def get_current_notificationEventId(self, ):
+ def get_current_notificationEventId(self):
pass
def fire_listener_event(self, rqst):
@@ -1042,16 +1042,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_getMetaConf(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_getMetaConf(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = getMetaConf_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1076,16 +1077,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_setMetaConf(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_setMetaConf(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = setMetaConf_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
return
@@ -1106,16 +1108,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_create_database(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_create_database(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = create_database_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -1140,16 +1143,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_database(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_database(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_database_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1178,16 +1182,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_database(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_database(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_database_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -1212,43 +1217,45 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_databases(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_databases(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_databases_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
raise result.o1
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_databases failed: unknown result");
- def get_all_databases(self, ):
+ def get_all_databases(self):
self.send_get_all_databases()
return self.recv_get_all_databases()
- def send_get_all_databases(self, ):
+ def send_get_all_databases(self):
self._oprot.writeMessageBegin('get_all_databases', TMessageType.CALL, self._seqid)
args = get_all_databases_args()
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_all_databases(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_all_databases(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_all_databases_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1273,16 +1280,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_database(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_database(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_database_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -1305,16 +1313,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_type(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_type(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_type_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1339,16 +1348,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_create_type(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_create_type(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = create_type_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1375,16 +1385,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_type(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_type(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_type_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1409,16 +1420,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_type_all(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_type_all(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_type_all_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o2 is not None:
@@ -1443,16 +1455,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_fields(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_fields(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_fields_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1483,16 +1496,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_fields_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_fields_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_fields_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1521,16 +1535,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_schema(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_schema(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_schema_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1561,16 +1576,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_schema_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_schema_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_schema_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1597,16 +1613,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_create_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_create_table(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = create_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -1635,16 +1652,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_create_table_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_create_table_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = create_table_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -1675,16 +1693,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_table(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o3 is not None:
@@ -1713,16 +1732,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_table_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_table_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_table_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o3 is not None:
@@ -1747,16 +1767,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_tables(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_tables(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_tables_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1779,16 +1800,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_all_tables(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_all_tables(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_all_tables_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1813,16 +1835,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_table(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1849,16 +1872,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_table_objects_by_name(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_table_objects_by_name(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_table_objects_by_name_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1889,16 +1913,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_table_names_by_filter(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_table_names_by_filter(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_table_names_by_filter_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -1929,16 +1954,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_table(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_table(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_table_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -1967,16 +1993,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_table_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_table_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_table_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -2005,16 +2032,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_table_with_cascade(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_table_with_cascade(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_table_with_cascade_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -2037,16 +2065,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_add_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_add_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = add_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2075,16 +2104,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_add_partition_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_add_partition_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = add_partition_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2111,16 +2141,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_add_partitions(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_add_partitions(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = add_partitions_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2147,16 +2178,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_add_partitions_pspec(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_add_partitions_pspec(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = add_partitions_pspec_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2187,16 +2219,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_append_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_append_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = append_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2223,16 +2256,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_add_partitions_req(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_add_partitions_req(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = add_partitions_req_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2265,16 +2299,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_append_partition_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_append_partition_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = append_partition_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2305,16 +2340,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_append_partition_by_name(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_append_partition_by_name(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = append_partition_by_name_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2347,16 +2383,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_append_partition_by_name_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_append_partition_by_name_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = append_partition_by_name_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2389,16 +2426,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2431,16 +2469,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_partition_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_partition_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_partition_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2471,16 +2510,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_partition_by_name(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_partition_by_name(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_partition_by_name_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2513,16 +2553,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_partition_by_name_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_partition_by_name_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_partition_by_name_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2547,16 +2588,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_partitions_req(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_partitions_req(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_partitions_req_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2585,16 +2627,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2627,16 +2670,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_exchange_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_exchange_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = exchange_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2673,16 +2717,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partition_with_auth(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partition_with_auth(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partition_with_auth_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2711,16 +2756,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partition_by_name(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partition_by_name(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partition_by_name_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2749,16 +2795,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2791,16 +2838,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_with_auth(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_with_auth(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_with_auth_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2829,16 +2877,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_pspec(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_pspec(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_pspec_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2867,16 +2916,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partition_names(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partition_names(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partition_names_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o2 is not None:
@@ -2905,16 +2955,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_ps(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_ps(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_ps_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2949,16 +3000,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_ps_with_auth(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_ps_with_auth(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_ps_with_auth_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -2989,16 +3041,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partition_names_ps(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partition_names_ps(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partition_names_ps_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3029,16 +3082,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_by_filter(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_by_filter(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_by_filter_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3069,16 +3123,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_part_specs_by_filter(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_part_specs_by_filter(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_part_specs_by_filter_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3103,16 +3158,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_by_expr(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_by_expr(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_by_expr_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3141,16 +3197,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_by_names(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_by_names(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_by_names_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3179,16 +3236,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -3215,16 +3273,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_partitions(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_partitions(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_partitions_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -3253,16 +3312,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_partition_with_environment_context(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_partition_with_environment_context(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_partition_with_environment_context_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -3291,16 +3351,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_rename_partition(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_rename_partition(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = rename_partition_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -3325,16 +3386,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_partition_name_has_valid_characters(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_partition_name_has_valid_characters(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = partition_name_has_valid_characters_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3359,16 +3421,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_config_value(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_config_value(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_config_value_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3391,16 +3454,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_partition_name_to_vals(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_partition_name_to_vals(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = partition_name_to_vals_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3423,16 +3487,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_partition_name_to_spec(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_partition_name_to_spec(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = partition_name_to_spec_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3461,16 +3526,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_markPartitionForEvent(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_markPartitionForEvent(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = markPartitionForEvent_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -3507,16 +3573,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_isPartitionMarkedForEvent(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_isPartitionMarkedForEvent(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = isPartitionMarkedForEvent_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3551,16 +3618,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_add_index(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_add_index(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = add_index_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3593,16 +3661,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_index(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_index(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_index_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -3631,16 +3700,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_index_by_name(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_index_by_name(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_index_by_name_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3669,16 +3739,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_index_by_name(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_index_by_name(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_index_by_name_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3707,16 +3778,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_indexes(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_indexes(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_indexes_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3745,16 +3817,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_index_names(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_index_names(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_index_names_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o2 is not None:
@@ -3777,16 +3850,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_update_table_column_statistics(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_update_table_column_statistics(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = update_table_column_statistics_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3815,16 +3889,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_update_partition_column_statistics(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_update_partition_column_statistics(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = update_partition_column_statistics_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3857,16 +3932,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_table_column_statistics(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_table_column_statistics(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_table_column_statistics_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3901,16 +3977,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partition_column_statistics(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partition_column_statistics(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partition_column_statistics_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3939,16 +4016,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_table_statistics_req(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_table_statistics_req(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_table_statistics_req_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -3973,16 +4051,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_partitions_statistics_req(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_partitions_statistics_req(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_partitions_statistics_req_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4007,16 +4086,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_aggr_stats_for(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_aggr_stats_for(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_aggr_stats_for_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4041,16 +4121,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_set_aggr_stats_for(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_set_aggr_stats_for(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = set_aggr_stats_for_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4085,16 +4166,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_delete_partition_column_statistics(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_delete_partition_column_statistics(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = delete_partition_column_statistics_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4127,16 +4209,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_delete_table_column_statistics(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_delete_table_column_statistics(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = delete_table_column_statistics_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4165,16 +4248,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_create_function(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_create_function(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = create_function_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -4203,16 +4287,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_function(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_function(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_function_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o3 is not None:
@@ -4239,16 +4324,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_alter_function(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_alter_function(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = alter_function_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.o1 is not None:
raise result.o1
if result.o2 is not None:
@@ -4273,16 +4359,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_functions(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_functions(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_functions_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4307,16 +4394,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_function(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_function(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_function_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4341,16 +4429,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_create_role(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_create_role(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = create_role_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4373,43 +4462,45 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_drop_role(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_drop_role(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = drop_role_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
raise result.o1
raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_role failed: unknown result");
- def get_role_names(self, ):
+ def get_role_names(self):
self.send_get_role_names()
return self.recv_get_role_names()
- def send_get_role_names(self, ):
+ def send_get_role_names(self):
self._oprot.writeMessageBegin('get_role_names', TMessageType.CALL, self._seqid)
args = get_role_names_args()
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_role_names(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_role_names(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_role_names_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4442,16 +4533,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_grant_role(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_grant_role(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = grant_role_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4478,16 +4570,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_revoke_role(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_revoke_role(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = revoke_role_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4512,16 +4605,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_list_roles(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_list_roles(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = list_roles_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4544,16 +4638,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_grant_revoke_role(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_grant_revoke_role(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = grant_revoke_role_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4576,16 +4671,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_principals_in_role(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_principals_in_role(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_principals_in_role_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4608,16 +4704,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_role_grants_for_principal(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_role_grants_for_principal(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_role_grants_for_principal_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4644,16 +4741,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_privilege_set(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_privilege_set(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_privilege_set_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4680,16 +4778,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_list_privileges(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_list_privileges(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = list_privileges_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4712,16 +4811,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_grant_privileges(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_grant_privileges(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = grant_privileges_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4744,16 +4844,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_revoke_privileges(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_revoke_privileges(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = revoke_privileges_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4776,16 +4877,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_grant_revoke_privileges(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_grant_revoke_privileges(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = grant_revoke_privileges_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4810,16 +4912,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_set_ugi(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_set_ugi(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = set_ugi_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4844,16 +4947,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_get_delegation_token(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_get_delegation_token(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = get_delegation_token_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4876,16 +4980,17 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_renew_delegation_token(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_renew_delegation_token(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EXCEPTION:
x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
+ x.read(iprot)
+ iprot.readMessageEnd()
raise x
result = renew_delegation_token_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
+ result.read(iprot)
+ iprot.readMessageEnd()
if result.success is not None:
return result.success
if result.o1 is not None:
@@ -4908,66 +5013,69 @@ class Client(fb303.FacebookService.Client, Iface):
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
- def recv_cancel_delegation_token(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ def recv_cancel_delegation_token(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
if mtype == TMessageType.EX
<TRUNCATED>