Modified: hive/branches/cbo/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py URL: http://svn.apache.org/viewvc/hive/branches/cbo/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1619936&r1=1619935&r2=1619936&view=diff ============================================================================== --- hive/branches/cbo/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original) +++ hive/branches/cbo/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Fri Aug 22 21:36:47 2014 @@ -22,6 +22,21 @@ class Iface(fb303.FacebookService.Iface) """ This interface is live. """ + def getMetaConf(self, key): + """ + Parameters: + - key + """ + pass + + def setMetaConf(self, key, value): + """ + Parameters: + - key + - value + """ + pass + def create_database(self, database): """ Parameters: @@ -640,6 +655,13 @@ class Iface(fb303.FacebookService.Iface) """ pass + def set_aggr_stats_for(self, request): + """ + Parameters: + - request + """ + pass + def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name): """ Parameters: @@ -926,6 +948,70 @@ class Client(fb303.FacebookService.Clien def __init__(self, iprot, oprot=None): fb303.FacebookService.Client.__init__(self, iprot, oprot) + def getMetaConf(self, key): + """ + Parameters: + - key + """ + self.send_getMetaConf(key) + return self.recv_getMetaConf() + + def send_getMetaConf(self, key): + self._oprot.writeMessageBegin('getMetaConf', TMessageType.CALL, self._seqid) + args = getMetaConf_args() + args.key = key + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_getMetaConf(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = getMetaConf_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + raise TApplicationException(TApplicationException.MISSING_RESULT, "getMetaConf failed: unknown result"); + + def setMetaConf(self, key, value): + """ + Parameters: + - key + - value + """ + self.send_setMetaConf(key, value) + self.recv_setMetaConf() + + def send_setMetaConf(self, key, value): + self._oprot.writeMessageBegin('setMetaConf', TMessageType.CALL, self._seqid) + args = setMetaConf_args() + args.key = key + args.value = value + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_setMetaConf(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = setMetaConf_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + return + def create_database(self, database): """ Parameters: @@ -3629,6 +3715,44 @@ class Client(fb303.FacebookService.Clien raise result.o2 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_aggr_stats_for failed: unknown result"); + def set_aggr_stats_for(self, request): + """ + Parameters: + - request + """ + self.send_set_aggr_stats_for(request) + return self.recv_set_aggr_stats_for() + + def send_set_aggr_stats_for(self, request): + self._oprot.writeMessageBegin('set_aggr_stats_for', TMessageType.CALL, self._seqid) + args = set_aggr_stats_for_args() + args.request = request + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_set_aggr_stats_for(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = set_aggr_stats_for_result() + result.read(self._iprot) + self._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 + if result.o3 is not None: + raise result.o3 + if result.o4 is not None: + raise result.o4 + raise TApplicationException(TApplicationException.MISSING_RESULT, "set_aggr_stats_for failed: unknown result"); + def delete_partition_column_statistics(self, db_name, tbl_name, part_name, col_name): """ Parameters: @@ -4888,6 +5012,8 @@ class Client(fb303.FacebookService.Clien class Processor(fb303.FacebookService.Processor, Iface, TProcessor): def __init__(self, handler): fb303.FacebookService.Processor.__init__(self, handler) + self._processMap["getMetaConf"] = Processor.process_getMetaConf + self._processMap["setMetaConf"] = Processor.process_setMetaConf self._processMap["create_database"] = Processor.process_create_database self._processMap["get_database"] = Processor.process_get_database self._processMap["drop_database"] = Processor.process_drop_database @@ -4960,6 +5086,7 @@ class Processor(fb303.FacebookService.Pr self._processMap["get_table_statistics_req"] = Processor.process_get_table_statistics_req self._processMap["get_partitions_statistics_req"] = Processor.process_get_partitions_statistics_req self._processMap["get_aggr_stats_for"] = Processor.process_get_aggr_stats_for + self._processMap["set_aggr_stats_for"] = Processor.process_set_aggr_stats_for self._processMap["delete_partition_column_statistics"] = Processor.process_delete_partition_column_statistics self._processMap["delete_table_column_statistics"] = Processor.process_delete_table_column_statistics self._processMap["create_function"] = Processor.process_create_function @@ -5014,6 +5141,34 @@ class Processor(fb303.FacebookService.Pr self._processMap[name](self, seqid, iprot, oprot) return True + def process_getMetaConf(self, seqid, iprot, oprot): + args = getMetaConf_args() + args.read(iprot) + iprot.readMessageEnd() + result = getMetaConf_result() + try: + result.success = self._handler.getMetaConf(args.key) + except MetaException as o1: + result.o1 = o1 + oprot.writeMessageBegin("getMetaConf", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_setMetaConf(self, seqid, iprot, oprot): + args = setMetaConf_args() + args.read(iprot) + iprot.readMessageEnd() + result = setMetaConf_result() + try: + self._handler.setMetaConf(args.key, args.value) + except MetaException as o1: + result.o1 = o1 + oprot.writeMessageBegin("setMetaConf", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_create_database(self, seqid, iprot, oprot): args = create_database_args() args.read(iprot) @@ -6220,6 +6375,26 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() + def process_set_aggr_stats_for(self, seqid, iprot, oprot): + args = set_aggr_stats_for_args() + args.read(iprot) + iprot.readMessageEnd() + result = set_aggr_stats_for_result() + try: + result.success = self._handler.set_aggr_stats_for(args.request) + except NoSuchObjectException as o1: + result.o1 = o1 + except InvalidObjectException as o2: + result.o2 = o2 + except MetaException as o3: + result.o3 = o3 + except InvalidInputException as o4: + result.o4 = o4 + oprot.writeMessageBegin("set_aggr_stats_for", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_delete_partition_column_statistics(self, seqid, iprot, oprot): args = delete_partition_column_statistics_args() args.read(iprot) @@ -6736,41 +6911,306 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() - def process_heartbeat_txn_range(self, seqid, iprot, oprot): - args = heartbeat_txn_range_args() - args.read(iprot) - iprot.readMessageEnd() - result = heartbeat_txn_range_result() - result.success = self._handler.heartbeat_txn_range(args.txns) - oprot.writeMessageBegin("heartbeat_txn_range", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() + def process_heartbeat_txn_range(self, seqid, iprot, oprot): + args = heartbeat_txn_range_args() + args.read(iprot) + iprot.readMessageEnd() + result = heartbeat_txn_range_result() + result.success = self._handler.heartbeat_txn_range(args.txns) + oprot.writeMessageBegin("heartbeat_txn_range", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_compact(self, seqid, iprot, oprot): + args = compact_args() + args.read(iprot) + iprot.readMessageEnd() + result = compact_result() + self._handler.compact(args.rqst) + oprot.writeMessageBegin("compact", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_show_compact(self, seqid, iprot, oprot): + args = show_compact_args() + args.read(iprot) + iprot.readMessageEnd() + result = show_compact_result() + result.success = self._handler.show_compact(args.rqst) + oprot.writeMessageBegin("show_compact", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + +# HELPER FUNCTIONS AND STRUCTURES + +class getMetaConf_args: + """ + Attributes: + - key + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'key', None, None, ), # 1 + ) + + def __init__(self, key=None,): + self.key = key + + 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.key = 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('getMetaConf_args') + if self.key is not None: + oprot.writeFieldBegin('key', TType.STRING, 1) + oprot.writeString(self.key) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 getMetaConf_result: + """ + Attributes: + - success + - o1 + """ + + thrift_spec = ( + (0, TType.STRING, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + ) + + def __init__(self, success=None, o1=None,): + self.success = success + self.o1 = o1 + + 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.STRING: + self.success = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.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('getMetaConf_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRING, 0) + oprot.writeString(self.success) + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 setMetaConf_args: + """ + Attributes: + - key + - value + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRING, 'key', None, None, ), # 1 + (2, TType.STRING, 'value', None, None, ), # 2 + ) + + def __init__(self, key=None, value=None,): + self.key = key + self.value = value + + 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.key = iprot.readString(); + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRING: + self.value = 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('setMetaConf_args') + if self.key is not None: + oprot.writeFieldBegin('key', TType.STRING, 1) + oprot.writeString(self.key) + oprot.writeFieldEnd() + if self.value is not None: + oprot.writeFieldBegin('value', TType.STRING, 2) + oprot.writeString(self.value) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 setMetaConf_result: + """ + Attributes: + - o1 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + ) + + def __init__(self, o1=None,): + self.o1 = o1 + + 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.o1 = MetaException() + self.o1.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('setMetaConf_result') + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() - def process_compact(self, seqid, iprot, oprot): - args = compact_args() - args.read(iprot) - iprot.readMessageEnd() - result = compact_result() - self._handler.compact(args.rqst) - oprot.writeMessageBegin("compact", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() + def validate(self): + return - def process_show_compact(self, seqid, iprot, oprot): - args = show_compact_args() - args.read(iprot) - iprot.readMessageEnd() - result = show_compact_result() - result.success = self._handler.show_compact(args.rqst) - oprot.writeMessageBegin("show_compact", TMessageType.REPLY, seqid) - result.write(oprot) - oprot.writeMessageEnd() - oprot.trans.flush() + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) -# HELPER FUNCTIONS AND STRUCTURES + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) class create_database_args: """ @@ -7325,10 +7765,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype400, _size397) = iprot.readListBegin() - for _i401 in xrange(_size397): - _elem402 = iprot.readString(); - self.success.append(_elem402) + (_etype407, _size404) = iprot.readListBegin() + for _i408 in xrange(_size404): + _elem409 = iprot.readString(); + self.success.append(_elem409) iprot.readListEnd() else: iprot.skip(ftype) @@ -7351,8 +7791,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 iter403 in self.success: - oprot.writeString(iter403) + for iter410 in self.success: + oprot.writeString(iter410) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -7447,10 +7887,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype407, _size404) = iprot.readListBegin() - for _i408 in xrange(_size404): - _elem409 = iprot.readString(); - self.success.append(_elem409) + (_etype414, _size411) = iprot.readListBegin() + for _i415 in xrange(_size411): + _elem416 = iprot.readString(); + self.success.append(_elem416) iprot.readListEnd() else: iprot.skip(ftype) @@ -7473,8 +7913,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 iter410 in self.success: - oprot.writeString(iter410) + for iter417 in self.success: + oprot.writeString(iter417) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8184,12 +8624,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype412, _vtype413, _size411 ) = iprot.readMapBegin() - for _i415 in xrange(_size411): - _key416 = iprot.readString(); - _val417 = Type() - _val417.read(iprot) - self.success[_key416] = _val417 + (_ktype419, _vtype420, _size418 ) = iprot.readMapBegin() + for _i422 in xrange(_size418): + _key423 = iprot.readString(); + _val424 = Type() + _val424.read(iprot) + self.success[_key423] = _val424 iprot.readMapEnd() else: iprot.skip(ftype) @@ -8212,9 +8652,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 kiter418,viter419 in self.success.items(): - oprot.writeString(kiter418) - viter419.write(oprot) + for kiter425,viter426 in self.success.items(): + oprot.writeString(kiter425) + viter426.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -8345,11 +8785,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype423, _size420) = iprot.readListBegin() - for _i424 in xrange(_size420): - _elem425 = FieldSchema() - _elem425.read(iprot) - self.success.append(_elem425) + (_etype430, _size427) = iprot.readListBegin() + for _i431 in xrange(_size427): + _elem432 = FieldSchema() + _elem432.read(iprot) + self.success.append(_elem432) iprot.readListEnd() else: iprot.skip(ftype) @@ -8384,8 +8824,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 iter426 in self.success: - iter426.write(oprot) + for iter433 in self.success: + iter433.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8524,11 +8964,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype430, _size427) = iprot.readListBegin() - for _i431 in xrange(_size427): - _elem432 = FieldSchema() - _elem432.read(iprot) - self.success.append(_elem432) + (_etype437, _size434) = iprot.readListBegin() + for _i438 in xrange(_size434): + _elem439 = FieldSchema() + _elem439.read(iprot) + self.success.append(_elem439) iprot.readListEnd() else: iprot.skip(ftype) @@ -8563,8 +9003,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 iter433 in self.success: - iter433.write(oprot) + for iter440 in self.success: + iter440.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9361,10 +9801,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype437, _size434) = iprot.readListBegin() - for _i438 in xrange(_size434): - _elem439 = iprot.readString(); - self.success.append(_elem439) + (_etype444, _size441) = iprot.readListBegin() + for _i445 in xrange(_size441): + _elem446 = iprot.readString(); + self.success.append(_elem446) iprot.readListEnd() else: iprot.skip(ftype) @@ -9387,8 +9827,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 iter440 in self.success: - oprot.writeString(iter440) + for iter447 in self.success: + oprot.writeString(iter447) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9501,10 +9941,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype444, _size441) = iprot.readListBegin() - for _i445 in xrange(_size441): - _elem446 = iprot.readString(); - self.success.append(_elem446) + (_etype451, _size448) = iprot.readListBegin() + for _i452 in xrange(_size448): + _elem453 = iprot.readString(); + self.success.append(_elem453) iprot.readListEnd() else: iprot.skip(ftype) @@ -9527,8 +9967,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 iter447 in self.success: - oprot.writeString(iter447) + for iter454 in self.success: + oprot.writeString(iter454) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9745,10 +10185,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype451, _size448) = iprot.readListBegin() - for _i452 in xrange(_size448): - _elem453 = iprot.readString(); - self.tbl_names.append(_elem453) + (_etype458, _size455) = iprot.readListBegin() + for _i459 in xrange(_size455): + _elem460 = iprot.readString(); + self.tbl_names.append(_elem460) iprot.readListEnd() else: iprot.skip(ftype) @@ -9769,8 +10209,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 iter454 in self.tbl_names: - oprot.writeString(iter454) + for iter461 in self.tbl_names: + oprot.writeString(iter461) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -9825,11 +10265,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype458, _size455) = iprot.readListBegin() - for _i459 in xrange(_size455): - _elem460 = Table() - _elem460.read(iprot) - self.success.append(_elem460) + (_etype465, _size462) = iprot.readListBegin() + for _i466 in xrange(_size462): + _elem467 = Table() + _elem467.read(iprot) + self.success.append(_elem467) iprot.readListEnd() else: iprot.skip(ftype) @@ -9864,8 +10304,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 iter461 in self.success: - iter461.write(oprot) + for iter468 in self.success: + iter468.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10016,10 +10456,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype465, _size462) = iprot.readListBegin() - for _i466 in xrange(_size462): - _elem467 = iprot.readString(); - self.success.append(_elem467) + (_etype472, _size469) = iprot.readListBegin() + for _i473 in xrange(_size469): + _elem474 = iprot.readString(); + self.success.append(_elem474) iprot.readListEnd() else: iprot.skip(ftype) @@ -10054,8 +10494,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 iter468 in self.success: - oprot.writeString(iter468) + for iter475 in self.success: + oprot.writeString(iter475) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10778,11 +11218,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype472, _size469) = iprot.readListBegin() - for _i473 in xrange(_size469): - _elem474 = Partition() - _elem474.read(iprot) - self.new_parts.append(_elem474) + (_etype479, _size476) = iprot.readListBegin() + for _i480 in xrange(_size476): + _elem481 = Partition() + _elem481.read(iprot) + self.new_parts.append(_elem481) iprot.readListEnd() else: iprot.skip(ftype) @@ -10799,8 +11239,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 iter475 in self.new_parts: - iter475.write(oprot) + for iter482 in self.new_parts: + iter482.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10961,10 +11401,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype479, _size476) = iprot.readListBegin() - for _i480 in xrange(_size476): - _elem481 = iprot.readString(); - self.part_vals.append(_elem481) + (_etype486, _size483) = iprot.readListBegin() + for _i487 in xrange(_size483): + _elem488 = iprot.readString(); + self.part_vals.append(_elem488) iprot.readListEnd() else: iprot.skip(ftype) @@ -10989,8 +11429,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 iter482 in self.part_vals: - oprot.writeString(iter482) + for iter489 in self.part_vals: + oprot.writeString(iter489) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11315,10 +11755,10 @@ class append_partition_with_environment_ elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype486, _size483) = iprot.readListBegin() - for _i487 in xrange(_size483): - _elem488 = iprot.readString(); - self.part_vals.append(_elem488) + (_etype493, _size490) = iprot.readListBegin() + for _i494 in xrange(_size490): + _elem495 = iprot.readString(); + self.part_vals.append(_elem495) iprot.readListEnd() else: iprot.skip(ftype) @@ -11349,8 +11789,8 @@ class append_partition_with_environment_ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter489 in self.part_vals: - oprot.writeString(iter489) + for iter496 in self.part_vals: + oprot.writeString(iter496) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -11898,10 +12338,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype493, _size490) = iprot.readListBegin() - for _i494 in xrange(_size490): - _elem495 = iprot.readString(); - self.part_vals.append(_elem495) + (_etype500, _size497) = iprot.readListBegin() + for _i501 in xrange(_size497): + _elem502 = iprot.readString(); + self.part_vals.append(_elem502) iprot.readListEnd() else: iprot.skip(ftype) @@ -11931,8 +12371,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 iter496 in self.part_vals: - oprot.writeString(iter496) + for iter503 in self.part_vals: + oprot.writeString(iter503) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -12090,10 +12530,10 @@ class drop_partition_with_environment_co elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype500, _size497) = iprot.readListBegin() - for _i501 in xrange(_size497): - _elem502 = iprot.readString(); - self.part_vals.append(_elem502) + (_etype507, _size504) = iprot.readListBegin() + for _i508 in xrange(_size504): + _elem509 = iprot.readString(); + self.part_vals.append(_elem509) iprot.readListEnd() else: iprot.skip(ftype) @@ -12129,8 +12569,8 @@ class drop_partition_with_environment_co if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter503 in self.part_vals: - oprot.writeString(iter503) + for iter510 in self.part_vals: + oprot.writeString(iter510) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -12808,10 +13248,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype507, _size504) = iprot.readListBegin() - for _i508 in xrange(_size504): - _elem509 = iprot.readString(); - self.part_vals.append(_elem509) + (_etype514, _size511) = iprot.readListBegin() + for _i515 in xrange(_size511): + _elem516 = iprot.readString(); + self.part_vals.append(_elem516) iprot.readListEnd() else: iprot.skip(ftype) @@ -12836,8 +13276,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 iter510 in self.part_vals: - oprot.writeString(iter510) + for iter517 in self.part_vals: + oprot.writeString(iter517) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12982,11 +13422,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype512, _vtype513, _size511 ) = iprot.readMapBegin() - for _i515 in xrange(_size511): - _key516 = iprot.readString(); - _val517 = iprot.readString(); - self.partitionSpecs[_key516] = _val517 + (_ktype519, _vtype520, _size518 ) = iprot.readMapBegin() + for _i522 in xrange(_size518): + _key523 = iprot.readString(); + _val524 = iprot.readString(); + self.partitionSpecs[_key523] = _val524 iprot.readMapEnd() else: iprot.skip(ftype) @@ -13023,9 +13463,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 kiter518,viter519 in self.partitionSpecs.items(): - oprot.writeString(kiter518) - oprot.writeString(viter519) + for kiter525,viter526 in self.partitionSpecs.items(): + oprot.writeString(kiter525) + oprot.writeString(viter526) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -13222,10 +13662,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype523, _size520) = iprot.readListBegin() - for _i524 in xrange(_size520): - _elem525 = iprot.readString(); - self.part_vals.append(_elem525) + (_etype530, _size527) = iprot.readListBegin() + for _i531 in xrange(_size527): + _elem532 = iprot.readString(); + self.part_vals.append(_elem532) iprot.readListEnd() else: iprot.skip(ftype) @@ -13237,10 +13677,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype529, _size526) = iprot.readListBegin() - for _i530 in xrange(_size526): - _elem531 = iprot.readString(); - self.group_names.append(_elem531) + (_etype536, _size533) = iprot.readListBegin() + for _i537 in xrange(_size533): + _elem538 = iprot.readString(); + self.group_names.append(_elem538) iprot.readListEnd() else: iprot.skip(ftype) @@ -13265,8 +13705,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 iter532 in self.part_vals: - oprot.writeString(iter532) + for iter539 in self.part_vals: + oprot.writeString(iter539) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -13276,8 +13716,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 iter533 in self.group_names: - oprot.writeString(iter533) + for iter540 in self.group_names: + oprot.writeString(iter540) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13669,11 +14109,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype537, _size534) = iprot.readListBegin() - for _i538 in xrange(_size534): - _elem539 = Partition() - _elem539.read(iprot) - self.success.append(_elem539) + (_etype544, _size541) = iprot.readListBegin() + for _i545 in xrange(_size541): + _elem546 = Partition() + _elem546.read(iprot) + self.success.append(_elem546) iprot.readListEnd() else: iprot.skip(ftype) @@ -13702,8 +14142,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 iter540 in self.success: - iter540.write(oprot) + for iter547 in self.success: + iter547.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13790,10 +14230,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype544, _size541) = iprot.readListBegin() - for _i545 in xrange(_size541): - _elem546 = iprot.readString(); - self.group_names.append(_elem546) + (_etype551, _size548) = iprot.readListBegin() + for _i552 in xrange(_size548): + _elem553 = iprot.readString(); + self.group_names.append(_elem553) iprot.readListEnd() else: iprot.skip(ftype) @@ -13826,8 +14266,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 iter547 in self.group_names: - oprot.writeString(iter547) + for iter554 in self.group_names: + oprot.writeString(iter554) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13879,11 +14319,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype551, _size548) = iprot.readListBegin() - for _i552 in xrange(_size548): - _elem553 = Partition() - _elem553.read(iprot) - self.success.append(_elem553) + (_etype558, _size555) = iprot.readListBegin() + for _i559 in xrange(_size555): + _elem560 = Partition() + _elem560.read(iprot) + self.success.append(_elem560) iprot.readListEnd() else: iprot.skip(ftype) @@ -13912,8 +14352,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 iter554 in self.success: - iter554.write(oprot) + for iter561 in self.success: + iter561.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14054,10 +14494,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype558, _size555) = iprot.readListBegin() - for _i559 in xrange(_size555): - _elem560 = iprot.readString(); - self.success.append(_elem560) + (_etype565, _size562) = iprot.readListBegin() + for _i566 in xrange(_size562): + _elem567 = iprot.readString(); + self.success.append(_elem567) iprot.readListEnd() else: iprot.skip(ftype) @@ -14080,8 +14520,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 iter561 in self.success: - oprot.writeString(iter561) + for iter568 in self.success: + oprot.writeString(iter568) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -14151,10 +14591,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype565, _size562) = iprot.readListBegin() - for _i566 in xrange(_size562): - _elem567 = iprot.readString(); - self.part_vals.append(_elem567) + (_etype572, _size569) = iprot.readListBegin() + for _i573 in xrange(_size569): + _elem574 = iprot.readString(); + self.part_vals.append(_elem574) iprot.readListEnd() else: iprot.skip(ftype) @@ -14184,8 +14624,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 iter568 in self.part_vals: - oprot.writeString(iter568) + for iter575 in self.part_vals: + oprot.writeString(iter575) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -14241,11 +14681,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype572, _size569) = iprot.readListBegin() - for _i573 in xrange(_size569): - _elem574 = Partition() - _elem574.read(iprot) - self.success.append(_elem574) + (_etype579, _size576) = iprot.readListBegin() + for _i580 in xrange(_size576): + _elem581 = Partition() + _elem581.read(iprot) + self.success.append(_elem581) iprot.readListEnd() else: iprot.skip(ftype) @@ -14274,8 +14714,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 iter575 in self.success: - iter575.write(oprot) + for iter582 in self.success: + iter582.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14355,10 +14795,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype579, _size576) = iprot.readListBegin() - for _i580 in xrange(_size576): - _elem581 = iprot.readString(); - self.part_vals.append(_elem581) + (_etype586, _size583) = iprot.readListBegin() + for _i587 in xrange(_size583): + _elem588 = iprot.readString(); + self.part_vals.append(_elem588) iprot.readListEnd() else: iprot.skip(ftype) @@ -14375,10 +14815,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype585, _size582) = iprot.readListBegin() - for _i586 in xrange(_size582): - _elem587 = iprot.readString(); - self.group_names.append(_elem587) + (_etype592, _size589) = iprot.readListBegin() + for _i593 in xrange(_size589): + _elem594 = iprot.readString(); + self.group_names.append(_elem594) iprot.readListEnd() else: iprot.skip(ftype) @@ -14403,8 +14843,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 iter588 in self.part_vals: - oprot.writeString(iter588) + for iter595 in self.part_vals: + oprot.writeString(iter595) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -14418,8 +14858,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 iter589 in self.group_names: - oprot.writeString(iter589) + for iter596 in self.group_names: + oprot.writeString(iter596) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14471,11 +14911,11 @@ class get_partitions_ps_with_auth_result if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype593, _size590) = iprot.readListBegin() - for _i594 in xrange(_size590): - _elem595 = Partition() - _elem595.read(iprot) - self.success.append(_elem595) + (_etype600, _size597) = iprot.readListBegin() + for _i601 in xrange(_size597): + _elem602 = Partition() + _elem602.read(iprot) + self.success.append(_elem602) iprot.readListEnd() else: iprot.skip(ftype) @@ -14504,8 +14944,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 iter596 in self.success: - iter596.write(oprot) + for iter603 in self.success: + iter603.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14579,10 +15019,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype600, _size597) = iprot.readListBegin() - for _i601 in xrange(_size597): - _elem602 = iprot.readString(); - self.part_vals.append(_elem602) + (_etype607, _size604) = iprot.readListBegin() + for _i608 in xrange(_size604): + _elem609 = iprot.readString(); + self.part_vals.append(_elem609) iprot.readListEnd() else: iprot.skip(ftype) @@ -14612,8 +15052,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 iter603 in self.part_vals: - oprot.writeString(iter603) + for iter610 in self.part_vals: + oprot.writeString(iter610) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -14669,10 +15109,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype607, _size604) = iprot.readListBegin() - for _i608 in xrange(_size604): - _elem609 = iprot.readString(); - self.success.append(_elem609) + (_etype614, _size611) = iprot.readListBegin() + for _i615 in xrange(_size611): + _elem616 = iprot.readString(); + self.success.append(_elem616) iprot.readListEnd() else: iprot.skip(ftype) @@ -14701,8 +15141,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 iter610 in self.success: - oprot.writeString(iter610) + for iter617 in self.success: + oprot.writeString(iter617) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14858,11 +15298,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype614, _size611) = iprot.readListBegin() - for _i615 in xrange(_size611): - _elem616 = Partition() - _elem616.read(iprot) - self.success.append(_elem616) + (_etype621, _size618) = iprot.readListBegin() + for _i622 in xrange(_size618): + _elem623 = Partition() + _elem623.read(iprot) + self.success.append(_elem623) iprot.readListEnd() else: iprot.skip(ftype) @@ -14891,8 +15331,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 iter617 in self.success: - iter617.write(oprot) + for iter624 in self.success: + iter624.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15110,10 +15550,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype621, _size618) = iprot.readListBegin() - for _i622 in xrange(_size618): - _elem623 = iprot.readString(); - self.names.append(_elem623) + (_etype628, _size625) = iprot.readListBegin() + for _i629 in xrange(_size625): + _elem630 = iprot.readString(); + self.names.append(_elem630) iprot.readListEnd() else: iprot.skip(ftype) @@ -15138,8 +15578,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 iter624 in self.names: - oprot.writeString(iter624) + for iter631 in self.names: + oprot.writeString(iter631) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15191,11 +15631,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype628, _size625) = iprot.readListBegin() - for _i629 in xrange(_size625): - _elem630 = Partition() - _elem630.read(iprot) - self.success.append(_elem630) + (_etype635, _size632) = iprot.readListBegin() + for _i636 in xrange(_size632): + _elem637 = Partition() + _elem637.read(iprot) + self.success.append(_elem637) iprot.readListEnd() else: iprot.skip(ftype) @@ -15224,8 +15664,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 iter631 in self.success: - iter631.write(oprot) + for iter638 in self.success: + iter638.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15452,14 +15892,14 @@ class alter_partitions_args: self.tbl_name = iprot.readString(); else: iprot.skip(ftype) - elif fid == 3: - if ftype == TType.LIST: - self.new_parts = [] - (_etype635, _size632) = iprot.readListBegin() - for _i636 in xrange(_size632): - _elem637 = Partition() - _elem637.read(iprot) - self.new_parts.append(_elem637) + elif fid == 3: + if ftype == TType.LIST: + self.new_parts = [] + (_etype642, _size639) = iprot.readListBegin() + for _i643 in xrange(_size639): + _elem644 = Partition() + _elem644.read(iprot) + self.new_parts.append(_elem644) iprot.readListEnd() else: iprot.skip(ftype) @@ -15484,8 +15924,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 iter638 in self.new_parts: - iter638.write(oprot) + for iter645 in self.new_parts: + iter645.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15797,10 +16237,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype642, _size639) = iprot.readListBegin() - for _i643 in xrange(_size639): - _elem644 = iprot.readString(); - self.part_vals.append(_elem644) + (_etype649, _size646) = iprot.readListBegin() + for _i650 in xrange(_size646): + _elem651 = iprot.readString(); + self.part_vals.append(_elem651) iprot.readListEnd() else: iprot.skip(ftype) @@ -15831,8 +16271,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 iter645 in self.part_vals: - oprot.writeString(iter645) + for iter652 in self.part_vals: + oprot.writeString(iter652) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -15960,10 +16400,10 @@ class partition_name_has_valid_character if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype649, _size646) = iprot.readListBegin() - for _i650 in xrange(_size646): - _elem651 = iprot.readString(); - self.part_vals.append(_elem651) + (_etype656, _size653) = iprot.readListBegin() + for _i657 in xrange(_size653): + _elem658 = iprot.readString(); + self.part_vals.append(_elem658) iprot.readListEnd() else: iprot.skip(ftype) @@ -15985,8 +16425,8 @@ class partition_name_has_valid_character if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter652 in self.part_vals: - oprot.writeString(iter652) + for iter659 in self.part_vals: + oprot.writeString(iter659) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -16315,10 +16755,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype656, _size653) = iprot.readListBegin() - for _i657 in xrange(_size653): - _elem658 = iprot.readString(); - self.success.append(_elem658) + (_etype663, _size660) = iprot.readListBegin() + for _i664 in xrange(_size660): + _elem665 = iprot.readString(); + self.success.append(_elem665) iprot.readListEnd() else: iprot.skip(ftype) @@ -16341,8 +16781,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 iter659 in self.success: - oprot.writeString(iter659) + for iter666 in self.success: + oprot.writeString(iter666) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16455,11 +16895,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype661, _vtype662, _size660 ) = iprot.readMapBegin() - for _i664 in xrange(_size660): - _key665 = iprot.readString(); - _val666 = iprot.readString(); - self.success[_key665] = _val666 + (_ktype668, _vtype669, _size667 ) = iprot.readMapBegin() + for _i671 in xrange(_size667): + _key672 = iprot.readString(); + _val673 = iprot.readString(); + self.success[_key672] = _val673 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16482,9 +16922,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 kiter667,viter668 in self.success.items(): - oprot.writeString(kiter667) - oprot.writeString(viter668) + for kiter674,viter675 in self.success.items(): + oprot.writeString(kiter674) + oprot.writeString(viter675) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16554,11 +16994,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype670, _vtype671, _size669 ) = iprot.readMapBegin() - for _i673 in xrange(_size669): - _key674 = iprot.readString(); - _val675 = iprot.readString(); - self.part_vals[_key674] = _val675 + (_ktype677, _vtype678, _size676 ) = iprot.readMapBegin() + for _i680 in xrange(_size676): + _key681 = iprot.readString(); + _val682 = iprot.readString(); + self.part_vals[_key681] = _val682 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16588,9 +17028,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 kiter676,viter677 in self.part_vals.items(): - oprot.writeString(kiter676) - oprot.writeString(viter677) + for kiter683,viter684 in self.part_vals.items(): + oprot.writeString(kiter683) + oprot.writeString(viter684) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -16786,11 +17226,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype679, _vtype680, _size678 ) = iprot.readMapBegin() - for _i682 in xrange(_size678): - _key683 = iprot.readString(); - _val684 = iprot.readString(); - self.part_vals[_key683] = _val684 + (_ktype686, _vtype687, _size685 ) = iprot.readMapBegin() + for _i689 in xrange(_size685): + _key690 = iprot.readString(); + _val691 = iprot.readString(); + self.part_vals[_key690] = _val691 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16820,9 +17260,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 kiter685,viter686 in self.part_vals.items(): - oprot.writeString(kiter685) - oprot.writeString(viter686) + for kiter692,viter693 in self.part_vals.items(): + oprot.writeString(kiter692) + oprot.writeString(viter693) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -17794,11 +18234,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype690, _size687) = iprot.readListBegin() - for _i691 in xrange(_size687): - _elem692 = Index() - _elem692.read(iprot) - self.success.append(_elem692) + (_etype697, _size694) = iprot.readListBegin() + for _i698 in xrange(_size694): + _elem699 = Index() + _elem699.read(iprot) + self.success.append(_elem699) iprot.readListEnd() else: iprot.skip(ftype) @@ -17827,8 +18267,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 iter693 in self.success: - iter693.write(oprot) + for iter700 in self.success: + iter700.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17969,10 +18409,10 @@ class get_index_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype697, _size694) = iprot.readListBegin() - for _i698 in xrange(_size694): - _elem699 = iprot.readString(); - self.success.append(_elem699) + (_etype704, _size701) = iprot.readListBegin() + for _i705 in xrange(_size701): + _elem706 = iprot.readString(); + self.success.append(_elem706) iprot.readListEnd() else: iprot.skip(ftype) @@ -17995,8 +18435,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 iter700 in self.success: - oprot.writeString(iter700) + for iter707 in self.success: + oprot.writeString(iter707) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -19210,6 +19650,178 @@ class get_aggr_stats_for_result: def __ne__(self, other): return not (self == other) +class set_aggr_stats_for_args: + """ + Attributes: + - request + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'request', (SetPartitionsStatsRequest, SetPartitionsStatsRequest.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 = SetPartitionsStatsRequest() + 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('set_aggr_stats_for_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 __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 set_aggr_stats_for_result: + """ + Attributes: + - success + - o1 + - o2 + - o3 + - o4 + """ + + thrift_spec = ( + (0, TType.BOOL, 'success', None, None, ), # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 2 + (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3 + (4, TType.STRUCT, 'o4', (InvalidInputException, InvalidInputException.thrift_spec), None, ), # 4 + ) + + def __init__(self, success=None, o1=None, o2=None, o3=None, o4=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + self.o3 = o3 + self.o4 = o4 + + 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.BOOL: + self.success = iprot.readBool(); + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = NoSuchObjectException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = InvalidObjectException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + elif fid == 3: + if ftype == TType.STRUCT: + self.o3 = MetaException() + self.o3.read(iprot) + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.STRUCT: + self.o4 = InvalidInputException() + self.o4.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('set_aggr_stats_for_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.BOOL, 0) + oprot.writeBool(self.success) + 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() + if self.o4 is not None: + oprot.writeFieldBegin('o4', TType.STRUCT, 4) + self.o4.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 delete_partition_column_statistics_args: """ Attributes: @@ -20178,10 +20790,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype704, _size701) = iprot.readListBegin() - for _i705 in xrange(_size701): - _elem706 = iprot.readString(); - self.success.append(_elem706) + (_etype711, _size708) = iprot.readListBegin() + for _i712 in xrange(_size708): + _elem713 = iprot.readString(); + self.success.append(_elem713) iprot.readListEnd() else: iprot.skip(ftype) @@ -20204,8 +20816,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 iter707 in self.success: - oprot.writeString(iter707) + for iter714 in self.success: + oprot.writeString(iter714) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20723,10 +21335,10 @@ class get_role_names_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) + (_etype718, _size715) = iprot.readListBegin() + for _i719 in xrange(_size715): + _elem720 = iprot.readString(); + self.success.append(_elem720) iprot.readListEnd() else: iprot.skip(ftype) @@ -20749,8 +21361,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 iter714 in self.success: - oprot.writeString(iter714) + for iter721 in self.success: + oprot.writeString(iter721) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21223,11 +21835,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype718, _size715) = iprot.readListBegin() - for _i719 in xrange(_size715): - _elem720 = Role() - _elem720.read(iprot) - self.success.append(_elem720) + (_etype725, _size722) = iprot.readListBegin() + for _i726 in xrange(_size722): + _elem727 = Role() + _elem727.read(iprot) + self.success.append(_elem727) iprot.readListEnd() else: iprot.skip(ftype) @@ -21250,8 +21862,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 iter721 in self.success: - iter721.write(oprot) + for iter728 in self.success: + iter728.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21721,10 +22333,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype725, _size722) = iprot.readListBegin() - for _i726 in xrange(_size722): - _elem727 = iprot.readString(); - self.group_names.append(_elem727) + (_etype732, _size729) = iprot.readListBegin() + for _i733 in xrange(_size729): + _elem734 = iprot.readString(); + self.group_names.append(_elem734) iprot.readListEnd() else: iprot.skip(ftype) @@ -21749,8 +22361,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 iter728 in self.group_names: - oprot.writeString(iter728) + for iter735 in self.group_names: + oprot.writeString(iter735) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21957,11 +22569,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype732, _size729) = iprot.readListBegin() - for _i733 in xrange(_size729): - _elem734 = HiveObjectPrivilege() - _elem734.read(iprot) - self.success.append(_elem734) + (_etype739, _size736) = iprot.readListBegin() + for _i740 in xrange(_size736): + _elem741 = HiveObjectPrivilege() + _elem741.read(iprot) + self.success.append(_elem741) iprot.readListEnd() else: iprot.skip(ftype) @@ -21984,8 +22596,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 iter735 in self.success: - iter735.write(oprot) + for iter742 in self.success: + iter742.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22444,10 +23056,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype739, _size736) = iprot.readListBegin() - for _i740 in xrange(_size736): - _elem741 = iprot.readString(); - self.group_names.append(_elem741) + (_etype746, _size743) = iprot.readListBegin() + for _i747 in xrange(_size743): + _elem748 = iprot.readString(); + self.group_names.append(_elem748) iprot.readListEnd() else: iprot.skip(ftype) @@ -22468,8 +23080,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 iter742 in self.group_names: - oprot.writeString(iter742) + for iter749 in self.group_names: + oprot.writeString(iter749) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22518,10 +23130,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype746, _size743) = iprot.readListBegin() - for _i747 in xrange(_size743): - _elem748 = iprot.readString(); - self.success.append(_elem748) + (_etype753, _size750) = iprot.readListBegin() + for _i754 in xrange(_size750): + _elem755 = iprot.readString(); + self.success.append(_elem755) iprot.readListEnd() else: iprot.skip(ftype) @@ -22544,8 +23156,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 iter749 in self.success: - oprot.writeString(iter749) + for iter756 in self.success: + oprot.writeString(iter756) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: