http://git-wip-us.apache.org/repos/asf/hive/blob/dec4efd3/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 86bbef3..f345165 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -518,6 +518,13 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_partition_values(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
def get_partitions_ps(self, db_name, tbl_name, part_vals, max_parts):
"""
Parameters:
@@ -3472,6 +3479,41 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_partition_names failed: unknown result")
+ def get_partition_values(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_partition_values(request)
+ return self.recv_get_partition_values()
+
+ def send_get_partition_values(self, request):
+ self._oprot.writeMessageBegin('get_partition_values', TMessageType.CALL,
self._seqid)
+ args = get_partition_values_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_partition_values(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_partition_values_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ raise TApplicationException(TApplicationException.MISSING_RESULT,
"get_partition_values failed: unknown result")
+
def get_partitions_ps(self, db_name, tbl_name, part_vals, max_parts):
"""
Parameters:
@@ -6823,6 +6865,7 @@ class Processor(fb303.FacebookService.Processor, Iface,
TProcessor):
self._processMap["get_partitions_with_auth"] =
Processor.process_get_partitions_with_auth
self._processMap["get_partitions_pspec"] =
Processor.process_get_partitions_pspec
self._processMap["get_partition_names"] =
Processor.process_get_partition_names
+ self._processMap["get_partition_values"] =
Processor.process_get_partition_values
self._processMap["get_partitions_ps"] = Processor.process_get_partitions_ps
self._processMap["get_partitions_ps_with_auth"] =
Processor.process_get_partitions_ps_with_auth
self._processMap["get_partition_names_ps"] =
Processor.process_get_partition_names_ps
@@ -8456,6 +8499,31 @@ class Processor(fb303.FacebookService.Processor, Iface,
TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_partition_values(self, seqid, iprot, oprot):
+ args = get_partition_values_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_partition_values_result()
+ try:
+ result.success = self._handler.get_partition_values(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except MetaException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except NoSuchObjectException 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_partition_values", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_get_partitions_ps(self, seqid, iprot, oprot):
args = get_partitions_ps_args()
args.read(iprot)
@@ -11551,10 +11619,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype597, _size594) = iprot.readListBegin()
- for _i598 in xrange(_size594):
- _elem599 = iprot.readString()
- self.success.append(_elem599)
+ (_etype625, _size622) = iprot.readListBegin()
+ for _i626 in xrange(_size622):
+ _elem627 = iprot.readString()
+ self.success.append(_elem627)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11577,8 +11645,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 iter600 in self.success:
- oprot.writeString(iter600)
+ for iter628 in self.success:
+ oprot.writeString(iter628)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11683,10 +11751,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype604, _size601) = iprot.readListBegin()
- for _i605 in xrange(_size601):
- _elem606 = iprot.readString()
- self.success.append(_elem606)
+ (_etype632, _size629) = iprot.readListBegin()
+ for _i633 in xrange(_size629):
+ _elem634 = iprot.readString()
+ self.success.append(_elem634)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11709,8 +11777,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 iter607 in self.success:
- oprot.writeString(iter607)
+ for iter635 in self.success:
+ oprot.writeString(iter635)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12480,12 +12548,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype609, _vtype610, _size608 ) = iprot.readMapBegin()
- for _i612 in xrange(_size608):
- _key613 = iprot.readString()
- _val614 = Type()
- _val614.read(iprot)
- self.success[_key613] = _val614
+ (_ktype637, _vtype638, _size636 ) = iprot.readMapBegin()
+ for _i640 in xrange(_size636):
+ _key641 = iprot.readString()
+ _val642 = Type()
+ _val642.read(iprot)
+ self.success[_key641] = _val642
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12508,9 +12576,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 kiter615,viter616 in self.success.items():
- oprot.writeString(kiter615)
- viter616.write(oprot)
+ for kiter643,viter644 in self.success.items():
+ oprot.writeString(kiter643)
+ viter644.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -12653,11 +12721,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype620, _size617) = iprot.readListBegin()
- for _i621 in xrange(_size617):
- _elem622 = FieldSchema()
- _elem622.read(iprot)
- self.success.append(_elem622)
+ (_etype648, _size645) = iprot.readListBegin()
+ for _i649 in xrange(_size645):
+ _elem650 = FieldSchema()
+ _elem650.read(iprot)
+ self.success.append(_elem650)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12692,8 +12760,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 iter623 in self.success:
- iter623.write(oprot)
+ for iter651 in self.success:
+ iter651.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12860,11 +12928,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype627, _size624) = iprot.readListBegin()
- for _i628 in xrange(_size624):
- _elem629 = FieldSchema()
- _elem629.read(iprot)
- self.success.append(_elem629)
+ (_etype655, _size652) = iprot.readListBegin()
+ for _i656 in xrange(_size652):
+ _elem657 = FieldSchema()
+ _elem657.read(iprot)
+ self.success.append(_elem657)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12899,8 +12967,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 iter630 in self.success:
- iter630.write(oprot)
+ for iter658 in self.success:
+ iter658.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13053,11 +13121,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype634, _size631) = iprot.readListBegin()
- for _i635 in xrange(_size631):
- _elem636 = FieldSchema()
- _elem636.read(iprot)
- self.success.append(_elem636)
+ (_etype662, _size659) = iprot.readListBegin()
+ for _i663 in xrange(_size659):
+ _elem664 = FieldSchema()
+ _elem664.read(iprot)
+ self.success.append(_elem664)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13092,8 +13160,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 iter637 in self.success:
- iter637.write(oprot)
+ for iter665 in self.success:
+ iter665.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13260,11 +13328,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype641, _size638) = iprot.readListBegin()
- for _i642 in xrange(_size638):
- _elem643 = FieldSchema()
- _elem643.read(iprot)
- self.success.append(_elem643)
+ (_etype669, _size666) = iprot.readListBegin()
+ for _i670 in xrange(_size666):
+ _elem671 = FieldSchema()
+ _elem671.read(iprot)
+ self.success.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13299,8 +13367,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 iter644 in self.success:
- iter644.write(oprot)
+ for iter672 in self.success:
+ iter672.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13741,22 +13809,22 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype648, _size645) = iprot.readListBegin()
- for _i649 in xrange(_size645):
- _elem650 = SQLPrimaryKey()
- _elem650.read(iprot)
- self.primaryKeys.append(_elem650)
+ (_etype676, _size673) = iprot.readListBegin()
+ for _i677 in xrange(_size673):
+ _elem678 = SQLPrimaryKey()
+ _elem678.read(iprot)
+ self.primaryKeys.append(_elem678)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype654, _size651) = iprot.readListBegin()
- for _i655 in xrange(_size651):
- _elem656 = SQLForeignKey()
- _elem656.read(iprot)
- self.foreignKeys.append(_elem656)
+ (_etype682, _size679) = iprot.readListBegin()
+ for _i683 in xrange(_size679):
+ _elem684 = SQLForeignKey()
+ _elem684.read(iprot)
+ self.foreignKeys.append(_elem684)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13777,15 +13845,15 @@ 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 iter657 in self.primaryKeys:
- iter657.write(oprot)
+ for iter685 in self.primaryKeys:
+ iter685.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 iter658 in self.foreignKeys:
- iter658.write(oprot)
+ for iter686 in self.foreignKeys:
+ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14821,10 +14889,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype662, _size659) = iprot.readListBegin()
- for _i663 in xrange(_size659):
- _elem664 = iprot.readString()
- self.success.append(_elem664)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = iprot.readString()
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14847,8 +14915,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 iter665 in self.success:
- oprot.writeString(iter665)
+ for iter693 in self.success:
+ oprot.writeString(iter693)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14998,10 +15066,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype669, _size666) = iprot.readListBegin()
- for _i670 in xrange(_size666):
- _elem671 = iprot.readString()
- self.success.append(_elem671)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = iprot.readString()
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15024,8 +15092,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 iter672 in self.success:
- oprot.writeString(iter672)
+ for iter700 in self.success:
+ oprot.writeString(iter700)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15098,10 +15166,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = iprot.readString()
- self.tbl_types.append(_elem678)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = iprot.readString()
+ self.tbl_types.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15126,8 +15194,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 iter679 in self.tbl_types:
- oprot.writeString(iter679)
+ for iter707 in self.tbl_types:
+ oprot.writeString(iter707)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15183,11 +15251,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = TableMeta()
- _elem685.read(iprot)
- self.success.append(_elem685)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = TableMeta()
+ _elem713.read(iprot)
+ self.success.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15210,8 +15278,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 iter686 in self.success:
- iter686.write(oprot)
+ for iter714 in self.success:
+ iter714.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15335,10 +15403,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = iprot.readString()
- self.success.append(_elem692)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = iprot.readString()
+ self.success.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15361,8 +15429,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 iter693 in self.success:
- oprot.writeString(iter693)
+ for iter721 in self.success:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15598,10 +15666,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = iprot.readString()
- self.tbl_names.append(_elem699)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = iprot.readString()
+ self.tbl_names.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15622,8 +15690,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 iter700 in self.tbl_names:
- oprot.writeString(iter700)
+ for iter728 in self.tbl_names:
+ oprot.writeString(iter728)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15675,11 +15743,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = Table()
- _elem706.read(iprot)
- self.success.append(_elem706)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = Table()
+ _elem734.read(iprot)
+ self.success.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15696,8 +15764,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 iter707 in self.success:
- iter707.write(oprot)
+ for iter735 in self.success:
+ iter735.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16180,10 +16248,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = iprot.readString()
- self.success.append(_elem713)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString()
+ self.success.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16218,8 +16286,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 iter714 in self.success:
- oprot.writeString(iter714)
+ for iter742 in self.success:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17189,11 +17257,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = Partition()
- _elem720.read(iprot)
- self.new_parts.append(_elem720)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = Partition()
+ _elem748.read(iprot)
+ self.new_parts.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17210,8 +17278,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 iter721 in self.new_parts:
- iter721.write(oprot)
+ for iter749 in self.new_parts:
+ iter749.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17369,11 +17437,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = PartitionSpec()
- _elem727.read(iprot)
- self.new_parts.append(_elem727)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = PartitionSpec()
+ _elem755.read(iprot)
+ self.new_parts.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17390,8 +17458,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 iter728 in self.new_parts:
- iter728.write(oprot)
+ for iter756 in self.new_parts:
+ iter756.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17565,10 +17633,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = iprot.readString()
- self.part_vals.append(_elem734)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = iprot.readString()
+ self.part_vals.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17593,8 +17661,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 iter735 in self.part_vals:
- oprot.writeString(iter735)
+ for iter763 in self.part_vals:
+ oprot.writeString(iter763)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17947,10 +18015,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype739, _size736) = iprot.readListBegin()
- for _i740 in xrange(_size736):
- _elem741 = iprot.readString()
- self.part_vals.append(_elem741)
+ (_etype767, _size764) = iprot.readListBegin()
+ for _i768 in xrange(_size764):
+ _elem769 = iprot.readString()
+ self.part_vals.append(_elem769)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17981,8 +18049,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 iter742 in self.part_vals:
- oprot.writeString(iter742)
+ for iter770 in self.part_vals:
+ oprot.writeString(iter770)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -18577,10 +18645,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = iprot.readString()
- self.part_vals.append(_elem748)
+ (_etype774, _size771) = iprot.readListBegin()
+ for _i775 in xrange(_size771):
+ _elem776 = iprot.readString()
+ self.part_vals.append(_elem776)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18610,8 +18678,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 iter749 in self.part_vals:
- oprot.writeString(iter749)
+ for iter777 in self.part_vals:
+ oprot.writeString(iter777)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -18784,10 +18852,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = iprot.readString()
- self.part_vals.append(_elem755)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = iprot.readString()
+ self.part_vals.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18823,8 +18891,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 iter756 in self.part_vals:
- oprot.writeString(iter756)
+ for iter784 in self.part_vals:
+ oprot.writeString(iter784)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -19561,10 +19629,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype760, _size757) = iprot.readListBegin()
- for _i761 in xrange(_size757):
- _elem762 = iprot.readString()
- self.part_vals.append(_elem762)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = iprot.readString()
+ self.part_vals.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19589,8 +19657,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 iter763 in self.part_vals:
- oprot.writeString(iter763)
+ for iter791 in self.part_vals:
+ oprot.writeString(iter791)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19749,11 +19817,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype765, _vtype766, _size764 ) = iprot.readMapBegin()
- for _i768 in xrange(_size764):
- _key769 = iprot.readString()
- _val770 = iprot.readString()
- self.partitionSpecs[_key769] = _val770
+ (_ktype793, _vtype794, _size792 ) = iprot.readMapBegin()
+ for _i796 in xrange(_size792):
+ _key797 = iprot.readString()
+ _val798 = iprot.readString()
+ self.partitionSpecs[_key797] = _val798
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19790,9 +19858,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 kiter771,viter772 in self.partitionSpecs.items():
- oprot.writeString(kiter771)
- oprot.writeString(viter772)
+ for kiter799,viter800 in self.partitionSpecs.items():
+ oprot.writeString(kiter799)
+ oprot.writeString(viter800)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -19997,11 +20065,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype774, _vtype775, _size773 ) = iprot.readMapBegin()
- for _i777 in xrange(_size773):
- _key778 = iprot.readString()
- _val779 = iprot.readString()
- self.partitionSpecs[_key778] = _val779
+ (_ktype802, _vtype803, _size801 ) = iprot.readMapBegin()
+ for _i805 in xrange(_size801):
+ _key806 = iprot.readString()
+ _val807 = iprot.readString()
+ self.partitionSpecs[_key806] = _val807
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -20038,9 +20106,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 kiter780,viter781 in self.partitionSpecs.items():
- oprot.writeString(kiter780)
- oprot.writeString(viter781)
+ for kiter808,viter809 in self.partitionSpecs.items():
+ oprot.writeString(kiter808)
+ oprot.writeString(viter809)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -20123,11 +20191,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype785, _size782) = iprot.readListBegin()
- for _i786 in xrange(_size782):
- _elem787 = Partition()
- _elem787.read(iprot)
- self.success.append(_elem787)
+ (_etype813, _size810) = iprot.readListBegin()
+ for _i814 in xrange(_size810):
+ _elem815 = Partition()
+ _elem815.read(iprot)
+ self.success.append(_elem815)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20168,8 +20236,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 iter788 in self.success:
- iter788.write(oprot)
+ for iter816 in self.success:
+ iter816.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20263,10 +20331,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype792, _size789) = iprot.readListBegin()
- for _i793 in xrange(_size789):
- _elem794 = iprot.readString()
- self.part_vals.append(_elem794)
+ (_etype820, _size817) = iprot.readListBegin()
+ for _i821 in xrange(_size817):
+ _elem822 = iprot.readString()
+ self.part_vals.append(_elem822)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20278,10 +20346,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype798, _size795) = iprot.readListBegin()
- for _i799 in xrange(_size795):
- _elem800 = iprot.readString()
- self.group_names.append(_elem800)
+ (_etype826, _size823) = iprot.readListBegin()
+ for _i827 in xrange(_size823):
+ _elem828 = iprot.readString()
+ self.group_names.append(_elem828)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20306,8 +20374,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 iter801 in self.part_vals:
- oprot.writeString(iter801)
+ for iter829 in self.part_vals:
+ oprot.writeString(iter829)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -20317,8 +20385,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 iter802 in self.group_names:
- oprot.writeString(iter802)
+ for iter830 in self.group_names:
+ oprot.writeString(iter830)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20747,11 +20815,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype806, _size803) = iprot.readListBegin()
- for _i807 in xrange(_size803):
- _elem808 = Partition()
- _elem808.read(iprot)
- self.success.append(_elem808)
+ (_etype834, _size831) = iprot.readListBegin()
+ for _i835 in xrange(_size831):
+ _elem836 = Partition()
+ _elem836.read(iprot)
+ self.success.append(_elem836)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20780,8 +20848,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 iter809 in self.success:
- iter809.write(oprot)
+ for iter837 in self.success:
+ iter837.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20875,10 +20943,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype813, _size810) = iprot.readListBegin()
- for _i814 in xrange(_size810):
- _elem815 = iprot.readString()
- self.group_names.append(_elem815)
+ (_etype841, _size838) = iprot.readListBegin()
+ for _i842 in xrange(_size838):
+ _elem843 = iprot.readString()
+ self.group_names.append(_elem843)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20911,8 +20979,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 iter816 in self.group_names:
- oprot.writeString(iter816)
+ for iter844 in self.group_names:
+ oprot.writeString(iter844)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20973,11 +21041,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype820, _size817) = iprot.readListBegin()
- for _i821 in xrange(_size817):
- _elem822 = Partition()
- _elem822.read(iprot)
- self.success.append(_elem822)
+ (_etype848, _size845) = iprot.readListBegin()
+ for _i849 in xrange(_size845):
+ _elem850 = Partition()
+ _elem850.read(iprot)
+ self.success.append(_elem850)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21006,8 +21074,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 iter823 in self.success:
- iter823.write(oprot)
+ for iter851 in self.success:
+ iter851.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21165,11 +21233,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype827, _size824) = iprot.readListBegin()
- for _i828 in xrange(_size824):
- _elem829 = PartitionSpec()
- _elem829.read(iprot)
- self.success.append(_elem829)
+ (_etype855, _size852) = iprot.readListBegin()
+ for _i856 in xrange(_size852):
+ _elem857 = PartitionSpec()
+ _elem857.read(iprot)
+ self.success.append(_elem857)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21198,8 +21266,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 iter830 in self.success:
- iter830.write(oprot)
+ for iter858 in self.success:
+ iter858.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21354,10 +21422,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype834, _size831) = iprot.readListBegin()
- for _i835 in xrange(_size831):
- _elem836 = iprot.readString()
- self.success.append(_elem836)
+ (_etype862, _size859) = iprot.readListBegin()
+ for _i863 in xrange(_size859):
+ _elem864 = iprot.readString()
+ self.success.append(_elem864)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21380,8 +21448,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 iter837 in self.success:
- oprot.writeString(iter837)
+ for iter865 in self.success:
+ oprot.writeString(iter865)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -21412,6 +21480,165 @@ class get_partition_names_result:
def __ne__(self, other):
return not (self == other)
+class get_partition_values_args:
+ """
+ Attributes:
+ - request
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'request', (PartitionValuesRequest,
PartitionValuesRequest.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 = PartitionValuesRequest()
+ 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_partition_values_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_partition_values_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (PartitionValuesResponse,
PartitionValuesResponse.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None,
), # 1
+ (2, TType.STRUCT, 'o2', (NoSuchObjectException,
NoSuchObjectException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, success=None, o1=None, o2=None,):
+ self.success = success
+ self.o1 = o1
+ 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 = PartitionValuesResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = MetaException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = NoSuchObjectException()
+ 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_partition_values_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 2)
+ 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.o1)
+ 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_partitions_ps_args:
"""
Attributes:
@@ -21457,10 +21684,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype841, _size838) = iprot.readListBegin()
- for _i842 in xrange(_size838):
- _elem843 = iprot.readString()
- self.part_vals.append(_elem843)
+ (_etype869, _size866) = iprot.readListBegin()
+ for _i870 in xrange(_size866):
+ _elem871 = iprot.readString()
+ self.part_vals.append(_elem871)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21490,8 +21717,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 iter844 in self.part_vals:
- oprot.writeString(iter844)
+ for iter872 in self.part_vals:
+ oprot.writeString(iter872)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21555,11 +21782,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype848, _size845) = iprot.readListBegin()
- for _i849 in xrange(_size845):
- _elem850 = Partition()
- _elem850.read(iprot)
- self.success.append(_elem850)
+ (_etype876, _size873) = iprot.readListBegin()
+ for _i877 in xrange(_size873):
+ _elem878 = Partition()
+ _elem878.read(iprot)
+ self.success.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21588,8 +21815,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 iter851 in self.success:
- iter851.write(oprot)
+ for iter879 in self.success:
+ iter879.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21676,10 +21903,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype855, _size852) = iprot.readListBegin()
- for _i856 in xrange(_size852):
- _elem857 = iprot.readString()
- self.part_vals.append(_elem857)
+ (_etype883, _size880) = iprot.readListBegin()
+ for _i884 in xrange(_size880):
+ _elem885 = iprot.readString()
+ self.part_vals.append(_elem885)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21696,10 +21923,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype861, _size858) = iprot.readListBegin()
- for _i862 in xrange(_size858):
- _elem863 = iprot.readString()
- self.group_names.append(_elem863)
+ (_etype889, _size886) = iprot.readListBegin()
+ for _i890 in xrange(_size886):
+ _elem891 = iprot.readString()
+ self.group_names.append(_elem891)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21724,8 +21951,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 iter864 in self.part_vals:
- oprot.writeString(iter864)
+ for iter892 in self.part_vals:
+ oprot.writeString(iter892)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21739,8 +21966,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 iter865 in self.group_names:
- oprot.writeString(iter865)
+ for iter893 in self.group_names:
+ oprot.writeString(iter893)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21802,11 +22029,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = Partition()
- _elem871.read(iprot)
- self.success.append(_elem871)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = Partition()
+ _elem899.read(iprot)
+ self.success.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21835,8 +22062,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 iter872 in self.success:
- iter872.write(oprot)
+ for iter900 in self.success:
+ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21917,10 +22144,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype876, _size873) = iprot.readListBegin()
- for _i877 in xrange(_size873):
- _elem878 = iprot.readString()
- self.part_vals.append(_elem878)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = iprot.readString()
+ self.part_vals.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21950,8 +22177,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 iter879 in self.part_vals:
- oprot.writeString(iter879)
+ for iter907 in self.part_vals:
+ oprot.writeString(iter907)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -22015,10 +22242,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype883, _size880) = iprot.readListBegin()
- for _i884 in xrange(_size880):
- _elem885 = iprot.readString()
- self.success.append(_elem885)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = iprot.readString()
+ self.success.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22047,8 +22274,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 iter886 in self.success:
- oprot.writeString(iter886)
+ for iter914 in self.success:
+ oprot.writeString(iter914)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22219,11 +22446,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype890, _size887) = iprot.readListBegin()
- for _i891 in xrange(_size887):
- _elem892 = Partition()
- _elem892.read(iprot)
- self.success.append(_elem892)
+ (_etype918, _size915) = iprot.readListBegin()
+ for _i919 in xrange(_size915):
+ _elem920 = Partition()
+ _elem920.read(iprot)
+ self.success.append(_elem920)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22252,8 +22479,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 iter893 in self.success:
- iter893.write(oprot)
+ for iter921 in self.success:
+ iter921.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22424,11 +22651,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = PartitionSpec()
- _elem899.read(iprot)
- self.success.append(_elem899)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = PartitionSpec()
+ _elem927.read(iprot)
+ self.success.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22457,8 +22684,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 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:
@@ -22878,10 +23105,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = iprot.readString()
- self.names.append(_elem906)
+ (_etype932, _size929) = iprot.readListBegin()
+ for _i933 in xrange(_size929):
+ _elem934 = iprot.readString()
+ self.names.append(_elem934)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22906,8 +23133,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 iter907 in self.names:
- oprot.writeString(iter907)
+ for iter935 in self.names:
+ oprot.writeString(iter935)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22966,11 +23193,11 @@ class get_partitions_by_names_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)
@@ -22999,8 +23226,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 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:
@@ -23250,11 +23477,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype918, _size915) = iprot.readListBegin()
- for _i919 in xrange(_size915):
- _elem920 = Partition()
- _elem920.read(iprot)
- self.new_parts.append(_elem920)
+ (_etype946, _size943) = iprot.readListBegin()
+ for _i947 in xrange(_size943):
+ _elem948 = Partition()
+ _elem948.read(iprot)
+ self.new_parts.append(_elem948)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23279,8 +23506,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 iter921 in self.new_parts:
- iter921.write(oprot)
+ for iter949 in self.new_parts:
+ iter949.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23433,11 +23660,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype925, _size922) = iprot.readListBegin()
- for _i926 in xrange(_size922):
- _elem927 = Partition()
- _elem927.read(iprot)
- self.new_parts.append(_elem927)
+ (_etype953, _size950) = iprot.readListBegin()
+ for _i954 in xrange(_size950):
+ _elem955 = Partition()
+ _elem955.read(iprot)
+ self.new_parts.append(_elem955)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23468,8 +23695,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 iter928 in self.new_parts:
- iter928.write(oprot)
+ for iter956 in self.new_parts:
+ iter956.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -23813,10 +24040,10 @@ class rename_partition_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)
@@ -23847,8 +24074,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 iter935 in self.part_vals:
- oprot.writeString(iter935)
+ for iter963 in self.part_vals:
+ oprot.writeString(iter963)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -23990,10 +24217,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype939, _size936) = iprot.readListBegin()
- for _i940 in xrange(_size936):
- _elem941 = iprot.readString()
- self.part_vals.append(_elem941)
+ (_etype967, _size964) = iprot.readListBegin()
+ for _i968 in xrange(_size964):
+ _elem969 = iprot.readString()
+ self.part_vals.append(_elem969)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24015,8 +24242,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 iter942 in self.part_vals:
- oprot.writeString(iter942)
+ for iter970 in self.part_vals:
+ oprot.writeString(iter970)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -24374,10 +24601,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype946, _size943) = iprot.readListBegin()
- for _i947 in xrange(_size943):
- _elem948 = iprot.readString()
- self.success.append(_elem948)
+ (_etype974, _size971) = iprot.readListBegin()
+ for _i975 in xrange(_size971):
+ _elem976 = iprot.readString()
+ self.success.append(_elem976)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24400,8 +24627,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 iter949 in self.success:
- oprot.writeString(iter949)
+ for iter977 in self.success:
+ oprot.writeString(iter977)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24525,11 +24752,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype951, _vtype952, _size950 ) = iprot.readMapBegin()
- for _i954 in xrange(_size950):
- _key955 = iprot.readString()
- _val956 = iprot.readString()
- self.success[_key955] = _val956
+ (_ktype979, _vtype980, _size978 ) = iprot.readMapBegin()
+ for _i982 in xrange(_size978):
+ _key983 = iprot.readString()
+ _val984 = iprot.readString()
+ self.success[_key983] = _val984
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24552,9 +24779,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 kiter957,viter958 in self.success.items():
- oprot.writeString(kiter957)
- oprot.writeString(viter958)
+ for kiter985,viter986 in self.success.items():
+ oprot.writeString(kiter985)
+ oprot.writeString(viter986)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24630,11 +24857,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype960, _vtype961, _size959 ) = iprot.readMapBegin()
- for _i963 in xrange(_size959):
- _key964 = iprot.readString()
- _val965 = iprot.readString()
- self.part_vals[_key964] = _val965
+ (_ktype988, _vtype989, _size987 ) = iprot.readMapBegin()
+ for _i991 in xrange(_size987):
+ _key992 = iprot.readString()
+ _val993 = iprot.readString()
+ self.part_vals[_key992] = _val993
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24664,9 +24891,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 kiter966,viter967 in self.part_vals.items():
- oprot.writeString(kiter966)
- oprot.writeString(viter967)
+ for kiter994,viter995 in self.part_vals.items():
+ oprot.writeString(kiter994)
+ oprot.writeString(viter995)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -24880,11 +25107,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype969, _vtype970, _size968 ) = iprot.readMapBegin()
- for _i972 in xrange(_size968):
- _key973 = iprot.readString()
- _val974 = iprot.readString()
- self.part_vals[_key973] = _val974
+ (_ktype997, _vtype998, _size996 ) = iprot.readMapBegin()
+ for _i1000 in xrange(_size996):
+ _key1001 = iprot.readString()
+ _val1002 = iprot.readString()
+ self.part_vals[_key1001] = _val1002
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24914,9 +25141,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 kiter975,viter976 in self.part_vals.items():
- oprot.writeString(kiter975)
- oprot.writeString(viter976)
+ for kiter1003,viter1004 in self.part_vals.items():
+ oprot.writeString(kiter1003)
+ oprot.writeString(viter1004)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -25971,11 +26198,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype980, _size977) = iprot.readListBegin()
- for _i981 in xrange(_size977):
- _elem982 = Index()
- _elem982.read(iprot)
- self.success.append(_elem982)
+ (_etype1008, _size1005) = iprot.readListBegin()
+ for _i1009 in xrange(_size1005):
+ _elem1010 = Index()
+ _elem1010.read(iprot)
+ self.success.append(_elem1010)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26004,8 +26231,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 iter983 in self.success:
- iter983.write(oprot)
+ for iter1011 in self.success:
+ iter1011.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26160,10 +26387,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype987, _size984) = iprot.readListBegin()
- for _i988 in xrange(_size984):
- _elem989 = iprot.readString()
- self.success.append(_elem989)
+ (_etype1015, _size1012) = iprot.readListBegin()
+ for _i1016 in xrange(_size1012):
+ _elem1017 = iprot.readString()
+ self.success.append(_elem1017)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26186,8 +26413,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 iter990 in self.success:
- oprot.writeString(iter990)
+ for iter1018 in self.success:
+ oprot.writeString(iter1018)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -29053,10 +29280,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype994, _size991) = iprot.readListBegin()
- for _i995 in xrange(_size991):
- _elem996 = iprot.readString()
- self.success.append(_elem996)
+ (_etype1022, _size1019) = iprot.readListBegin()
+ for _i1023 in xrange(_size1019):
+ _elem1024 = iprot.readString()
+ self.success.append(_elem1024)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29079,8 +29306,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 iter997 in self.success:
- oprot.writeString(iter997)
+ for iter1025 in self.success:
+ oprot.writeString(iter1025)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29768,10 +29995,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1001, _size998) = iprot.readListBegin()
- for _i1002 in xrange(_size998):
- _elem1003 = iprot.readString()
- self.success.append(_elem1003)
+ (_etype1029, _size1026) = iprot.readListBegin()
+ for _i1030 in xrange(_size1026):
+ _elem1031 = iprot.readString()
+ self.success.append(_elem1031)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29794,8 +30021,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 iter1004 in self.success:
- oprot.writeString(iter1004)
+ for iter1032 in self.success:
+ oprot.writeString(iter1032)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30309,11 +30536,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1008, _size1005) = iprot.readListBegin()
- for _i1009 in xrange(_size1005):
- _elem1010 = Role()
- _elem1010.read(iprot)
- self.success.append(_elem1010)
+ (_etype1036, _size1033) = iprot.readListBegin()
+ for _i1037 in xrange(_size1033):
+ _elem1038 = Role()
+ _elem1038.read(iprot)
+ self.success.append(_elem1038)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30336,8 +30563,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 iter1011 in self.success:
- iter1011.write(oprot)
+ for iter1039 in self.success:
+ iter1039.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30846,10 +31073,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1015, _size1012) = iprot.readListBegin()
- for _i1016 in xrange(_size1012):
- _elem1017 = iprot.readString()
- self.group_names.append(_elem1017)
+ (_etype1043, _size1040) = iprot.readListBegin()
+ for _i1044 in xrange(_size1040):
+ _elem1045 = iprot.readString()
+ self.group_names.append(_elem1045)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30874,8 +31101,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 iter1018 in self.group_names:
- oprot.writeString(iter1018)
+ for iter1046 in self.group_names:
+ oprot.writeString(iter1046)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -31102,11 +31329,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1022, _size1019) = iprot.readListBegin()
- for _i1023 in xrange(_size1019):
- _elem1024 = HiveObjectPrivilege()
- _elem1024.read(iprot)
- self.success.append(_elem1024)
+ (_etype1050, _size1047) = iprot.readListBegin()
+ for _i1051 in xrange(_size1047):
+ _elem1052 = HiveObjectPrivilege()
+ _elem1052.read(iprot)
+ self.success.append(_elem1052)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31129,8 +31356,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 iter1025 in self.success:
- iter1025.write(oprot)
+ for iter1053 in self.success:
+ iter1053.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -31628,10 +31855,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1029, _size1026) = iprot.readListBegin()
- for _i1030 in xrange(_size1026):
- _elem1031 = iprot.readString()
- self.group_names.append(_elem1031)
+ (_etype1057, _size1054) = iprot.readListBegin()
+ for _i1058 in xrange(_size1054):
+ _elem1059 = iprot.readString()
+ self.group_names.append(_elem1059)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31652,8 +31879,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 iter1032 in self.group_names:
- oprot.writeString(iter1032)
+ for iter1060 in self.group_names:
+ oprot.writeString(iter1060)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -31708,10 +31935,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1036, _size1033) = iprot.readListBegin()
- for _i1037 in xrange(_size1033):
- _elem1038 = iprot.readString()
- self.success.append(_elem1038)
+ (_etype1064, _size1061) = iprot.readListBegin()
+ for _i1065 in xrange(_size1061):
+ _elem1066 = iprot.readString()
+ self.success.append(_elem1066)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31734,8 +31961,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 iter1039 in self.success:
- oprot.writeString(iter1039)
+ for iter1067 in self.success:
+ oprot.writeString(iter1067)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32667,10 +32894,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1043, _size1040) = iprot.readListBegin()
- for _i1044 in xrange(_size1040):
- _elem1045 = iprot.readString()
- self.success.append(_elem1045)
+ (_etype1071, _size1068) = iprot.readListBegin()
+ for _i1072 in xrange(_size1068):
+ _elem1073 = iprot.readString()
+ self.success.append(_elem1073)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32687,8 +32914,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 iter1046 in self.success:
- oprot.writeString(iter1046)
+ for iter1074 in self.success:
+ oprot.writeString(iter1074)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -33215,10 +33442,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1050, _size1047) = iprot.readListBegin()
- for _i1051 in xrange(_size1047):
- _elem1052 = iprot.readString()
- self.success.append(_elem1052)
+ (_etype1078, _size1075) = iprot.readListBegin()
+ for _i1079 in xrange(_size1075):
+ _elem1080 = iprot.readString()
+ self.success.append(_elem1080)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -33235,8 +33462,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 iter1053 in self.success:
- oprot.writeString(iter1053)
+ for iter1081 in self.success:
+ oprot.writeString(iter1081)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
