http://git-wip-us.apache.org/repos/asf/hive/blob/b3cb8526/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 808ee09..1e4c4fd 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 @@ -1412,6 +1412,111 @@ class Iface(fb303.FacebookService.Iface): """ pass + def create_ischema(self, schema): + """ + Parameters: + - schema + """ + pass + + def alter_ischema(self, schemaName, newSchema): + """ + Parameters: + - schemaName + - newSchema + """ + pass + + def get_ischema(self, schemaName): + """ + Parameters: + - schemaName + """ + pass + + def drop_ischema(self, schemaName): + """ + Parameters: + - schemaName + """ + pass + + def add_schema_version(self, schemaVersion): + """ + Parameters: + - schemaVersion + """ + pass + + def get_schema_version(self, schemaName, version): + """ + Parameters: + - schemaName + - version + """ + 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, schemaName, version): + """ + Parameters: + - schemaName + - version + """ + pass + + def get_schemas_by_cols(self, rqst): + """ + Parameters: + - rqst + """ + pass + + def map_schema_version_to_serde(self, schemaName, version, serdeName): + """ + Parameters: + - schemaName + - version + - serdeName + """ + pass + + def set_schema_version_state(self, schemaName, version, state): + """ + Parameters: + - schemaName + - version + - state + """ + pass + + def add_serde(self, serde): + """ + Parameters: + - serde + """ + pass + + def get_serde(self, serdeName): + """ + Parameters: + - serdeName + """ + pass + class Client(fb303.FacebookService.Client, Iface): """ @@ -7871,6 +7976,500 @@ 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, schemaName, newSchema): + """ + Parameters: + - schemaName + - newSchema + """ + self.send_alter_ischema(schemaName, newSchema) + self.recv_alter_ischema() + + def send_alter_ischema(self, schemaName, newSchema): + self._oprot.writeMessageBegin('alter_ischema', TMessageType.CALL, self._seqid) + args = alter_ischema_args() + args.schemaName = schemaName + args.newSchema = newSchema + 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, schemaName): + """ + Parameters: + - schemaName + """ + self.send_get_ischema(schemaName) + return self.recv_get_ischema() + + def send_get_ischema(self, schemaName): + self._oprot.writeMessageBegin('get_ischema', TMessageType.CALL, self._seqid) + args = get_ischema_args() + args.schemaName = schemaName + 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, schemaName): + """ + Parameters: + - schemaName + """ + self.send_drop_ischema(schemaName) + self.recv_drop_ischema() + + def send_drop_ischema(self, schemaName): + self._oprot.writeMessageBegin('drop_ischema', TMessageType.CALL, self._seqid) + args = drop_ischema_args() + args.schemaName = schemaName + 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, schemaName, version): + """ + Parameters: + - schemaName + - version + """ + self.send_get_schema_version(schemaName, version) + return self.recv_get_schema_version() + + def send_get_schema_version(self, schemaName, version): + self._oprot.writeMessageBegin('get_schema_version', TMessageType.CALL, self._seqid) + args = get_schema_version_args() + args.schemaName = schemaName + args.version = version + 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, schemaName, version): + """ + Parameters: + - schemaName + - version + """ + self.send_drop_schema_version(schemaName, version) + self.recv_drop_schema_version() + + def send_drop_schema_version(self, schemaName, version): + self._oprot.writeMessageBegin('drop_schema_version', TMessageType.CALL, self._seqid) + args = drop_schema_version_args() + args.schemaName = schemaName + args.version = version + 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, schemaName, version, serdeName): + """ + Parameters: + - schemaName + - version + - serdeName + """ + self.send_map_schema_version_to_serde(schemaName, version, serdeName) + self.recv_map_schema_version_to_serde() + + def send_map_schema_version_to_serde(self, schemaName, version, serdeName): + self._oprot.writeMessageBegin('map_schema_version_to_serde', TMessageType.CALL, self._seqid) + args = map_schema_version_to_serde_args() + args.schemaName = schemaName + args.version = version + args.serdeName = serdeName + 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, schemaName, version, state): + """ + Parameters: + - schemaName + - version + - state + """ + self.send_set_schema_version_state(schemaName, version, state) + self.recv_set_schema_version_state() + + def send_set_schema_version_state(self, schemaName, version, state): + self._oprot.writeMessageBegin('set_schema_version_state', TMessageType.CALL, self._seqid) + args = set_schema_version_state_args() + args.schemaName = schemaName + args.version = version + args.state = state + 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, serdeName): + """ + Parameters: + - serdeName + """ + self.send_get_serde(serdeName) + return self.recv_get_serde() + + def send_get_serde(self, serdeName): + self._oprot.writeMessageBegin('get_serde', TMessageType.CALL, self._seqid) + args = get_serde_args() + args.serdeName = serdeName + 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): @@ -8054,6 +8653,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() @@ -12485,6 +13098,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.schemaName, args.newSchema) + 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.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_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.schemaName) + 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.schemaName, args.version) + 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.schemaName, args.version) + 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.schemaName, args.version, args.serdeName) + 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.schemaName, args.version, args.state) + 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.serdeName) + 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 @@ -13371,10 +14343,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype702, _size699) = iprot.readListBegin() - for _i703 in xrange(_size699): - _elem704 = iprot.readString() - self.success.append(_elem704) + (_etype716, _size713) = iprot.readListBegin() + for _i717 in xrange(_size713): + _elem718 = iprot.readString() + self.success.append(_elem718) iprot.readListEnd() else: iprot.skip(ftype) @@ -13397,8 +14369,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 iter705 in self.success: - oprot.writeString(iter705) + for iter719 in self.success: + oprot.writeString(iter719) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13503,10 +14475,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype709, _size706) = iprot.readListBegin() - for _i710 in xrange(_size706): - _elem711 = iprot.readString() - self.success.append(_elem711) + (_etype723, _size720) = iprot.readListBegin() + for _i724 in xrange(_size720): + _elem725 = iprot.readString() + self.success.append(_elem725) iprot.readListEnd() else: iprot.skip(ftype) @@ -13529,8 +14501,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 iter712 in self.success: - oprot.writeString(iter712) + for iter726 in self.success: + oprot.writeString(iter726) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14300,12 +15272,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype714, _vtype715, _size713 ) = iprot.readMapBegin() - for _i717 in xrange(_size713): - _key718 = iprot.readString() - _val719 = Type() - _val719.read(iprot) - self.success[_key718] = _val719 + (_ktype728, _vtype729, _size727 ) = iprot.readMapBegin() + for _i731 in xrange(_size727): + _key732 = iprot.readString() + _val733 = Type() + _val733.read(iprot) + self.success[_key732] = _val733 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14328,9 +15300,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 kiter720,viter721 in self.success.items(): - oprot.writeString(kiter720) - viter721.write(oprot) + for kiter734,viter735 in self.success.items(): + oprot.writeString(kiter734) + viter735.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -14473,11 +15445,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype725, _size722) = iprot.readListBegin() - for _i726 in xrange(_size722): - _elem727 = FieldSchema() - _elem727.read(iprot) - self.success.append(_elem727) + (_etype739, _size736) = iprot.readListBegin() + for _i740 in xrange(_size736): + _elem741 = FieldSchema() + _elem741.read(iprot) + self.success.append(_elem741) iprot.readListEnd() else: iprot.skip(ftype) @@ -14512,8 +15484,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 iter728 in self.success: - iter728.write(oprot) + for iter742 in self.success: + iter742.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14680,11 +15652,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype732, _size729) = iprot.readListBegin() - for _i733 in xrange(_size729): - _elem734 = FieldSchema() - _elem734.read(iprot) - self.success.append(_elem734) + (_etype746, _size743) = iprot.readListBegin() + for _i747 in xrange(_size743): + _elem748 = FieldSchema() + _elem748.read(iprot) + self.success.append(_elem748) iprot.readListEnd() else: iprot.skip(ftype) @@ -14719,8 +15691,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 iter735 in self.success: - iter735.write(oprot) + for iter749 in self.success: + iter749.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14873,11 +15845,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype739, _size736) = iprot.readListBegin() - for _i740 in xrange(_size736): - _elem741 = FieldSchema() - _elem741.read(iprot) - self.success.append(_elem741) + (_etype753, _size750) = iprot.readListBegin() + for _i754 in xrange(_size750): + _elem755 = FieldSchema() + _elem755.read(iprot) + self.success.append(_elem755) iprot.readListEnd() else: iprot.skip(ftype) @@ -14912,8 +15884,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 iter742 in self.success: - iter742.write(oprot) + for iter756 in self.success: + iter756.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15080,11 +16052,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype746, _size743) = iprot.readListBegin() - for _i747 in xrange(_size743): - _elem748 = FieldSchema() - _elem748.read(iprot) - self.success.append(_elem748) + (_etype760, _size757) = iprot.readListBegin() + for _i761 in xrange(_size757): + _elem762 = FieldSchema() + _elem762.read(iprot) + self.success.append(_elem762) iprot.readListEnd() else: iprot.skip(ftype) @@ -15119,8 +16091,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 iter749 in self.success: - iter749.write(oprot) + for iter763 in self.success: + iter763.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15567,44 +16539,44 @@ class create_table_with_constraints_args: elif fid == 2: if ftype == TType.LIST: self.primaryKeys = [] - (_etype753, _size750) = iprot.readListBegin() - for _i754 in xrange(_size750): - _elem755 = SQLPrimaryKey() - _elem755.read(iprot) - self.primaryKeys.append(_elem755) + (_etype767, _size764) = iprot.readListBegin() + for _i768 in xrange(_size764): + _elem769 = SQLPrimaryKey() + _elem769.read(iprot) + self.primaryKeys.append(_elem769) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 3: if ftype == TType.LIST: self.foreignKeys = [] - (_etype759, _size756) = iprot.readListBegin() - for _i760 in xrange(_size756): - _elem761 = SQLForeignKey() - _elem761.read(iprot) - self.foreignKeys.append(_elem761) + (_etype773, _size770) = iprot.readListBegin() + for _i774 in xrange(_size770): + _elem775 = SQLForeignKey() + _elem775.read(iprot) + self.foreignKeys.append(_elem775) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 4: if ftype == TType.LIST: self.uniqueConstraints = [] - (_etype765, _size762) = iprot.readListBegin() - for _i766 in xrange(_size762): - _elem767 = SQLUniqueConstraint() - _elem767.read(iprot) - self.uniqueConstraints.append(_elem767) + (_etype779, _size776) = iprot.readListBegin() + for _i780 in xrange(_size776): + _elem781 = SQLUniqueConstraint() + _elem781.read(iprot) + self.uniqueConstraints.append(_elem781) iprot.readListEnd() else: iprot.skip(ftype) elif fid == 5: if ftype == TType.LIST: self.notNullConstraints = [] - (_etype771, _size768) = iprot.readListBegin() - for _i772 in xrange(_size768): - _elem773 = SQLNotNullConstraint() - _elem773.read(iprot) - self.notNullConstraints.append(_elem773) + (_etype785, _size782) = iprot.readListBegin() + for _i786 in xrange(_size782): + _elem787 = SQLNotNullConstraint() + _elem787.read(iprot) + self.notNullConstraints.append(_elem787) iprot.readListEnd() else: iprot.skip(ftype) @@ -15625,29 +16597,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 iter774 in self.primaryKeys: - iter774.write(oprot) + for iter788 in self.primaryKeys: + iter788.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 iter775 in self.foreignKeys: - iter775.write(oprot) + for iter789 in self.foreignKeys: + iter789.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 iter776 in self.uniqueConstraints: - iter776.write(oprot) + for iter790 in self.uniqueConstraints: + iter790.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 iter777 in self.notNullConstraints: - iter777.write(oprot) + for iter791 in self.notNullConstraints: + iter791.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16913,10 +17885,10 @@ class truncate_table_args: elif fid == 3: if ftype == TType.LIST: self.partNames = [] - (_etype781, _size778) = iprot.readListBegin() - for _i782 in xrange(_size778): - _elem783 = iprot.readString() - self.partNames.append(_elem783) + (_etype795, _size792) = iprot.readListBegin() + for _i796 in xrange(_size792): + _elem797 = iprot.readString() + self.partNames.append(_elem797) iprot.readListEnd() else: iprot.skip(ftype) @@ -16941,8 +17913,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 iter784 in self.partNames: - oprot.writeString(iter784) + for iter798 in self.partNames: + oprot.writeString(iter798) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17142,10 +18114,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype788, _size785) = iprot.readListBegin() - for _i789 in xrange(_size785): - _elem790 = iprot.readString() - self.success.append(_elem790) + (_etype802, _size799) = iprot.readListBegin() + for _i803 in xrange(_size799): + _elem804 = iprot.readString() + self.success.append(_elem804) iprot.readListEnd() else: iprot.skip(ftype) @@ -17168,8 +18140,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 iter791 in self.success: - oprot.writeString(iter791) + for iter805 in self.success: + oprot.writeString(iter805) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17319,10 +18291,10 @@ class get_tables_by_type_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype795, _size792) = iprot.readListBegin() - for _i796 in xrange(_size792): - _elem797 = iprot.readString() - self.success.append(_elem797) + (_etype809, _size806) = iprot.readListBegin() + for _i810 in xrange(_size806): + _elem811 = iprot.readString() + self.success.append(_elem811) iprot.readListEnd() else: iprot.skip(ftype) @@ -17345,8 +18317,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 iter798 in self.success: - oprot.writeString(iter798) + for iter812 in self.success: + oprot.writeString(iter812) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17419,10 +18391,10 @@ class get_table_meta_args: elif fid == 3: if ftype == TType.LIST: self.tbl_types = [] - (_etype802, _size799) = iprot.readListBegin() - for _i803 in xrange(_size799): - _elem804 = iprot.readString() - self.tbl_types.append(_elem804) + (_etype816, _size813) = iprot.readListBegin() + for _i817 in xrange(_size813): + _elem818 = iprot.readString() + self.tbl_types.append(_elem818) iprot.readListEnd() else: iprot.skip(ftype) @@ -17447,8 +18419,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 iter805 in self.tbl_types: - oprot.writeString(iter805) + for iter819 in self.tbl_types: + oprot.writeString(iter819) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17504,11 +18476,11 @@ class get_table_meta_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype809, _size806) = iprot.readListBegin() - for _i810 in xrange(_size806): - _elem811 = TableMeta() - _elem811.read(iprot) - self.success.append(_elem811) + (_etype823, _size820) = iprot.readListBegin() + for _i824 in xrange(_size820): + _elem825 = TableMeta() + _elem825.read(iprot) + self.success.append(_elem825) iprot.readListEnd() else: iprot.skip(ftype) @@ -17531,8 +18503,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 iter812 in self.success: - iter812.write(oprot) + for iter826 in self.success: + iter826.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17656,10 +18628,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype816, _size813) = iprot.readListBegin() - for _i817 in xrange(_size813): - _elem818 = iprot.readString() - self.success.append(_elem818) + (_etype830, _size827) = iprot.readListBegin() + for _i831 in xrange(_size827): + _elem832 = iprot.readString() + self.success.append(_elem832) iprot.readListEnd() else: iprot.skip(ftype) @@ -17682,8 +18654,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 iter819 in self.success: - oprot.writeString(iter819) + for iter833 in self.success: + oprot.writeString(iter833) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17919,10 +18891,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype823, _size820) = iprot.readListBegin() - for _i824 in xrange(_size820): - _elem825 = iprot.readString() - self.tbl_names.append(_elem825) + (_etype837, _size834) = iprot.readListBegin() + for _i838 in xrange(_size834): + _elem839 = iprot.readString() + self.tbl_names.append(_elem839) iprot.readListEnd() else: iprot.skip(ftype) @@ -17943,8 +18915,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 iter826 in self.tbl_names: - oprot.writeString(iter826) + for iter840 in self.tbl_names: + oprot.writeString(iter840) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17996,11 +18968,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype830, _size827) = iprot.readListBegin() - for _i831 in xrange(_size827): - _elem832 = Table() - _elem832.read(iprot) - self.success.append(_elem832) + (_etype844, _size841) = iprot.readListBegin() + for _i845 in xrange(_size841): + _elem846 = Table() + _elem846.read(iprot) + self.success.append(_elem846) iprot.readListEnd() else: iprot.skip(ftype) @@ -18017,8 +18989,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 iter833 in self.success: - iter833.write(oprot) + for iter847 in self.success: + iter847.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18501,10 +19473,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype837, _size834) = iprot.readListBegin() - for _i838 in xrange(_size834): - _elem839 = iprot.readString() - self.success.append(_elem839) + (_etype851, _size848) = iprot.readListBegin() + for _i852 in xrange(_size848): + _elem853 = iprot.readString() + self.success.append(_elem853) iprot.readListEnd() else: iprot.skip(ftype) @@ -18539,8 +19511,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 iter840 in self.success: - oprot.writeString(iter840) + for iter854 in self.success: + oprot.writeString(iter854) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19510,11 +20482,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype844, _size841) = iprot.readListBegin() - for _i845 in xrange(_size841): - _elem846 = Partition() - _elem846.read(iprot) - self.new_parts.append(_elem846) + (_etype858, _size855) = iprot.readListBegin() + for _i859 in xrange(_size855): + _elem860 = Partition() + _elem860.read(iprot) + self.new_parts.append(_elem860) iprot.readListEnd() else: iprot.skip(ftype) @@ -19531,8 +20503,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 iter847 in self.new_parts: - iter847.write(oprot) + for iter861 in self.new_parts: + iter861.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19690,11 +20662,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype851, _size848) = iprot.readListBegin() - for _i852 in xrange(_size848): - _elem853 = PartitionSpec() - _elem853.read(iprot) - self.new_parts.append(_elem853) + (_etype865, _size862) = iprot.readListBegin() + for _i866 in xrange(_size862): + _elem867 = PartitionSpec() + _elem867.read(iprot) + self.new_parts.append(_elem867) iprot.readListEnd() else: iprot.skip(ftype) @@ -19711,8 +20683,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 iter854 in self.new_parts: - iter854.write(oprot) + for iter868 in self.new_parts: + iter868.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19886,10 +20858,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype858, _size855) = iprot.readListBegin() - for _i859 in xrange(_size855): - _elem860 = iprot.readString() - self.part_vals.append(_elem860) + (_etype872, _size869) = iprot.readListBegin() + for _i873 in xrange(_size869): + _elem874 = iprot.readString() + self.part_vals.append(_elem874) iprot.readListEnd() else: iprot.skip(ftype) @@ -19914,8 +20886,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 iter861 in self.part_vals: - oprot.writeString(iter861) + for iter875 in self.part_vals: + oprot.writeString(iter875) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20268,10 +21240,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype865, _size862) = iprot.readListBegin() - for _i866 in xrange(_size862): - _elem867 = iprot.readString() - self.part_vals.append(_elem867) + (_etype879, _size876) = iprot.readListBegin() + for _i880 in xrange(_size876): + _elem881 = iprot.readString() + self.part_vals.append(_elem881) iprot.readListEnd() else: iprot.skip(ftype) @@ -20302,8 +21274,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 iter868 in self.part_vals: - oprot.writeString(iter868) + for iter882 in self.part_vals: + oprot.writeString(iter882) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -20898,10 +21870,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype872, _size869) = iprot.readListBegin() - for _i873 in xrange(_size869): - _elem874 = iprot.readString() - self.part_vals.append(_elem874) + (_etype886, _size883) = iprot.readListBegin() + for _i887 in xrange(_size883): + _elem888 = iprot.readString() + self.part_vals.append(_elem888) iprot.readListEnd() else: iprot.skip(ftype) @@ -20931,8 +21903,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 iter875 in self.part_vals: - oprot.writeString(iter875) + for iter889 in self.part_vals: + oprot.writeString(iter889) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -21105,10 +22077,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype879, _size876) = iprot.readListBegin() - for _i880 in xrange(_size876): - _elem881 = iprot.readString() - self.part_vals.append(_elem881) + (_etype893, _size890) = iprot.readListBegin() + for _i894 in xrange(_size890): + _elem895 = iprot.readString() + self.part_vals.append(_elem895) iprot.readListEnd() else: iprot.skip(ftype) @@ -21144,8 +22116,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 iter882 in self.part_vals: - oprot.writeString(iter882) + for iter896 in self.part_vals: + oprot.writeString(iter896) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -21882,10 +22854,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype886, _size883) = iprot.readListBegin() - for _i887 in xrange(_size883): - _elem888 = iprot.readString() - self.part_vals.append(_elem888) + (_etype900, _size897) = iprot.readListBegin() + for _i901 in xrange(_size897): + _elem902 = iprot.readString() + self.part_vals.append(_elem902) iprot.readListEnd() else: iprot.skip(ftype) @@ -21910,8 +22882,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 iter889 in self.part_vals: - oprot.writeString(iter889) + for iter903 in self.part_vals: + oprot.writeString(iter903) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -22070,11 +23042,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype891, _vtype892, _size890 ) = iprot.readMapBegin() - for _i894 in xrange(_size890): - _key895 = iprot.readString() - _val896 = iprot.readString() - self.partitionSpecs[_key895] = _val896 + (_ktype905, _vtype906, _size904 ) = iprot.readMapBegin() + for _i908 in xrange(_size904): + _key909 = iprot.readString() + _val910 = iprot.readString() + self.partitionSpecs[_key909] = _val910 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22111,9 +23083,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 kiter897,viter898 in self.partitionSpecs.items(): - oprot.writeString(kiter897) - oprot.writeString(viter898) + for kiter911,viter912 in self.partitionSpecs.items(): + oprot.writeString(kiter911) + oprot.writeString(viter912) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -22318,11 +23290,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype900, _vtype901, _size899 ) = iprot.readMapBegin() - for _i903 in xrange(_size899): - _key904 = iprot.readString() - _val905 = iprot.readString() - self.partitionSpecs[_key904] = _val905 + (_ktype914, _vtype915, _size913 ) = iprot.readMapBegin() + for _i917 in xrange(_size913): + _key918 = iprot.readString() + _val919 = iprot.readString() + self.partitionSpecs[_key918] = _val919 iprot.readMapEnd() else: iprot.skip(ftype) @@ -22359,9 +23331,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 kiter906,viter907 in self.partitionSpecs.items(): - oprot.writeString(kiter906) - oprot.writeString(viter907) + for kiter920,viter921 in self.partitionSpecs.items(): + oprot.writeString(kiter920) + oprot.writeString(viter921) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -22444,11 +23416,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype911, _size908) = iprot.readListBegin() - for _i912 in xrange(_size908): - _elem913 = Partition() - _elem913.read(iprot) - self.success.append(_elem913) + (_etype925, _size922) = iprot.readListBegin() + for _i926 in xrange(_size922): + _elem927 = Partition() + _elem927.read(iprot) + self.success.append(_elem927) iprot.readListEnd() else: iprot.skip(ftype) @@ -22489,8 +23461,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 iter914 in self.success: - iter914.write(oprot) + for iter928 in self.success: + iter928.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22584,10 +23556,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype918, _size915) = iprot.readListBegin() - for _i919 in xrange(_size915): - _elem920 = iprot.readString() - self.part_vals.append(_elem920) + (_etype932, _size929) = iprot.readListBegin() + for _i933 in xrange(_size929): + _elem934 = iprot.readString() + self.part_vals.append(_elem934) iprot.readListEnd() else: iprot.skip(ftype) @@ -22599,10 +23571,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype924, _size921) = iprot.readListBegin() - for _i925 in xrange(_size921): - _elem926 = iprot.readString() - self.group_names.append(_elem926) + (_etype938, _size935) = iprot.readListBegin() + for _i939 in xrange(_size935): + _elem940 = iprot.readString() + self.group_names.append(_elem940) iprot.readListEnd() else: iprot.skip(ftype) @@ -22627,8 +23599,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 iter927 in self.part_vals: - oprot.writeString(iter927) + for iter941 in self.part_vals: + oprot.writeString(iter941) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -22638,8 +23610,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 iter928 in self.group_names: - oprot.writeString(iter928) + for iter942 in self.group_names: + oprot.writeString(iter942) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23068,11 +24040,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype932, _size929) = iprot.readListBegin() - for _i933 in xrange(_size929): - _elem934 = Partition() - _elem934.read(iprot) - self.success.append(_elem934) + (_etype946, _size943) = iprot.readListBegin() + for _i947 in xrange(_size943): + _elem948 = Partition() + _elem948.read(iprot) + self.success.append(_elem948) iprot.readListEnd() else: iprot.skip(ftype) @@ -23101,8 +24073,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 iter935 in self.success: - iter935.write(oprot) + for iter949 in self.success: + iter949.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23196,10 +24168,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype939, _size936) = iprot.readListBegin() - for _i940 in xrange(_size936): - _elem941 = iprot.readString() - self.group_names.append(_elem941) + (_etype953, _size950) = iprot.readListBegin() + for _i954 in xrange(_size950): + _elem955 = iprot.readString() + self.group_names.append(_elem955) iprot.readListEnd() else: iprot.skip(ftype) @@ -23232,8 +24204,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 iter942 in self.group_names: - oprot.writeString(iter942) + for iter956 in self.group_names: + oprot.writeString(iter956) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23294,11 +24266,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype946, _size943) = iprot.readListBegin() - for _i947 in xrange(_size943): - _elem948 = Partition() - _elem948.read(iprot) - self.success.append(_elem948) + (_etype960, _size957) = iprot.readListBegin() + for _i961 in xrange(_size957): + _elem962 = Partition() + _elem962.read(iprot) + self.success.append(_elem962) iprot.readListEnd() else: iprot.skip(ftype) @@ -23327,8 +24299,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 iter949 in self.success: - iter949.write(oprot) + for iter963 in self.success: + iter963.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23486,11 +24458,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype953, _size950) = iprot.readListBegin() - for _i954 in xrange(_size950): - _elem955 = PartitionSpec() - _elem955.read(iprot) - self.success.append(_elem955) + (_etype967, _size964) = iprot.readListBegin() + for _i968 in xrange(_size964): + _elem969 = PartitionSpec() + _elem969.read(iprot) + self.success.append(_elem969) iprot.readListEnd() else: iprot.skip(ftype) @@ -23519,8 +24491,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 iter956 in self.success: - iter956.write(oprot) + for iter970 in self.success: + iter970.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23678,10 +24650,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype960, _size957) = iprot.readListBegin() - for _i961 in xrange(_size957): - _elem962 = iprot.readString() - self.success.append(_elem962) + (_etype974, _size971) = iprot.readListBegin() + for _i975 in xrange(_size971): + _elem976 = iprot.readString() + self.success.append(_elem976) iprot.readListEnd() else: iprot.skip(ftype) @@ -23710,8 +24682,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 iter963 in self.success: - oprot.writeString(iter963) + for iter977 in self.success: + oprot.writeString(iter977) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23951,10 +24923,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype967, _size964) = iprot.readListBegin() - for _i968 in xrange(_size964): - _elem969 = iprot.readString() - self.part_vals.append(_elem969) + (_etype981, _size978) = iprot.readListBegin() + for _i982 in xrange(_size978): + _elem983 = iprot.readString() + self.part_vals.append(_elem983) iprot.readListEnd() else: iprot.skip(ftype) @@ -23984,8 +24956,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 iter970 in self.part_vals: - oprot.writeString(iter970) + for iter984 in self.part_vals: + oprot.writeString(iter984) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24049,11 +25021,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype974, _size971) = iprot.readListBegin() - for _i975 in xrange(_size971): - _elem976 = Partition() - _elem976.read(iprot) - self.success.append(_elem976) + (_etype988, _size985) = iprot.readListBegin() + for _i989 in xrange(_size985): + _elem990 = Partition() + _elem990.read(iprot) + self.success.append(_elem990) iprot.readListEnd() else: iprot.skip(ftype) @@ -24082,8 +25054,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 iter977 in self.success: - iter977.write(oprot) + for iter991 in self.success: + iter991.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24170,10 +25142,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype981, _size978) = iprot.readListBegin() - for _i982 in xrange(_size978): - _elem983 = iprot.readString() - self.part_vals.append(_elem983) + (_etype995, _size992) = iprot.readListBegin() + for _i996 in xrange(_size992): + _elem997 = iprot.readString() + self.part_vals.append(_elem997) iprot.readListEnd() else: iprot.skip(ftype) @@ -24190,10 +25162,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype987, _size984) = iprot.readListBegin() - for _i988 in xrange(_size984): - _elem989 = iprot.readString() - self.group_names.append(_elem989) + (_etype1001, _size998) = iprot.readListBegin() + for _i1002 in xrange(_size998): + _elem1003 = iprot.readString() + self.group_names.append(_elem1003) iprot.readListEnd() else: iprot.skip(ftype) @@ -24218,8 +25190,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 iter990 in self.part_vals: - oprot.writeString(iter990) + for iter1004 in self.part_vals: + oprot.writeString(iter1004) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24233,8 +25205,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 iter991 in self.group_names: - oprot.writeString(iter991) + for iter1005 in self.group_names: + oprot.writeString(iter1005) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24296,11 +25268,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype995, _size992) = iprot.readListBegin() - for _i996 in xrange(_size992): - _elem997 = Partition() - _elem997.read(iprot) - self.success.append(_elem997) + (_etype1009, _size1006) = iprot.readListBegin() + for _i1010 in xrange(_size1006): + _elem1011 = Partition() + _elem1011.read(iprot) + self.success.append(_elem1011) iprot.readListEnd() else: iprot.skip(ftype) @@ -24329,8 +25301,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 iter998 in self.success: - iter998.write(oprot) + for iter1012 in self.success: + iter1012.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24411,10 +25383,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype1002, _size999) = iprot.readListBegin() - for _i1003 in xrange(_size999): - _elem1004 = iprot.readString() - self.part_vals.append(_elem1004) + (_etype1016, _size1013) = iprot.readListBegin() + for _i1017 in xrange(_size1013): + _elem1018 = iprot.readString() + self.part_vals.append(_elem1018) iprot.readListEnd() else: iprot.skip(ftype) @@ -24444,8 +25416,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 iter1005 in self.part_vals: - oprot.writeString(iter1005) + for iter1019 in self.part_vals: + oprot.writeString(iter1019) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -24509,10 +25481,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1009, _size1006) = iprot.readListBegin() - for _i1010 in xrange(_size1006): - _elem1011 = iprot.readString() - self.success.append(_elem1011) + (_etype1023, _size1020) = iprot.readListBegin() + for _i1024 in xrange(_size1020): + _elem1025 = iprot.readString() + self.success.append(_elem1025) iprot.readListEnd() else: iprot.skip(ftype) @@ -24541,8 +25513,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 iter1012 in self.success: - oprot.writeString(iter1012) + for iter1026 in self.success: + oprot.writeString(iter1026) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24713,11 +25685,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1016, _size1013) = iprot.readListBegin() - for _i1017 in xrange(_size1013): - _elem1018 = Partition() - _elem1018.read(iprot) - self.success.append(_elem1018) + (_etype1030, _size1027) = iprot.readListBegin() + for _i1031 in xrange(_size1027): + _elem1032 = Partition() + _elem1032.read(iprot) + self.success.append(_elem1032) iprot.readListEnd() else: iprot.skip(ftype) @@ -24746,8 +25718,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 iter1019 in self.success: - iter1019.write(oprot) + for iter1033 in self.success: + iter1033.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24918,11 +25890,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1023, _size1020) = iprot.readListBegin() - for _i1024 in xrange(_size1020): - _elem1025 = PartitionSpec() - _elem1025.read(iprot) - self.success.append(_elem1025) + (_etype1037, _size1034) = iprot.readListBegin() + for _i1038 in xrange(_size1034): + _elem1039 = PartitionSpec() + _elem1039.read(iprot) + self.success.append(_elem1039) iprot.readListEnd() else: iprot.skip(ftype) @@ -24951,8 +25923,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 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: @@ -25372,10 +26344,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype1030, _size1027) = iprot.readListBegin() - for _i1031 in xrange(_size1027): - _elem1032 = iprot.readString() - self.names.append(_elem1032) + (_etype1044, _size1041) = iprot.readListBegin() + for _i1045 in xrange(_size1041): + _elem1046 = iprot.readString() + self.names.append(_elem1046) iprot.readListEnd() else: iprot.skip(ftype) @@ -25400,8 +26372,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 iter1033 in self.names: - oprot.writeString(iter1033) + for iter1047 in self.names: + oprot.writeString(iter1047) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25460,11 +26432,11 @@ class get_partitions_by_names_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) @@ -25493,8 +26465,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 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: @@ -25744,11 +26716,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1044, _size1041) = iprot.readListBegin() - for _i1045 in xrange(_size1041): - _elem1046 = Partition() - _elem1046.read(iprot) - self.new_parts.append(_elem1046) + (_etype1058, _size1055) = iprot.readListBegin() + for _i1059 in xrange(_size1055): + _elem1060 = Partition() + _elem1060.read(iprot) + self.new_parts.append(_elem1060) iprot.readListEnd() else: iprot.skip(ftype) @@ -25773,8 +26745,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 iter1047 in self.new_parts: - iter1047.write(oprot) + for iter1061 in self.new_parts: + iter1061.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -25927,11 +26899,11 @@ class alter_partitions_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype1051, _size1048) = iprot.readListBegin() - for _i1052 in xrange(_size1048): - _elem1053 = Partition() - _elem1053.read(iprot) - self.new_parts.append(_elem1053) + (_etype1065, _size1062) = iprot.readListBegin() + for _i1066 in xrange(_size1062): + _elem1067 = Partition() + _elem1067.read(iprot) + self.new_parts.append(_elem1067) iprot.readListEnd() else: iprot.skip(ftype) @@ -25962,8 +26934,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 iter1054 in self.new_parts: - iter1054.write(oprot) + for iter1068 in self.new_parts: + iter1068.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -26307,10 +27279,10 @@ class rename_partition_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) @@ -26341,8 +27313,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 iter1061 in self.part_vals: - oprot.writeString(iter1061) + for iter1075 in self.part_vals: + oprot.writeString(iter1075) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -26484,10 +27456,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype1065, _size1062) = iprot.readListBegin() - for _i1066 in xrange(_size1062): - _elem1067 = iprot.readString() - self.part_vals.append(_elem1067) + (_etype1079, _size1076) = iprot.readListBegin() + for _i1080 in xrange(_size1076): + _elem1081 = iprot.readString() + self.part_vals.append(_elem1081) iprot.readListEnd() else: iprot.skip(ftype) @@ -26509,8 +27481,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 iter1068 in self.part_vals: - oprot.writeString(iter1068) + for iter1082 in self.part_vals: + oprot.writeString(iter1082) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -26868,10 +27840,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype1072, _size1069) = iprot.readListBegin() - for _i1073 in xrange(_size1069): - _elem1074 = iprot.readString() - self.success.append(_elem1074) + (_etype1086, _size1083) = iprot.readListBegin() + for _i1087 in xrange(_size1083): + _elem1088 = iprot.readString() + self.success.append(_elem1088) iprot.readListEnd() else: iprot.skip(ftype) @@ -26894,8 +27866,8 @@ class partition_name_to_vals_result: if self.
<TRUNCATED>
