You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/11/06 19:44:51 UTC
[02/10] hive git commit: HIVE-17907 : enable and apply resource plan
commands in HS2 (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index e627952..0351cd8 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -1307,6 +1307,13 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_active_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
def get_all_resource_plans(self, request):
"""
Parameters:
@@ -7269,6 +7276,39 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_resource_plan failed: unknown result")
+ def get_active_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_active_resource_plan(request)
+ return self.recv_get_active_resource_plan()
+
+ def send_get_active_resource_plan(self, request):
+ self._oprot.writeMessageBegin('get_active_resource_plan', TMessageType.CALL, self._seqid)
+ args = get_active_resource_plan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_active_resource_plan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_active_resource_plan_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o2 is not None:
+ raise result.o2
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_active_resource_plan failed: unknown result")
+
def get_all_resource_plans(self, request):
"""
Parameters:
@@ -7727,6 +7767,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["get_metastore_db_uuid"] = Processor.process_get_metastore_db_uuid
self._processMap["create_resource_plan"] = Processor.process_create_resource_plan
self._processMap["get_resource_plan"] = Processor.process_get_resource_plan
+ self._processMap["get_active_resource_plan"] = Processor.process_get_active_resource_plan
self._processMap["get_all_resource_plans"] = Processor.process_get_all_resource_plans
self._processMap["alter_resource_plan"] = Processor.process_alter_resource_plan
self._processMap["validate_resource_plan"] = Processor.process_validate_resource_plan
@@ -11749,6 +11790,28 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_active_resource_plan(self, seqid, iprot, oprot):
+ args = get_active_resource_plan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_active_resource_plan_result()
+ try:
+ result.success = self._handler.get_active_resource_plan(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except MetaException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("get_active_resource_plan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_get_all_resource_plans(self, seqid, iprot, oprot):
args = get_all_resource_plans_args()
args.read(iprot)
@@ -12850,10 +12913,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype667, _size664) = iprot.readListBegin()
- for _i668 in xrange(_size664):
- _elem669 = iprot.readString()
- self.success.append(_elem669)
+ (_etype695, _size692) = iprot.readListBegin()
+ for _i696 in xrange(_size692):
+ _elem697 = iprot.readString()
+ self.success.append(_elem697)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12876,8 +12939,8 @@ class get_databases_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter670 in self.success:
- oprot.writeString(iter670)
+ for iter698 in self.success:
+ oprot.writeString(iter698)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12982,10 +13045,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype674, _size671) = iprot.readListBegin()
- for _i675 in xrange(_size671):
- _elem676 = iprot.readString()
- self.success.append(_elem676)
+ (_etype702, _size699) = iprot.readListBegin()
+ for _i703 in xrange(_size699):
+ _elem704 = iprot.readString()
+ self.success.append(_elem704)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13008,8 +13071,8 @@ class get_all_databases_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter677 in self.success:
- oprot.writeString(iter677)
+ for iter705 in self.success:
+ oprot.writeString(iter705)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13779,12 +13842,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype679, _vtype680, _size678 ) = iprot.readMapBegin()
- for _i682 in xrange(_size678):
- _key683 = iprot.readString()
- _val684 = Type()
- _val684.read(iprot)
- self.success[_key683] = _val684
+ (_ktype707, _vtype708, _size706 ) = iprot.readMapBegin()
+ for _i710 in xrange(_size706):
+ _key711 = iprot.readString()
+ _val712 = Type()
+ _val712.read(iprot)
+ self.success[_key711] = _val712
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13807,9 +13870,9 @@ class get_type_all_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter685,viter686 in self.success.items():
- oprot.writeString(kiter685)
- viter686.write(oprot)
+ for kiter713,viter714 in self.success.items():
+ oprot.writeString(kiter713)
+ viter714.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -13952,11 +14015,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = FieldSchema()
- _elem692.read(iprot)
- self.success.append(_elem692)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = FieldSchema()
+ _elem720.read(iprot)
+ self.success.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13991,8 +14054,8 @@ class get_fields_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter693 in self.success:
- iter693.write(oprot)
+ for iter721 in self.success:
+ iter721.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14159,11 +14222,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = FieldSchema()
- _elem699.read(iprot)
- self.success.append(_elem699)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = FieldSchema()
+ _elem727.read(iprot)
+ self.success.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14198,8 +14261,8 @@ class get_fields_with_environment_context_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter700 in self.success:
- iter700.write(oprot)
+ for iter728 in self.success:
+ iter728.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14352,11 +14415,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = FieldSchema()
- _elem706.read(iprot)
- self.success.append(_elem706)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = FieldSchema()
+ _elem734.read(iprot)
+ self.success.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14391,8 +14454,8 @@ class get_schema_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter707 in self.success:
- iter707.write(oprot)
+ for iter735 in self.success:
+ iter735.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14559,11 +14622,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = FieldSchema()
- _elem713.read(iprot)
- self.success.append(_elem713)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = FieldSchema()
+ _elem741.read(iprot)
+ self.success.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14598,8 +14661,8 @@ class get_schema_with_environment_context_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter714 in self.success:
- iter714.write(oprot)
+ for iter742 in self.success:
+ iter742.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15046,44 +15109,44 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = SQLPrimaryKey()
- _elem720.read(iprot)
- self.primaryKeys.append(_elem720)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = SQLPrimaryKey()
+ _elem748.read(iprot)
+ self.primaryKeys.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype724, _size721) = iprot.readListBegin()
- for _i725 in xrange(_size721):
- _elem726 = SQLForeignKey()
- _elem726.read(iprot)
- self.foreignKeys.append(_elem726)
+ (_etype752, _size749) = iprot.readListBegin()
+ for _i753 in xrange(_size749):
+ _elem754 = SQLForeignKey()
+ _elem754.read(iprot)
+ self.foreignKeys.append(_elem754)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype730, _size727) = iprot.readListBegin()
- for _i731 in xrange(_size727):
- _elem732 = SQLUniqueConstraint()
- _elem732.read(iprot)
- self.uniqueConstraints.append(_elem732)
+ (_etype758, _size755) = iprot.readListBegin()
+ for _i759 in xrange(_size755):
+ _elem760 = SQLUniqueConstraint()
+ _elem760.read(iprot)
+ self.uniqueConstraints.append(_elem760)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype736, _size733) = iprot.readListBegin()
- for _i737 in xrange(_size733):
- _elem738 = SQLNotNullConstraint()
- _elem738.read(iprot)
- self.notNullConstraints.append(_elem738)
+ (_etype764, _size761) = iprot.readListBegin()
+ for _i765 in xrange(_size761):
+ _elem766 = SQLNotNullConstraint()
+ _elem766.read(iprot)
+ self.notNullConstraints.append(_elem766)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15104,29 +15167,29 @@ class create_table_with_constraints_args:
if self.primaryKeys is not None:
oprot.writeFieldBegin('primaryKeys', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys))
- for iter739 in self.primaryKeys:
- iter739.write(oprot)
+ for iter767 in self.primaryKeys:
+ iter767.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.foreignKeys is not None:
oprot.writeFieldBegin('foreignKeys', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys))
- for iter740 in self.foreignKeys:
- iter740.write(oprot)
+ for iter768 in self.foreignKeys:
+ iter768.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.uniqueConstraints is not None:
oprot.writeFieldBegin('uniqueConstraints', TType.LIST, 4)
oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraints))
- for iter741 in self.uniqueConstraints:
- iter741.write(oprot)
+ for iter769 in self.uniqueConstraints:
+ iter769.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.notNullConstraints is not None:
oprot.writeFieldBegin('notNullConstraints', TType.LIST, 5)
oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraints))
- for iter742 in self.notNullConstraints:
- iter742.write(oprot)
+ for iter770 in self.notNullConstraints:
+ iter770.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16392,10 +16455,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = iprot.readString()
- self.partNames.append(_elem748)
+ (_etype774, _size771) = iprot.readListBegin()
+ for _i775 in xrange(_size771):
+ _elem776 = iprot.readString()
+ self.partNames.append(_elem776)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16420,8 +16483,8 @@ class truncate_table_args:
if self.partNames is not None:
oprot.writeFieldBegin('partNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.partNames))
- for iter749 in self.partNames:
- oprot.writeString(iter749)
+ for iter777 in self.partNames:
+ oprot.writeString(iter777)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16621,10 +16684,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = iprot.readString()
- self.success.append(_elem755)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = iprot.readString()
+ self.success.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16647,8 +16710,8 @@ class get_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter756 in self.success:
- oprot.writeString(iter756)
+ for iter784 in self.success:
+ oprot.writeString(iter784)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16798,10 +16861,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype760, _size757) = iprot.readListBegin()
- for _i761 in xrange(_size757):
- _elem762 = iprot.readString()
- self.success.append(_elem762)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = iprot.readString()
+ self.success.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16824,8 +16887,8 @@ class get_tables_by_type_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter763 in self.success:
- oprot.writeString(iter763)
+ for iter791 in self.success:
+ oprot.writeString(iter791)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16898,10 +16961,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype767, _size764) = iprot.readListBegin()
- for _i768 in xrange(_size764):
- _elem769 = iprot.readString()
- self.tbl_types.append(_elem769)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = iprot.readString()
+ self.tbl_types.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16926,8 +16989,8 @@ class get_table_meta_args:
if self.tbl_types is not None:
oprot.writeFieldBegin('tbl_types', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.tbl_types))
- for iter770 in self.tbl_types:
- oprot.writeString(iter770)
+ for iter798 in self.tbl_types:
+ oprot.writeString(iter798)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16983,11 +17046,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype774, _size771) = iprot.readListBegin()
- for _i775 in xrange(_size771):
- _elem776 = TableMeta()
- _elem776.read(iprot)
- self.success.append(_elem776)
+ (_etype802, _size799) = iprot.readListBegin()
+ for _i803 in xrange(_size799):
+ _elem804 = TableMeta()
+ _elem804.read(iprot)
+ self.success.append(_elem804)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17010,8 +17073,8 @@ class get_table_meta_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter777 in self.success:
- iter777.write(oprot)
+ for iter805 in self.success:
+ iter805.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17135,10 +17198,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype781, _size778) = iprot.readListBegin()
- for _i782 in xrange(_size778):
- _elem783 = iprot.readString()
- self.success.append(_elem783)
+ (_etype809, _size806) = iprot.readListBegin()
+ for _i810 in xrange(_size806):
+ _elem811 = iprot.readString()
+ self.success.append(_elem811)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17161,8 +17224,8 @@ class get_all_tables_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter784 in self.success:
- oprot.writeString(iter784)
+ for iter812 in self.success:
+ oprot.writeString(iter812)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17398,10 +17461,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype788, _size785) = iprot.readListBegin()
- for _i789 in xrange(_size785):
- _elem790 = iprot.readString()
- self.tbl_names.append(_elem790)
+ (_etype816, _size813) = iprot.readListBegin()
+ for _i817 in xrange(_size813):
+ _elem818 = iprot.readString()
+ self.tbl_names.append(_elem818)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17422,8 +17485,8 @@ class get_table_objects_by_name_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter791 in self.tbl_names:
- oprot.writeString(iter791)
+ for iter819 in self.tbl_names:
+ oprot.writeString(iter819)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17475,11 +17538,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype795, _size792) = iprot.readListBegin()
- for _i796 in xrange(_size792):
- _elem797 = Table()
- _elem797.read(iprot)
- self.success.append(_elem797)
+ (_etype823, _size820) = iprot.readListBegin()
+ for _i824 in xrange(_size820):
+ _elem825 = Table()
+ _elem825.read(iprot)
+ self.success.append(_elem825)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17496,8 +17559,8 @@ class get_table_objects_by_name_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter798 in self.success:
- iter798.write(oprot)
+ for iter826 in self.success:
+ iter826.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17980,10 +18043,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = iprot.readString()
- self.success.append(_elem804)
+ (_etype830, _size827) = iprot.readListBegin()
+ for _i831 in xrange(_size827):
+ _elem832 = iprot.readString()
+ self.success.append(_elem832)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18018,8 +18081,8 @@ class get_table_names_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter805 in self.success:
- oprot.writeString(iter805)
+ for iter833 in self.success:
+ oprot.writeString(iter833)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18989,11 +19052,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = Partition()
- _elem811.read(iprot)
- self.new_parts.append(_elem811)
+ (_etype837, _size834) = iprot.readListBegin()
+ for _i838 in xrange(_size834):
+ _elem839 = Partition()
+ _elem839.read(iprot)
+ self.new_parts.append(_elem839)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19010,8 +19073,8 @@ class add_partitions_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter812 in self.new_parts:
- iter812.write(oprot)
+ for iter840 in self.new_parts:
+ iter840.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19169,11 +19232,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = PartitionSpec()
- _elem818.read(iprot)
- self.new_parts.append(_elem818)
+ (_etype844, _size841) = iprot.readListBegin()
+ for _i845 in xrange(_size841):
+ _elem846 = PartitionSpec()
+ _elem846.read(iprot)
+ self.new_parts.append(_elem846)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19190,8 +19253,8 @@ class add_partitions_pspec_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter819 in self.new_parts:
- iter819.write(oprot)
+ for iter847 in self.new_parts:
+ iter847.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19365,10 +19428,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = iprot.readString()
- self.part_vals.append(_elem825)
+ (_etype851, _size848) = iprot.readListBegin()
+ for _i852 in xrange(_size848):
+ _elem853 = iprot.readString()
+ self.part_vals.append(_elem853)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19393,8 +19456,8 @@ class append_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter826 in self.part_vals:
- oprot.writeString(iter826)
+ for iter854 in self.part_vals:
+ oprot.writeString(iter854)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19747,10 +19810,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype830, _size827) = iprot.readListBegin()
- for _i831 in xrange(_size827):
- _elem832 = iprot.readString()
- self.part_vals.append(_elem832)
+ (_etype858, _size855) = iprot.readListBegin()
+ for _i859 in xrange(_size855):
+ _elem860 = iprot.readString()
+ self.part_vals.append(_elem860)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19781,8 +19844,8 @@ class append_partition_with_environment_context_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter833 in self.part_vals:
- oprot.writeString(iter833)
+ for iter861 in self.part_vals:
+ oprot.writeString(iter861)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -20377,10 +20440,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype837, _size834) = iprot.readListBegin()
- for _i838 in xrange(_size834):
- _elem839 = iprot.readString()
- self.part_vals.append(_elem839)
+ (_etype865, _size862) = iprot.readListBegin()
+ for _i866 in xrange(_size862):
+ _elem867 = iprot.readString()
+ self.part_vals.append(_elem867)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20410,8 +20473,8 @@ class drop_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter840 in self.part_vals:
- oprot.writeString(iter840)
+ for iter868 in self.part_vals:
+ oprot.writeString(iter868)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -20584,10 +20647,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype844, _size841) = iprot.readListBegin()
- for _i845 in xrange(_size841):
- _elem846 = iprot.readString()
- self.part_vals.append(_elem846)
+ (_etype872, _size869) = iprot.readListBegin()
+ for _i873 in xrange(_size869):
+ _elem874 = iprot.readString()
+ self.part_vals.append(_elem874)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20623,8 +20686,8 @@ class drop_partition_with_environment_context_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter847 in self.part_vals:
- oprot.writeString(iter847)
+ for iter875 in self.part_vals:
+ oprot.writeString(iter875)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -21361,10 +21424,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype851, _size848) = iprot.readListBegin()
- for _i852 in xrange(_size848):
- _elem853 = iprot.readString()
- self.part_vals.append(_elem853)
+ (_etype879, _size876) = iprot.readListBegin()
+ for _i880 in xrange(_size876):
+ _elem881 = iprot.readString()
+ self.part_vals.append(_elem881)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21389,8 +21452,8 @@ class get_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter854 in self.part_vals:
- oprot.writeString(iter854)
+ for iter882 in self.part_vals:
+ oprot.writeString(iter882)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21549,11 +21612,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype856, _vtype857, _size855 ) = iprot.readMapBegin()
- for _i859 in xrange(_size855):
- _key860 = iprot.readString()
- _val861 = iprot.readString()
- self.partitionSpecs[_key860] = _val861
+ (_ktype884, _vtype885, _size883 ) = iprot.readMapBegin()
+ for _i887 in xrange(_size883):
+ _key888 = iprot.readString()
+ _val889 = iprot.readString()
+ self.partitionSpecs[_key888] = _val889
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21590,9 +21653,9 @@ class exchange_partition_args:
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
- for kiter862,viter863 in self.partitionSpecs.items():
- oprot.writeString(kiter862)
- oprot.writeString(viter863)
+ for kiter890,viter891 in self.partitionSpecs.items():
+ oprot.writeString(kiter890)
+ oprot.writeString(viter891)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21797,11 +21860,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype865, _vtype866, _size864 ) = iprot.readMapBegin()
- for _i868 in xrange(_size864):
- _key869 = iprot.readString()
- _val870 = iprot.readString()
- self.partitionSpecs[_key869] = _val870
+ (_ktype893, _vtype894, _size892 ) = iprot.readMapBegin()
+ for _i896 in xrange(_size892):
+ _key897 = iprot.readString()
+ _val898 = iprot.readString()
+ self.partitionSpecs[_key897] = _val898
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21838,9 +21901,9 @@ class exchange_partitions_args:
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
- for kiter871,viter872 in self.partitionSpecs.items():
- oprot.writeString(kiter871)
- oprot.writeString(viter872)
+ for kiter899,viter900 in self.partitionSpecs.items():
+ oprot.writeString(kiter899)
+ oprot.writeString(viter900)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21923,11 +21986,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype876, _size873) = iprot.readListBegin()
- for _i877 in xrange(_size873):
- _elem878 = Partition()
- _elem878.read(iprot)
- self.success.append(_elem878)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = Partition()
+ _elem906.read(iprot)
+ self.success.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21968,8 +22031,8 @@ class exchange_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter879 in self.success:
- iter879.write(oprot)
+ for iter907 in self.success:
+ iter907.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22063,10 +22126,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype883, _size880) = iprot.readListBegin()
- for _i884 in xrange(_size880):
- _elem885 = iprot.readString()
- self.part_vals.append(_elem885)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = iprot.readString()
+ self.part_vals.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22078,10 +22141,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype889, _size886) = iprot.readListBegin()
- for _i890 in xrange(_size886):
- _elem891 = iprot.readString()
- self.group_names.append(_elem891)
+ (_etype917, _size914) = iprot.readListBegin()
+ for _i918 in xrange(_size914):
+ _elem919 = iprot.readString()
+ self.group_names.append(_elem919)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22106,8 +22169,8 @@ class get_partition_with_auth_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter892 in self.part_vals:
- oprot.writeString(iter892)
+ for iter920 in self.part_vals:
+ oprot.writeString(iter920)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -22117,8 +22180,8 @@ class get_partition_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter893 in self.group_names:
- oprot.writeString(iter893)
+ for iter921 in self.group_names:
+ oprot.writeString(iter921)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22547,11 +22610,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = Partition()
- _elem899.read(iprot)
- self.success.append(_elem899)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = Partition()
+ _elem927.read(iprot)
+ self.success.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22580,8 +22643,8 @@ class get_partitions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter900 in self.success:
- iter900.write(oprot)
+ for iter928 in self.success:
+ iter928.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22675,10 +22738,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = iprot.readString()
- self.group_names.append(_elem906)
+ (_etype932, _size929) = iprot.readListBegin()
+ for _i933 in xrange(_size929):
+ _elem934 = iprot.readString()
+ self.group_names.append(_elem934)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22711,8 +22774,8 @@ class get_partitions_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter907 in self.group_names:
- oprot.writeString(iter907)
+ for iter935 in self.group_names:
+ oprot.writeString(iter935)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22773,11 +22836,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype911, _size908) = iprot.readListBegin()
- for _i912 in xrange(_size908):
- _elem913 = Partition()
- _elem913.read(iprot)
- self.success.append(_elem913)
+ (_etype939, _size936) = iprot.readListBegin()
+ for _i940 in xrange(_size936):
+ _elem941 = Partition()
+ _elem941.read(iprot)
+ self.success.append(_elem941)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22806,8 +22869,8 @@ class get_partitions_with_auth_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter914 in self.success:
- iter914.write(oprot)
+ for iter942 in self.success:
+ iter942.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22965,11 +23028,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype918, _size915) = iprot.readListBegin()
- for _i919 in xrange(_size915):
- _elem920 = PartitionSpec()
- _elem920.read(iprot)
- self.success.append(_elem920)
+ (_etype946, _size943) = iprot.readListBegin()
+ for _i947 in xrange(_size943):
+ _elem948 = PartitionSpec()
+ _elem948.read(iprot)
+ self.success.append(_elem948)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22998,8 +23061,8 @@ class get_partitions_pspec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter921 in self.success:
- iter921.write(oprot)
+ for iter949 in self.success:
+ iter949.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23157,10 +23220,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype925, _size922) = iprot.readListBegin()
- for _i926 in xrange(_size922):
- _elem927 = iprot.readString()
- self.success.append(_elem927)
+ (_etype953, _size950) = iprot.readListBegin()
+ for _i954 in xrange(_size950):
+ _elem955 = iprot.readString()
+ self.success.append(_elem955)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23189,8 +23252,8 @@ class get_partition_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter928 in self.success:
- oprot.writeString(iter928)
+ for iter956 in self.success:
+ oprot.writeString(iter956)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23430,10 +23493,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype932, _size929) = iprot.readListBegin()
- for _i933 in xrange(_size929):
- _elem934 = iprot.readString()
- self.part_vals.append(_elem934)
+ (_etype960, _size957) = iprot.readListBegin()
+ for _i961 in xrange(_size957):
+ _elem962 = iprot.readString()
+ self.part_vals.append(_elem962)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23463,8 +23526,8 @@ class get_partitions_ps_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter935 in self.part_vals:
- oprot.writeString(iter935)
+ for iter963 in self.part_vals:
+ oprot.writeString(iter963)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23528,11 +23591,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype939, _size936) = iprot.readListBegin()
- for _i940 in xrange(_size936):
- _elem941 = Partition()
- _elem941.read(iprot)
- self.success.append(_elem941)
+ (_etype967, _size964) = iprot.readListBegin()
+ for _i968 in xrange(_size964):
+ _elem969 = Partition()
+ _elem969.read(iprot)
+ self.success.append(_elem969)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23561,8 +23624,8 @@ class get_partitions_ps_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter942 in self.success:
- iter942.write(oprot)
+ for iter970 in self.success:
+ iter970.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23649,10 +23712,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype946, _size943) = iprot.readListBegin()
- for _i947 in xrange(_size943):
- _elem948 = iprot.readString()
- self.part_vals.append(_elem948)
+ (_etype974, _size971) = iprot.readListBegin()
+ for _i975 in xrange(_size971):
+ _elem976 = iprot.readString()
+ self.part_vals.append(_elem976)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23669,10 +23732,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype952, _size949) = iprot.readListBegin()
- for _i953 in xrange(_size949):
- _elem954 = iprot.readString()
- self.group_names.append(_elem954)
+ (_etype980, _size977) = iprot.readListBegin()
+ for _i981 in xrange(_size977):
+ _elem982 = iprot.readString()
+ self.group_names.append(_elem982)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23697,8 +23760,8 @@ class get_partitions_ps_with_auth_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter955 in self.part_vals:
- oprot.writeString(iter955)
+ for iter983 in self.part_vals:
+ oprot.writeString(iter983)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23712,8 +23775,8 @@ class get_partitions_ps_with_auth_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 6)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter956 in self.group_names:
- oprot.writeString(iter956)
+ for iter984 in self.group_names:
+ oprot.writeString(iter984)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23775,11 +23838,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype960, _size957) = iprot.readListBegin()
- for _i961 in xrange(_size957):
- _elem962 = Partition()
- _elem962.read(iprot)
- self.success.append(_elem962)
+ (_etype988, _size985) = iprot.readListBegin()
+ for _i989 in xrange(_size985):
+ _elem990 = Partition()
+ _elem990.read(iprot)
+ self.success.append(_elem990)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23808,8 +23871,8 @@ class get_partitions_ps_with_auth_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter963 in self.success:
- iter963.write(oprot)
+ for iter991 in self.success:
+ iter991.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23890,10 +23953,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype967, _size964) = iprot.readListBegin()
- for _i968 in xrange(_size964):
- _elem969 = iprot.readString()
- self.part_vals.append(_elem969)
+ (_etype995, _size992) = iprot.readListBegin()
+ for _i996 in xrange(_size992):
+ _elem997 = iprot.readString()
+ self.part_vals.append(_elem997)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23923,8 +23986,8 @@ class get_partition_names_ps_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter970 in self.part_vals:
- oprot.writeString(iter970)
+ for iter998 in self.part_vals:
+ oprot.writeString(iter998)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23988,10 +24051,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype974, _size971) = iprot.readListBegin()
- for _i975 in xrange(_size971):
- _elem976 = iprot.readString()
- self.success.append(_elem976)
+ (_etype1002, _size999) = iprot.readListBegin()
+ for _i1003 in xrange(_size999):
+ _elem1004 = iprot.readString()
+ self.success.append(_elem1004)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24020,8 +24083,8 @@ class get_partition_names_ps_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter977 in self.success:
- oprot.writeString(iter977)
+ for iter1005 in self.success:
+ oprot.writeString(iter1005)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24192,11 +24255,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype981, _size978) = iprot.readListBegin()
- for _i982 in xrange(_size978):
- _elem983 = Partition()
- _elem983.read(iprot)
- self.success.append(_elem983)
+ (_etype1009, _size1006) = iprot.readListBegin()
+ for _i1010 in xrange(_size1006):
+ _elem1011 = Partition()
+ _elem1011.read(iprot)
+ self.success.append(_elem1011)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24225,8 +24288,8 @@ class get_partitions_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter984 in self.success:
- iter984.write(oprot)
+ for iter1012 in self.success:
+ iter1012.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24397,11 +24460,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype988, _size985) = iprot.readListBegin()
- for _i989 in xrange(_size985):
- _elem990 = PartitionSpec()
- _elem990.read(iprot)
- self.success.append(_elem990)
+ (_etype1016, _size1013) = iprot.readListBegin()
+ for _i1017 in xrange(_size1013):
+ _elem1018 = PartitionSpec()
+ _elem1018.read(iprot)
+ self.success.append(_elem1018)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24430,8 +24493,8 @@ class get_part_specs_by_filter_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter991 in self.success:
- iter991.write(oprot)
+ for iter1019 in self.success:
+ iter1019.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24851,10 +24914,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype995, _size992) = iprot.readListBegin()
- for _i996 in xrange(_size992):
- _elem997 = iprot.readString()
- self.names.append(_elem997)
+ (_etype1023, _size1020) = iprot.readListBegin()
+ for _i1024 in xrange(_size1020):
+ _elem1025 = iprot.readString()
+ self.names.append(_elem1025)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24879,8 +24942,8 @@ class get_partitions_by_names_args:
if self.names is not None:
oprot.writeFieldBegin('names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.names))
- for iter998 in self.names:
- oprot.writeString(iter998)
+ for iter1026 in self.names:
+ oprot.writeString(iter1026)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24939,11 +25002,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1002, _size999) = iprot.readListBegin()
- for _i1003 in xrange(_size999):
- _elem1004 = Partition()
- _elem1004.read(iprot)
- self.success.append(_elem1004)
+ (_etype1030, _size1027) = iprot.readListBegin()
+ for _i1031 in xrange(_size1027):
+ _elem1032 = Partition()
+ _elem1032.read(iprot)
+ self.success.append(_elem1032)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24972,8 +25035,8 @@ class get_partitions_by_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1005 in self.success:
- iter1005.write(oprot)
+ for iter1033 in self.success:
+ iter1033.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25223,11 +25286,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1009, _size1006) = iprot.readListBegin()
- for _i1010 in xrange(_size1006):
- _elem1011 = Partition()
- _elem1011.read(iprot)
- self.new_parts.append(_elem1011)
+ (_etype1037, _size1034) = iprot.readListBegin()
+ for _i1038 in xrange(_size1034):
+ _elem1039 = Partition()
+ _elem1039.read(iprot)
+ self.new_parts.append(_elem1039)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25252,8 +25315,8 @@ class alter_partitions_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1012 in self.new_parts:
- iter1012.write(oprot)
+ for iter1040 in self.new_parts:
+ iter1040.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25406,11 +25469,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1016, _size1013) = iprot.readListBegin()
- for _i1017 in xrange(_size1013):
- _elem1018 = Partition()
- _elem1018.read(iprot)
- self.new_parts.append(_elem1018)
+ (_etype1044, _size1041) = iprot.readListBegin()
+ for _i1045 in xrange(_size1041):
+ _elem1046 = Partition()
+ _elem1046.read(iprot)
+ self.new_parts.append(_elem1046)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25441,8 +25504,8 @@ class alter_partitions_with_environment_context_args:
if self.new_parts is not None:
oprot.writeFieldBegin('new_parts', TType.LIST, 3)
oprot.writeListBegin(TType.STRUCT, len(self.new_parts))
- for iter1019 in self.new_parts:
- iter1019.write(oprot)
+ for iter1047 in self.new_parts:
+ iter1047.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -25786,10 +25849,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1023, _size1020) = iprot.readListBegin()
- for _i1024 in xrange(_size1020):
- _elem1025 = iprot.readString()
- self.part_vals.append(_elem1025)
+ (_etype1051, _size1048) = iprot.readListBegin()
+ for _i1052 in xrange(_size1048):
+ _elem1053 = iprot.readString()
+ self.part_vals.append(_elem1053)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25820,8 +25883,8 @@ class rename_partition_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1026 in self.part_vals:
- oprot.writeString(iter1026)
+ for iter1054 in self.part_vals:
+ oprot.writeString(iter1054)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -25963,10 +26026,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1030, _size1027) = iprot.readListBegin()
- for _i1031 in xrange(_size1027):
- _elem1032 = iprot.readString()
- self.part_vals.append(_elem1032)
+ (_etype1058, _size1055) = iprot.readListBegin()
+ for _i1059 in xrange(_size1055):
+ _elem1060 = iprot.readString()
+ self.part_vals.append(_elem1060)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25988,8 +26051,8 @@ class partition_name_has_valid_characters_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1033 in self.part_vals:
- oprot.writeString(iter1033)
+ for iter1061 in self.part_vals:
+ oprot.writeString(iter1061)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -26347,10 +26410,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1037, _size1034) = iprot.readListBegin()
- for _i1038 in xrange(_size1034):
- _elem1039 = iprot.readString()
- self.success.append(_elem1039)
+ (_etype1065, _size1062) = iprot.readListBegin()
+ for _i1066 in xrange(_size1062):
+ _elem1067 = iprot.readString()
+ self.success.append(_elem1067)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26373,8 +26436,8 @@ class partition_name_to_vals_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1040 in self.success:
- oprot.writeString(iter1040)
+ for iter1068 in self.success:
+ oprot.writeString(iter1068)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26498,11 +26561,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1042, _vtype1043, _size1041 ) = iprot.readMapBegin()
- for _i1045 in xrange(_size1041):
- _key1046 = iprot.readString()
- _val1047 = iprot.readString()
- self.success[_key1046] = _val1047
+ (_ktype1070, _vtype1071, _size1069 ) = iprot.readMapBegin()
+ for _i1073 in xrange(_size1069):
+ _key1074 = iprot.readString()
+ _val1075 = iprot.readString()
+ self.success[_key1074] = _val1075
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26525,9 +26588,9 @@ class partition_name_to_spec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter1048,viter1049 in self.success.items():
- oprot.writeString(kiter1048)
- oprot.writeString(viter1049)
+ for kiter1076,viter1077 in self.success.items():
+ oprot.writeString(kiter1076)
+ oprot.writeString(viter1077)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26603,11 +26666,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1051, _vtype1052, _size1050 ) = iprot.readMapBegin()
- for _i1054 in xrange(_size1050):
- _key1055 = iprot.readString()
- _val1056 = iprot.readString()
- self.part_vals[_key1055] = _val1056
+ (_ktype1079, _vtype1080, _size1078 ) = iprot.readMapBegin()
+ for _i1082 in xrange(_size1078):
+ _key1083 = iprot.readString()
+ _val1084 = iprot.readString()
+ self.part_vals[_key1083] = _val1084
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26637,9 +26700,9 @@ class markPartitionForEvent_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
- for kiter1057,viter1058 in self.part_vals.items():
- oprot.writeString(kiter1057)
- oprot.writeString(viter1058)
+ for kiter1085,viter1086 in self.part_vals.items():
+ oprot.writeString(kiter1085)
+ oprot.writeString(viter1086)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -26853,11 +26916,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1060, _vtype1061, _size1059 ) = iprot.readMapBegin()
- for _i1063 in xrange(_size1059):
- _key1064 = iprot.readString()
- _val1065 = iprot.readString()
- self.part_vals[_key1064] = _val1065
+ (_ktype1088, _vtype1089, _size1087 ) = iprot.readMapBegin()
+ for _i1091 in xrange(_size1087):
+ _key1092 = iprot.readString()
+ _val1093 = iprot.readString()
+ self.part_vals[_key1092] = _val1093
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26887,9 +26950,9 @@ class isPartitionMarkedForEvent_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
- for kiter1066,viter1067 in self.part_vals.items():
- oprot.writeString(kiter1066)
- oprot.writeString(viter1067)
+ for kiter1094,viter1095 in self.part_vals.items():
+ oprot.writeString(kiter1094)
+ oprot.writeString(viter1095)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -27944,11 +28007,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1071, _size1068) = iprot.readListBegin()
- for _i1072 in xrange(_size1068):
- _elem1073 = Index()
- _elem1073.read(iprot)
- self.success.append(_elem1073)
+ (_etype1099, _size1096) = iprot.readListBegin()
+ for _i1100 in xrange(_size1096):
+ _elem1101 = Index()
+ _elem1101.read(iprot)
+ self.success.append(_elem1101)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27977,8 +28040,8 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1074 in self.success:
- iter1074.write(oprot)
+ for iter1102 in self.success:
+ iter1102.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28133,10 +28196,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1078, _size1075) = iprot.readListBegin()
- for _i1079 in xrange(_size1075):
- _elem1080 = iprot.readString()
- self.success.append(_elem1080)
+ (_etype1106, _size1103) = iprot.readListBegin()
+ for _i1107 in xrange(_size1103):
+ _elem1108 = iprot.readString()
+ self.success.append(_elem1108)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28159,8 +28222,8 @@ class get_index_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1081 in self.success:
- oprot.writeString(iter1081)
+ for iter1109 in self.success:
+ oprot.writeString(iter1109)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -31344,10 +31407,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1085, _size1082) = iprot.readListBegin()
- for _i1086 in xrange(_size1082):
- _elem1087 = iprot.readString()
- self.success.append(_elem1087)
+ (_etype1113, _size1110) = iprot.readListBegin()
+ for _i1114 in xrange(_size1110):
+ _elem1115 = iprot.readString()
+ self.success.append(_elem1115)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31370,8 +31433,8 @@ class get_functions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1088 in self.success:
- oprot.writeString(iter1088)
+ for iter1116 in self.success:
+ oprot.writeString(iter1116)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32059,10 +32122,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1092, _size1089) = iprot.readListBegin()
- for _i1093 in xrange(_size1089):
- _elem1094 = iprot.readString()
- self.success.append(_elem1094)
+ (_etype1120, _size1117) = iprot.readListBegin()
+ for _i1121 in xrange(_size1117):
+ _elem1122 = iprot.readString()
+ self.success.append(_elem1122)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32085,8 +32148,8 @@ class get_role_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1095 in self.success:
- oprot.writeString(iter1095)
+ for iter1123 in self.success:
+ oprot.writeString(iter1123)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32600,11 +32663,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1099, _size1096) = iprot.readListBegin()
- for _i1100 in xrange(_size1096):
- _elem1101 = Role()
- _elem1101.read(iprot)
- self.success.append(_elem1101)
+ (_etype1127, _size1124) = iprot.readListBegin()
+ for _i1128 in xrange(_size1124):
+ _elem1129 = Role()
+ _elem1129.read(iprot)
+ self.success.append(_elem1129)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32627,8 +32690,8 @@ class list_roles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1102 in self.success:
- iter1102.write(oprot)
+ for iter1130 in self.success:
+ iter1130.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -33137,10 +33200,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1106, _size1103) = iprot.readListBegin()
- for _i1107 in xrange(_size1103):
- _elem1108 = iprot.readString()
- self.group_names.append(_elem1108)
+ (_etype1134, _size1131) = iprot.readListBegin()
+ for _i1135 in xrange(_size1131):
+ _elem1136 = iprot.readString()
+ self.group_names.append(_elem1136)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33165,8 +33228,8 @@ class get_privilege_set_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1109 in self.group_names:
- oprot.writeString(iter1109)
+ for iter1137 in self.group_names:
+ oprot.writeString(iter1137)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -33393,11 +33456,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1113, _size1110) = iprot.readListBegin()
- for _i1114 in xrange(_size1110):
- _elem1115 = HiveObjectPrivilege()
- _elem1115.read(iprot)
- self.success.append(_elem1115)
+ (_etype1141, _size1138) = iprot.readListBegin()
+ for _i1142 in xrange(_size1138):
+ _elem1143 = HiveObjectPrivilege()
+ _elem1143.read(iprot)
+ self.success.append(_elem1143)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33420,8 +33483,8 @@ class list_privileges_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1116 in self.success:
- iter1116.write(oprot)
+ for iter1144 in self.success:
+ iter1144.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -33919,10 +33982,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1120, _size1117) = iprot.readListBegin()
- for _i1121 in xrange(_size1117):
- _elem1122 = iprot.readString()
- self.group_names.append(_elem1122)
+ (_etype1148, _size1145) = iprot.readListBegin()
+ for _i1149 in xrange(_size1145):
+ _elem1150 = iprot.readString()
+ self.group_names.append(_elem1150)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33943,8 +34006,8 @@ class set_ugi_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1123 in self.group_names:
- oprot.writeString(iter1123)
+ for iter1151 in self.group_names:
+ oprot.writeString(iter1151)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -33999,10 +34062,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1127, _size1124) = iprot.readListBegin()
- for _i1128 in xrange(_size1124):
- _elem1129 = iprot.readString()
- self.success.append(_elem1129)
+ (_etype1155, _size1152) = iprot.readListBegin()
+ for _i1156 in xrange(_size1152):
+ _elem1157 = iprot.readString()
+ self.success.append(_elem1157)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34025,8 +34088,8 @@ class set_ugi_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1130 in self.success:
- oprot.writeString(iter1130)
+ for iter1158 in self.success:
+ oprot.writeString(iter1158)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -34958,10 +35021,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1134, _size1131) = iprot.readListBegin()
- for _i1135 in xrange(_size1131):
- _elem1136 = iprot.readString()
- self.success.append(_elem1136)
+ (_etype1162, _size1159) = iprot.readListBegin()
+ for _i1163 in xrange(_size1159):
+ _elem1164 = iprot.readString()
+ self.success.append(_elem1164)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34978,8 +35041,8 @@ class get_all_token_identifiers_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1137 in self.success:
- oprot.writeString(iter1137)
+ for iter1165 in self.success:
+ oprot.writeString(iter1165)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -35506,10 +35569,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1141, _size1138) = iprot.readListBegin()
- for _i1142 in xrange(_size1138):
- _elem1143 = iprot.readString()
- self.success.append(_elem1143)
+ (_etype1169, _size1166) = iprot.readListBegin()
+ for _i1170 in xrange(_size1166):
+ _elem1171 = iprot.readString()
+ self.success.append(_elem1171)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35526,8 +35589,8 @@ class get_master_keys_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1144 in self.success:
- oprot.writeString(iter1144)
+ for iter1172 in self.success:
+ oprot.writeString(iter1172)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -39584,6 +39647,151 @@ class get_resource_plan_result:
def __ne__(self, other):
return not (self == other)
+class get_active_resource_plan_args:
+ """
+ Attributes:
+ - request
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'request', (WMGetActiveResourcePlanRequest, WMGetActiveResourcePlanRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, request=None,):
+ self.request = request
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRUCT:
+ self.request = WMGetActiveResourcePlanRequest()
+ self.request.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_active_resource_plan_args')
+ if self.request is not None:
+ oprot.writeFieldBegin('request', TType.STRUCT, 1)
+ self.request.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.request)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class get_active_resource_plan_result:
+ """
+ Attributes:
+ - success
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (WMGetActiveResourcePlanResponse, WMGetActiveResourcePlanResponse.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, success=None, o2=None,):
+ self.success = success
+ self.o2 = o2
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.STRUCT:
+ self.success = WMGetActiveResourcePlanResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o2 = MetaException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_active_resource_plan_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 1)
+ self.o2.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o2)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
class get_all_resource_plans_args:
"""
Attributes: