http://git-wip-us.apache.org/repos/asf/hive/blob/4c0475ff/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 d94951b..49d966f 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 @@ -1175,6 +1175,13 @@ class Iface(fb303.FacebookService.Iface): """ pass + def repl_tbl_writeid_state(self, rqst): + """ + Parameters: + - rqst + """ + pass + def get_valid_write_ids(self, rqst): """ Parameters: @@ -6881,6 +6888,35 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 return + def repl_tbl_writeid_state(self, rqst): + """ + Parameters: + - rqst + """ + self.send_repl_tbl_writeid_state(rqst) + self.recv_repl_tbl_writeid_state() + + def send_repl_tbl_writeid_state(self, rqst): + self._oprot.writeMessageBegin('repl_tbl_writeid_state', TMessageType.CALL, self._seqid) + args = repl_tbl_writeid_state_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_repl_tbl_writeid_state(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = repl_tbl_writeid_state_result() + result.read(iprot) + iprot.readMessageEnd() + return + def get_valid_write_ids(self, rqst): """ Parameters: @@ -9026,6 +9062,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["abort_txn"] = Processor.process_abort_txn self._processMap["abort_txns"] = Processor.process_abort_txns self._processMap["commit_txn"] = Processor.process_commit_txn + self._processMap["repl_tbl_writeid_state"] = Processor.process_repl_tbl_writeid_state self._processMap["get_valid_write_ids"] = Processor.process_get_valid_write_ids self._processMap["allocate_table_write_ids"] = Processor.process_allocate_table_write_ids self._processMap["lock"] = Processor.process_lock @@ -12717,6 +12754,25 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_repl_tbl_writeid_state(self, seqid, iprot, oprot): + args = repl_tbl_writeid_state_args() + args.read(iprot) + iprot.readMessageEnd() + result = repl_tbl_writeid_state_result() + try: + self._handler.repl_tbl_writeid_state(args.rqst) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("repl_tbl_writeid_state", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_get_valid_write_ids(self, seqid, iprot, oprot): args = get_valid_write_ids_args() args.read(iprot) @@ -15631,10 +15687,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype812, _size809) = iprot.readListBegin() - for _i813 in xrange(_size809): - _elem814 = iprot.readString() - self.success.append(_elem814) + (_etype819, _size816) = iprot.readListBegin() + for _i820 in xrange(_size816): + _elem821 = iprot.readString() + self.success.append(_elem821) iprot.readListEnd() else: iprot.skip(ftype) @@ -15657,8 +15713,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 iter815 in self.success: - oprot.writeString(iter815) + for iter822 in self.success: + oprot.writeString(iter822) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15763,10 +15819,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype819, _size816) = iprot.readListBegin() - for _i820 in xrange(_size816): - _elem821 = iprot.readString() - self.success.append(_elem821) + (_etype826, _size823) = iprot.readListBegin() + for _i827 in xrange(_size823): + _elem828 = iprot.readString() + self.success.append(_elem828) iprot.readListEnd() else: iprot.skip(ftype) @@ -15789,8 +15845,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 iter822 in self.success: - oprot.writeString(iter822) + for iter829 in self.success: + oprot.writeString(iter829) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16560,12 +16616,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype824, _vtype825, _size823 ) = iprot.readMapBegin() - for _i827 in xrange(_size823): - _key828 = iprot.readString() - _val829 = Type() - _val829.read(iprot) - self.success[_key828] = _val829 + (_ktype831, _vtype832, _size830 ) = iprot.readMapBegin() + for _i834 in xrange(_size830): + _key835 = iprot.readString() + _val836 = Type() + _val836.read(iprot) + self.success[_key835] = _val836 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16588,9 +16644,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 kiter830,viter831 in self.success.items(): - oprot.writeString(kiter830) - viter831.write(oprot) + for kiter837,viter838 in self.success.items(): + oprot.writeString(kiter837) + viter838.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -16733,11 +16789,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype835, _size832) = iprot.readListBegin() - for _i836 in xrange(_size832): - _elem837 = FieldSchema() - _elem837.read(iprot) - self.success.append(_elem837) + (_etype842, _size839) = iprot.readListBegin() + for _i843 in xrange(_size839): + _elem844 = FieldSchema() + _elem844.read(iprot) + self.success.append(_elem844) iprot.readListEnd() else: iprot.skip(ftype) @@ -16772,8 +16828,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 iter838 in self.success: - iter838.write(oprot) + for iter845 in self.success: + iter845.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16940,199 +16996,6 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype842, _size839) = iprot.readListBegin() - for _i843 in xrange(_size839): - _elem844 = FieldSchema() - _elem844.read(iprot) - self.success.append(_elem844) - iprot.readListEnd() - 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 = UnknownTableException() - self.o2.read(iprot) - else: - iprot.skip(ftype) - elif fid == 3: - if ftype == TType.STRUCT: - self.o3 = UnknownDBException() - self.o3.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_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 iter845 in self.success: - iter845.write(oprot) - oprot.writeListEnd() - 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() - if self.o3 is not None: - oprot.writeFieldBegin('o3', TType.STRUCT, 3) - self.o3.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) - value = (value * 31) ^ hash(self.o3) - 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_schema_args: - """ - Attributes: - - db_name - - table_name - """ - - thrift_spec = ( - None, # 0 - (1, TType.STRING, 'db_name', None, None, ), # 1 - (2, TType.STRING, 'table_name', None, None, ), # 2 - ) - - def __init__(self, db_name=None, table_name=None,): - self.db_name = db_name - self.table_name = table_name - - 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.STRING: - self.db_name = iprot.readString() - else: - iprot.skip(ftype) - elif fid == 2: - if ftype == TType.STRING: - self.table_name = iprot.readString() - 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_schema_args') - if self.db_name is not None: - oprot.writeFieldBegin('db_name', TType.STRING, 1) - oprot.writeString(self.db_name) - oprot.writeFieldEnd() - if self.table_name is not None: - oprot.writeFieldBegin('table_name', TType.STRING, 2) - oprot.writeString(self.table_name) - oprot.writeFieldEnd() - oprot.writeFieldStop() - oprot.writeStructEnd() - - def validate(self): - return - - - def __hash__(self): - value = 17 - value = (value * 31) ^ hash(self.db_name) - value = (value * 31) ^ hash(self.table_name) - 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_schema_result: - """ - Attributes: - - success - - o1 - - o2 - - o3 - """ - - thrift_spec = ( - (0, TType.LIST, 'success', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 0 - (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 - (2, TType.STRUCT, 'o2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2 - (3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3 - ) - - def __init__(self, success=None, o1=None, o2=None, o3=None,): - self.success = success - self.o1 = o1 - self.o2 = o2 - self.o3 = o3 - - 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.LIST: - self.success = [] (_etype849, _size846) = iprot.readListBegin() for _i850 in xrange(_size846): _elem851 = FieldSchema() @@ -17168,7 +17031,7 @@ class get_schema_result: 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_schema_result') + oprot.writeStructBegin('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)) @@ -17214,6 +17077,199 @@ class get_schema_result: def __ne__(self, other): return not (self == other) +class get_schema_args: + """ + Attributes: + - db_name + - table_name + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'db_name', None, None, ), # 1 + (2, TType.STRING, 'table_name', None, None, ), # 2 + ) + + def __init__(self, db_name=None, table_name=None,): + self.db_name = db_name + self.table_name = table_name + + 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.STRING: + self.db_name = iprot.readString() + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.table_name = iprot.readString() + 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_schema_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.table_name is not None: + oprot.writeFieldBegin('table_name', TType.STRING, 2) + oprot.writeString(self.table_name) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.db_name) + value = (value * 31) ^ hash(self.table_name) + 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_schema_result: + """ + Attributes: + - success + - o1 + - o2 + - o3 + """ + + thrift_spec = ( + (0, TType.LIST, 'success', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3 + ) + + def __init__(self, success=None, o1=None, o2=None, o3=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + self.o3 = o3 + + 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.LIST: + self.success = [] + (_etype856, _size853) = iprot.readListBegin() + for _i857 in xrange(_size853): + _elem858 = FieldSchema() + _elem858.read(iprot) + self.success.append(_elem858) + iprot.readListEnd() + 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 = UnknownTableException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = UnknownDBException() + self.o3.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_schema_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.LIST, 0) + oprot.writeListBegin(TType.STRUCT, len(self.success)) + for iter859 in self.success: + iter859.write(oprot) + oprot.writeListEnd() + 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() + if self.o3 is not None: + oprot.writeFieldBegin('o3', TType.STRUCT, 3) + self.o3.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) + value = (value * 31) ^ hash(self.o3) + 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_schema_with_environment_context_args: """ Attributes: @@ -17340,11 +17396,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype856, _size853) = iprot.readListBegin() - for _i857 in xrange(_size853): - _elem858 = FieldSchema() - _elem858.read(iprot) - self.success.append(_elem858) + (_etype863, _size860) = iprot.readListBegin() + for _i864 in xrange(_size860): + _elem865 = FieldSchema() + _elem865.read(iprot) + self.success.append(_elem865) iprot.readListEnd() else: iprot.skip(ftype) @@ -17379,8 +17435,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 iter859 in self.success: - iter859.write(oprot) + for iter866 in self.success: + iter866.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17833,66 +17889,66 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype863, _size860) = iprot.readListBegin() - for _i864 in xrange(_size860): - _elem865 = SQLPrimaryKey() - _elem865.read(iprot) - self.primaryKeys.append(_elem865) + (_etype870, _size867) = iprot.readListBegin() + for _i871 in xrange(_size867): + _elem872 = SQLPrimaryKey() + _elem872.read(iprot) + self.primaryKeys.append(_elem872) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype869, _size866) = iprot.readListBegin() - for _i870 in xrange(_size866): - _elem871 = SQLForeignKey() - _elem871.read(iprot) - self.foreignKeys.append(_elem871) + (_etype876, _size873) = iprot.readListBegin() + for _i877 in xrange(_size873): + _elem878 = SQLForeignKey() + _elem878.read(iprot) + self.foreignKeys.append(_elem878) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype875, _size872) = iprot.readListBegin() - for _i876 in xrange(_size872): - _elem877 = SQLUniqueConstraint() - _elem877.read(iprot) - self.uniqueConstraints.append(_elem877) + (_etype882, _size879) = iprot.readListBegin() + for _i883 in xrange(_size879): + _elem884 = SQLUniqueConstraint() + _elem884.read(iprot) + self.uniqueConstraints.append(_elem884) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype881, _size878) = iprot.readListBegin() - for _i882 in xrange(_size878): - _elem883 = SQLNotNullConstraint() - _elem883.read(iprot) - self.notNullConstraints.append(_elem883) + (_etype888, _size885) = iprot.readListBegin() + for _i889 in xrange(_size885): + _elem890 = SQLNotNullConstraint() + _elem890.read(iprot) + self.notNullConstraints.append(_elem890) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.LIST: self.defaultConstraints = [] - (_etype887, _size884) = iprot.readListBegin() - for _i888 in xrange(_size884): - _elem889 = SQLDefaultConstraint() - _elem889.read(iprot) - self.defaultConstraints.append(_elem889) + (_etype894, _size891) = iprot.readListBegin() + for _i895 in xrange(_size891): + _elem896 = SQLDefaultConstraint() + _elem896.read(iprot) + self.defaultConstraints.append(_elem896) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 7: if ftype == TType.LIST: self.checkConstraints = [] - (_etype893, _size890) = iprot.readListBegin() - for _i894 in xrange(_size890): - _elem895 = SQLCheckConstraint() - _elem895.read(iprot) - self.checkConstraints.append(_elem895) + (_etype900, _size897) = iprot.readListBegin() + for _i901 in xrange(_size897): + _elem902 = SQLCheckConstraint() + _elem902.read(iprot) + self.checkConstraints.append(_elem902) iprot.readListEnd() else: iprot.skip(ftype) @@ -17913,43 +17969,43 @@ 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 iter896 in self.primaryKeys: - iter896.write(oprot) + for iter903 in self.primaryKeys: + iter903.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 iter897 in self.foreignKeys: - iter897.write(oprot) + for iter904 in self.foreignKeys: + iter904.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 iter898 in self.uniqueConstraints: - iter898.write(oprot) + for iter905 in self.uniqueConstraints: + iter905.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 iter899 in self.notNullConstraints: - iter899.write(oprot) + for iter906 in self.notNullConstraints: + iter906.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.defaultConstraints is not None: oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6) oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints)) - for iter900 in self.defaultConstraints: - iter900.write(oprot) + for iter907 in self.defaultConstraints: + iter907.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.checkConstraints is not None: oprot.writeFieldBegin('checkConstraints', TType.LIST, 7) oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints)) - for iter901 in self.checkConstraints: - iter901.write(oprot) + for iter908 in self.checkConstraints: + iter908.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19509,10 +19565,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype905, _size902) = iprot.readListBegin() - for _i906 in xrange(_size902): - _elem907 = iprot.readString() - self.partNames.append(_elem907) + (_etype912, _size909) = iprot.readListBegin() + for _i913 in xrange(_size909): + _elem914 = iprot.readString() + self.partNames.append(_elem914) iprot.readListEnd() else: iprot.skip(ftype) @@ -19537,8 +19593,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 iter908 in self.partNames: - oprot.writeString(iter908) + for iter915 in self.partNames: + oprot.writeString(iter915) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19738,10 +19794,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype912, _size909) = iprot.readListBegin() - for _i913 in xrange(_size909): - _elem914 = iprot.readString() - self.success.append(_elem914) + (_etype919, _size916) = iprot.readListBegin() + for _i920 in xrange(_size916): + _elem921 = iprot.readString() + self.success.append(_elem921) iprot.readListEnd() else: iprot.skip(ftype) @@ -19764,8 +19820,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 iter915 in self.success: - oprot.writeString(iter915) + for iter922 in self.success: + oprot.writeString(iter922) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19915,10 +19971,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype919, _size916) = iprot.readListBegin() - for _i920 in xrange(_size916): - _elem921 = iprot.readString() - self.success.append(_elem921) + (_etype926, _size923) = iprot.readListBegin() + for _i927 in xrange(_size923): + _elem928 = iprot.readString() + self.success.append(_elem928) iprot.readListEnd() else: iprot.skip(ftype) @@ -19941,8 +19997,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 iter922 in self.success: - oprot.writeString(iter922) + for iter929 in self.success: + oprot.writeString(iter929) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20066,10 +20122,10 @@ class get_materialized_views_for_rewriting_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype926, _size923) = iprot.readListBegin() - for _i927 in xrange(_size923): - _elem928 = iprot.readString() - self.success.append(_elem928) + (_etype933, _size930) = iprot.readListBegin() + for _i934 in xrange(_size930): + _elem935 = iprot.readString() + self.success.append(_elem935) iprot.readListEnd() else: iprot.skip(ftype) @@ -20092,8 +20148,8 @@ class get_materialized_views_for_rewriting_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter929 in self.success: - oprot.writeString(iter929) + for iter936 in self.success: + oprot.writeString(iter936) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20166,10 +20222,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype933, _size930) = iprot.readListBegin() - for _i934 in xrange(_size930): - _elem935 = iprot.readString() - self.tbl_types.append(_elem935) + (_etype940, _size937) = iprot.readListBegin() + for _i941 in xrange(_size937): + _elem942 = iprot.readString() + self.tbl_types.append(_elem942) iprot.readListEnd() else: iprot.skip(ftype) @@ -20194,8 +20250,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 iter936 in self.tbl_types: - oprot.writeString(iter936) + for iter943 in self.tbl_types: + oprot.writeString(iter943) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20251,11 +20307,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype940, _size937) = iprot.readListBegin() - for _i941 in xrange(_size937): - _elem942 = TableMeta() - _elem942.read(iprot) - self.success.append(_elem942) + (_etype947, _size944) = iprot.readListBegin() + for _i948 in xrange(_size944): + _elem949 = TableMeta() + _elem949.read(iprot) + self.success.append(_elem949) iprot.readListEnd() else: iprot.skip(ftype) @@ -20278,8 +20334,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 iter943 in self.success: - iter943.write(oprot) + for iter950 in self.success: + iter950.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20403,10 +20459,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype947, _size944) = iprot.readListBegin() - for _i948 in xrange(_size944): - _elem949 = iprot.readString() - self.success.append(_elem949) + (_etype954, _size951) = iprot.readListBegin() + for _i955 in xrange(_size951): + _elem956 = iprot.readString() + self.success.append(_elem956) iprot.readListEnd() else: iprot.skip(ftype) @@ -20429,8 +20485,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 iter950 in self.success: - oprot.writeString(iter950) + for iter957 in self.success: + oprot.writeString(iter957) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20666,10 +20722,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype954, _size951) = iprot.readListBegin() - for _i955 in xrange(_size951): - _elem956 = iprot.readString() - self.tbl_names.append(_elem956) + (_etype961, _size958) = iprot.readListBegin() + for _i962 in xrange(_size958): + _elem963 = iprot.readString() + self.tbl_names.append(_elem963) iprot.readListEnd() else: iprot.skip(ftype) @@ -20690,8 +20746,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 iter957 in self.tbl_names: - oprot.writeString(iter957) + for iter964 in self.tbl_names: + oprot.writeString(iter964) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20743,11 +20799,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype961, _size958) = iprot.readListBegin() - for _i962 in xrange(_size958): - _elem963 = Table() - _elem963.read(iprot) - self.success.append(_elem963) + (_etype968, _size965) = iprot.readListBegin() + for _i969 in xrange(_size965): + _elem970 = Table() + _elem970.read(iprot) + self.success.append(_elem970) iprot.readListEnd() else: iprot.skip(ftype) @@ -20764,8 +20820,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 iter964 in self.success: - iter964.write(oprot) + for iter971 in self.success: + iter971.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21157,10 +21213,10 @@ class get_materialization_invalidation_info_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype968, _size965) = iprot.readListBegin() - for _i969 in xrange(_size965): - _elem970 = iprot.readString() - self.tbl_names.append(_elem970) + (_etype975, _size972) = iprot.readListBegin() + for _i976 in xrange(_size972): + _elem977 = iprot.readString() + self.tbl_names.append(_elem977) iprot.readListEnd() else: iprot.skip(ftype) @@ -21181,8 +21237,8 @@ class get_materialization_invalidation_info_args: if self.tbl_names is not None: oprot.writeFieldBegin('tbl_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tbl_names)) - for iter971 in self.tbl_names: - oprot.writeString(iter971) + for iter978 in self.tbl_names: + oprot.writeString(iter978) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21243,12 +21299,12 @@ class get_materialization_invalidation_info_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype973, _vtype974, _size972 ) = iprot.readMapBegin() - for _i976 in xrange(_size972): - _key977 = iprot.readString() - _val978 = Materialization() - _val978.read(iprot) - self.success[_key977] = _val978 + (_ktype980, _vtype981, _size979 ) = iprot.readMapBegin() + for _i983 in xrange(_size979): + _key984 = iprot.readString() + _val985 = Materialization() + _val985.read(iprot) + self.success[_key984] = _val985 iprot.readMapEnd() else: iprot.skip(ftype) @@ -21283,9 +21339,9 @@ class get_materialization_invalidation_info_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter979,viter980 in self.success.items(): - oprot.writeString(kiter979) - viter980.write(oprot) + for kiter986,viter987 in self.success.items(): + oprot.writeString(kiter986) + viter987.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21650,10 +21706,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype984, _size981) = iprot.readListBegin() - for _i985 in xrange(_size981): - _elem986 = iprot.readString() - self.success.append(_elem986) + (_etype991, _size988) = iprot.readListBegin() + for _i992 in xrange(_size988): + _elem993 = iprot.readString() + self.success.append(_elem993) iprot.readListEnd() else: iprot.skip(ftype) @@ -21688,8 +21744,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 iter987 in self.success: - oprot.writeString(iter987) + for iter994 in self.success: + oprot.writeString(iter994) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22659,11 +22715,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype991, _size988) = iprot.readListBegin() - for _i992 in xrange(_size988): - _elem993 = Partition() - _elem993.read(iprot) - self.new_parts.append(_elem993) + (_etype998, _size995) = iprot.readListBegin() + for _i999 in xrange(_size995): + _elem1000 = Partition() + _elem1000.read(iprot) + self.new_parts.append(_elem1000) iprot.readListEnd() else: iprot.skip(ftype) @@ -22680,8 +22736,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 iter994 in self.new_parts: - iter994.write(oprot) + for iter1001 in self.new_parts: + iter1001.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22839,11 +22895,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype998, _size995) = iprot.readListBegin() - for _i999 in xrange(_size995): - _elem1000 = PartitionSpec() - _elem1000.read(iprot) - self.new_parts.append(_elem1000) + (_etype1005, _size1002) = iprot.readListBegin() + for _i1006 in xrange(_size1002): + _elem1007 = PartitionSpec() + _elem1007.read(iprot) + self.new_parts.append(_elem1007) iprot.readListEnd() else: iprot.skip(ftype) @@ -22860,8 +22916,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 iter1001 in self.new_parts: - iter1001.write(oprot) + for iter1008 in self.new_parts: + iter1008.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23035,10 +23091,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1005, _size1002) = iprot.readListBegin() - for _i1006 in xrange(_size1002): - _elem1007 = iprot.readString() - self.part_vals.append(_elem1007) + (_etype1012, _size1009) = iprot.readListBegin() + for _i1013 in xrange(_size1009): + _elem1014 = iprot.readString() + self.part_vals.append(_elem1014) iprot.readListEnd() else: iprot.skip(ftype) @@ -23063,8 +23119,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 iter1008 in self.part_vals: - oprot.writeString(iter1008) + for iter1015 in self.part_vals: + oprot.writeString(iter1015) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23417,10 +23473,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1012, _size1009) = iprot.readListBegin() - for _i1013 in xrange(_size1009): - _elem1014 = iprot.readString() - self.part_vals.append(_elem1014) + (_etype1019, _size1016) = iprot.readListBegin() + for _i1020 in xrange(_size1016): + _elem1021 = iprot.readString() + self.part_vals.append(_elem1021) iprot.readListEnd() else: iprot.skip(ftype) @@ -23451,8 +23507,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 iter1015 in self.part_vals: - oprot.writeString(iter1015) + for iter1022 in self.part_vals: + oprot.writeString(iter1022) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -24047,10 +24103,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1019, _size1016) = iprot.readListBegin() - for _i1020 in xrange(_size1016): - _elem1021 = iprot.readString() - self.part_vals.append(_elem1021) + (_etype1026, _size1023) = iprot.readListBegin() + for _i1027 in xrange(_size1023): + _elem1028 = iprot.readString() + self.part_vals.append(_elem1028) iprot.readListEnd() else: iprot.skip(ftype) @@ -24080,8 +24136,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 iter1022 in self.part_vals: - oprot.writeString(iter1022) + for iter1029 in self.part_vals: + oprot.writeString(iter1029) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -24254,10 +24310,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1026, _size1023) = iprot.readListBegin() - for _i1027 in xrange(_size1023): - _elem1028 = iprot.readString() - self.part_vals.append(_elem1028) + (_etype1033, _size1030) = iprot.readListBegin() + for _i1034 in xrange(_size1030): + _elem1035 = iprot.readString() + self.part_vals.append(_elem1035) iprot.readListEnd() else: iprot.skip(ftype) @@ -24293,8 +24349,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 iter1029 in self.part_vals: - oprot.writeString(iter1029) + for iter1036 in self.part_vals: + oprot.writeString(iter1036) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -25031,10 +25087,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1033, _size1030) = iprot.readListBegin() - for _i1034 in xrange(_size1030): - _elem1035 = iprot.readString() - self.part_vals.append(_elem1035) + (_etype1040, _size1037) = iprot.readListBegin() + for _i1041 in xrange(_size1037): + _elem1042 = iprot.readString() + self.part_vals.append(_elem1042) iprot.readListEnd() else: iprot.skip(ftype) @@ -25059,8 +25115,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 iter1036 in self.part_vals: - oprot.writeString(iter1036) + for iter1043 in self.part_vals: + oprot.writeString(iter1043) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25219,11 +25275,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype1038, _vtype1039, _size1037 ) = iprot.readMapBegin() - for _i1041 in xrange(_size1037): - _key1042 = iprot.readString() - _val1043 = iprot.readString() - self.partitionSpecs[_key1042] = _val1043 + (_ktype1045, _vtype1046, _size1044 ) = iprot.readMapBegin() + for _i1048 in xrange(_size1044): + _key1049 = iprot.readString() + _val1050 = iprot.readString() + self.partitionSpecs[_key1049] = _val1050 iprot.readMapEnd() else: iprot.skip(ftype) @@ -25260,9 +25316,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 kiter1044,viter1045 in self.partitionSpecs.items(): - oprot.writeString(kiter1044) - oprot.writeString(viter1045) + for kiter1051,viter1052 in self.partitionSpecs.items(): + oprot.writeString(kiter1051) + oprot.writeString(viter1052) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -25467,11 +25523,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype1047, _vtype1048, _size1046 ) = iprot.readMapBegin() - for _i1050 in xrange(_size1046): - _key1051 = iprot.readString() - _val1052 = iprot.readString() - self.partitionSpecs[_key1051] = _val1052 + (_ktype1054, _vtype1055, _size1053 ) = iprot.readMapBegin() + for _i1057 in xrange(_size1053): + _key1058 = iprot.readString() + _val1059 = iprot.readString() + self.partitionSpecs[_key1058] = _val1059 iprot.readMapEnd() else: iprot.skip(ftype) @@ -25508,9 +25564,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 kiter1053,viter1054 in self.partitionSpecs.items(): - oprot.writeString(kiter1053) - oprot.writeString(viter1054) + for kiter1060,viter1061 in self.partitionSpecs.items(): + oprot.writeString(kiter1060) + oprot.writeString(viter1061) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -25593,11 +25649,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1058, _size1055) = iprot.readListBegin() - for _i1059 in xrange(_size1055): - _elem1060 = Partition() - _elem1060.read(iprot) - self.success.append(_elem1060) + (_etype1065, _size1062) = iprot.readListBegin() + for _i1066 in xrange(_size1062): + _elem1067 = Partition() + _elem1067.read(iprot) + self.success.append(_elem1067) iprot.readListEnd() else: iprot.skip(ftype) @@ -25638,8 +25694,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 iter1061 in self.success: - iter1061.write(oprot) + for iter1068 in self.success: + iter1068.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25733,10 +25789,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1065, _size1062) = iprot.readListBegin() - for _i1066 in xrange(_size1062): - _elem1067 = iprot.readString() - self.part_vals.append(_elem1067) + (_etype1072, _size1069) = iprot.readListBegin() + for _i1073 in xrange(_size1069): + _elem1074 = iprot.readString() + self.part_vals.append(_elem1074) iprot.readListEnd() else: iprot.skip(ftype) @@ -25748,10 +25804,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype1071, _size1068) = iprot.readListBegin() - for _i1072 in xrange(_size1068): - _elem1073 = iprot.readString() - self.group_names.append(_elem1073) + (_etype1078, _size1075) = iprot.readListBegin() + for _i1079 in xrange(_size1075): + _elem1080 = iprot.readString() + self.group_names.append(_elem1080) iprot.readListEnd() else: iprot.skip(ftype) @@ -25776,8 +25832,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 iter1074 in self.part_vals: - oprot.writeString(iter1074) + for iter1081 in self.part_vals: + oprot.writeString(iter1081) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -25787,8 +25843,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 iter1075 in self.group_names: - oprot.writeString(iter1075) + for iter1082 in self.group_names: + oprot.writeString(iter1082) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -26217,11 +26273,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1079, _size1076) = iprot.readListBegin() - for _i1080 in xrange(_size1076): - _elem1081 = Partition() - _elem1081.read(iprot) - self.success.append(_elem1081) + (_etype1086, _size1083) = iprot.readListBegin() + for _i1087 in xrange(_size1083): + _elem1088 = Partition() + _elem1088.read(iprot) + self.success.append(_elem1088) iprot.readListEnd() else: iprot.skip(ftype) @@ -26250,8 +26306,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 iter1082 in self.success: - iter1082.write(oprot) + for iter1089 in self.success: + iter1089.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26345,10 +26401,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype1086, _size1083) = iprot.readListBegin() - for _i1087 in xrange(_size1083): - _elem1088 = iprot.readString() - self.group_names.append(_elem1088) + (_etype1093, _size1090) = iprot.readListBegin() + for _i1094 in xrange(_size1090): + _elem1095 = iprot.readString() + self.group_names.append(_elem1095) iprot.readListEnd() else: iprot.skip(ftype) @@ -26381,8 +26437,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 iter1089 in self.group_names: - oprot.writeString(iter1089) + for iter1096 in self.group_names: + oprot.writeString(iter1096) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -26443,11 +26499,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1093, _size1090) = iprot.readListBegin() - for _i1094 in xrange(_size1090): - _elem1095 = Partition() - _elem1095.read(iprot) - self.success.append(_elem1095) + (_etype1100, _size1097) = iprot.readListBegin() + for _i1101 in xrange(_size1097): + _elem1102 = Partition() + _elem1102.read(iprot) + self.success.append(_elem1102) iprot.readListEnd() else: iprot.skip(ftype) @@ -26476,8 +26532,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 iter1096 in self.success: - iter1096.write(oprot) + for iter1103 in self.success: + iter1103.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26635,11 +26691,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1100, _size1097) = iprot.readListBegin() - for _i1101 in xrange(_size1097): - _elem1102 = PartitionSpec() - _elem1102.read(iprot) - self.success.append(_elem1102) + (_etype1107, _size1104) = iprot.readListBegin() + for _i1108 in xrange(_size1104): + _elem1109 = PartitionSpec() + _elem1109.read(iprot) + self.success.append(_elem1109) iprot.readListEnd() else: iprot.skip(ftype) @@ -26668,8 +26724,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 iter1103 in self.success: - iter1103.write(oprot) + for iter1110 in self.success: + iter1110.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26827,10 +26883,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1107, _size1104) = iprot.readListBegin() - for _i1108 in xrange(_size1104): - _elem1109 = iprot.readString() - self.success.append(_elem1109) + (_etype1114, _size1111) = iprot.readListBegin() + for _i1115 in xrange(_size1111): + _elem1116 = iprot.readString() + self.success.append(_elem1116) iprot.readListEnd() else: iprot.skip(ftype) @@ -26859,8 +26915,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 iter1110 in self.success: - oprot.writeString(iter1110) + for iter1117 in self.success: + oprot.writeString(iter1117) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27100,10 +27156,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1114, _size1111) = iprot.readListBegin() - for _i1115 in xrange(_size1111): - _elem1116 = iprot.readString() - self.part_vals.append(_elem1116) + (_etype1121, _size1118) = iprot.readListBegin() + for _i1122 in xrange(_size1118): + _elem1123 = iprot.readString() + self.part_vals.append(_elem1123) iprot.readListEnd() else: iprot.skip(ftype) @@ -27133,8 +27189,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 iter1117 in self.part_vals: - oprot.writeString(iter1117) + for iter1124 in self.part_vals: + oprot.writeString(iter1124) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -27198,11 +27254,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1121, _size1118) = iprot.readListBegin() - for _i1122 in xrange(_size1118): - _elem1123 = Partition() - _elem1123.read(iprot) - self.success.append(_elem1123) + (_etype1128, _size1125) = iprot.readListBegin() + for _i1129 in xrange(_size1125): + _elem1130 = Partition() + _elem1130.read(iprot) + self.success.append(_elem1130) iprot.readListEnd() else: iprot.skip(ftype) @@ -27231,8 +27287,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 iter1124 in self.success: - iter1124.write(oprot) + for iter1131 in self.success: + iter1131.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27319,10 +27375,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1128, _size1125) = iprot.readListBegin() - for _i1129 in xrange(_size1125): - _elem1130 = iprot.readString() - self.part_vals.append(_elem1130) + (_etype1135, _size1132) = iprot.readListBegin() + for _i1136 in xrange(_size1132): + _elem1137 = iprot.readString() + self.part_vals.append(_elem1137) iprot.readListEnd() else: iprot.skip(ftype) @@ -27339,10 +27395,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype1134, _size1131) = iprot.readListBegin() - for _i1135 in xrange(_size1131): - _elem1136 = iprot.readString() - self.group_names.append(_elem1136) + (_etype1141, _size1138) = iprot.readListBegin() + for _i1142 in xrange(_size1138): + _elem1143 = iprot.readString() + self.group_names.append(_elem1143) iprot.readListEnd() else: iprot.skip(ftype) @@ -27367,8 +27423,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 iter1137 in self.part_vals: - oprot.writeString(iter1137) + for iter1144 in self.part_vals: + oprot.writeString(iter1144) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -27382,8 +27438,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 iter1138 in self.group_names: - oprot.writeString(iter1138) + for iter1145 in self.group_names: + oprot.writeString(iter1145) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -27445,11 +27501,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1142, _size1139) = iprot.readListBegin() - for _i1143 in xrange(_size1139): - _elem1144 = Partition() - _elem1144.read(iprot) - self.success.append(_elem1144) + (_etype1149, _size1146) = iprot.readListBegin() + for _i1150 in xrange(_size1146): + _elem1151 = Partition() + _elem1151.read(iprot) + self.success.append(_elem1151) iprot.readListEnd() else: iprot.skip(ftype) @@ -27478,8 +27534,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 iter1145 in self.success: - iter1145.write(oprot) + for iter1152 in self.success: + iter1152.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27560,10 +27616,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1149, _size1146) = iprot.readListBegin() - for _i1150 in xrange(_size1146): - _elem1151 = iprot.readString() - self.part_vals.append(_elem1151) + (_etype1156, _size1153) = iprot.readListBegin() + for _i1157 in xrange(_size1153): + _elem1158 = iprot.readString() + self.part_vals.append(_elem1158) iprot.readListEnd() else: iprot.skip(ftype) @@ -27593,8 +27649,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 iter1152 in self.part_vals: - oprot.writeString(iter1152) + for iter1159 in self.part_vals: + oprot.writeString(iter1159) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -27658,10 +27714,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1156, _size1153) = iprot.readListBegin() - for _i1157 in xrange(_size1153): - _elem1158 = iprot.readString() - self.success.append(_elem1158) + (_etype1163, _size1160) = iprot.readListBegin() + for _i1164 in xrange(_size1160): + _elem1165 = iprot.readString() + self.success.append(_elem1165) iprot.readListEnd() else: iprot.skip(ftype) @@ -27690,8 +27746,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 iter1159 in self.success: - oprot.writeString(iter1159) + for iter1166 in self.success: + oprot.writeString(iter1166) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27862,11 +27918,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1163, _size1160) = iprot.readListBegin() - for _i1164 in xrange(_size1160): - _elem1165 = Partition() - _elem1165.read(iprot) - self.success.append(_elem1165) + (_etype1170, _size1167) = iprot.readListBegin() + for _i1171 in xrange(_size1167): + _elem1172 = Partition() + _elem1172.read(iprot) + self.success.append(_elem1172) iprot.readListEnd() else: iprot.skip(ftype) @@ -27895,8 +27951,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 iter1166 in self.success: - iter1166.write(oprot) + for iter1173 in self.success: + iter1173.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28067,11 +28123,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1170, _size1167) = iprot.readListBegin() - for _i1171 in xrange(_size1167): - _elem1172 = PartitionSpec() - _elem1172.read(iprot) - self.success.append(_elem1172) + (_etype1177, _size1174) = iprot.readListBegin() + for _i1178 in xrange(_size1174): + _elem1179 = PartitionSpec() + _elem1179.read(iprot) + self.success.append(_elem1179) iprot.readListEnd() else: iprot.skip(ftype) @@ -28100,8 +28156,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 iter1173 in self.success: - iter1173.write(oprot) + for iter1180 in self.success: + iter1180.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28521,10 +28577,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype1177, _size1174) = iprot.readListBegin() - for _i1178 in xrange(_size1174): - _elem1179 = iprot.readString() - self.names.append(_elem1179) + (_etype1184, _size1181) = iprot.readListBegin() + for _i1185 in xrange(_size1181): + _elem1186 = iprot.readString() + self.names.append(_elem1186) iprot.readListEnd() else: iprot.skip(ftype) @@ -28549,8 +28605,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 iter1180 in self.names: - oprot.writeString(iter1180) + for iter1187 in self.names: + oprot.writeString(iter1187) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -28609,11 +28665,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1184, _size1181) = iprot.readListBegin() - for _i1185 in xrange(_size1181): - _elem1186 = Partition() - _elem1186.read(iprot) - self.success.append(_elem1186) + (_etype1191, _size1188) = iprot.readListBegin() + for _i1192 in xrange(_size1188): + _elem1193 = Partition() + _elem1193.read(iprot) + self.success.append(_elem1193) iprot.readListEnd() else: iprot.skip(ftype) @@ -28642,8 +28698,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 iter1187 in self.success: - iter1187.write(oprot) + for iter1194 in self.success: + iter1194.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28893,11 +28949,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1191, _size1188) = iprot.readListBegin() - for _i1192 in xrange(_size1188): - _elem1193 = Partition() - _elem1193.read(iprot) - self.new_parts.append(_elem1193) + (_etype1198, _size1195) = iprot.readListBegin() + for _i1199 in xrange(_size1195): + _elem1200 = Partition() + _elem1200.read(iprot) + self.new_parts.append(_elem1200) iprot.readListEnd() else: iprot.skip(ftype) @@ -28922,8 +28978,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 iter1194 in self.new_parts: - iter1194.write(oprot) + for iter1201 in self.new_parts: + iter1201.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -29076,11 +29132,11 @@ class alter_partitions_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1198, _size1195) = iprot.readListBegin() - for _i1199 in xrange(_size1195): - _elem1200 = Partition() - _elem1200.read(iprot) - self.new_parts.append(_elem1200) + (_etype1205, _size1202) = iprot.readListBegin() + for _i1206 in xrange(_size1202): + _elem1207 = Partition() + _elem1207.read(iprot) + self.new_parts.append(_elem1207) iprot.readListEnd() else: iprot.skip(ftype) @@ -29111,8 +29167,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 iter1201 in self.new_parts: - iter1201.write(oprot) + for iter1208 in self.new_parts: + iter1208.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -29456,10 +29512,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1205, _size1202) = iprot.readListBegin() - for _i1206 in xrange(_size1202): - _elem1207 = iprot.readString() - self.part_vals.append(_elem1207) + (_etype1212, _size1209) = iprot.readListBegin() + for _i1213 in xrange(_size1209): + _elem1214 = iprot.readString() + self.part_vals.append(_elem1214) iprot.readListEnd() else: iprot.skip(ftype) @@ -29490,8 +29546,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 iter1208 in self.part_vals: - oprot.writeString(iter1208) + for iter1215 in self.part_vals: + oprot.writeString(iter1215) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -29633,10 +29689,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype1212, _size1209) = iprot.readListBegin() - for _i1213 in xrange(_size1209): - _elem1214 = iprot.readString() - self.part_vals.append(_elem1214) + (_etype1219, _size1216) = iprot.readListBegin() + for _i1220 in xrange(_size1216): + _elem1221 = iprot.readString() + self.part_vals.append(_elem1221) iprot.readListEnd() else: iprot.skip(ftype) @@ -29658,8 +29714,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 iter1215 in self.part_vals: - oprot.writeString(iter1215) + for iter1222 in self.part_vals: + oprot.writeString(iter1222) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -30017,10 +30073,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1219, _size1216) = iprot.readListBegin() - for _i1220 in xrange(_size1216): - _elem1221 = iprot.readString() - self.success.append(_elem1221) + (_etype1226, _size1223) = iprot.readListBegin() + for _i1227 in xrange(_size1223): + _elem1228 = iprot.readString() + self.success.append(_elem1228) iprot.readListEnd() else: iprot.skip(ftype) @@ -30043,8 +30099,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 iter1222 in self.success: - oprot.writeString(iter1222) + for iter1229 in self.success: + oprot.writeString(iter1229) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -30168,11 +30224,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype1224, _vtype1225, _size1223 ) = iprot.readMapBegin() - for _i1227 in xrange(_size1223): - _key1228 = iprot.readString() - _val1229 = iprot.readString() - self.success[_key1228] = _val1229 + (_ktype1231, _vtype1232, _size1230 ) = iprot.readMapBegin() + for _i1234 in xrange(_size1230): + _key1235 = iprot.readString() + _val1236 = iprot.readString() + self.success[_key1235] = _val1236 iprot.readMapEnd() else: iprot.skip(ftype) @@ -30195,9 +30251,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 kiter1230,viter1231 in self.success.items(): - oprot.writeString(kiter1230) - oprot.writeString(viter1231) + for kiter1237,viter1238 in self.success.items(): + oprot.writeString(kiter1237) + oprot.writeString(viter1238) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -30273,11 +30329,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype1233, _vtype1234, _size1232 ) = iprot.readMapBegin() - for _i1236 in xrange(_size1232): - _key1237 = iprot.readString() - _val1238 = iprot.readString() - self.part_vals[_key1237] = _val1238 + (_ktype1240, _vtype1241, _size1239 ) = iprot.readMapBegin() + for _i1243 in xrange(_size1239): + _key1244 = iprot.readString() + _val1245 = iprot.readString() + self.part_vals[_key1244] = _val1245 iprot.readMapEnd() else: iprot.skip(ftype) @@ -30307,9 +30363,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 kiter1239,viter1240 in self.part_vals.items(): - oprot.writeString(kiter1239) - oprot.writeString(viter1240) + for kiter1246,viter1247 in self.part_vals.items(): + oprot.writeString(kiter1246) + oprot.writeString(viter1247) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -30523,11 +30579,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype1242, _vtype1243, _size1241 ) = iprot.readMapBegin() - for _i1245 in xrange(_size1241): - _key1246 = iprot.readString() - _val1247 = iprot.readString() - self.part_vals[_key1246] = _val1247 + (_ktype1249, _vtype1250, _size1248 ) = iprot.readMapBegin() + for _i1252 in xrange(_size1248): + _key1253 = iprot.readString() + _val1254 = iprot.readString() + self.part_vals[_key1253] = _val1254 iprot.readMapEnd() else: iprot.skip(ftype) @@ -30557,9 +30613,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 kiter1248,viter1249 in self.part_vals.items(): - oprot.writeString(kiter1248) - oprot.writeString(viter1249) + for kiter1255,viter1256 in self.part_vals.items(): + oprot.writeString(kiter1255) + oprot.writeString(viter1256) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -34211,10 +34267,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1253, _size1250) = iprot.readListBegin() - for _i1254 in xrange(_size1250): - _elem1255 = iprot.readString() - self.success.append(_elem1255) + (_etype1260, _size1257) = iprot.readListBegin() + for _i1261 in xrange(_size1257): + _elem1262 = iprot.readString() + self.success.append(_elem1262) iprot.readListEnd() else: iprot.skip(ftype) @@ -34237,8 +34293,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 iter1256 in self.success: - oprot.writeString(iter1256) + for iter1263 in self.success: + oprot.writeString(iter1263) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -34926,10 +34982,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1260, _size1257) = iprot.readListBegin() - for _i1261 in xrange(_size1257): - _elem1262 = iprot.readString() - self.success.append(_elem1262) + (_etype1267, _size1264) = iprot.readListBegin() + for _i1268 in xrange(_size1264): + _elem1269 = iprot.readString() + self.success.append(_elem1269) iprot.readListEnd() else: iprot.skip(ftype) @@ -34952,8 +35008,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 iter1263 in self.success: - oprot.writeString(iter1263) + for iter1270 in self.success: + oprot.writeString(iter1270) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -35467,11 +35523,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1267, _size1264) = iprot.readListBegin() - for _i1268 in xrange(_size1264): - _elem1269 = Role() - _elem1269.read(iprot) - self.success.append(_elem1269) + (_etype1274, _size1271) = iprot.readListBegin() + for _i1275 in xrange(_size1271): + _elem1276 = Role() + _elem1276.read(iprot) + self.success.append(_elem1276) iprot.readListEnd() else: iprot.skip(ftype) @@ -35494,8 +35550,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 iter1270 in self.success: - iter1270.write(oprot) + for iter1277 in self.success: + iter1277.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -36004,10 +36060,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype1274, _size1271) = iprot.readListBegin() - for _i1275 in xrange(_size1271): - _elem1276 = iprot.readString() - self.group_names.append(_elem1276) + (_etype1281, _size1278) = iprot.readListBegin() + for _i1282 in xrange(_size1278): + _elem1283 = iprot.readString() + self.group_names.append(_elem1283) iprot.readListEnd() else: iprot.skip(ftype) @@ -36032,8 +36088,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 iter1277 in self.group_names: - oprot.writeString(iter1277) + for iter1284 in self.group_names: + oprot.writeString(iter1284) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -36260,11 +36316,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1281, _size1278) = iprot.readListBegin() - for _i1282 in xrange(_size1278): - _elem1283 = HiveObjectPrivilege() - _elem1283.read(iprot) - self.success.append(_elem1283) + (_etype1288, _size1285) = iprot.readListBegin() + for _i1289 in xrange(_size1285): + _elem1290 = HiveObjectPrivilege() + _elem1290.read(iprot) + self.success.append(_elem1290) iprot.readListEnd() else: iprot.skip(ftype) @@ -36287,8 +36343,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 iter1284 in self.success: - iter1284.write(oprot) + for iter1291 in self.success: + iter1291.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -36786,10 +36842,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype1288, _size1285) = iprot.readListBegin() - for _i1289 in xrange(_size1285): - _elem1290 = iprot.readString() - self.group_names.append(_elem1290) + (_etype1295, _size1292) = iprot.readListBegin() + for _i1296 in xrange(_size1292): + _elem1297 = iprot.readString() + self.group_names.append(_elem1297) iprot.readListEnd() else: iprot.skip(ftype) @@ -36810,8 +36866,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 iter1291 in self.group_names: - oprot.writeString(iter1291) + for iter1298 in self.group_names: + oprot.writeString(iter1298) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -36866,10 +36922,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1295, _size1292) = iprot.readListBegin() - for _i1296 in xrange(_size1292): - _elem1297 = iprot.readString() - self.success.append(_elem1297) + (_etype1302, _size1299) = iprot.readListBegin() + for _i1303 in xrange(_size1299): + _elem1304 = iprot.readString() + self.success.append(_elem1304) iprot.readListEnd() else: iprot.skip(ftype) @@ -36892,8 +36948,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 iter1298 in self.success: - oprot.writeString(iter1298) + for iter1305 in self.success: + oprot.writeString(iter1305) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -37825,10 +37881,10 @@ class get_all_token_identifiers_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1302, _size1299) = iprot.readListBegin() - for _i1303 in xrange(_size1299): - _elem1304 = iprot.readString() - self.success.append(_elem1304) + (_etype1309, _size1306) = iprot.readListBegin() + for _i1310 in xrange(_size1306): + _elem1311 = iprot.readString() + self.success.append(_elem1311) iprot.readListEnd() else: iprot.skip(ftype) @@ -37845,8 +37901,8 @@ class get_all_token_id
<TRUNCATED>
