http://git-wip-us.apache.org/repos/asf/hive/blob/696be9f5/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index b6306f0..a4937e2 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -156,12 +156,14 @@ class Iface(fb303.FacebookService.Iface): """ pass - def create_table_with_constraints(self, tbl, primaryKeys, foreignKeys): + def create_table_with_constraints(self, tbl, primaryKeys, foreignKeys, uniqueConstraints, notNullConstraints): """ Parameters: - tbl - primaryKeys - foreignKeys + - uniqueConstraints + - notNullConstraints """ pass @@ -186,6 +188,20 @@ class Iface(fb303.FacebookService.Iface): """ pass + def add_unique_constraint(self, req): + """ + Parameters: + - req + """ + pass + + def add_not_null_constraint(self, req): + """ + Parameters: + - req + """ + pass + def drop_table(self, dbname, name, deleteData): """ Parameters: @@ -771,6 +787,20 @@ class Iface(fb303.FacebookService.Iface): """ pass + def get_unique_constraints(self, request): + """ + Parameters: + - request + """ + pass + + def get_not_null_constraints(self, request): + """ + Parameters: + - request + """ + pass + def update_table_column_statistics(self, stats_obj): """ Parameters: @@ -1897,22 +1927,26 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o4 return - def create_table_with_constraints(self, tbl, primaryKeys, foreignKeys): + def create_table_with_constraints(self, tbl, primaryKeys, foreignKeys, uniqueConstraints, notNullConstraints): """ Parameters: - tbl - primaryKeys - foreignKeys + - uniqueConstraints + - notNullConstraints """ - self.send_create_table_with_constraints(tbl, primaryKeys, foreignKeys) + self.send_create_table_with_constraints(tbl, primaryKeys, foreignKeys, uniqueConstraints, notNullConstraints) self.recv_create_table_with_constraints() - def send_create_table_with_constraints(self, tbl, primaryKeys, foreignKeys): + def send_create_table_with_constraints(self, tbl, primaryKeys, foreignKeys, uniqueConstraints, notNullConstraints): self._oprot.writeMessageBegin('create_table_with_constraints', TMessageType.CALL, self._seqid) args = create_table_with_constraints_args() args.tbl = tbl args.primaryKeys = primaryKeys args.foreignKeys = foreignKeys + args.uniqueConstraints = uniqueConstraints + args.notNullConstraints = notNullConstraints args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() @@ -2037,6 +2071,72 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 return + def add_unique_constraint(self, req): + """ + Parameters: + - req + """ + self.send_add_unique_constraint(req) + self.recv_add_unique_constraint() + + def send_add_unique_constraint(self, req): + self._oprot.writeMessageBegin('add_unique_constraint', TMessageType.CALL, self._seqid) + args = add_unique_constraint_args() + args.req = req + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_add_unique_constraint(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = add_unique_constraint_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + return + + def add_not_null_constraint(self, req): + """ + Parameters: + - req + """ + self.send_add_not_null_constraint(req) + self.recv_add_not_null_constraint() + + def send_add_not_null_constraint(self, req): + self._oprot.writeMessageBegin('add_not_null_constraint', TMessageType.CALL, self._seqid) + args = add_not_null_constraint_args() + args.req = req + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_add_not_null_constraint(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = add_not_null_constraint_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + return + def drop_table(self, dbname, name, deleteData): """ Parameters: @@ -4568,6 +4668,76 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o2 raise TApplicationException(TApplicationException.MISSING_RESULT, "get_foreign_keys failed: unknown result") + def get_unique_constraints(self, request): + """ + Parameters: + - request + """ + self.send_get_unique_constraints(request) + return self.recv_get_unique_constraints() + + def send_get_unique_constraints(self, request): + self._oprot.writeMessageBegin('get_unique_constraints', TMessageType.CALL, self._seqid) + args = get_unique_constraints_args() + args.request = request + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_unique_constraints(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_unique_constraints_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_unique_constraints failed: unknown result") + + def get_not_null_constraints(self, request): + """ + Parameters: + - request + """ + self.send_get_not_null_constraints(request) + return self.recv_get_not_null_constraints() + + def send_get_not_null_constraints(self, request): + self._oprot.writeMessageBegin('get_not_null_constraints', TMessageType.CALL, self._seqid) + args = get_not_null_constraints_args() + args.request = request + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_not_null_constraints(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_not_null_constraints_result() + result.read(iprot) + iprot.readMessageEnd() + if result.success is not None: + return result.success + if result.o1 is not None: + raise result.o1 + if result.o2 is not None: + raise result.o2 + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_not_null_constraints failed: unknown result") + def update_table_column_statistics(self, stats_obj): """ Parameters: @@ -6861,6 +7031,8 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["drop_constraint"] = Processor.process_drop_constraint self._processMap["add_primary_key"] = Processor.process_add_primary_key self._processMap["add_foreign_key"] = Processor.process_add_foreign_key + self._processMap["add_unique_constraint"] = Processor.process_add_unique_constraint + self._processMap["add_not_null_constraint"] = Processor.process_add_not_null_constraint self._processMap["drop_table"] = Processor.process_drop_table self._processMap["drop_table_with_environment_context"] = Processor.process_drop_table_with_environment_context self._processMap["truncate_table"] = Processor.process_truncate_table @@ -6926,6 +7098,8 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["get_index_names"] = Processor.process_get_index_names self._processMap["get_primary_keys"] = Processor.process_get_primary_keys self._processMap["get_foreign_keys"] = Processor.process_get_foreign_keys + self._processMap["get_unique_constraints"] = Processor.process_get_unique_constraints + self._processMap["get_not_null_constraints"] = Processor.process_get_not_null_constraints self._processMap["update_table_column_statistics"] = Processor.process_update_table_column_statistics self._processMap["update_partition_column_statistics"] = Processor.process_update_partition_column_statistics self._processMap["get_table_column_statistics"] = Processor.process_get_table_column_statistics @@ -7484,7 +7658,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): iprot.readMessageEnd() result = create_table_with_constraints_result() try: - self._handler.create_table_with_constraints(args.tbl, args.primaryKeys, args.foreignKeys) + self._handler.create_table_with_constraints(args.tbl, args.primaryKeys, args.foreignKeys, args.uniqueConstraints, args.notNullConstraints) msg_type = TMessageType.REPLY except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): raise @@ -7584,6 +7758,56 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_add_unique_constraint(self, seqid, iprot, oprot): + args = add_unique_constraint_args() + args.read(iprot) + iprot.readMessageEnd() + result = add_unique_constraint_result() + try: + self._handler.add_unique_constraint(args.req) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except MetaException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_unique_constraint", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_add_not_null_constraint(self, seqid, iprot, oprot): + args = add_not_null_constraint_args() + args.read(iprot) + iprot.readMessageEnd() + result = add_not_null_constraint_result() + try: + self._handler.add_not_null_constraint(args.req) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except MetaException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_not_null_constraint", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_drop_table(self, seqid, iprot, oprot): args = drop_table_args() args.read(iprot) @@ -9242,6 +9466,56 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_get_unique_constraints(self, seqid, iprot, oprot): + args = get_unique_constraints_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_unique_constraints_result() + try: + result.success = self._handler.get_unique_constraints(args.request) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_unique_constraints", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_not_null_constraints(self, seqid, iprot, oprot): + args = get_not_null_constraints_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_not_null_constraints_result() + try: + result.success = self._handler.get_not_null_constraints(args.request) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_not_null_constraints", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_update_table_column_statistics(self, seqid, iprot, oprot): args = update_table_column_statistics_args() args.read(iprot) @@ -11672,10 +11946,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype597, _size594) = iprot.readListBegin() - for _i598 in xrange(_size594): - _elem599 = iprot.readString() - self.success.append(_elem599) + (_etype625, _size622) = iprot.readListBegin() + for _i626 in xrange(_size622): + _elem627 = iprot.readString() + self.success.append(_elem627) iprot.readListEnd() else: iprot.skip(ftype) @@ -11698,8 +11972,8 @@ class get_databases_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter600 in self.success: - oprot.writeString(iter600) + for iter628 in self.success: + oprot.writeString(iter628) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11804,10 +12078,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype604, _size601) = iprot.readListBegin() - for _i605 in xrange(_size601): - _elem606 = iprot.readString() - self.success.append(_elem606) + (_etype632, _size629) = iprot.readListBegin() + for _i633 in xrange(_size629): + _elem634 = iprot.readString() + self.success.append(_elem634) iprot.readListEnd() else: iprot.skip(ftype) @@ -11830,8 +12104,8 @@ class get_all_databases_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter607 in self.success: - oprot.writeString(iter607) + for iter635 in self.success: + oprot.writeString(iter635) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -12601,12 +12875,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype609, _vtype610, _size608 ) = iprot.readMapBegin() - for _i612 in xrange(_size608): - _key613 = iprot.readString() - _val614 = Type() - _val614.read(iprot) - self.success[_key613] = _val614 + (_ktype637, _vtype638, _size636 ) = iprot.readMapBegin() + for _i640 in xrange(_size636): + _key641 = iprot.readString() + _val642 = Type() + _val642.read(iprot) + self.success[_key641] = _val642 iprot.readMapEnd() else: iprot.skip(ftype) @@ -12629,9 +12903,9 @@ class get_type_all_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter615,viter616 in self.success.items(): - oprot.writeString(kiter615) - viter616.write(oprot) + for kiter643,viter644 in self.success.items(): + oprot.writeString(kiter643) + viter644.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -12774,11 +13048,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype620, _size617) = iprot.readListBegin() - for _i621 in xrange(_size617): - _elem622 = FieldSchema() - _elem622.read(iprot) - self.success.append(_elem622) + (_etype648, _size645) = iprot.readListBegin() + for _i649 in xrange(_size645): + _elem650 = FieldSchema() + _elem650.read(iprot) + self.success.append(_elem650) iprot.readListEnd() else: iprot.skip(ftype) @@ -12813,8 +13087,8 @@ class get_fields_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter623 in self.success: - iter623.write(oprot) + for iter651 in self.success: + iter651.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -12981,11 +13255,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype627, _size624) = iprot.readListBegin() - for _i628 in xrange(_size624): - _elem629 = FieldSchema() - _elem629.read(iprot) - self.success.append(_elem629) + (_etype655, _size652) = iprot.readListBegin() + for _i656 in xrange(_size652): + _elem657 = FieldSchema() + _elem657.read(iprot) + self.success.append(_elem657) iprot.readListEnd() else: iprot.skip(ftype) @@ -13020,8 +13294,8 @@ class get_fields_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter630 in self.success: - iter630.write(oprot) + for iter658 in self.success: + iter658.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13174,11 +13448,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype634, _size631) = iprot.readListBegin() - for _i635 in xrange(_size631): - _elem636 = FieldSchema() - _elem636.read(iprot) - self.success.append(_elem636) + (_etype662, _size659) = iprot.readListBegin() + for _i663 in xrange(_size659): + _elem664 = FieldSchema() + _elem664.read(iprot) + self.success.append(_elem664) iprot.readListEnd() else: iprot.skip(ftype) @@ -13213,8 +13487,8 @@ class get_schema_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter637 in self.success: - iter637.write(oprot) + for iter665 in self.success: + iter665.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13381,11 +13655,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype641, _size638) = iprot.readListBegin() - for _i642 in xrange(_size638): - _elem643 = FieldSchema() - _elem643.read(iprot) - self.success.append(_elem643) + (_etype669, _size666) = iprot.readListBegin() + for _i670 in xrange(_size666): + _elem671 = FieldSchema() + _elem671.read(iprot) + self.success.append(_elem671) iprot.readListEnd() else: iprot.skip(ftype) @@ -13420,8 +13694,8 @@ class get_schema_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter644 in self.success: - iter644.write(oprot) + for iter672 in self.success: + iter672.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13830,6 +14104,8 @@ class create_table_with_constraints_args: - tbl - primaryKeys - foreignKeys + - uniqueConstraints + - notNullConstraints """ thrift_spec = ( @@ -13837,12 +14113,16 @@ class create_table_with_constraints_args: (1, TType.STRUCT, 'tbl', (Table, Table.thrift_spec), None, ), # 1 (2, TType.LIST, 'primaryKeys', (TType.STRUCT,(SQLPrimaryKey, SQLPrimaryKey.thrift_spec)), None, ), # 2 (3, TType.LIST, 'foreignKeys', (TType.STRUCT,(SQLForeignKey, SQLForeignKey.thrift_spec)), None, ), # 3 + (4, TType.LIST, 'uniqueConstraints', (TType.STRUCT,(SQLUniqueConstraint, SQLUniqueConstraint.thrift_spec)), None, ), # 4 + (5, TType.LIST, 'notNullConstraints', (TType.STRUCT,(SQLNotNullConstraint, SQLNotNullConstraint.thrift_spec)), None, ), # 5 ) - def __init__(self, tbl=None, primaryKeys=None, foreignKeys=None,): + def __init__(self, tbl=None, primaryKeys=None, foreignKeys=None, uniqueConstraints=None, notNullConstraints=None,): self.tbl = tbl self.primaryKeys = primaryKeys self.foreignKeys = foreignKeys + self.uniqueConstraints = uniqueConstraints + self.notNullConstraints = notNullConstraints 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: @@ -13862,22 +14142,44 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype648, _size645) = iprot.readListBegin() - for _i649 in xrange(_size645): - _elem650 = SQLPrimaryKey() - _elem650.read(iprot) - self.primaryKeys.append(_elem650) + (_etype676, _size673) = iprot.readListBegin() + for _i677 in xrange(_size673): + _elem678 = SQLPrimaryKey() + _elem678.read(iprot) + self.primaryKeys.append(_elem678) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype654, _size651) = iprot.readListBegin() - for _i655 in xrange(_size651): - _elem656 = SQLForeignKey() - _elem656.read(iprot) - self.foreignKeys.append(_elem656) + (_etype682, _size679) = iprot.readListBegin() + for _i683 in xrange(_size679): + _elem684 = SQLForeignKey() + _elem684.read(iprot) + self.foreignKeys.append(_elem684) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 4: + if ftype == TType.LIST: + self.uniqueConstraints = [] + (_etype688, _size685) = iprot.readListBegin() + for _i689 in xrange(_size685): + _elem690 = SQLUniqueConstraint() + _elem690.read(iprot) + self.uniqueConstraints.append(_elem690) + iprot.readListEnd() + else: + iprot.skip(ftype) + elif fid == 5: + if ftype == TType.LIST: + self.notNullConstraints = [] + (_etype694, _size691) = iprot.readListBegin() + for _i695 in xrange(_size691): + _elem696 = SQLNotNullConstraint() + _elem696.read(iprot) + self.notNullConstraints.append(_elem696) iprot.readListEnd() else: iprot.skip(ftype) @@ -13898,15 +14200,29 @@ class create_table_with_constraints_args: if self.primaryKeys is not None: oprot.writeFieldBegin('primaryKeys', TType.LIST, 2) oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys)) - for iter657 in self.primaryKeys: - iter657.write(oprot) + for iter697 in self.primaryKeys: + iter697.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.foreignKeys is not None: oprot.writeFieldBegin('foreignKeys', TType.LIST, 3) oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys)) - for iter658 in self.foreignKeys: - iter658.write(oprot) + for iter698 in self.foreignKeys: + iter698.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 iter699 in self.uniqueConstraints: + iter699.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 iter700 in self.notNullConstraints: + iter700.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -13921,6 +14237,8 @@ class create_table_with_constraints_args: value = (value * 31) ^ hash(self.tbl) value = (value * 31) ^ hash(self.primaryKeys) value = (value * 31) ^ hash(self.foreignKeys) + value = (value * 31) ^ hash(self.uniqueConstraints) + value = (value * 31) ^ hash(self.notNullConstraints) return value def __repr__(self): @@ -14480,6 +14798,298 @@ class add_foreign_key_result: def __ne__(self, other): return not (self == other) +class add_unique_constraint_args: + """ + Attributes: + - req + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'req', (AddUniqueConstraintRequest, AddUniqueConstraintRequest.thrift_spec), None, ), # 1 + ) + + def __init__(self, req=None,): + self.req = req + + 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.req = AddUniqueConstraintRequest() + self.req.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('add_unique_constraint_args') + if self.req is not None: + oprot.writeFieldBegin('req', TType.STRUCT, 1) + self.req.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + 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 add_unique_constraint_result: + """ + Attributes: + - o1 + - o2 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 + ) + + def __init__(self, o1=None, o2=None,): + self.o1 = o1 + self.o2 = o2 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 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 = MetaException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('add_unique_constraint_result') + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.o1) + value = (value * 31) ^ hash(self.o2) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class add_not_null_constraint_args: + """ + Attributes: + - req + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'req', (AddNotNullConstraintRequest, AddNotNullConstraintRequest.thrift_spec), None, ), # 1 + ) + + def __init__(self, req=None,): + self.req = req + + 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.req = AddNotNullConstraintRequest() + self.req.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('add_not_null_constraint_args') + if self.req is not None: + oprot.writeFieldBegin('req', TType.STRUCT, 1) + self.req.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.req) + 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 add_not_null_constraint_result: + """ + Attributes: + - o1 + - o2 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2 + ) + + def __init__(self, o1=None, o2=None,): + self.o1 = o1 + self.o2 = o2 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 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 = MetaException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('add_not_null_constraint_result') + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.o1) + value = (value * 31) ^ hash(self.o2) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class drop_table_args: """ Attributes: @@ -14878,10 +15488,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype662, _size659) = iprot.readListBegin() - for _i663 in xrange(_size659): - _elem664 = iprot.readString() - self.partNames.append(_elem664) + (_etype704, _size701) = iprot.readListBegin() + for _i705 in xrange(_size701): + _elem706 = iprot.readString() + self.partNames.append(_elem706) iprot.readListEnd() else: iprot.skip(ftype) @@ -14906,8 +15516,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 iter665 in self.partNames: - oprot.writeString(iter665) + for iter707 in self.partNames: + oprot.writeString(iter707) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15107,10 +15717,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype669, _size666) = iprot.readListBegin() - for _i670 in xrange(_size666): - _elem671 = iprot.readString() - self.success.append(_elem671) + (_etype711, _size708) = iprot.readListBegin() + for _i712 in xrange(_size708): + _elem713 = iprot.readString() + self.success.append(_elem713) iprot.readListEnd() else: iprot.skip(ftype) @@ -15133,8 +15743,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 iter672 in self.success: - oprot.writeString(iter672) + for iter714 in self.success: + oprot.writeString(iter714) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15284,10 +15894,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype676, _size673) = iprot.readListBegin() - for _i677 in xrange(_size673): - _elem678 = iprot.readString() - self.success.append(_elem678) + (_etype718, _size715) = iprot.readListBegin() + for _i719 in xrange(_size715): + _elem720 = iprot.readString() + self.success.append(_elem720) iprot.readListEnd() else: iprot.skip(ftype) @@ -15310,8 +15920,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 iter679 in self.success: - oprot.writeString(iter679) + for iter721 in self.success: + oprot.writeString(iter721) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15384,10 +15994,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype683, _size680) = iprot.readListBegin() - for _i684 in xrange(_size680): - _elem685 = iprot.readString() - self.tbl_types.append(_elem685) + (_etype725, _size722) = iprot.readListBegin() + for _i726 in xrange(_size722): + _elem727 = iprot.readString() + self.tbl_types.append(_elem727) iprot.readListEnd() else: iprot.skip(ftype) @@ -15412,8 +16022,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 iter686 in self.tbl_types: - oprot.writeString(iter686) + for iter728 in self.tbl_types: + oprot.writeString(iter728) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15469,11 +16079,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype690, _size687) = iprot.readListBegin() - for _i691 in xrange(_size687): - _elem692 = TableMeta() - _elem692.read(iprot) - self.success.append(_elem692) + (_etype732, _size729) = iprot.readListBegin() + for _i733 in xrange(_size729): + _elem734 = TableMeta() + _elem734.read(iprot) + self.success.append(_elem734) iprot.readListEnd() else: iprot.skip(ftype) @@ -15496,8 +16106,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 iter693 in self.success: - iter693.write(oprot) + for iter735 in self.success: + iter735.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15621,10 +16231,10 @@ class get_all_tables_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) + (_etype739, _size736) = iprot.readListBegin() + for _i740 in xrange(_size736): + _elem741 = iprot.readString() + self.success.append(_elem741) iprot.readListEnd() else: iprot.skip(ftype) @@ -15647,8 +16257,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 iter700 in self.success: - oprot.writeString(iter700) + for iter742 in self.success: + oprot.writeString(iter742) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15884,10 +16494,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype704, _size701) = iprot.readListBegin() - for _i705 in xrange(_size701): - _elem706 = iprot.readString() - self.tbl_names.append(_elem706) + (_etype746, _size743) = iprot.readListBegin() + for _i747 in xrange(_size743): + _elem748 = iprot.readString() + self.tbl_names.append(_elem748) iprot.readListEnd() else: iprot.skip(ftype) @@ -15908,8 +16518,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 iter707 in self.tbl_names: - oprot.writeString(iter707) + for iter749 in self.tbl_names: + oprot.writeString(iter749) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15961,11 +16571,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype711, _size708) = iprot.readListBegin() - for _i712 in xrange(_size708): - _elem713 = Table() - _elem713.read(iprot) - self.success.append(_elem713) + (_etype753, _size750) = iprot.readListBegin() + for _i754 in xrange(_size750): + _elem755 = Table() + _elem755.read(iprot) + self.success.append(_elem755) iprot.readListEnd() else: iprot.skip(ftype) @@ -15982,8 +16592,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 iter714 in self.success: - iter714.write(oprot) + for iter756 in self.success: + iter756.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16466,10 +17076,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype718, _size715) = iprot.readListBegin() - for _i719 in xrange(_size715): - _elem720 = iprot.readString() - self.success.append(_elem720) + (_etype760, _size757) = iprot.readListBegin() + for _i761 in xrange(_size757): + _elem762 = iprot.readString() + self.success.append(_elem762) iprot.readListEnd() else: iprot.skip(ftype) @@ -16504,8 +17114,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 iter721 in self.success: - oprot.writeString(iter721) + for iter763 in self.success: + oprot.writeString(iter763) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17475,11 +18085,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype725, _size722) = iprot.readListBegin() - for _i726 in xrange(_size722): - _elem727 = Partition() - _elem727.read(iprot) - self.new_parts.append(_elem727) + (_etype767, _size764) = iprot.readListBegin() + for _i768 in xrange(_size764): + _elem769 = Partition() + _elem769.read(iprot) + self.new_parts.append(_elem769) iprot.readListEnd() else: iprot.skip(ftype) @@ -17496,8 +18106,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 iter728 in self.new_parts: - iter728.write(oprot) + for iter770 in self.new_parts: + iter770.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17655,11 +18265,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype732, _size729) = iprot.readListBegin() - for _i733 in xrange(_size729): - _elem734 = PartitionSpec() - _elem734.read(iprot) - self.new_parts.append(_elem734) + (_etype774, _size771) = iprot.readListBegin() + for _i775 in xrange(_size771): + _elem776 = PartitionSpec() + _elem776.read(iprot) + self.new_parts.append(_elem776) iprot.readListEnd() else: iprot.skip(ftype) @@ -17676,8 +18286,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 iter735 in self.new_parts: - iter735.write(oprot) + for iter777 in self.new_parts: + iter777.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17851,10 +18461,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype739, _size736) = iprot.readListBegin() - for _i740 in xrange(_size736): - _elem741 = iprot.readString() - self.part_vals.append(_elem741) + (_etype781, _size778) = iprot.readListBegin() + for _i782 in xrange(_size778): + _elem783 = iprot.readString() + self.part_vals.append(_elem783) iprot.readListEnd() else: iprot.skip(ftype) @@ -17879,8 +18489,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 iter742 in self.part_vals: - oprot.writeString(iter742) + for iter784 in self.part_vals: + oprot.writeString(iter784) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18233,10 +18843,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype746, _size743) = iprot.readListBegin() - for _i747 in xrange(_size743): - _elem748 = iprot.readString() - self.part_vals.append(_elem748) + (_etype788, _size785) = iprot.readListBegin() + for _i789 in xrange(_size785): + _elem790 = iprot.readString() + self.part_vals.append(_elem790) iprot.readListEnd() else: iprot.skip(ftype) @@ -18267,8 +18877,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 iter749 in self.part_vals: - oprot.writeString(iter749) + for iter791 in self.part_vals: + oprot.writeString(iter791) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -18863,10 +19473,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype753, _size750) = iprot.readListBegin() - for _i754 in xrange(_size750): - _elem755 = iprot.readString() - self.part_vals.append(_elem755) + (_etype795, _size792) = iprot.readListBegin() + for _i796 in xrange(_size792): + _elem797 = iprot.readString() + self.part_vals.append(_elem797) iprot.readListEnd() else: iprot.skip(ftype) @@ -18896,8 +19506,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 iter756 in self.part_vals: - oprot.writeString(iter756) + for iter798 in self.part_vals: + oprot.writeString(iter798) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -19070,10 +19680,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype760, _size757) = iprot.readListBegin() - for _i761 in xrange(_size757): - _elem762 = iprot.readString() - self.part_vals.append(_elem762) + (_etype802, _size799) = iprot.readListBegin() + for _i803 in xrange(_size799): + _elem804 = iprot.readString() + self.part_vals.append(_elem804) iprot.readListEnd() else: iprot.skip(ftype) @@ -19109,8 +19719,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 iter763 in self.part_vals: - oprot.writeString(iter763) + for iter805 in self.part_vals: + oprot.writeString(iter805) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -19847,10 +20457,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype767, _size764) = iprot.readListBegin() - for _i768 in xrange(_size764): - _elem769 = iprot.readString() - self.part_vals.append(_elem769) + (_etype809, _size806) = iprot.readListBegin() + for _i810 in xrange(_size806): + _elem811 = iprot.readString() + self.part_vals.append(_elem811) iprot.readListEnd() else: iprot.skip(ftype) @@ -19875,8 +20485,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 iter770 in self.part_vals: - oprot.writeString(iter770) + for iter812 in self.part_vals: + oprot.writeString(iter812) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20035,11 +20645,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype772, _vtype773, _size771 ) = iprot.readMapBegin() - for _i775 in xrange(_size771): - _key776 = iprot.readString() - _val777 = iprot.readString() - self.partitionSpecs[_key776] = _val777 + (_ktype814, _vtype815, _size813 ) = iprot.readMapBegin() + for _i817 in xrange(_size813): + _key818 = iprot.readString() + _val819 = iprot.readString() + self.partitionSpecs[_key818] = _val819 iprot.readMapEnd() else: iprot.skip(ftype) @@ -20076,9 +20686,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 kiter778,viter779 in self.partitionSpecs.items(): - oprot.writeString(kiter778) - oprot.writeString(viter779) + for kiter820,viter821 in self.partitionSpecs.items(): + oprot.writeString(kiter820) + oprot.writeString(viter821) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -20283,11 +20893,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype781, _vtype782, _size780 ) = iprot.readMapBegin() - for _i784 in xrange(_size780): - _key785 = iprot.readString() - _val786 = iprot.readString() - self.partitionSpecs[_key785] = _val786 + (_ktype823, _vtype824, _size822 ) = iprot.readMapBegin() + for _i826 in xrange(_size822): + _key827 = iprot.readString() + _val828 = iprot.readString() + self.partitionSpecs[_key827] = _val828 iprot.readMapEnd() else: iprot.skip(ftype) @@ -20324,9 +20934,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 kiter787,viter788 in self.partitionSpecs.items(): - oprot.writeString(kiter787) - oprot.writeString(viter788) + for kiter829,viter830 in self.partitionSpecs.items(): + oprot.writeString(kiter829) + oprot.writeString(viter830) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -20409,11 +21019,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype792, _size789) = iprot.readListBegin() - for _i793 in xrange(_size789): - _elem794 = Partition() - _elem794.read(iprot) - self.success.append(_elem794) + (_etype834, _size831) = iprot.readListBegin() + for _i835 in xrange(_size831): + _elem836 = Partition() + _elem836.read(iprot) + self.success.append(_elem836) iprot.readListEnd() else: iprot.skip(ftype) @@ -20454,8 +21064,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 iter795 in self.success: - iter795.write(oprot) + for iter837 in self.success: + iter837.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20549,10 +21159,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype799, _size796) = iprot.readListBegin() - for _i800 in xrange(_size796): - _elem801 = iprot.readString() - self.part_vals.append(_elem801) + (_etype841, _size838) = iprot.readListBegin() + for _i842 in xrange(_size838): + _elem843 = iprot.readString() + self.part_vals.append(_elem843) iprot.readListEnd() else: iprot.skip(ftype) @@ -20564,10 +21174,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype805, _size802) = iprot.readListBegin() - for _i806 in xrange(_size802): - _elem807 = iprot.readString() - self.group_names.append(_elem807) + (_etype847, _size844) = iprot.readListBegin() + for _i848 in xrange(_size844): + _elem849 = iprot.readString() + self.group_names.append(_elem849) iprot.readListEnd() else: iprot.skip(ftype) @@ -20592,8 +21202,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 iter808 in self.part_vals: - oprot.writeString(iter808) + for iter850 in self.part_vals: + oprot.writeString(iter850) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -20603,8 +21213,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 iter809 in self.group_names: - oprot.writeString(iter809) + for iter851 in self.group_names: + oprot.writeString(iter851) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21033,11 +21643,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype813, _size810) = iprot.readListBegin() - for _i814 in xrange(_size810): - _elem815 = Partition() - _elem815.read(iprot) - self.success.append(_elem815) + (_etype855, _size852) = iprot.readListBegin() + for _i856 in xrange(_size852): + _elem857 = Partition() + _elem857.read(iprot) + self.success.append(_elem857) iprot.readListEnd() else: iprot.skip(ftype) @@ -21066,8 +21676,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 iter816 in self.success: - iter816.write(oprot) + for iter858 in self.success: + iter858.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21161,10 +21771,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype820, _size817) = iprot.readListBegin() - for _i821 in xrange(_size817): - _elem822 = iprot.readString() - self.group_names.append(_elem822) + (_etype862, _size859) = iprot.readListBegin() + for _i863 in xrange(_size859): + _elem864 = iprot.readString() + self.group_names.append(_elem864) iprot.readListEnd() else: iprot.skip(ftype) @@ -21197,8 +21807,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 iter823 in self.group_names: - oprot.writeString(iter823) + for iter865 in self.group_names: + oprot.writeString(iter865) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21259,11 +21869,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype827, _size824) = iprot.readListBegin() - for _i828 in xrange(_size824): - _elem829 = Partition() - _elem829.read(iprot) - self.success.append(_elem829) + (_etype869, _size866) = iprot.readListBegin() + for _i870 in xrange(_size866): + _elem871 = Partition() + _elem871.read(iprot) + self.success.append(_elem871) iprot.readListEnd() else: iprot.skip(ftype) @@ -21292,8 +21902,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 iter830 in self.success: - iter830.write(oprot) + for iter872 in self.success: + iter872.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21451,11 +22061,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype834, _size831) = iprot.readListBegin() - for _i835 in xrange(_size831): - _elem836 = PartitionSpec() - _elem836.read(iprot) - self.success.append(_elem836) + (_etype876, _size873) = iprot.readListBegin() + for _i877 in xrange(_size873): + _elem878 = PartitionSpec() + _elem878.read(iprot) + self.success.append(_elem878) iprot.readListEnd() else: iprot.skip(ftype) @@ -21484,8 +22094,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 iter837 in self.success: - iter837.write(oprot) + for iter879 in self.success: + iter879.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21640,10 +22250,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype841, _size838) = iprot.readListBegin() - for _i842 in xrange(_size838): - _elem843 = iprot.readString() - self.success.append(_elem843) + (_etype883, _size880) = iprot.readListBegin() + for _i884 in xrange(_size880): + _elem885 = iprot.readString() + self.success.append(_elem885) iprot.readListEnd() else: iprot.skip(ftype) @@ -21666,8 +22276,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 iter844 in self.success: - oprot.writeString(iter844) + for iter886 in self.success: + oprot.writeString(iter886) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -21743,10 +22353,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype848, _size845) = iprot.readListBegin() - for _i849 in xrange(_size845): - _elem850 = iprot.readString() - self.part_vals.append(_elem850) + (_etype890, _size887) = iprot.readListBegin() + for _i891 in xrange(_size887): + _elem892 = iprot.readString() + self.part_vals.append(_elem892) iprot.readListEnd() else: iprot.skip(ftype) @@ -21776,8 +22386,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 iter851 in self.part_vals: - oprot.writeString(iter851) + for iter893 in self.part_vals: + oprot.writeString(iter893) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -21841,11 +22451,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype855, _size852) = iprot.readListBegin() - for _i856 in xrange(_size852): - _elem857 = Partition() - _elem857.read(iprot) - self.success.append(_elem857) + (_etype897, _size894) = iprot.readListBegin() + for _i898 in xrange(_size894): + _elem899 = Partition() + _elem899.read(iprot) + self.success.append(_elem899) iprot.readListEnd() else: iprot.skip(ftype) @@ -21874,8 +22484,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 iter858 in self.success: - iter858.write(oprot) + for iter900 in self.success: + iter900.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21962,10 +22572,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype862, _size859) = iprot.readListBegin() - for _i863 in xrange(_size859): - _elem864 = iprot.readString() - self.part_vals.append(_elem864) + (_etype904, _size901) = iprot.readListBegin() + for _i905 in xrange(_size901): + _elem906 = iprot.readString() + self.part_vals.append(_elem906) iprot.readListEnd() else: iprot.skip(ftype) @@ -21982,10 +22592,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype868, _size865) = iprot.readListBegin() - for _i869 in xrange(_size865): - _elem870 = iprot.readString() - self.group_names.append(_elem870) + (_etype910, _size907) = iprot.readListBegin() + for _i911 in xrange(_size907): + _elem912 = iprot.readString() + self.group_names.append(_elem912) iprot.readListEnd() else: iprot.skip(ftype) @@ -22010,8 +22620,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 iter871 in self.part_vals: - oprot.writeString(iter871) + for iter913 in self.part_vals: + oprot.writeString(iter913) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -22025,8 +22635,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 iter872 in self.group_names: - oprot.writeString(iter872) + for iter914 in self.group_names: + oprot.writeString(iter914) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22088,11 +22698,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype876, _size873) = iprot.readListBegin() - for _i877 in xrange(_size873): - _elem878 = Partition() - _elem878.read(iprot) - self.success.append(_elem878) + (_etype918, _size915) = iprot.readListBegin() + for _i919 in xrange(_size915): + _elem920 = Partition() + _elem920.read(iprot) + self.success.append(_elem920) iprot.readListEnd() else: iprot.skip(ftype) @@ -22121,8 +22731,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 iter879 in self.success: - iter879.write(oprot) + for iter921 in self.success: + iter921.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22203,10 +22813,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype883, _size880) = iprot.readListBegin() - for _i884 in xrange(_size880): - _elem885 = iprot.readString() - self.part_vals.append(_elem885) + (_etype925, _size922) = iprot.readListBegin() + for _i926 in xrange(_size922): + _elem927 = iprot.readString() + self.part_vals.append(_elem927) iprot.readListEnd() else: iprot.skip(ftype) @@ -22236,8 +22846,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 iter886 in self.part_vals: - oprot.writeString(iter886) + for iter928 in self.part_vals: + oprot.writeString(iter928) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -22301,10 +22911,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype890, _size887) = iprot.readListBegin() - for _i891 in xrange(_size887): - _elem892 = iprot.readString() - self.success.append(_elem892) + (_etype932, _size929) = iprot.readListBegin() + for _i933 in xrange(_size929): + _elem934 = iprot.readString() + self.success.append(_elem934) iprot.readListEnd() else: iprot.skip(ftype) @@ -22333,8 +22943,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 iter893 in self.success: - oprot.writeString(iter893) + for iter935 in self.success: + oprot.writeString(iter935) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22505,11 +23115,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype897, _size894) = iprot.readListBegin() - for _i898 in xrange(_size894): - _elem899 = Partition() - _elem899.read(iprot) - self.success.append(_elem899) + (_etype939, _size936) = iprot.readListBegin() + for _i940 in xrange(_size936): + _elem941 = Partition() + _elem941.read(iprot) + self.success.append(_elem941) iprot.readListEnd() else: iprot.skip(ftype) @@ -22538,8 +23148,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 iter900 in self.success: - iter900.write(oprot) + for iter942 in self.success: + iter942.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22710,11 +23320,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype904, _size901) = iprot.readListBegin() - for _i905 in xrange(_size901): - _elem906 = PartitionSpec() - _elem906.read(iprot) - self.success.append(_elem906) + (_etype946, _size943) = iprot.readListBegin() + for _i947 in xrange(_size943): + _elem948 = PartitionSpec() + _elem948.read(iprot) + self.success.append(_elem948) iprot.readListEnd() else: iprot.skip(ftype) @@ -22743,8 +23353,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 iter907 in self.success: - iter907.write(oprot) + for iter949 in self.success: + iter949.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23164,10 +23774,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype911, _size908) = iprot.readListBegin() - for _i912 in xrange(_size908): - _elem913 = iprot.readString() - self.names.append(_elem913) + (_etype953, _size950) = iprot.readListBegin() + for _i954 in xrange(_size950): + _elem955 = iprot.readString() + self.names.append(_elem955) iprot.readListEnd() else: iprot.skip(ftype) @@ -23192,8 +23802,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 iter914 in self.names: - oprot.writeString(iter914) + for iter956 in self.names: + oprot.writeString(iter956) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23252,11 +23862,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype918, _size915) = iprot.readListBegin() - for _i919 in xrange(_size915): - _elem920 = Partition() - _elem920.read(iprot) - self.success.append(_elem920) + (_etype960, _size957) = iprot.readListBegin() + for _i961 in xrange(_size957): + _elem962 = Partition() + _elem962.read(iprot) + self.success.append(_elem962) iprot.readListEnd() else: iprot.skip(ftype) @@ -23285,8 +23895,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 iter921 in self.success: - iter921.write(oprot) + for iter963 in self.success: + iter963.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23536,11 +24146,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype925, _size922) = iprot.readListBegin() - for _i926 in xrange(_size922): - _elem927 = Partition() - _elem927.read(iprot) - self.new_parts.append(_elem927) + (_etype967, _size964) = iprot.readListBegin() + for _i968 in xrange(_size964): + _elem969 = Partition() + _elem969.read(iprot) + self.new_parts.append(_elem969) iprot.readListEnd() else: iprot.skip(ftype) @@ -23565,8 +24175,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 iter928 in self.new_parts: - iter928.write(oprot) + for iter970 in self.new_parts: + iter970.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23719,11 +24329,11 @@ class alter_partitions_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype932, _size929) = iprot.readListBegin() - for _i933 in xrange(_size929): - _elem934 = Partition() - _elem934.read(iprot) - self.new_parts.append(_elem934) + (_etype974, _size971) = iprot.readListBegin() + for _i975 in xrange(_size971): + _elem976 = Partition() + _elem976.read(iprot) + self.new_parts.append(_elem976) iprot.readListEnd() else: iprot.skip(ftype) @@ -23754,8 +24364,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 iter935 in self.new_parts: - iter935.write(oprot) + for iter977 in self.new_parts: + iter977.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -24099,10 +24709,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype939, _size936) = iprot.readListBegin() - for _i940 in xrange(_size936): - _elem941 = iprot.readString() - self.part_vals.append(_elem941) + (_etype981, _size978) = iprot.readListBegin() + for _i982 in xrange(_size978): + _elem983 = iprot.readString() + self.part_vals.append(_elem983) iprot.readListEnd() else: iprot.skip(ftype) @@ -24133,8 +24743,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 iter942 in self.part_vals: - oprot.writeString(iter942) + for iter984 in self.part_vals: + oprot.writeString(iter984) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -24276,10 +24886,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype946, _size943) = iprot.readListBegin() - for _i947 in xrange(_size943): - _elem948 = iprot.readString() - self.part_vals.append(_elem948) + (_etype988, _size985) = iprot.readListBegin() + for _i989 in xrange(_size985): + _elem990 = iprot.readString() + self.part_vals.append(_elem990) iprot.readListEnd() else: iprot.skip(ftype) @@ -24301,8 +24911,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 iter949 in self.part_vals: - oprot.writeString(iter949) + for iter991 in self.part_vals: + oprot.writeString(iter991) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -24660,10 +25270,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype953, _size950) = iprot.readListBegin() - for _i954 in xrange(_size950): - _elem955 = iprot.readString() - self.success.append(_elem955) + (_etype995, _size992) = iprot.readListBegin() + for _i996 in xrange(_size992): + _elem997 = iprot.readString() + self.success.append(_elem997) iprot.readListEnd() else: iprot.skip(ftype) @@ -24686,8 +25296,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 iter956 in self.success: - oprot.writeString(iter956) + for iter998 in self.success: + oprot.writeString(iter998) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24811,11 +25421,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype958, _vtype959, _size957 ) = iprot.readMapBegin() - for _i961 in xrange(_size957): - _key962 = iprot.readString() - _val963 = iprot.readString() - self.success[_key962] = _val963 + (_ktype1000, _vtype1001, _size999 ) = iprot.readMapBegin() + for _i1003 in xrange(_size999): + _key1004 = iprot.readString() + _val1005 = iprot.readString() + self.success[_key1004] = _val1005 iprot.readMapEnd() else: iprot.skip(ftype) @@ -24838,9 +25448,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 kiter964,viter965 in self.success.items(): - oprot.writeString(kiter964) - oprot.writeString(viter965) + for kiter1006,viter1007 in self.success.items(): + oprot.writeString(kiter1006) + oprot.writeString(viter1007) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24916,11 +25526,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype967, _vtype968, _size966 ) = iprot.readMapBegin() - for _i970 in xrange(_size966): - _key971 = iprot.readString() - _val972 = iprot.readString() - self.part_vals[_key971] = _val972 + (_ktype1009, _vtype1010, _size1008 ) = iprot.readMapBegin() + for _i1012 in xrange(_size1008): + _key1013 = iprot.readString() + _val1014 = iprot.readString() + self.part_vals[_key1013] = _val1014 iprot.readMapEnd() else: iprot.skip(ftype) @@ -24950,9 +25560,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 kiter973,viter974 in self.part_vals.items(): - oprot.writeString(kiter973) - oprot.writeString(viter974) + for kiter1015,viter1016 in self.part_vals.items(): + oprot.writeString(kiter1015) + oprot.writeString(viter1016) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -25166,11 +25776,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype976, _vtype977, _size975 ) = iprot.readMapBegin() - for _i979 in xrange(_size975): - _key980 = iprot.readString() - _val981 = iprot.readString() - self.part_vals[_key980] = _val981 + (_ktype1018, _vtype1019, _size1017 ) = iprot.readMapBegin() + for _i1021 in xrange(_size1017): + _key1022 = iprot.readString() + _val1023 = iprot.readString() + self.part_vals[_key1022] = _val1023 iprot.readMapEnd() else: iprot.skip(ftype) @@ -25200,9 +25810,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 kiter982,viter983 in self.part_vals.items(): - oprot.writeString(kiter982) - oprot.writeString(viter983) + for kiter1024,viter1025 in self.part_vals.items(): + oprot.writeString(kiter1024) + oprot.writeString(viter1025) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -25991,8 +26601,384 @@ class get_index_by_name_args: else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.STRING: - self.index_name = iprot.readString() + if ftype == TType.STRING: + self.index_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_index_by_name_args') + if self.db_name is not None: + oprot.writeFieldBegin('db_name', TType.STRING, 1) + oprot.writeString(self.db_name) + oprot.writeFieldEnd() + if self.tbl_name is not None: + oprot.writeFieldBegin('tbl_name', TType.STRING, 2) + oprot.writeString(self.tbl_name) + oprot.writeFieldEnd() + if self.index_name is not None: + oprot.writeFieldBegin('index_name', TType.STRING, 3) + oprot.writeString(self.index_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.tbl_name) + value = (value * 31) ^ hash(self.index_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_index_by_name_result: + """ + Attributes: + - success + - o1 + - o2 + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (Index, Index.thrift_spec), None, ), # 0 + (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1 + (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2 + ) + + def __init__(self, success=None, o1=None, o2=None,): + self.success = success + self.o1 = o1 + self.o2 = o2 + + def read(self, iprot): + if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None: + fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec)) + return + iprot.readStructBegin() + while True: + (fname, ftype, fid) = iprot.readFieldBegin() + if ftype == TType.STOP: + break + if fid == 0: + if ftype == TType.STRUCT: + self.success = Index() + self.success.read(iprot) + else: + iprot.skip(ftype) + elif fid == 1: + if ftype == TType.STRUCT: + self.o1 = MetaException() + self.o1.read(iprot) + else: + iprot.skip(ftype) + elif fid == 2: + if ftype == TType.STRUCT: + self.o2 = NoSuchObjectException() + self.o2.read(iprot) + else: + iprot.skip(ftype) + else: + iprot.skip(ftype) + iprot.readFieldEnd() + iprot.readStructEnd() + + def write(self, oprot): + if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None: + oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) + return + oprot.writeStructBegin('get_index_by_name_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + if self.o2 is not None: + oprot.writeFieldBegin('o2', TType.STRUCT, 2) + self.o2.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value
<TRUNCATED>