You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ga...@apache.org on 2017/11/21 23:57:23 UTC
[40/51] [abbrv] hive git commit: HIVE-17990 Add Thrift and DB storage
for Schema Registry objects
http://git-wip-us.apache.org/repos/asf/hive/blob/077d498d/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 0351cd8..b6fea0a 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
@@ -1370,6 +1370,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):
"""
@@ -7599,6 +7704,500 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_triggers_for_resourceplan 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):
@@ -7776,6 +8375,20 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["alter_wm_trigger"] = Processor.process_alter_wm_trigger
self._processMap["drop_wm_trigger"] = Processor.process_drop_wm_trigger
self._processMap["get_triggers_for_resourceplan"] = Processor.process_get_triggers_for_resourceplan
+ 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()
@@ -12027,6 +12640,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
@@ -12913,10 +13885,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype695, _size692) = iprot.readListBegin()
- for _i696 in xrange(_size692):
- _elem697 = iprot.readString()
- self.success.append(_elem697)
+ (_etype709, _size706) = iprot.readListBegin()
+ for _i710 in xrange(_size706):
+ _elem711 = iprot.readString()
+ self.success.append(_elem711)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12939,8 +13911,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 iter698 in self.success:
- oprot.writeString(iter698)
+ for iter712 in self.success:
+ oprot.writeString(iter712)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13045,10 +14017,10 @@ class get_all_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)
@@ -13071,8 +14043,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 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:
@@ -13842,12 +14814,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype707, _vtype708, _size706 ) = iprot.readMapBegin()
- for _i710 in xrange(_size706):
- _key711 = iprot.readString()
- _val712 = Type()
- _val712.read(iprot)
- self.success[_key711] = _val712
+ (_ktype721, _vtype722, _size720 ) = iprot.readMapBegin()
+ for _i724 in xrange(_size720):
+ _key725 = iprot.readString()
+ _val726 = Type()
+ _val726.read(iprot)
+ self.success[_key725] = _val726
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13870,9 +14842,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 kiter713,viter714 in self.success.items():
- oprot.writeString(kiter713)
- viter714.write(oprot)
+ for kiter727,viter728 in self.success.items():
+ oprot.writeString(kiter727)
+ viter728.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -14015,11 +14987,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = FieldSchema()
- _elem720.read(iprot)
- self.success.append(_elem720)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = FieldSchema()
+ _elem734.read(iprot)
+ self.success.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14054,8 +15026,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 iter721 in self.success:
- iter721.write(oprot)
+ for iter735 in self.success:
+ iter735.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14222,11 +15194,11 @@ class get_fields_with_environment_context_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)
@@ -14261,8 +15233,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 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:
@@ -14415,11 +15387,11 @@ class get_schema_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)
@@ -14454,8 +15426,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 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:
@@ -14622,11 +15594,11 @@ class get_schema_with_environment_context_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)
@@ -14661,8 +15633,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 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:
@@ -15109,44 +16081,44 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = SQLPrimaryKey()
- _elem748.read(iprot)
- self.primaryKeys.append(_elem748)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = SQLPrimaryKey()
+ _elem762.read(iprot)
+ self.primaryKeys.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype752, _size749) = iprot.readListBegin()
- for _i753 in xrange(_size749):
- _elem754 = SQLForeignKey()
- _elem754.read(iprot)
- self.foreignKeys.append(_elem754)
+ (_etype766, _size763) = iprot.readListBegin()
+ for _i767 in xrange(_size763):
+ _elem768 = SQLForeignKey()
+ _elem768.read(iprot)
+ self.foreignKeys.append(_elem768)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype758, _size755) = iprot.readListBegin()
- for _i759 in xrange(_size755):
- _elem760 = SQLUniqueConstraint()
- _elem760.read(iprot)
- self.uniqueConstraints.append(_elem760)
+ (_etype772, _size769) = iprot.readListBegin()
+ for _i773 in xrange(_size769):
+ _elem774 = SQLUniqueConstraint()
+ _elem774.read(iprot)
+ self.uniqueConstraints.append(_elem774)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype764, _size761) = iprot.readListBegin()
- for _i765 in xrange(_size761):
- _elem766 = SQLNotNullConstraint()
- _elem766.read(iprot)
- self.notNullConstraints.append(_elem766)
+ (_etype778, _size775) = iprot.readListBegin()
+ for _i779 in xrange(_size775):
+ _elem780 = SQLNotNullConstraint()
+ _elem780.read(iprot)
+ self.notNullConstraints.append(_elem780)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15167,29 +16139,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 iter767 in self.primaryKeys:
- iter767.write(oprot)
+ for iter781 in self.primaryKeys:
+ iter781.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 iter768 in self.foreignKeys:
- iter768.write(oprot)
+ for iter782 in self.foreignKeys:
+ iter782.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 iter769 in self.uniqueConstraints:
- iter769.write(oprot)
+ for iter783 in self.uniqueConstraints:
+ iter783.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 iter770 in self.notNullConstraints:
- iter770.write(oprot)
+ for iter784 in self.notNullConstraints:
+ iter784.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16455,10 +17427,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype774, _size771) = iprot.readListBegin()
- for _i775 in xrange(_size771):
- _elem776 = iprot.readString()
- self.partNames.append(_elem776)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = iprot.readString()
+ self.partNames.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16483,8 +17455,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 iter777 in self.partNames:
- oprot.writeString(iter777)
+ for iter791 in self.partNames:
+ oprot.writeString(iter791)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16684,10 +17656,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype781, _size778) = iprot.readListBegin()
- for _i782 in xrange(_size778):
- _elem783 = iprot.readString()
- self.success.append(_elem783)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = iprot.readString()
+ self.success.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16710,8 +17682,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 iter784 in self.success:
- oprot.writeString(iter784)
+ for iter798 in self.success:
+ oprot.writeString(iter798)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16861,10 +17833,10 @@ class get_tables_by_type_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)
@@ -16887,8 +17859,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 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:
@@ -16961,10 +17933,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype795, _size792) = iprot.readListBegin()
- for _i796 in xrange(_size792):
- _elem797 = iprot.readString()
- self.tbl_types.append(_elem797)
+ (_etype809, _size806) = iprot.readListBegin()
+ for _i810 in xrange(_size806):
+ _elem811 = iprot.readString()
+ self.tbl_types.append(_elem811)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16989,8 +17961,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 iter798 in self.tbl_types:
- oprot.writeString(iter798)
+ for iter812 in self.tbl_types:
+ oprot.writeString(iter812)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17046,11 +18018,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = TableMeta()
- _elem804.read(iprot)
- self.success.append(_elem804)
+ (_etype816, _size813) = iprot.readListBegin()
+ for _i817 in xrange(_size813):
+ _elem818 = TableMeta()
+ _elem818.read(iprot)
+ self.success.append(_elem818)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17073,8 +18045,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 iter805 in self.success:
- iter805.write(oprot)
+ for iter819 in self.success:
+ iter819.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17198,10 +18170,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = iprot.readString()
- self.success.append(_elem811)
+ (_etype823, _size820) = iprot.readListBegin()
+ for _i824 in xrange(_size820):
+ _elem825 = iprot.readString()
+ self.success.append(_elem825)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17224,8 +18196,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 iter812 in self.success:
- oprot.writeString(iter812)
+ for iter826 in self.success:
+ oprot.writeString(iter826)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17461,10 +18433,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = iprot.readString()
- self.tbl_names.append(_elem818)
+ (_etype830, _size827) = iprot.readListBegin()
+ for _i831 in xrange(_size827):
+ _elem832 = iprot.readString()
+ self.tbl_names.append(_elem832)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17485,8 +18457,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 iter819 in self.tbl_names:
- oprot.writeString(iter819)
+ for iter833 in self.tbl_names:
+ oprot.writeString(iter833)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17538,11 +18510,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = Table()
- _elem825.read(iprot)
- self.success.append(_elem825)
+ (_etype837, _size834) = iprot.readListBegin()
+ for _i838 in xrange(_size834):
+ _elem839 = Table()
+ _elem839.read(iprot)
+ self.success.append(_elem839)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17559,8 +18531,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 iter826 in self.success:
- iter826.write(oprot)
+ for iter840 in self.success:
+ iter840.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18043,10 +19015,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype830, _size827) = iprot.readListBegin()
- for _i831 in xrange(_size827):
- _elem832 = iprot.readString()
- self.success.append(_elem832)
+ (_etype844, _size841) = iprot.readListBegin()
+ for _i845 in xrange(_size841):
+ _elem846 = iprot.readString()
+ self.success.append(_elem846)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18081,8 +19053,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 iter833 in self.success:
- oprot.writeString(iter833)
+ for iter847 in self.success:
+ oprot.writeString(iter847)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19052,11 +20024,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype837, _size834) = iprot.readListBegin()
- for _i838 in xrange(_size834):
- _elem839 = Partition()
- _elem839.read(iprot)
- self.new_parts.append(_elem839)
+ (_etype851, _size848) = iprot.readListBegin()
+ for _i852 in xrange(_size848):
+ _elem853 = Partition()
+ _elem853.read(iprot)
+ self.new_parts.append(_elem853)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19073,8 +20045,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 iter840 in self.new_parts:
- iter840.write(oprot)
+ for iter854 in self.new_parts:
+ iter854.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19232,11 +20204,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype844, _size841) = iprot.readListBegin()
- for _i845 in xrange(_size841):
- _elem846 = PartitionSpec()
- _elem846.read(iprot)
- self.new_parts.append(_elem846)
+ (_etype858, _size855) = iprot.readListBegin()
+ for _i859 in xrange(_size855):
+ _elem860 = PartitionSpec()
+ _elem860.read(iprot)
+ self.new_parts.append(_elem860)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19253,8 +20225,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 iter847 in self.new_parts:
- iter847.write(oprot)
+ for iter861 in self.new_parts:
+ iter861.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19428,10 +20400,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype851, _size848) = iprot.readListBegin()
- for _i852 in xrange(_size848):
- _elem853 = iprot.readString()
- self.part_vals.append(_elem853)
+ (_etype865, _size862) = iprot.readListBegin()
+ for _i866 in xrange(_size862):
+ _elem867 = iprot.readString()
+ self.part_vals.append(_elem867)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19456,8 +20428,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 iter854 in self.part_vals:
- oprot.writeString(iter854)
+ for iter868 in self.part_vals:
+ oprot.writeString(iter868)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19810,10 +20782,10 @@ class append_partition_with_environment_context_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)
@@ -19844,8 +20816,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 iter861 in self.part_vals:
- oprot.writeString(iter861)
+ for iter875 in self.part_vals:
+ oprot.writeString(iter875)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -20440,10 +21412,10 @@ class drop_partition_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)
@@ -20473,8 +21445,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 iter868 in self.part_vals:
- oprot.writeString(iter868)
+ for iter882 in self.part_vals:
+ oprot.writeString(iter882)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -20647,10 +21619,10 @@ class drop_partition_with_environment_context_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)
@@ -20686,8 +21658,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 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:
@@ -21424,10 +22396,10 @@ class get_partition_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)
@@ -21452,8 +22424,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 iter882 in self.part_vals:
- oprot.writeString(iter882)
+ for iter896 in self.part_vals:
+ oprot.writeString(iter896)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21612,11 +22584,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype884, _vtype885, _size883 ) = iprot.readMapBegin()
- for _i887 in xrange(_size883):
- _key888 = iprot.readString()
- _val889 = iprot.readString()
- self.partitionSpecs[_key888] = _val889
+ (_ktype898, _vtype899, _size897 ) = iprot.readMapBegin()
+ for _i901 in xrange(_size897):
+ _key902 = iprot.readString()
+ _val903 = iprot.readString()
+ self.partitionSpecs[_key902] = _val903
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21653,9 +22625,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 kiter890,viter891 in self.partitionSpecs.items():
- oprot.writeString(kiter890)
- oprot.writeString(viter891)
+ for kiter904,viter905 in self.partitionSpecs.items():
+ oprot.writeString(kiter904)
+ oprot.writeString(viter905)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21860,11 +22832,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype893, _vtype894, _size892 ) = iprot.readMapBegin()
- for _i896 in xrange(_size892):
- _key897 = iprot.readString()
- _val898 = iprot.readString()
- self.partitionSpecs[_key897] = _val898
+ (_ktype907, _vtype908, _size906 ) = iprot.readMapBegin()
+ for _i910 in xrange(_size906):
+ _key911 = iprot.readString()
+ _val912 = iprot.readString()
+ self.partitionSpecs[_key911] = _val912
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21901,9 +22873,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 kiter899,viter900 in self.partitionSpecs.items():
- oprot.writeString(kiter899)
- oprot.writeString(viter900)
+ for kiter913,viter914 in self.partitionSpecs.items():
+ oprot.writeString(kiter913)
+ oprot.writeString(viter914)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21986,11 +22958,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = Partition()
- _elem906.read(iprot)
- self.success.append(_elem906)
+ (_etype918, _size915) = iprot.readListBegin()
+ for _i919 in xrange(_size915):
+ _elem920 = Partition()
+ _elem920.read(iprot)
+ self.success.append(_elem920)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22031,8 +23003,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 iter907 in self.success:
- iter907.write(oprot)
+ for iter921 in self.success:
+ iter921.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22126,10 +23098,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype911, _size908) = iprot.readListBegin()
- for _i912 in xrange(_size908):
- _elem913 = iprot.readString()
- self.part_vals.append(_elem913)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = iprot.readString()
+ self.part_vals.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22141,10 +23113,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype917, _size914) = iprot.readListBegin()
- for _i918 in xrange(_size914):
- _elem919 = iprot.readString()
- self.group_names.append(_elem919)
+ (_etype931, _size928) = iprot.readListBegin()
+ for _i932 in xrange(_size928):
+ _elem933 = iprot.readString()
+ self.group_names.append(_elem933)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22169,8 +23141,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 iter920 in self.part_vals:
- oprot.writeString(iter920)
+ for iter934 in self.part_vals:
+ oprot.writeString(iter934)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -22180,8 +23152,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 iter921 in self.group_names:
- oprot.writeString(iter921)
+ for iter935 in self.group_names:
+ oprot.writeString(iter935)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22610,11 +23582,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype925, _size922) = iprot.readListBegin()
- for _i926 in xrange(_size922):
- _elem927 = Partition()
- _elem927.read(iprot)
- self.success.append(_elem927)
+ (_etype939, _size936) = iprot.readListBegin()
+ for _i940 in xrange(_size936):
+ _elem941 = Partition()
+ _elem941.read(iprot)
+ self.success.append(_elem941)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22643,8 +23615,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 iter928 in self.success:
- iter928.write(oprot)
+ for iter942 in self.success:
+ iter942.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22738,10 +23710,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype932, _size929) = iprot.readListBegin()
- for _i933 in xrange(_size929):
- _elem934 = iprot.readString()
- self.group_names.append(_elem934)
+ (_etype946, _size943) = iprot.readListBegin()
+ for _i947 in xrange(_size943):
+ _elem948 = iprot.readString()
+ self.group_names.append(_elem948)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22774,8 +23746,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 iter935 in self.group_names:
- oprot.writeString(iter935)
+ for iter949 in self.group_names:
+ oprot.writeString(iter949)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22836,11 +23808,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype939, _size936) = iprot.readListBegin()
- for _i940 in xrange(_size936):
- _elem941 = Partition()
- _elem941.read(iprot)
- self.success.append(_elem941)
+ (_etype953, _size950) = iprot.readListBegin()
+ for _i954 in xrange(_size950):
+ _elem955 = Partition()
+ _elem955.read(iprot)
+ self.success.append(_elem955)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22869,8 +23841,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 iter942 in self.success:
- iter942.write(oprot)
+ for iter956 in self.success:
+ iter956.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23028,11 +24000,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype946, _size943) = iprot.readListBegin()
- for _i947 in xrange(_size943):
- _elem948 = PartitionSpec()
- _elem948.read(iprot)
- self.success.append(_elem948)
+ (_etype960, _size957) = iprot.readListBegin()
+ for _i961 in xrange(_size957):
+ _elem962 = PartitionSpec()
+ _elem962.read(iprot)
+ self.success.append(_elem962)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23061,8 +24033,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 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:
@@ -23220,10 +24192,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype953, _size950) = iprot.readListBegin()
- for _i954 in xrange(_size950):
- _elem955 = iprot.readString()
- self.success.append(_elem955)
+ (_etype967, _size964) = iprot.readListBegin()
+ for _i968 in xrange(_size964):
+ _elem969 = iprot.readString()
+ self.success.append(_elem969)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23252,8 +24224,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 iter956 in self.success:
- oprot.writeString(iter956)
+ for iter970 in self.success:
+ oprot.writeString(iter970)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23493,10 +24465,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype960, _size957) = iprot.readListBegin()
- for _i961 in xrange(_size957):
- _elem962 = iprot.readString()
- self.part_vals.append(_elem962)
+ (_etype974, _size971) = iprot.readListBegin()
+ for _i975 in xrange(_size971):
+ _elem976 = iprot.readString()
+ self.part_vals.append(_elem976)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23526,8 +24498,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 iter963 in self.part_vals:
- oprot.writeString(iter963)
+ for iter977 in self.part_vals:
+ oprot.writeString(iter977)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23591,11 +24563,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype967, _size964) = iprot.readListBegin()
- for _i968 in xrange(_size964):
- _elem969 = Partition()
- _elem969.read(iprot)
- self.success.append(_elem969)
+ (_etype981, _size978) = iprot.readListBegin()
+ for _i982 in xrange(_size978):
+ _elem983 = Partition()
+ _elem983.read(iprot)
+ self.success.append(_elem983)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23624,8 +24596,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 iter970 in self.success:
- iter970.write(oprot)
+ for iter984 in self.success:
+ iter984.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23712,10 +24684,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype974, _size971) = iprot.readListBegin()
- for _i975 in xrange(_size971):
- _elem976 = iprot.readString()
- self.part_vals.append(_elem976)
+ (_etype988, _size985) = iprot.readListBegin()
+ for _i989 in xrange(_size985):
+ _elem990 = iprot.readString()
+ self.part_vals.append(_elem990)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23732,10 +24704,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype980, _size977) = iprot.readListBegin()
- for _i981 in xrange(_size977):
- _elem982 = iprot.readString()
- self.group_names.append(_elem982)
+ (_etype994, _size991) = iprot.readListBegin()
+ for _i995 in xrange(_size991):
+ _elem996 = iprot.readString()
+ self.group_names.append(_elem996)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23760,8 +24732,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 iter983 in self.part_vals:
- oprot.writeString(iter983)
+ for iter997 in self.part_vals:
+ oprot.writeString(iter997)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23775,8 +24747,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 iter984 in self.group_names:
- oprot.writeString(iter984)
+ for iter998 in self.group_names:
+ oprot.writeString(iter998)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23838,11 +24810,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype988, _size985) = iprot.readListBegin()
- for _i989 in xrange(_size985):
- _elem990 = Partition()
- _elem990.read(iprot)
- self.success.append(_elem990)
+ (_etype1002, _size999) = iprot.readListBegin()
+ for _i1003 in xrange(_size999):
+ _elem1004 = Partition()
+ _elem1004.read(iprot)
+ self.success.append(_elem1004)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23871,8 +24843,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 iter991 in self.success:
- iter991.write(oprot)
+ for iter1005 in self.success:
+ iter1005.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23953,10 +24925,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype995, _size992) = iprot.readListBegin()
- for _i996 in xrange(_size992):
- _elem997 = iprot.readString()
- self.part_vals.append(_elem997)
+ (_etype1009, _size1006) = iprot.readListBegin()
+ for _i1010 in xrange(_size1006):
+ _elem1011 = iprot.readString()
+ self.part_vals.append(_elem1011)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23986,8 +24958,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 iter998 in self.part_vals:
- oprot.writeString(iter998)
+ for iter1012 in self.part_vals:
+ oprot.writeString(iter1012)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -24051,10 +25023,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1002, _size999) = iprot.readListBegin()
- for _i1003 in xrange(_size999):
- _elem1004 = iprot.readString()
- self.success.append(_elem1004)
+ (_etype1016, _size1013) = iprot.readListBegin()
+ for _i1017 in xrange(_size1013):
+ _elem1018 = iprot.readString()
+ self.success.append(_elem1018)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24083,8 +25055,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 iter1005 in self.success:
- oprot.writeString(iter1005)
+ for iter1019 in self.success:
+ oprot.writeString(iter1019)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24255,11 +25227,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1009, _size1006) = iprot.readListBegin()
- for _i1010 in xrange(_size1006):
- _elem1011 = Partition()
- _elem1011.read(iprot)
- self.success.append(_elem1011)
+ (_etype1023, _size1020) = iprot.readListBegin()
+ for _i1024 in xrange(_size1020):
+ _elem1025 = Partition()
+ _elem1025.read(iprot)
+ self.success.append(_elem1025)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24288,8 +25260,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 iter1012 in self.success:
- iter1012.write(oprot)
+ for iter1026 in self.success:
+ iter1026.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24460,11 +25432,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1016, _size1013) = iprot.readListBegin()
- for _i1017 in xrange(_size1013):
- _elem1018 = PartitionSpec()
- _elem1018.read(iprot)
- self.success.append(_elem1018)
+ (_etype1030, _size1027) = iprot.readListBegin()
+ for _i1031 in xrange(_size1027):
+ _elem1032 = PartitionSpec()
+ _elem1032.read(iprot)
+ self.success.append(_elem1032)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24493,8 +25465,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 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:
@@ -24914,10 +25886,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1023, _size1020) = iprot.readListBegin()
- for _i1024 in xrange(_size1020):
- _elem1025 = iprot.readString()
- self.names.append(_elem1025)
+ (_etype1037, _size1034) = iprot.readListBegin()
+ for _i1038 in xrange(_size1034):
+ _elem1039 = iprot.readString()
+ self.names.append(_elem1039)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24942,8 +25914,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 iter1026 in self.names:
- oprot.writeString(iter1026)
+ for iter1040 in self.names:
+ oprot.writeString(iter1040)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25002,11 +25974,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1030, _size1027) = iprot.readListBegin()
- for _i1031 in xrange(_size1027):
- _elem1032 = Partition()
- _elem1032.read(iprot)
- self.success.append(_elem1032)
+ (_etype1044, _size1041) = iprot.readListBegin()
+ for _i1045 in xrange(_size1041):
+ _elem1046 = Partition()
+ _elem1046.read(iprot)
+ self.success.append(_elem1046)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25035,8 +26007,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 iter1033 in self.success:
- iter1033.write(oprot)
+ for iter1047 in self.success:
+ iter1047.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25286,11 +26258,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1037, _size1034) = iprot.readListBegin()
- for _i1038 in xrange(_size1034):
- _elem1039 = Partition()
- _elem1039.read(iprot)
- self.new_parts.append(_elem1039)
+ (_etype1051, _size1048) = iprot.readListBegin()
+ for _i1052 in xrange(_size1048):
+ _elem1053 = Partition()
+ _elem1053.read(iprot)
+ self.new_parts.append(_elem1053)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25315,8 +26287,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 iter1040 in self.new_parts:
- iter1040.write(oprot)
+ for iter1054 in self.new_parts:
+ iter1054.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25469,11 +26441,11 @@ class alter_partitions_with_environment_context_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)
@@ -25504,8 +26476,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 iter1047 in self.new_parts:
- iter1047.write(oprot)
+ for iter1061 in self.new_parts:
+ iter1061.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -25849,10 +26821,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1051, _size1048) = iprot.readListBegin()
- for _i1052 in xrange(_size1048):
- _elem1053 = iprot.readString()
- self.part_vals.append(_elem1053)
+ (_etype1065, _size1062) = iprot.readListBegin()
+ for _i1066 in xrange(_size1062):
+ _elem1067 = iprot.readString()
+ self.part_vals.append(_elem1067)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25883,8 +26855,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 iter1054 in self.part_vals:
- oprot.writeString(iter1054)
+ for iter1068 in self.part_vals:
+ oprot.writeString(iter1068)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -26026,10 +26998,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
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)
@@ -26051,8 +27023,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 iter1061 in self.part_vals:
- oprot.writeString(iter1061)
+ for iter1075 in self.part_vals:
+ oprot.writeString(iter1075)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -26410,10 +27382,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1065, _size1062) = iprot.readListBegin()
- for _i1066 in xrange(_size1062):
- _elem1067 = iprot.readString()
- self.success.append(_elem1067)
+ (_etype1079, _size1076) = iprot.readListBegin()
+ for _i1080 in xrange(_size1076):
+ _elem1081 = iprot.readString()
+ self.success.append(_elem1081)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26436,8 +27408,8 @@ class partition_name_to_vals_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
<TRUNCATED>