http://git-wip-us.apache.org/repos/asf/hive/blob/12041d39/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index 516be77..30214d8 100644 --- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -1410,6 +1410,104 @@ class Iface(fb303.FacebookService.Iface): """ pass + def create_ischema(self, schema): + """ + Parameters: + - schema + """ + pass + + def alter_ischema(self, rqst): + """ + Parameters: + - rqst + """ + pass + + def get_ischema(self, name): + """ + Parameters: + - name + """ + pass + + def drop_ischema(self, name): + """ + Parameters: + - name + """ + pass + + def add_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + pass + + def get_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + pass + + def get_schema_latest_version(self, schemaName): + """ + Parameters: + - schemaName + """ + pass + + def get_schema_all_versions(self, schemaName): + """ + Parameters: + - schemaName + """ + pass + + def drop_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + pass + + def get_schemas_by_cols(self, rqst): + """ + Parameters: + - rqst + """ + pass + + def map_schema_version_to_serde(self, rqst): + """ + Parameters: + - rqst + """ + pass + + def set_schema_version_state(self, rqst): + """ + Parameters: + - rqst + """ + pass + + def add_serde(self, serde): + """ + Parameters: + - serde + """ + pass + + def get_serde(self, rqst): + """ + Parameters: + - rqst + """ + pass + class Client(fb303.FacebookService.Client, Iface): """ @@ -7888,6 +7986,486 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o4 raise TApplicationException(TApplicationException.MISSING_RESULT, "create_or_drop_wm_trigger_to_pool_mapping failed: unknown result") + def create_ischema(self, schema): + """ + Parameters: + - schema + """ + self.send_create_ischema(schema) + self.recv_create_ischema() + + def send_create_ischema(self, schema): + self._oprot.writeMessageBegin('create_ischema', TMessageType.CALL, self._seqid) + args = create_ischema_args() + args.schema = schema + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_create_ischema(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = create_ischema_result() + result.read(iprot) + iprot.readMessageEnd() + 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 + return + + def alter_ischema(self, rqst): + """ + Parameters: + - rqst + """ + self.send_alter_ischema(rqst) + self.recv_alter_ischema() + + def send_alter_ischema(self, rqst): + self._oprot.writeMessageBegin('alter_ischema', TMessageType.CALL, self._seqid) + args = alter_ischema_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_alter_ischema(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = alter_ischema_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 get_ischema(self, name): + """ + Parameters: + - name + """ + self.send_get_ischema(name) + return self.recv_get_ischema() + + def send_get_ischema(self, name): + self._oprot.writeMessageBegin('get_ischema', TMessageType.CALL, self._seqid) + args = get_ischema_args() + args.name = name + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_ischema(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_ischema_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_ischema failed: unknown result") + + def drop_ischema(self, name): + """ + Parameters: + - name + """ + self.send_drop_ischema(name) + self.recv_drop_ischema() + + def send_drop_ischema(self, name): + self._oprot.writeMessageBegin('drop_ischema', TMessageType.CALL, self._seqid) + args = drop_ischema_args() + args.name = name + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_drop_ischema(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = drop_ischema_result() + result.read(iprot) + iprot.readMessageEnd() + 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 + return + + def add_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + self.send_add_schema_version(schemaVersion) + self.recv_add_schema_version() + + def send_add_schema_version(self, schemaVersion): + self._oprot.writeMessageBegin('add_schema_version', TMessageType.CALL, self._seqid) + args = add_schema_version_args() + args.schemaVersion = schemaVersion + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_add_schema_version(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = add_schema_version_result() + result.read(iprot) + iprot.readMessageEnd() + 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 + return + + def get_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + self.send_get_schema_version(schemaVersion) + return self.recv_get_schema_version() + + def send_get_schema_version(self, schemaVersion): + self._oprot.writeMessageBegin('get_schema_version', TMessageType.CALL, self._seqid) + args = get_schema_version_args() + args.schemaVersion = schemaVersion + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_schema_version(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_schema_version_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_schema_version failed: unknown result") + + def get_schema_latest_version(self, schemaName): + """ + Parameters: + - schemaName + """ + self.send_get_schema_latest_version(schemaName) + return self.recv_get_schema_latest_version() + + def send_get_schema_latest_version(self, schemaName): + self._oprot.writeMessageBegin('get_schema_latest_version', TMessageType.CALL, self._seqid) + args = get_schema_latest_version_args() + args.schemaName = schemaName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_schema_latest_version(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_schema_latest_version_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_schema_latest_version failed: unknown result") + + def get_schema_all_versions(self, schemaName): + """ + Parameters: + - schemaName + """ + self.send_get_schema_all_versions(schemaName) + return self.recv_get_schema_all_versions() + + def send_get_schema_all_versions(self, schemaName): + self._oprot.writeMessageBegin('get_schema_all_versions', TMessageType.CALL, self._seqid) + args = get_schema_all_versions_args() + args.schemaName = schemaName + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_schema_all_versions(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_schema_all_versions_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_schema_all_versions failed: unknown result") + + def drop_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + self.send_drop_schema_version(schemaVersion) + self.recv_drop_schema_version() + + def send_drop_schema_version(self, schemaVersion): + self._oprot.writeMessageBegin('drop_schema_version', TMessageType.CALL, self._seqid) + args = drop_schema_version_args() + args.schemaVersion = schemaVersion + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_drop_schema_version(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = drop_schema_version_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 get_schemas_by_cols(self, rqst): + """ + Parameters: + - rqst + """ + self.send_get_schemas_by_cols(rqst) + return self.recv_get_schemas_by_cols() + + def send_get_schemas_by_cols(self, rqst): + self._oprot.writeMessageBegin('get_schemas_by_cols', TMessageType.CALL, self._seqid) + args = get_schemas_by_cols_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_schemas_by_cols(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_schemas_by_cols_result() + result.read(iprot) + 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, "get_schemas_by_cols failed: unknown result") + + def map_schema_version_to_serde(self, rqst): + """ + Parameters: + - rqst + """ + self.send_map_schema_version_to_serde(rqst) + self.recv_map_schema_version_to_serde() + + def send_map_schema_version_to_serde(self, rqst): + self._oprot.writeMessageBegin('map_schema_version_to_serde', TMessageType.CALL, self._seqid) + args = map_schema_version_to_serde_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_map_schema_version_to_serde(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = map_schema_version_to_serde_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 set_schema_version_state(self, rqst): + """ + Parameters: + - rqst + """ + self.send_set_schema_version_state(rqst) + self.recv_set_schema_version_state() + + def send_set_schema_version_state(self, rqst): + self._oprot.writeMessageBegin('set_schema_version_state', TMessageType.CALL, self._seqid) + args = set_schema_version_state_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_set_schema_version_state(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = set_schema_version_state_result() + result.read(iprot) + iprot.readMessageEnd() + 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 + return + + def add_serde(self, serde): + """ + Parameters: + - serde + """ + self.send_add_serde(serde) + self.recv_add_serde() + + def send_add_serde(self, serde): + self._oprot.writeMessageBegin('add_serde', TMessageType.CALL, self._seqid) + args = add_serde_args() + args.serde = serde + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_add_serde(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = add_serde_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 get_serde(self, rqst): + """ + Parameters: + - rqst + """ + self.send_get_serde(rqst) + return self.recv_get_serde() + + def send_get_serde(self, rqst): + self._oprot.writeMessageBegin('get_serde', TMessageType.CALL, self._seqid) + args = get_serde_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_serde(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = get_serde_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_serde failed: unknown result") + class Processor(fb303.FacebookService.Processor, Iface, TProcessor): def __init__(self, handler): @@ -8072,6 +8650,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["create_or_update_wm_mapping"] = Processor.process_create_or_update_wm_mapping self._processMap["drop_wm_mapping"] = Processor.process_drop_wm_mapping self._processMap["create_or_drop_wm_trigger_to_pool_mapping"] = Processor.process_create_or_drop_wm_trigger_to_pool_mapping + self._processMap["create_ischema"] = Processor.process_create_ischema + self._processMap["alter_ischema"] = Processor.process_alter_ischema + self._processMap["get_ischema"] = Processor.process_get_ischema + self._processMap["drop_ischema"] = Processor.process_drop_ischema + self._processMap["add_schema_version"] = Processor.process_add_schema_version + self._processMap["get_schema_version"] = Processor.process_get_schema_version + self._processMap["get_schema_latest_version"] = Processor.process_get_schema_latest_version + self._processMap["get_schema_all_versions"] = Processor.process_get_schema_all_versions + self._processMap["drop_schema_version"] = Processor.process_drop_schema_version + self._processMap["get_schemas_by_cols"] = Processor.process_get_schemas_by_cols + self._processMap["map_schema_version_to_serde"] = Processor.process_map_schema_version_to_serde + self._processMap["set_schema_version_state"] = Processor.process_set_schema_version_state + self._processMap["add_serde"] = Processor.process_add_serde + self._processMap["get_serde"] = Processor.process_get_serde def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -12534,6 +13126,365 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_create_ischema(self, seqid, iprot, oprot): + args = create_ischema_args() + args.read(iprot) + iprot.readMessageEnd() + result = create_ischema_result() + try: + self._handler.create_ischema(args.schema) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except MetaException as o3: + msg_type = TMessageType.REPLY + result.o3 = o3 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("create_ischema", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_alter_ischema(self, seqid, iprot, oprot): + args = alter_ischema_args() + args.read(iprot) + iprot.readMessageEnd() + result = alter_ischema_result() + try: + self._handler.alter_ischema(args.rqst) + 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("alter_ischema", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_ischema(self, seqid, iprot, oprot): + args = get_ischema_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_ischema_result() + try: + result.success = self._handler.get_ischema(args.name) + 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("get_ischema", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_drop_ischema(self, seqid, iprot, oprot): + args = drop_ischema_args() + args.read(iprot) + iprot.readMessageEnd() + result = drop_ischema_result() + try: + self._handler.drop_ischema(args.name) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except InvalidOperationException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except MetaException as o3: + msg_type = TMessageType.REPLY + result.o3 = o3 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("drop_ischema", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_add_schema_version(self, seqid, iprot, oprot): + args = add_schema_version_args() + args.read(iprot) + iprot.readMessageEnd() + result = add_schema_version_result() + try: + self._handler.add_schema_version(args.schemaVersion) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except NoSuchObjectException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except MetaException as o3: + msg_type = TMessageType.REPLY + result.o3 = o3 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("add_schema_version", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_schema_version(self, seqid, iprot, oprot): + args = get_schema_version_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_schema_version_result() + try: + result.success = self._handler.get_schema_version(args.schemaVersion) + 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("get_schema_version", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_schema_latest_version(self, seqid, iprot, oprot): + args = get_schema_latest_version_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_schema_latest_version_result() + try: + result.success = self._handler.get_schema_latest_version(args.schemaName) + 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("get_schema_latest_version", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_schema_all_versions(self, seqid, iprot, oprot): + args = get_schema_all_versions_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_schema_all_versions_result() + try: + result.success = self._handler.get_schema_all_versions(args.schemaName) + 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("get_schema_all_versions", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_drop_schema_version(self, seqid, iprot, oprot): + args = drop_schema_version_args() + args.read(iprot) + iprot.readMessageEnd() + result = drop_schema_version_result() + try: + self._handler.drop_schema_version(args.schemaVersion) + 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("drop_schema_version", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_schemas_by_cols(self, seqid, iprot, oprot): + args = get_schemas_by_cols_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_schemas_by_cols_result() + try: + result.success = self._handler.get_schemas_by_cols(args.rqst) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except MetaException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("get_schemas_by_cols", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_map_schema_version_to_serde(self, seqid, iprot, oprot): + args = map_schema_version_to_serde_args() + args.read(iprot) + iprot.readMessageEnd() + result = map_schema_version_to_serde_result() + try: + self._handler.map_schema_version_to_serde(args.rqst) + 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("map_schema_version_to_serde", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_set_schema_version_state(self, seqid, iprot, oprot): + args = set_schema_version_state_args() + args.read(iprot) + iprot.readMessageEnd() + result = set_schema_version_state_result() + try: + self._handler.set_schema_version_state(args.rqst) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchObjectException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except InvalidOperationException as o2: + msg_type = TMessageType.REPLY + result.o2 = o2 + except MetaException as o3: + msg_type = TMessageType.REPLY + result.o3 = o3 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("set_schema_version_state", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_add_serde(self, seqid, iprot, oprot): + args = add_serde_args() + args.read(iprot) + iprot.readMessageEnd() + result = add_serde_result() + try: + self._handler.add_serde(args.serde) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except AlreadyExistsException 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_serde", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_serde(self, seqid, iprot, oprot): + args = get_serde_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_serde_result() + try: + result.success = self._handler.get_serde(args.rqst) + 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("get_serde", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + # HELPER FUNCTIONS AND STRUCTURES @@ -13420,10 +14371,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype763, _size760) = iprot.readListBegin() - for _i764 in xrange(_size760): - _elem765 = iprot.readString() - self.success.append(_elem765) + (_etype777, _size774) = iprot.readListBegin() + for _i778 in xrange(_size774): + _elem779 = iprot.readString() + self.success.append(_elem779) iprot.readListEnd() else: iprot.skip(ftype) @@ -13446,8 +14397,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 iter766 in self.success: - oprot.writeString(iter766) + for iter780 in self.success: + oprot.writeString(iter780) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13552,10 +14503,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype770, _size767) = iprot.readListBegin() - for _i771 in xrange(_size767): - _elem772 = iprot.readString() - self.success.append(_elem772) + (_etype784, _size781) = iprot.readListBegin() + for _i785 in xrange(_size781): + _elem786 = iprot.readString() + self.success.append(_elem786) iprot.readListEnd() else: iprot.skip(ftype) @@ -13578,8 +14529,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 iter773 in self.success: - oprot.writeString(iter773) + for iter787 in self.success: + oprot.writeString(iter787) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14349,12 +15300,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype775, _vtype776, _size774 ) = iprot.readMapBegin() - for _i778 in xrange(_size774): - _key779 = iprot.readString() - _val780 = Type() - _val780.read(iprot) - self.success[_key779] = _val780 + (_ktype789, _vtype790, _size788 ) = iprot.readMapBegin() + for _i792 in xrange(_size788): + _key793 = iprot.readString() + _val794 = Type() + _val794.read(iprot) + self.success[_key793] = _val794 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14377,9 +15328,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 kiter781,viter782 in self.success.items(): - oprot.writeString(kiter781) - viter782.write(oprot) + for kiter795,viter796 in self.success.items(): + oprot.writeString(kiter795) + viter796.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -14522,11 +15473,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype786, _size783) = iprot.readListBegin() - for _i787 in xrange(_size783): - _elem788 = FieldSchema() - _elem788.read(iprot) - self.success.append(_elem788) + (_etype800, _size797) = iprot.readListBegin() + for _i801 in xrange(_size797): + _elem802 = FieldSchema() + _elem802.read(iprot) + self.success.append(_elem802) iprot.readListEnd() else: iprot.skip(ftype) @@ -14561,8 +15512,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 iter789 in self.success: - iter789.write(oprot) + for iter803 in self.success: + iter803.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14729,11 +15680,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype793, _size790) = iprot.readListBegin() - for _i794 in xrange(_size790): - _elem795 = FieldSchema() - _elem795.read(iprot) - self.success.append(_elem795) + (_etype807, _size804) = iprot.readListBegin() + for _i808 in xrange(_size804): + _elem809 = FieldSchema() + _elem809.read(iprot) + self.success.append(_elem809) iprot.readListEnd() else: iprot.skip(ftype) @@ -14768,8 +15719,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 iter796 in self.success: - iter796.write(oprot) + for iter810 in self.success: + iter810.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14922,11 +15873,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype800, _size797) = iprot.readListBegin() - for _i801 in xrange(_size797): - _elem802 = FieldSchema() - _elem802.read(iprot) - self.success.append(_elem802) + (_etype814, _size811) = iprot.readListBegin() + for _i815 in xrange(_size811): + _elem816 = FieldSchema() + _elem816.read(iprot) + self.success.append(_elem816) iprot.readListEnd() else: iprot.skip(ftype) @@ -14961,8 +15912,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 iter803 in self.success: - iter803.write(oprot) + for iter817 in self.success: + iter817.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15129,11 +16080,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype807, _size804) = iprot.readListBegin() - for _i808 in xrange(_size804): - _elem809 = FieldSchema() - _elem809.read(iprot) - self.success.append(_elem809) + (_etype821, _size818) = iprot.readListBegin() + for _i822 in xrange(_size818): + _elem823 = FieldSchema() + _elem823.read(iprot) + self.success.append(_elem823) iprot.readListEnd() else: iprot.skip(ftype) @@ -15168,8 +16119,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 iter810 in self.success: - iter810.write(oprot) + for iter824 in self.success: + iter824.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15619,55 +16570,55 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype814, _size811) = iprot.readListBegin() - for _i815 in xrange(_size811): - _elem816 = SQLPrimaryKey() - _elem816.read(iprot) - self.primaryKeys.append(_elem816) + (_etype828, _size825) = iprot.readListBegin() + for _i829 in xrange(_size825): + _elem830 = SQLPrimaryKey() + _elem830.read(iprot) + self.primaryKeys.append(_elem830) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype820, _size817) = iprot.readListBegin() - for _i821 in xrange(_size817): - _elem822 = SQLForeignKey() - _elem822.read(iprot) - self.foreignKeys.append(_elem822) + (_etype834, _size831) = iprot.readListBegin() + for _i835 in xrange(_size831): + _elem836 = SQLForeignKey() + _elem836.read(iprot) + self.foreignKeys.append(_elem836) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype826, _size823) = iprot.readListBegin() - for _i827 in xrange(_size823): - _elem828 = SQLUniqueConstraint() - _elem828.read(iprot) - self.uniqueConstraints.append(_elem828) + (_etype840, _size837) = iprot.readListBegin() + for _i841 in xrange(_size837): + _elem842 = SQLUniqueConstraint() + _elem842.read(iprot) + self.uniqueConstraints.append(_elem842) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype832, _size829) = iprot.readListBegin() - for _i833 in xrange(_size829): - _elem834 = SQLNotNullConstraint() - _elem834.read(iprot) - self.notNullConstraints.append(_elem834) + (_etype846, _size843) = iprot.readListBegin() + for _i847 in xrange(_size843): + _elem848 = SQLNotNullConstraint() + _elem848.read(iprot) + self.notNullConstraints.append(_elem848) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 6: if ftype == TType.LIST: self.defaultConstraints = [] - (_etype838, _size835) = iprot.readListBegin() - for _i839 in xrange(_size835): - _elem840 = SQLDefaultConstraint() - _elem840.read(iprot) - self.defaultConstraints.append(_elem840) + (_etype852, _size849) = iprot.readListBegin() + for _i853 in xrange(_size849): + _elem854 = SQLDefaultConstraint() + _elem854.read(iprot) + self.defaultConstraints.append(_elem854) iprot.readListEnd() else: iprot.skip(ftype) @@ -15688,36 +16639,36 @@ 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 iter841 in self.primaryKeys: - iter841.write(oprot) + for iter855 in self.primaryKeys: + iter855.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 iter842 in self.foreignKeys: - iter842.write(oprot) + for iter856 in self.foreignKeys: + iter856.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 iter843 in self.uniqueConstraints: - iter843.write(oprot) + for iter857 in self.uniqueConstraints: + iter857.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 iter844 in self.notNullConstraints: - iter844.write(oprot) + for iter858 in self.notNullConstraints: + iter858.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.defaultConstraints is not None: oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6) oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints)) - for iter845 in self.defaultConstraints: - iter845.write(oprot) + for iter859 in self.defaultConstraints: + iter859.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17130,10 +18081,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype849, _size846) = iprot.readListBegin() - for _i850 in xrange(_size846): - _elem851 = iprot.readString() - self.partNames.append(_elem851) + (_etype863, _size860) = iprot.readListBegin() + for _i864 in xrange(_size860): + _elem865 = iprot.readString() + self.partNames.append(_elem865) iprot.readListEnd() else: iprot.skip(ftype) @@ -17158,8 +18109,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 iter852 in self.partNames: - oprot.writeString(iter852) + for iter866 in self.partNames: + oprot.writeString(iter866) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17359,10 +18310,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype856, _size853) = iprot.readListBegin() - for _i857 in xrange(_size853): - _elem858 = iprot.readString() - self.success.append(_elem858) + (_etype870, _size867) = iprot.readListBegin() + for _i871 in xrange(_size867): + _elem872 = iprot.readString() + self.success.append(_elem872) iprot.readListEnd() else: iprot.skip(ftype) @@ -17385,8 +18336,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 iter859 in self.success: - oprot.writeString(iter859) + for iter873 in self.success: + oprot.writeString(iter873) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17536,10 +18487,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype863, _size860) = iprot.readListBegin() - for _i864 in xrange(_size860): - _elem865 = iprot.readString() - self.success.append(_elem865) + (_etype877, _size874) = iprot.readListBegin() + for _i878 in xrange(_size874): + _elem879 = iprot.readString() + self.success.append(_elem879) iprot.readListEnd() else: iprot.skip(ftype) @@ -17562,8 +18513,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 iter866 in self.success: - oprot.writeString(iter866) + for iter880 in self.success: + oprot.writeString(iter880) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17687,10 +18638,10 @@ class get_materialized_views_for_rewriting_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype870, _size867) = iprot.readListBegin() - for _i871 in xrange(_size867): - _elem872 = iprot.readString() - self.success.append(_elem872) + (_etype884, _size881) = iprot.readListBegin() + for _i885 in xrange(_size881): + _elem886 = iprot.readString() + self.success.append(_elem886) iprot.readListEnd() else: iprot.skip(ftype) @@ -17713,8 +18664,8 @@ class get_materialized_views_for_rewriting_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter873 in self.success: - oprot.writeString(iter873) + for iter887 in self.success: + oprot.writeString(iter887) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17787,10 +18738,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype877, _size874) = iprot.readListBegin() - for _i878 in xrange(_size874): - _elem879 = iprot.readString() - self.tbl_types.append(_elem879) + (_etype891, _size888) = iprot.readListBegin() + for _i892 in xrange(_size888): + _elem893 = iprot.readString() + self.tbl_types.append(_elem893) iprot.readListEnd() else: iprot.skip(ftype) @@ -17815,8 +18766,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 iter880 in self.tbl_types: - oprot.writeString(iter880) + for iter894 in self.tbl_types: + oprot.writeString(iter894) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17872,11 +18823,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype884, _size881) = iprot.readListBegin() - for _i885 in xrange(_size881): - _elem886 = TableMeta() - _elem886.read(iprot) - self.success.append(_elem886) + (_etype898, _size895) = iprot.readListBegin() + for _i899 in xrange(_size895): + _elem900 = TableMeta() + _elem900.read(iprot) + self.success.append(_elem900) iprot.readListEnd() else: iprot.skip(ftype) @@ -17899,8 +18850,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 iter887 in self.success: - iter887.write(oprot) + for iter901 in self.success: + iter901.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18024,10 +18975,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype891, _size888) = iprot.readListBegin() - for _i892 in xrange(_size888): - _elem893 = iprot.readString() - self.success.append(_elem893) + (_etype905, _size902) = iprot.readListBegin() + for _i906 in xrange(_size902): + _elem907 = iprot.readString() + self.success.append(_elem907) iprot.readListEnd() else: iprot.skip(ftype) @@ -18050,8 +19001,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 iter894 in self.success: - oprot.writeString(iter894) + for iter908 in self.success: + oprot.writeString(iter908) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18287,10 +19238,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype898, _size895) = iprot.readListBegin() - for _i899 in xrange(_size895): - _elem900 = iprot.readString() - self.tbl_names.append(_elem900) + (_etype912, _size909) = iprot.readListBegin() + for _i913 in xrange(_size909): + _elem914 = iprot.readString() + self.tbl_names.append(_elem914) iprot.readListEnd() else: iprot.skip(ftype) @@ -18311,8 +19262,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 iter901 in self.tbl_names: - oprot.writeString(iter901) + for iter915 in self.tbl_names: + oprot.writeString(iter915) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18364,11 +19315,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype905, _size902) = iprot.readListBegin() - for _i906 in xrange(_size902): - _elem907 = Table() - _elem907.read(iprot) - self.success.append(_elem907) + (_etype919, _size916) = iprot.readListBegin() + for _i920 in xrange(_size916): + _elem921 = Table() + _elem921.read(iprot) + self.success.append(_elem921) iprot.readListEnd() else: iprot.skip(ftype) @@ -18385,8 +19336,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 iter908 in self.success: - iter908.write(oprot) + for iter922 in self.success: + iter922.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18778,10 +19729,10 @@ class get_materialization_invalidation_info_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype912, _size909) = iprot.readListBegin() - for _i913 in xrange(_size909): - _elem914 = iprot.readString() - self.tbl_names.append(_elem914) + (_etype926, _size923) = iprot.readListBegin() + for _i927 in xrange(_size923): + _elem928 = iprot.readString() + self.tbl_names.append(_elem928) iprot.readListEnd() else: iprot.skip(ftype) @@ -18802,8 +19753,8 @@ class get_materialization_invalidation_info_args: if self.tbl_names is not None: oprot.writeFieldBegin('tbl_names', TType.LIST, 2) oprot.writeListBegin(TType.STRING, len(self.tbl_names)) - for iter915 in self.tbl_names: - oprot.writeString(iter915) + for iter929 in self.tbl_names: + oprot.writeString(iter929) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18864,12 +19815,12 @@ class get_materialization_invalidation_info_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype917, _vtype918, _size916 ) = iprot.readMapBegin() - for _i920 in xrange(_size916): - _key921 = iprot.readString() - _val922 = Materialization() - _val922.read(iprot) - self.success[_key921] = _val922 + (_ktype931, _vtype932, _size930 ) = iprot.readMapBegin() + for _i934 in xrange(_size930): + _key935 = iprot.readString() + _val936 = Materialization() + _val936.read(iprot) + self.success[_key935] = _val936 iprot.readMapEnd() else: iprot.skip(ftype) @@ -18904,9 +19855,9 @@ class get_materialization_invalidation_info_result: if self.success is not None: oprot.writeFieldBegin('success', TType.MAP, 0) oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success)) - for kiter923,viter924 in self.success.items(): - oprot.writeString(kiter923) - viter924.write(oprot) + for kiter937,viter938 in self.success.items(): + oprot.writeString(kiter937) + viter938.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19258,10 +20209,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype928, _size925) = iprot.readListBegin() - for _i929 in xrange(_size925): - _elem930 = iprot.readString() - self.success.append(_elem930) + (_etype942, _size939) = iprot.readListBegin() + for _i943 in xrange(_size939): + _elem944 = iprot.readString() + self.success.append(_elem944) iprot.readListEnd() else: iprot.skip(ftype) @@ -19296,8 +20247,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 iter931 in self.success: - oprot.writeString(iter931) + for iter945 in self.success: + oprot.writeString(iter945) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20267,11 +21218,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype935, _size932) = iprot.readListBegin() - for _i936 in xrange(_size932): - _elem937 = Partition() - _elem937.read(iprot) - self.new_parts.append(_elem937) + (_etype949, _size946) = iprot.readListBegin() + for _i950 in xrange(_size946): + _elem951 = Partition() + _elem951.read(iprot) + self.new_parts.append(_elem951) iprot.readListEnd() else: iprot.skip(ftype) @@ -20288,8 +21239,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 iter938 in self.new_parts: - iter938.write(oprot) + for iter952 in self.new_parts: + iter952.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20447,11 +21398,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype942, _size939) = iprot.readListBegin() - for _i943 in xrange(_size939): - _elem944 = PartitionSpec() - _elem944.read(iprot) - self.new_parts.append(_elem944) + (_etype956, _size953) = iprot.readListBegin() + for _i957 in xrange(_size953): + _elem958 = PartitionSpec() + _elem958.read(iprot) + self.new_parts.append(_elem958) iprot.readListEnd() else: iprot.skip(ftype) @@ -20468,8 +21419,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 iter945 in self.new_parts: - iter945.write(oprot) + for iter959 in self.new_parts: + iter959.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20643,10 +21594,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype949, _size946) = iprot.readListBegin() - for _i950 in xrange(_size946): - _elem951 = iprot.readString() - self.part_vals.append(_elem951) + (_etype963, _size960) = iprot.readListBegin() + for _i964 in xrange(_size960): + _elem965 = iprot.readString() + self.part_vals.append(_elem965) iprot.readListEnd() else: iprot.skip(ftype) @@ -20671,8 +21622,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 iter952 in self.part_vals: - oprot.writeString(iter952) + for iter966 in self.part_vals: + oprot.writeString(iter966) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -21025,10 +21976,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype956, _size953) = iprot.readListBegin() - for _i957 in xrange(_size953): - _elem958 = iprot.readString() - self.part_vals.append(_elem958) + (_etype970, _size967) = iprot.readListBegin() + for _i971 in xrange(_size967): + _elem972 = iprot.readString() + self.part_vals.append(_elem972) iprot.readListEnd() else: iprot.skip(ftype) @@ -21059,8 +22010,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 iter959 in self.part_vals: - oprot.writeString(iter959) + for iter973 in self.part_vals: + oprot.writeString(iter973) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -21655,10 +22606,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype963, _size960) = iprot.readListBegin() - for _i964 in xrange(_size960): - _elem965 = iprot.readString() - self.part_vals.append(_elem965) + (_etype977, _size974) = iprot.readListBegin() + for _i978 in xrange(_size974): + _elem979 = iprot.readString() + self.part_vals.append(_elem979) iprot.readListEnd() else: iprot.skip(ftype) @@ -21688,8 +22639,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 iter966 in self.part_vals: - oprot.writeString(iter966) + for iter980 in self.part_vals: + oprot.writeString(iter980) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -21862,10 +22813,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype970, _size967) = iprot.readListBegin() - for _i971 in xrange(_size967): - _elem972 = iprot.readString() - self.part_vals.append(_elem972) + (_etype984, _size981) = iprot.readListBegin() + for _i985 in xrange(_size981): + _elem986 = iprot.readString() + self.part_vals.append(_elem986) iprot.readListEnd() else: iprot.skip(ftype) @@ -21901,8 +22852,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 iter973 in self.part_vals: - oprot.writeString(iter973) + for iter987 in self.part_vals: + oprot.writeString(iter987) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -22639,10 +23590,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype977, _size974) = iprot.readListBegin() - for _i978 in xrange(_size974): - _elem979 = iprot.readString() - self.part_vals.append(_elem979) + (_etype991, _size988) = iprot.readListBegin() + for _i992 in xrange(_size988): + _elem993 = iprot.readString() + self.part_vals.append(_elem993) iprot.readListEnd() else: iprot.skip(ftype) @@ -22667,8 +23618,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 iter980 in self.part_vals: - oprot.writeString(iter980) + for iter994 in self.part_vals: + oprot.writeString(iter994) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22827,11 +23778,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype982, _vtype983, _size981 ) = iprot.readMapBegin() - for _i985 in xrange(_size981): - _key986 = iprot.readString() - _val987 = iprot.readString() - self.partitionSpecs[_key986] = _val987 + (_ktype996, _vtype997, _size995 ) = iprot.readMapBegin() + for _i999 in xrange(_size995): + _key1000 = iprot.readString() + _val1001 = iprot.readString() + self.partitionSpecs[_key1000] = _val1001 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22868,9 +23819,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 kiter988,viter989 in self.partitionSpecs.items(): - oprot.writeString(kiter988) - oprot.writeString(viter989) + for kiter1002,viter1003 in self.partitionSpecs.items(): + oprot.writeString(kiter1002) + oprot.writeString(viter1003) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -23075,11 +24026,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype991, _vtype992, _size990 ) = iprot.readMapBegin() - for _i994 in xrange(_size990): - _key995 = iprot.readString() - _val996 = iprot.readString() - self.partitionSpecs[_key995] = _val996 + (_ktype1005, _vtype1006, _size1004 ) = iprot.readMapBegin() + for _i1008 in xrange(_size1004): + _key1009 = iprot.readString() + _val1010 = iprot.readString() + self.partitionSpecs[_key1009] = _val1010 iprot.readMapEnd() else: iprot.skip(ftype) @@ -23116,9 +24067,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 kiter997,viter998 in self.partitionSpecs.items(): - oprot.writeString(kiter997) - oprot.writeString(viter998) + for kiter1011,viter1012 in self.partitionSpecs.items(): + oprot.writeString(kiter1011) + oprot.writeString(viter1012) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -23201,11 +24152,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1002, _size999) = iprot.readListBegin() - for _i1003 in xrange(_size999): - _elem1004 = Partition() - _elem1004.read(iprot) - self.success.append(_elem1004) + (_etype1016, _size1013) = iprot.readListBegin() + for _i1017 in xrange(_size1013): + _elem1018 = Partition() + _elem1018.read(iprot) + self.success.append(_elem1018) iprot.readListEnd() else: iprot.skip(ftype) @@ -23246,8 +24197,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 iter1005 in self.success: - iter1005.write(oprot) + for iter1019 in self.success: + iter1019.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23341,10 +24292,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1009, _size1006) = iprot.readListBegin() - for _i1010 in xrange(_size1006): - _elem1011 = iprot.readString() - self.part_vals.append(_elem1011) + (_etype1023, _size1020) = iprot.readListBegin() + for _i1024 in xrange(_size1020): + _elem1025 = iprot.readString() + self.part_vals.append(_elem1025) iprot.readListEnd() else: iprot.skip(ftype) @@ -23356,10 +24307,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype1015, _size1012) = iprot.readListBegin() - for _i1016 in xrange(_size1012): - _elem1017 = iprot.readString() - self.group_names.append(_elem1017) + (_etype1029, _size1026) = iprot.readListBegin() + for _i1030 in xrange(_size1026): + _elem1031 = iprot.readString() + self.group_names.append(_elem1031) iprot.readListEnd() else: iprot.skip(ftype) @@ -23384,8 +24335,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 iter1018 in self.part_vals: - oprot.writeString(iter1018) + for iter1032 in self.part_vals: + oprot.writeString(iter1032) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -23395,8 +24346,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 iter1019 in self.group_names: - oprot.writeString(iter1019) + for iter1033 in self.group_names: + oprot.writeString(iter1033) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23825,11 +24776,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1023, _size1020) = iprot.readListBegin() - for _i1024 in xrange(_size1020): - _elem1025 = Partition() - _elem1025.read(iprot) - self.success.append(_elem1025) + (_etype1037, _size1034) = iprot.readListBegin() + for _i1038 in xrange(_size1034): + _elem1039 = Partition() + _elem1039.read(iprot) + self.success.append(_elem1039) iprot.readListEnd() else: iprot.skip(ftype) @@ -23858,8 +24809,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 iter1026 in self.success: - iter1026.write(oprot) + for iter1040 in self.success: + iter1040.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23953,10 +24904,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype1030, _size1027) = iprot.readListBegin() - for _i1031 in xrange(_size1027): - _elem1032 = iprot.readString() - self.group_names.append(_elem1032) + (_etype1044, _size1041) = iprot.readListBegin() + for _i1045 in xrange(_size1041): + _elem1046 = iprot.readString() + self.group_names.append(_elem1046) iprot.readListEnd() else: iprot.skip(ftype) @@ -23989,8 +24940,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 iter1033 in self.group_names: - oprot.writeString(iter1033) + for iter1047 in self.group_names: + oprot.writeString(iter1047) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24051,11 +25002,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1037, _size1034) = iprot.readListBegin() - for _i1038 in xrange(_size1034): - _elem1039 = Partition() - _elem1039.read(iprot) - self.success.append(_elem1039) + (_etype1051, _size1048) = iprot.readListBegin() + for _i1052 in xrange(_size1048): + _elem1053 = Partition() + _elem1053.read(iprot) + self.success.append(_elem1053) iprot.readListEnd() else: iprot.skip(ftype) @@ -24084,8 +25035,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 iter1040 in self.success: - iter1040.write(oprot) + for iter1054 in self.success: + iter1054.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24243,11 +25194,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1044, _size1041) = iprot.readListBegin() - for _i1045 in xrange(_size1041): - _elem1046 = PartitionSpec() - _elem1046.read(iprot) - self.success.append(_elem1046) + (_etype1058, _size1055) = iprot.readListBegin() + for _i1059 in xrange(_size1055): + _elem1060 = PartitionSpec() + _elem1060.read(iprot) + self.success.append(_elem1060) iprot.readListEnd() else: iprot.skip(ftype) @@ -24276,8 +25227,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 iter1047 in self.success: - iter1047.write(oprot) + for iter1061 in self.success: + iter1061.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24435,10 +25386,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1051, _size1048) = iprot.readListBegin() - for _i1052 in xrange(_size1048): - _elem1053 = iprot.readString() - self.success.append(_elem1053) + (_etype1065, _size1062) = iprot.readListBegin() + for _i1066 in xrange(_size1062): + _elem1067 = iprot.readString() + self.success.append(_elem1067) iprot.readListEnd() else: iprot.skip(ftype) @@ -24467,8 +25418,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 iter1054 in self.success: - oprot.writeString(iter1054) + for iter1068 in self.success: + oprot.writeString(iter1068) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24708,10 +25659,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1058, _size1055) = iprot.readListBegin() - for _i1059 in xrange(_size1055): - _elem1060 = iprot.readString() - self.part_vals.append(_elem1060) + (_etype1072, _size1069) = iprot.readListBegin() + for _i1073 in xrange(_size1069): + _elem1074 = iprot.readString() + self.part_vals.append(_elem1074) iprot.readListEnd() else: iprot.skip(ftype) @@ -24741,8 +25692,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 iter1061 in self.part_vals: - oprot.writeString(iter1061) + for iter1075 in self.part_vals: + oprot.writeString(iter1075) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24806,11 +25757,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1065, _size1062) = iprot.readListBegin() - for _i1066 in xrange(_size1062): - _elem1067 = Partition() - _elem1067.read(iprot) - self.success.append(_elem1067) + (_etype1079, _size1076) = iprot.readListBegin() + for _i1080 in xrange(_size1076): + _elem1081 = Partition() + _elem1081.read(iprot) + self.success.append(_elem1081) iprot.readListEnd() else: iprot.skip(ftype) @@ -24839,8 +25790,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 iter1068 in self.success: - iter1068.write(oprot) + for iter1082 in self.success: + iter1082.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24927,10 +25878,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1072, _size1069) = iprot.readListBegin() - for _i1073 in xrange(_size1069): - _elem1074 = iprot.readString() - self.part_vals.append(_elem1074) + (_etype1086, _size1083) = iprot.readListBegin() + for _i1087 in xrange(_size1083): + _elem1088 = iprot.readString() + self.part_vals.append(_elem1088) iprot.readListEnd() else: iprot.skip(ftype) @@ -24947,10 +25898,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype1078, _size1075) = iprot.readListBegin() - for _i1079 in xrange(_size1075): - _elem1080 = iprot.readString() - self.group_names.append(_elem1080) + (_etype1092, _size1089) = iprot.readListBegin() + for _i1093 in xrange(_size1089): + _elem1094 = iprot.readString() + self.group_names.append(_elem1094) iprot.readListEnd() else: iprot.skip(ftype) @@ -24975,8 +25926,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 iter1081 in self.part_vals: - oprot.writeString(iter1081) + for iter1095 in self.part_vals: + oprot.writeString(iter1095) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24990,8 +25941,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 iter1082 in self.group_names: - oprot.writeString(iter1082) + for iter1096 in self.group_names: + oprot.writeString(iter1096) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25053,11 +26004,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1086, _size1083) = iprot.readListBegin() - for _i1087 in xrange(_size1083): - _elem1088 = Partition() - _elem1088.read(iprot) - self.success.append(_elem1088) + (_etype1100, _size1097) = iprot.readListBegin() + for _i1101 in xrange(_size1097): + _elem1102 = Partition() + _elem1102.read(iprot) + self.success.append(_elem1102) iprot.readListEnd() else: iprot.skip(ftype) @@ -25086,8 +26037,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 iter1089 in self.success: - iter1089.write(oprot) + for iter1103 in self.success: + iter1103.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25168,10 +26119,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1093, _size1090) = iprot.readListBegin() - for _i1094 in xrange(_size1090): - _elem1095 = iprot.readString() - self.part_vals.append(_elem1095) + (_etype1107, _size1104) = iprot.readListBegin() + for _i1108 in xrange(_size1104): + _elem1109 = iprot.readString() + self.part_vals.append(_elem1109) iprot.readListEnd() else: iprot.skip(ftype) @@ -25201,8 +26152,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 iter1096 in self.part_vals: - oprot.writeString(iter1096) + for iter1110 in self.part_vals: + oprot.writeString(iter1110) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -25266,10 +26217,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1100, _size1097) = iprot.readListBegin() - for _i1101 in xrange(_size1097): - _elem1102 = iprot.readString() - self.success.append(_elem1102) + (_etype1114, _size1111) = iprot.readListBegin() + for _i1115 in xrange(_size1111): + _elem1116 = iprot.readString() + self.success.append(_elem1116) iprot.readListEnd() else: iprot.skip(ftype) @@ -25298,8 +26249,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 iter1103 in self.success: - oprot.writeString(iter1103) + for iter1117 in self.success: + oprot.writeString(iter1117) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25470,11 +26421,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1107, _size1104) = iprot.readListBegin() - for _i1108 in xrange(_size1104): - _elem1109 = Partition() - _elem1109.read(iprot) - self.success.append(_elem1109) + (_etype1121, _size1118) = iprot.readListBegin() + for _i1122 in xrange(_size1118): + _elem1123 = Partition() + _elem1123.read(iprot) + self.success.append(_elem1123) iprot.readListEnd() else: iprot.skip(ftype) @@ -25503,8 +26454,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 iter1110 in self.success: - iter1110.write(oprot) + for iter1124 in self.success: + iter1124.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -25675,11 +26626,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1114, _size1111) = iprot.readListBegin() - for _i1115 in xrange(_size1111): - _elem1116 = PartitionSpec() - _elem1116.read(iprot) - self.success.append(_elem1116) + (_etype1128, _size1125) = iprot.readListBegin() + for _i1129 in xrange(_size1125): + _elem1130 = PartitionSpec() + _elem1130.read(iprot) + self.success.append(_elem1130) iprot.readListEnd() else: iprot.skip(ftype) @@ -25708,8 +26659,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 iter1117 in self.success: - iter1117.write(oprot) + for iter1131 in self.success: + iter1131.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26129,10 +27080,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype1121, _size1118) = iprot.readListBegin() - for _i1122 in xrange(_size1118): - _elem1123 = iprot.readString() - self.names.append(_elem1123) + (_etype1135, _size1132) = iprot.readListBegin() + for _i1136 in xrange(_size1132): + _elem1137 = iprot.readString() + self.names.append(_elem1137) iprot.readListEnd() else: iprot.skip(ftype) @@ -26157,8 +27108,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 iter1124 in self.names: - oprot.writeString(iter1124) + for iter1138 in self.names: + oprot.writeString(iter1138) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -26217,11 +27168,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1128, _size1125) = iprot.readListBegin() - for _i1129 in xrange(_size1125): - _elem1130 = Partition() - _elem1130.read(iprot) - self.success.append(_elem1130) + (_etype1142, _size1139) = iprot.readListBegin() + for _i1143 in xrange(_size1139): + _elem1144 = Partition() + _elem1144.read(iprot) + self.success.append(_elem1144) iprot.readListEnd() else: iprot.skip(ftype) @@ -26250,8 +27201,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 iter1131 in self.success: - iter1131.write(oprot) + for iter1145 in self.success: + iter1145.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26501,11 +27452,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1135, _size1132) = iprot.readListBegin() - for _i1136 in xrange(_size1132): - _elem1137 = Partition() - _elem1137.read(iprot) - self.new_parts.append(_elem1137) + (_etype1149, _size1146) = iprot.readListBegin() + for _i1150 in xrange(_size1146): + _elem1151 = Partition() + _elem1151.read(iprot) + self.new_parts.append(_elem1151) iprot.readListEnd() else: iprot.skip(ftype) @@ -26530,8 +27481,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 iter1138 in self.new_parts: - iter1138.write(oprot) + for iter1152 in self.new_parts: + iter1152.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -26684,11 +27635,11 @@ class alter_partitions_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1142, _size1139) = iprot.readListBegin() - for _i1143 in xrange(_size1139): - _elem1144 = Partition() -
<TRUNCATED>
