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