You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/10/21 01:04:59 UTC
[02/12] hive git commit: HIVE-17771 : Implement commands to manage
resource plan (Harish Jaiprakash, reviewed by Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/a7e34455/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 3457901..08864b7 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
@@ -1293,6 +1293,48 @@ class Iface(fb303.FacebookService.Iface):
def get_metastore_db_uuid(self):
pass
+ def create_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def get_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def get_all_resource_plans(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def alter_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def validate_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def drop_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
class Client(fb303.FacebookService.Client, Iface):
"""
@@ -7127,6 +7169,220 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o1
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_metastore_db_uuid failed: unknown result")
+ def create_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_create_resource_plan(request)
+ return self.recv_create_resource_plan()
+
+ def send_create_resource_plan(self, request):
+ self._oprot.writeMessageBegin('create_resource_plan', TMessageType.CALL, self._seqid)
+ args = create_resource_plan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_create_resource_plan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = create_resource_plan_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
+ if result.o3 is not None:
+ raise result.o3
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "create_resource_plan failed: unknown result")
+
+ def get_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_resource_plan(request)
+ return self.recv_get_resource_plan()
+
+ def send_get_resource_plan(self, request):
+ self._oprot.writeMessageBegin('get_resource_plan', TMessageType.CALL, self._seqid)
+ args = get_resource_plan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_resource_plan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_resource_plan_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_resource_plan failed: unknown result")
+
+ def get_all_resource_plans(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_all_resource_plans(request)
+ return self.recv_get_all_resource_plans()
+
+ def send_get_all_resource_plans(self, request):
+ self._oprot.writeMessageBegin('get_all_resource_plans', TMessageType.CALL, self._seqid)
+ args = get_all_resource_plans_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_all_resource_plans(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_all_resource_plans_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_all_resource_plans failed: unknown result")
+
+ def alter_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_alter_resource_plan(request)
+ return self.recv_alter_resource_plan()
+
+ def send_alter_resource_plan(self, request):
+ self._oprot.writeMessageBegin('alter_resource_plan', TMessageType.CALL, self._seqid)
+ args = alter_resource_plan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_alter_resource_plan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = alter_resource_plan_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
+ if result.o3 is not None:
+ raise result.o3
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "alter_resource_plan failed: unknown result")
+
+ def validate_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_validate_resource_plan(request)
+ return self.recv_validate_resource_plan()
+
+ def send_validate_resource_plan(self, request):
+ self._oprot.writeMessageBegin('validate_resource_plan', TMessageType.CALL, self._seqid)
+ args = validate_resource_plan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_validate_resource_plan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = validate_resource_plan_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, "validate_resource_plan failed: unknown result")
+
+ def drop_resource_plan(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_drop_resource_plan(request)
+ return self.recv_drop_resource_plan()
+
+ def send_drop_resource_plan(self, request):
+ self._oprot.writeMessageBegin('drop_resource_plan', TMessageType.CALL, self._seqid)
+ args = drop_resource_plan_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_drop_resource_plan(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = drop_resource_plan_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
+ if result.o3 is not None:
+ raise result.o3
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_resource_plan failed: unknown result")
+
class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
def __init__(self, handler):
@@ -7293,6 +7549,12 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["clear_file_metadata"] = Processor.process_clear_file_metadata
self._processMap["cache_file_metadata"] = Processor.process_cache_file_metadata
self._processMap["get_metastore_db_uuid"] = Processor.process_get_metastore_db_uuid
+ self._processMap["create_resource_plan"] = Processor.process_create_resource_plan
+ self._processMap["get_resource_plan"] = Processor.process_get_resource_plan
+ self._processMap["get_all_resource_plans"] = Processor.process_get_all_resource_plans
+ self._processMap["alter_resource_plan"] = Processor.process_alter_resource_plan
+ self._processMap["validate_resource_plan"] = Processor.process_validate_resource_plan
+ self._processMap["drop_resource_plan"] = Processor.process_drop_resource_plan
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
@@ -11254,6 +11516,162 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_create_resource_plan(self, seqid, iprot, oprot):
+ args = create_resource_plan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = create_resource_plan_result()
+ try:
+ result.success = self._handler.create_resource_plan(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AlreadyExistsException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except InvalidObjectException 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_resource_plan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_get_resource_plan(self, seqid, iprot, oprot):
+ args = get_resource_plan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_resource_plan_result()
+ try:
+ result.success = self._handler.get_resource_plan(args.request)
+ 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_resource_plan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_get_all_resource_plans(self, seqid, iprot, oprot):
+ args = get_all_resource_plans_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_all_resource_plans_result()
+ try:
+ result.success = self._handler.get_all_resource_plans(args.request)
+ 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_all_resource_plans", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_alter_resource_plan(self, seqid, iprot, oprot):
+ args = alter_resource_plan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = alter_resource_plan_result()
+ try:
+ result.success = self._handler.alter_resource_plan(args.request)
+ 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("alter_resource_plan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_validate_resource_plan(self, seqid, iprot, oprot):
+ args = validate_resource_plan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = validate_resource_plan_result()
+ try:
+ result.success = self._handler.validate_resource_plan(args.request)
+ 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("validate_resource_plan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_drop_resource_plan(self, seqid, iprot, oprot):
+ args = drop_resource_plan_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = drop_resource_plan_result()
+ try:
+ result.success = self._handler.drop_resource_plan(args.request)
+ 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_resource_plan", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
# HELPER FUNCTIONS AND STRUCTURES
@@ -12140,10 +12558,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype653, _size650) = iprot.readListBegin()
- for _i654 in xrange(_size650):
- _elem655 = iprot.readString()
- self.success.append(_elem655)
+ (_etype660, _size657) = iprot.readListBegin()
+ for _i661 in xrange(_size657):
+ _elem662 = iprot.readString()
+ self.success.append(_elem662)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12166,8 +12584,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 iter656 in self.success:
- oprot.writeString(iter656)
+ for iter663 in self.success:
+ oprot.writeString(iter663)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12272,10 +12690,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = iprot.readString()
- self.success.append(_elem662)
+ (_etype667, _size664) = iprot.readListBegin()
+ for _i668 in xrange(_size664):
+ _elem669 = iprot.readString()
+ self.success.append(_elem669)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12298,8 +12716,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 iter663 in self.success:
- oprot.writeString(iter663)
+ for iter670 in self.success:
+ oprot.writeString(iter670)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13069,12 +13487,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype665, _vtype666, _size664 ) = iprot.readMapBegin()
- for _i668 in xrange(_size664):
- _key669 = iprot.readString()
- _val670 = Type()
- _val670.read(iprot)
- self.success[_key669] = _val670
+ (_ktype672, _vtype673, _size671 ) = iprot.readMapBegin()
+ for _i675 in xrange(_size671):
+ _key676 = iprot.readString()
+ _val677 = Type()
+ _val677.read(iprot)
+ self.success[_key676] = _val677
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -13097,9 +13515,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 kiter671,viter672 in self.success.items():
- oprot.writeString(kiter671)
- viter672.write(oprot)
+ for kiter678,viter679 in self.success.items():
+ oprot.writeString(kiter678)
+ viter679.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -13242,11 +13660,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = FieldSchema()
- _elem678.read(iprot)
- self.success.append(_elem678)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = FieldSchema()
+ _elem685.read(iprot)
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13281,8 +13699,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 iter679 in self.success:
- iter679.write(oprot)
+ for iter686 in self.success:
+ iter686.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13449,11 +13867,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = FieldSchema()
- _elem685.read(iprot)
- self.success.append(_elem685)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = FieldSchema()
+ _elem692.read(iprot)
+ self.success.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13488,8 +13906,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 iter686 in self.success:
- iter686.write(oprot)
+ for iter693 in self.success:
+ iter693.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13642,11 +14060,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = FieldSchema()
- _elem692.read(iprot)
- self.success.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = FieldSchema()
+ _elem699.read(iprot)
+ self.success.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13681,8 +14099,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 iter693 in self.success:
- iter693.write(oprot)
+ for iter700 in self.success:
+ iter700.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13849,11 +14267,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = FieldSchema()
- _elem699.read(iprot)
- self.success.append(_elem699)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = FieldSchema()
+ _elem706.read(iprot)
+ self.success.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13888,8 +14306,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 iter700 in self.success:
- iter700.write(oprot)
+ for iter707 in self.success:
+ iter707.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14336,44 +14754,44 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = SQLPrimaryKey()
- _elem706.read(iprot)
- self.primaryKeys.append(_elem706)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = SQLPrimaryKey()
+ _elem713.read(iprot)
+ self.primaryKeys.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype710, _size707) = iprot.readListBegin()
- for _i711 in xrange(_size707):
- _elem712 = SQLForeignKey()
- _elem712.read(iprot)
- self.foreignKeys.append(_elem712)
+ (_etype717, _size714) = iprot.readListBegin()
+ for _i718 in xrange(_size714):
+ _elem719 = SQLForeignKey()
+ _elem719.read(iprot)
+ self.foreignKeys.append(_elem719)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype716, _size713) = iprot.readListBegin()
- for _i717 in xrange(_size713):
- _elem718 = SQLUniqueConstraint()
- _elem718.read(iprot)
- self.uniqueConstraints.append(_elem718)
+ (_etype723, _size720) = iprot.readListBegin()
+ for _i724 in xrange(_size720):
+ _elem725 = SQLUniqueConstraint()
+ _elem725.read(iprot)
+ self.uniqueConstraints.append(_elem725)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype722, _size719) = iprot.readListBegin()
- for _i723 in xrange(_size719):
- _elem724 = SQLNotNullConstraint()
- _elem724.read(iprot)
- self.notNullConstraints.append(_elem724)
+ (_etype729, _size726) = iprot.readListBegin()
+ for _i730 in xrange(_size726):
+ _elem731 = SQLNotNullConstraint()
+ _elem731.read(iprot)
+ self.notNullConstraints.append(_elem731)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14394,29 +14812,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 iter725 in self.primaryKeys:
- iter725.write(oprot)
+ for iter732 in self.primaryKeys:
+ iter732.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 iter726 in self.foreignKeys:
- iter726.write(oprot)
+ for iter733 in self.foreignKeys:
+ iter733.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 iter727 in self.uniqueConstraints:
- iter727.write(oprot)
+ for iter734 in self.uniqueConstraints:
+ iter734.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 iter728 in self.notNullConstraints:
- iter728.write(oprot)
+ for iter735 in self.notNullConstraints:
+ iter735.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15682,10 +16100,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype732, _size729) = iprot.readListBegin()
- for _i733 in xrange(_size729):
- _elem734 = iprot.readString()
- self.partNames.append(_elem734)
+ (_etype739, _size736) = iprot.readListBegin()
+ for _i740 in xrange(_size736):
+ _elem741 = iprot.readString()
+ self.partNames.append(_elem741)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15710,8 +16128,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 iter735 in self.partNames:
- oprot.writeString(iter735)
+ for iter742 in self.partNames:
+ oprot.writeString(iter742)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15911,10 +16329,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype739, _size736) = iprot.readListBegin()
- for _i740 in xrange(_size736):
- _elem741 = iprot.readString()
- self.success.append(_elem741)
+ (_etype746, _size743) = iprot.readListBegin()
+ for _i747 in xrange(_size743):
+ _elem748 = iprot.readString()
+ self.success.append(_elem748)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15937,8 +16355,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 iter742 in self.success:
- oprot.writeString(iter742)
+ for iter749 in self.success:
+ oprot.writeString(iter749)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16088,10 +16506,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype746, _size743) = iprot.readListBegin()
- for _i747 in xrange(_size743):
- _elem748 = iprot.readString()
- self.success.append(_elem748)
+ (_etype753, _size750) = iprot.readListBegin()
+ for _i754 in xrange(_size750):
+ _elem755 = iprot.readString()
+ self.success.append(_elem755)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16114,8 +16532,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 iter749 in self.success:
- oprot.writeString(iter749)
+ for iter756 in self.success:
+ oprot.writeString(iter756)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16188,10 +16606,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype753, _size750) = iprot.readListBegin()
- for _i754 in xrange(_size750):
- _elem755 = iprot.readString()
- self.tbl_types.append(_elem755)
+ (_etype760, _size757) = iprot.readListBegin()
+ for _i761 in xrange(_size757):
+ _elem762 = iprot.readString()
+ self.tbl_types.append(_elem762)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16216,8 +16634,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 iter756 in self.tbl_types:
- oprot.writeString(iter756)
+ for iter763 in self.tbl_types:
+ oprot.writeString(iter763)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16273,11 +16691,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype760, _size757) = iprot.readListBegin()
- for _i761 in xrange(_size757):
- _elem762 = TableMeta()
- _elem762.read(iprot)
- self.success.append(_elem762)
+ (_etype767, _size764) = iprot.readListBegin()
+ for _i768 in xrange(_size764):
+ _elem769 = TableMeta()
+ _elem769.read(iprot)
+ self.success.append(_elem769)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16300,8 +16718,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 iter763 in self.success:
- iter763.write(oprot)
+ for iter770 in self.success:
+ iter770.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16425,10 +16843,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype767, _size764) = iprot.readListBegin()
- for _i768 in xrange(_size764):
- _elem769 = iprot.readString()
- self.success.append(_elem769)
+ (_etype774, _size771) = iprot.readListBegin()
+ for _i775 in xrange(_size771):
+ _elem776 = iprot.readString()
+ self.success.append(_elem776)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16451,8 +16869,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 iter770 in self.success:
- oprot.writeString(iter770)
+ for iter777 in self.success:
+ oprot.writeString(iter777)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16688,10 +17106,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype774, _size771) = iprot.readListBegin()
- for _i775 in xrange(_size771):
- _elem776 = iprot.readString()
- self.tbl_names.append(_elem776)
+ (_etype781, _size778) = iprot.readListBegin()
+ for _i782 in xrange(_size778):
+ _elem783 = iprot.readString()
+ self.tbl_names.append(_elem783)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16712,8 +17130,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 iter777 in self.tbl_names:
- oprot.writeString(iter777)
+ for iter784 in self.tbl_names:
+ oprot.writeString(iter784)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16765,11 +17183,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype781, _size778) = iprot.readListBegin()
- for _i782 in xrange(_size778):
- _elem783 = Table()
- _elem783.read(iprot)
- self.success.append(_elem783)
+ (_etype788, _size785) = iprot.readListBegin()
+ for _i789 in xrange(_size785):
+ _elem790 = Table()
+ _elem790.read(iprot)
+ self.success.append(_elem790)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16786,8 +17204,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 iter784 in self.success:
- iter784.write(oprot)
+ for iter791 in self.success:
+ iter791.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17270,10 +17688,10 @@ class get_table_names_by_filter_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)
+ (_etype795, _size792) = iprot.readListBegin()
+ for _i796 in xrange(_size792):
+ _elem797 = iprot.readString()
+ self.success.append(_elem797)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17308,8 +17726,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 iter791 in self.success:
- oprot.writeString(iter791)
+ for iter798 in self.success:
+ oprot.writeString(iter798)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18279,11 +18697,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype795, _size792) = iprot.readListBegin()
- for _i796 in xrange(_size792):
- _elem797 = Partition()
- _elem797.read(iprot)
- self.new_parts.append(_elem797)
+ (_etype802, _size799) = iprot.readListBegin()
+ for _i803 in xrange(_size799):
+ _elem804 = Partition()
+ _elem804.read(iprot)
+ self.new_parts.append(_elem804)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18300,8 +18718,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 iter798 in self.new_parts:
- iter798.write(oprot)
+ for iter805 in self.new_parts:
+ iter805.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18459,11 +18877,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = PartitionSpec()
- _elem804.read(iprot)
- self.new_parts.append(_elem804)
+ (_etype809, _size806) = iprot.readListBegin()
+ for _i810 in xrange(_size806):
+ _elem811 = PartitionSpec()
+ _elem811.read(iprot)
+ self.new_parts.append(_elem811)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18480,8 +18898,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 iter805 in self.new_parts:
- iter805.write(oprot)
+ for iter812 in self.new_parts:
+ iter812.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18655,10 +19073,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = iprot.readString()
- self.part_vals.append(_elem811)
+ (_etype816, _size813) = iprot.readListBegin()
+ for _i817 in xrange(_size813):
+ _elem818 = iprot.readString()
+ self.part_vals.append(_elem818)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18683,8 +19101,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 iter812 in self.part_vals:
- oprot.writeString(iter812)
+ for iter819 in self.part_vals:
+ oprot.writeString(iter819)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19037,10 +19455,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = iprot.readString()
- self.part_vals.append(_elem818)
+ (_etype823, _size820) = iprot.readListBegin()
+ for _i824 in xrange(_size820):
+ _elem825 = iprot.readString()
+ self.part_vals.append(_elem825)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19071,8 +19489,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 iter819 in self.part_vals:
- oprot.writeString(iter819)
+ for iter826 in self.part_vals:
+ oprot.writeString(iter826)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -19667,10 +20085,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = iprot.readString()
- self.part_vals.append(_elem825)
+ (_etype830, _size827) = iprot.readListBegin()
+ for _i831 in xrange(_size827):
+ _elem832 = iprot.readString()
+ self.part_vals.append(_elem832)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19700,8 +20118,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 iter826 in self.part_vals:
- oprot.writeString(iter826)
+ for iter833 in self.part_vals:
+ oprot.writeString(iter833)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -19874,10 +20292,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype830, _size827) = iprot.readListBegin()
- for _i831 in xrange(_size827):
- _elem832 = iprot.readString()
- self.part_vals.append(_elem832)
+ (_etype837, _size834) = iprot.readListBegin()
+ for _i838 in xrange(_size834):
+ _elem839 = iprot.readString()
+ self.part_vals.append(_elem839)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19913,8 +20331,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 iter833 in self.part_vals:
- oprot.writeString(iter833)
+ for iter840 in self.part_vals:
+ oprot.writeString(iter840)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -20651,10 +21069,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype837, _size834) = iprot.readListBegin()
- for _i838 in xrange(_size834):
- _elem839 = iprot.readString()
- self.part_vals.append(_elem839)
+ (_etype844, _size841) = iprot.readListBegin()
+ for _i845 in xrange(_size841):
+ _elem846 = iprot.readString()
+ self.part_vals.append(_elem846)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20679,8 +21097,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 iter840 in self.part_vals:
- oprot.writeString(iter840)
+ for iter847 in self.part_vals:
+ oprot.writeString(iter847)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20839,11 +21257,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype842, _vtype843, _size841 ) = iprot.readMapBegin()
- for _i845 in xrange(_size841):
- _key846 = iprot.readString()
- _val847 = iprot.readString()
- self.partitionSpecs[_key846] = _val847
+ (_ktype849, _vtype850, _size848 ) = iprot.readMapBegin()
+ for _i852 in xrange(_size848):
+ _key853 = iprot.readString()
+ _val854 = iprot.readString()
+ self.partitionSpecs[_key853] = _val854
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -20880,9 +21298,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 kiter848,viter849 in self.partitionSpecs.items():
- oprot.writeString(kiter848)
- oprot.writeString(viter849)
+ for kiter855,viter856 in self.partitionSpecs.items():
+ oprot.writeString(kiter855)
+ oprot.writeString(viter856)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21087,11 +21505,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype851, _vtype852, _size850 ) = iprot.readMapBegin()
- for _i854 in xrange(_size850):
- _key855 = iprot.readString()
- _val856 = iprot.readString()
- self.partitionSpecs[_key855] = _val856
+ (_ktype858, _vtype859, _size857 ) = iprot.readMapBegin()
+ for _i861 in xrange(_size857):
+ _key862 = iprot.readString()
+ _val863 = iprot.readString()
+ self.partitionSpecs[_key862] = _val863
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21128,9 +21546,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 kiter857,viter858 in self.partitionSpecs.items():
- oprot.writeString(kiter857)
- oprot.writeString(viter858)
+ for kiter864,viter865 in self.partitionSpecs.items():
+ oprot.writeString(kiter864)
+ oprot.writeString(viter865)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -21213,11 +21631,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype862, _size859) = iprot.readListBegin()
- for _i863 in xrange(_size859):
- _elem864 = Partition()
- _elem864.read(iprot)
- self.success.append(_elem864)
+ (_etype869, _size866) = iprot.readListBegin()
+ for _i870 in xrange(_size866):
+ _elem871 = Partition()
+ _elem871.read(iprot)
+ self.success.append(_elem871)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21258,8 +21676,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 iter865 in self.success:
- iter865.write(oprot)
+ for iter872 in self.success:
+ iter872.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21353,10 +21771,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = iprot.readString()
- self.part_vals.append(_elem871)
+ (_etype876, _size873) = iprot.readListBegin()
+ for _i877 in xrange(_size873):
+ _elem878 = iprot.readString()
+ self.part_vals.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21368,10 +21786,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype875, _size872) = iprot.readListBegin()
- for _i876 in xrange(_size872):
- _elem877 = iprot.readString()
- self.group_names.append(_elem877)
+ (_etype882, _size879) = iprot.readListBegin()
+ for _i883 in xrange(_size879):
+ _elem884 = iprot.readString()
+ self.group_names.append(_elem884)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21396,8 +21814,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 iter878 in self.part_vals:
- oprot.writeString(iter878)
+ for iter885 in self.part_vals:
+ oprot.writeString(iter885)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -21407,8 +21825,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 iter879 in self.group_names:
- oprot.writeString(iter879)
+ for iter886 in self.group_names:
+ oprot.writeString(iter886)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21837,11 +22255,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype883, _size880) = iprot.readListBegin()
- for _i884 in xrange(_size880):
- _elem885 = Partition()
- _elem885.read(iprot)
- self.success.append(_elem885)
+ (_etype890, _size887) = iprot.readListBegin()
+ for _i891 in xrange(_size887):
+ _elem892 = Partition()
+ _elem892.read(iprot)
+ self.success.append(_elem892)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21870,8 +22288,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 iter886 in self.success:
- iter886.write(oprot)
+ for iter893 in self.success:
+ iter893.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21965,10 +22383,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype890, _size887) = iprot.readListBegin()
- for _i891 in xrange(_size887):
- _elem892 = iprot.readString()
- self.group_names.append(_elem892)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = iprot.readString()
+ self.group_names.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22001,8 +22419,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 iter893 in self.group_names:
- oprot.writeString(iter893)
+ for iter900 in self.group_names:
+ oprot.writeString(iter900)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22063,11 +22481,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = Partition()
- _elem899.read(iprot)
- self.success.append(_elem899)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = Partition()
+ _elem906.read(iprot)
+ self.success.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22096,8 +22514,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 iter900 in self.success:
- iter900.write(oprot)
+ for iter907 in self.success:
+ iter907.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22255,11 +22673,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = PartitionSpec()
- _elem906.read(iprot)
- self.success.append(_elem906)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = PartitionSpec()
+ _elem913.read(iprot)
+ self.success.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22288,8 +22706,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 iter907 in self.success:
- iter907.write(oprot)
+ for iter914 in self.success:
+ iter914.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22447,10 +22865,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype911, _size908) = iprot.readListBegin()
- for _i912 in xrange(_size908):
- _elem913 = iprot.readString()
- self.success.append(_elem913)
+ (_etype918, _size915) = iprot.readListBegin()
+ for _i919 in xrange(_size915):
+ _elem920 = iprot.readString()
+ self.success.append(_elem920)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22479,8 +22897,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 iter914 in self.success:
- oprot.writeString(iter914)
+ for iter921 in self.success:
+ oprot.writeString(iter921)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22720,10 +23138,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype918, _size915) = iprot.readListBegin()
- for _i919 in xrange(_size915):
- _elem920 = iprot.readString()
- self.part_vals.append(_elem920)
+ (_etype925, _size922) = iprot.readListBegin()
+ for _i926 in xrange(_size922):
+ _elem927 = iprot.readString()
+ self.part_vals.append(_elem927)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22753,8 +23171,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 iter921 in self.part_vals:
- oprot.writeString(iter921)
+ for iter928 in self.part_vals:
+ oprot.writeString(iter928)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -22818,11 +23236,11 @@ class get_partitions_ps_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)
+ (_etype932, _size929) = iprot.readListBegin()
+ for _i933 in xrange(_size929):
+ _elem934 = Partition()
+ _elem934.read(iprot)
+ self.success.append(_elem934)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22851,8 +23269,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 iter928 in self.success:
- iter928.write(oprot)
+ for iter935 in self.success:
+ iter935.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22939,10 +23357,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype932, _size929) = iprot.readListBegin()
- for _i933 in xrange(_size929):
- _elem934 = iprot.readString()
- self.part_vals.append(_elem934)
+ (_etype939, _size936) = iprot.readListBegin()
+ for _i940 in xrange(_size936):
+ _elem941 = iprot.readString()
+ self.part_vals.append(_elem941)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22959,10 +23377,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype938, _size935) = iprot.readListBegin()
- for _i939 in xrange(_size935):
- _elem940 = iprot.readString()
- self.group_names.append(_elem940)
+ (_etype945, _size942) = iprot.readListBegin()
+ for _i946 in xrange(_size942):
+ _elem947 = iprot.readString()
+ self.group_names.append(_elem947)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22987,8 +23405,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 iter941 in self.part_vals:
- oprot.writeString(iter941)
+ for iter948 in self.part_vals:
+ oprot.writeString(iter948)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23002,8 +23420,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 iter942 in self.group_names:
- oprot.writeString(iter942)
+ for iter949 in self.group_names:
+ oprot.writeString(iter949)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23065,11 +23483,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype946, _size943) = iprot.readListBegin()
- for _i947 in xrange(_size943):
- _elem948 = Partition()
- _elem948.read(iprot)
- self.success.append(_elem948)
+ (_etype953, _size950) = iprot.readListBegin()
+ for _i954 in xrange(_size950):
+ _elem955 = Partition()
+ _elem955.read(iprot)
+ self.success.append(_elem955)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23098,8 +23516,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 iter949 in self.success:
- iter949.write(oprot)
+ for iter956 in self.success:
+ iter956.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23180,10 +23598,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype953, _size950) = iprot.readListBegin()
- for _i954 in xrange(_size950):
- _elem955 = iprot.readString()
- self.part_vals.append(_elem955)
+ (_etype960, _size957) = iprot.readListBegin()
+ for _i961 in xrange(_size957):
+ _elem962 = iprot.readString()
+ self.part_vals.append(_elem962)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23213,8 +23631,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 iter956 in self.part_vals:
- oprot.writeString(iter956)
+ for iter963 in self.part_vals:
+ oprot.writeString(iter963)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -23278,10 +23696,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype960, _size957) = iprot.readListBegin()
- for _i961 in xrange(_size957):
- _elem962 = iprot.readString()
- self.success.append(_elem962)
+ (_etype967, _size964) = iprot.readListBegin()
+ for _i968 in xrange(_size964):
+ _elem969 = iprot.readString()
+ self.success.append(_elem969)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23310,8 +23728,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 iter963 in self.success:
- oprot.writeString(iter963)
+ for iter970 in self.success:
+ oprot.writeString(iter970)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23482,11 +23900,11 @@ class get_partitions_by_filter_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)
+ (_etype974, _size971) = iprot.readListBegin()
+ for _i975 in xrange(_size971):
+ _elem976 = Partition()
+ _elem976.read(iprot)
+ self.success.append(_elem976)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23515,8 +23933,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 iter970 in self.success:
- iter970.write(oprot)
+ for iter977 in self.success:
+ iter977.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23687,11 +24105,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype974, _size971) = iprot.readListBegin()
- for _i975 in xrange(_size971):
- _elem976 = PartitionSpec()
- _elem976.read(iprot)
- self.success.append(_elem976)
+ (_etype981, _size978) = iprot.readListBegin()
+ for _i982 in xrange(_size978):
+ _elem983 = PartitionSpec()
+ _elem983.read(iprot)
+ self.success.append(_elem983)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23720,8 +24138,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 iter977 in self.success:
- iter977.write(oprot)
+ for iter984 in self.success:
+ iter984.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24141,10 +24559,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype981, _size978) = iprot.readListBegin()
- for _i982 in xrange(_size978):
- _elem983 = iprot.readString()
- self.names.append(_elem983)
+ (_etype988, _size985) = iprot.readListBegin()
+ for _i989 in xrange(_size985):
+ _elem990 = iprot.readString()
+ self.names.append(_elem990)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24169,8 +24587,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 iter984 in self.names:
- oprot.writeString(iter984)
+ for iter991 in self.names:
+ oprot.writeString(iter991)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24229,11 +24647,11 @@ class get_partitions_by_names_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)
+ (_etype995, _size992) = iprot.readListBegin()
+ for _i996 in xrange(_size992):
+ _elem997 = Partition()
+ _elem997.read(iprot)
+ self.success.append(_elem997)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24262,8 +24680,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 iter991 in self.success:
- iter991.write(oprot)
+ for iter998 in self.success:
+ iter998.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24513,11 +24931,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype995, _size992) = iprot.readListBegin()
- for _i996 in xrange(_size992):
- _elem997 = Partition()
- _elem997.read(iprot)
- self.new_parts.append(_elem997)
+ (_etype1002, _size999) = iprot.readListBegin()
+ for _i1003 in xrange(_size999):
+ _elem1004 = Partition()
+ _elem1004.read(iprot)
+ self.new_parts.append(_elem1004)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24542,8 +24960,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 iter998 in self.new_parts:
- iter998.write(oprot)
+ for iter1005 in self.new_parts:
+ iter1005.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24696,11 +25114,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1002, _size999) = iprot.readListBegin()
- for _i1003 in xrange(_size999):
- _elem1004 = Partition()
- _elem1004.read(iprot)
- self.new_parts.append(_elem1004)
+ (_etype1009, _size1006) = iprot.readListBegin()
+ for _i1010 in xrange(_size1006):
+ _elem1011 = Partition()
+ _elem1011.read(iprot)
+ self.new_parts.append(_elem1011)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24731,8 +25149,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 iter1005 in self.new_parts:
- iter1005.write(oprot)
+ for iter1012 in self.new_parts:
+ iter1012.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -25076,10 +25494,10 @@ class rename_partition_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)
+ (_etype1016, _size1013) = iprot.readListBegin()
+ for _i1017 in xrange(_size1013):
+ _elem1018 = iprot.readString()
+ self.part_vals.append(_elem1018)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25110,8 +25528,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 iter1012 in self.part_vals:
- oprot.writeString(iter1012)
+ for iter1019 in self.part_vals:
+ oprot.writeString(iter1019)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -25253,10 +25671,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1016, _size1013) = iprot.readListBegin()
- for _i1017 in xrange(_size1013):
- _elem1018 = iprot.readString()
- self.part_vals.append(_elem1018)
+ (_etype1023, _size1020) = iprot.readListBegin()
+ for _i1024 in xrange(_size1020):
+ _elem1025 = iprot.readString()
+ self.part_vals.append(_elem1025)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25278,8 +25696,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 iter1019 in self.part_vals:
- oprot.writeString(iter1019)
+ for iter1026 in self.part_vals:
+ oprot.writeString(iter1026)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -25637,10 +26055,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1023, _size1020) = iprot.readListBegin()
- for _i1024 in xrange(_size1020):
- _elem1025 = iprot.readString()
- self.success.append(_elem1025)
+ (_etype1030, _size1027) = iprot.readListBegin()
+ for _i1031 in xrange(_size1027):
+ _elem1032 = iprot.readString()
+ self.success.append(_elem1032)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25663,8 +26081,8 @@ class partition_name_to_vals_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1026 in self.success:
- oprot.writeString(iter1026)
+ for iter1033 in self.success:
+ oprot.writeString(iter1033)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25788,11 +26206,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1028, _vtype1029, _size1027 ) = iprot.readMapBegin()
- for _i1031 in xrange(_size1027):
- _key1032 = iprot.readString()
- _val1033 = iprot.readString()
- self.success[_key1032] = _val1033
+ (_ktype1035, _vtype1036, _size1034 ) = iprot.readMapBegin()
+ for _i1038 in xrange(_size1034):
+ _key1039 = iprot.readString()
+ _val1040 = iprot.readString()
+ self.success[_key1039] = _val1040
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25815,9 +26233,9 @@ class partition_name_to_spec_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.success))
- for kiter1034,viter1035 in self.success.items():
- oprot.writeString(kiter1034)
- oprot.writeString(viter1035)
+ for kiter1041,viter1042 in self.success.items():
+ oprot.writeString(kiter1041)
+ oprot.writeString(viter1042)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25893,11 +26311,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1037, _vtype1038, _size1036 ) = iprot.readMapBegin()
- for _i1040 in xrange(_size1036):
- _key1041 = iprot.readString()
- _val1042 = iprot.readString()
- self.part_vals[_key1041] = _val1042
+ (_ktype1044, _vtype1045, _size1043 ) = iprot.readMapBegin()
+ for _i1047 in xrange(_size1043):
+ _key1048 = iprot.readString()
+ _val1049 = iprot.readString()
+ self.part_vals[_key1048] = _val1049
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25927,9 +26345,9 @@ class markPartitionForEvent_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
- for kiter1043,viter1044 in self.part_vals.items():
- oprot.writeString(kiter1043)
- oprot.writeString(viter1044)
+ for kiter1050,viter1051 in self.part_vals.items():
+ oprot.writeString(kiter1050)
+ oprot.writeString(viter1051)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -26143,11 +26561,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1046, _vtype1047, _size1045 ) = iprot.readMapBegin()
- for _i1049 in xrange(_size1045):
- _key1050 = iprot.readString()
- _val1051 = iprot.readString()
- self.part_vals[_key1050] = _val1051
+ (_ktype1053, _vtype1054, _size1052 ) = iprot.readMapBegin()
+ for _i1056 in xrange(_size1052):
+ _key1057 = iprot.readString()
+ _val1058 = iprot.readString()
+ self.part_vals[_key1057] = _val1058
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -26177,9 +26595,9 @@ class isPartitionMarkedForEvent_args:
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.MAP, 3)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.part_vals))
- for kiter1052,viter1053 in self.part_vals.items():
- oprot.writeString(kiter1052)
- oprot.writeString(viter1053)
+ for kiter1059,viter1060 in self.part_vals.items():
+ oprot.writeString(kiter1059)
+ oprot.writeString(viter1060)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -27234,11 +27652,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1057, _size1054) = iprot.readListBegin()
- for _i1058 in xrange(_size1054):
- _elem1059 = Index()
- _elem1059.read(iprot)
- self.success.append(_elem1059)
+ (_etype1064, _size1061) = iprot.readListBegin()
+ for _i1065 in xrange(_size1061):
+ _elem1066 = Index()
+ _elem1066.read(iprot)
+ self.success.append(_elem1066)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27267,346 +27685,10 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1060 in self.success:
- iter1060.write(oprot)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.o1 is not None:
- oprot.writeFieldBegin('o1', TType.STRUCT, 1)
- self.o1.write(oprot)
- oprot.writeFieldEnd()
- if self.o2 is not None:
- oprot.writeFieldBegin('o2', TType.STRUCT, 2)
- self.o2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.o1)
- value = (value * 31) ^ hash(self.o2)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_index_names_args:
- """
- Attributes:
- - db_name
- - tbl_name
- - max_indexes
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'db_name', None, None, ), # 1
- (2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.I16, 'max_indexes', None, -1, ), # 3
- )
-
- def __init__(self, db_name=None, tbl_name=None, max_indexes=thrift_spec[3][4],):
- self.db_name = db_name
- self.tbl_name = tbl_name
- self.max_indexes = max_indexes
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRING:
- self.db_name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRING:
- self.tbl_name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.I16:
- self.max_indexes = iprot.readI16()
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_index_names_args')
- if self.db_name is not None:
- oprot.writeFieldBegin('db_name', TType.STRING, 1)
- oprot.writeString(self.db_name)
- oprot.writeFieldEnd()
- if self.tbl_name is not None:
- oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
- oprot.writeString(self.tbl_name)
- oprot.writeFieldEnd()
- if self.max_indexes is not None:
- oprot.writeFieldBegin('max_indexes', TType.I16, 3)
- oprot.writeI16(self.max_indexes)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.db_name)
- value = (value * 31) ^ hash(self.tbl_name)
- value = (value * 31) ^ hash(self.max_indexes)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_index_names_result:
- """
- Attributes:
- - success
- - o2
- """
-
- thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRING,None), None, ), # 0
- (1, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 1
- )
-
- def __init__(self, success=None, o2=None,):
- self.success = success
- self.o2 = o2
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype1064, _size1061) = iprot.readListBegin()
- for _i1065 in xrange(_size1061):
- _elem1066 = iprot.readString()
- self.success.append(_elem1066)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.o2 = MetaException()
- self.o2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_index_names_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRING, len(self.success))
for iter1067 in self.success:
- oprot.writeString(iter1067)
+ iter1067.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.o2 is not None:
- oprot.writeFieldBegin('o2', TType.STRUCT, 1)
- self.o2.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.success)
- value = (value * 31) ^ hash(self.o2)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_primary_keys_args:
- """
- Attributes:
- - request
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRUCT, 'request', (PrimaryKeysRequest, PrimaryKeysRequest.thrift_spec), None, ), # 1
- )
-
- def __init__(self, request=None,):
- self.request = request
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 1:
- if ftype == TType.STRUCT:
- self.request = PrimaryKeysRequest()
- self.request.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_primary_keys_args')
- if self.request is not None:
- oprot.writeFieldBegin('request', TType.STRUCT, 1)
- self.request.write(oprot)
- oprot.writeFieldEnd()
- oprot.writeFieldStop()
- oprot.writeStructEnd()
-
- def validate(self):
- return
-
-
- def __hash__(self):
- value = 17
- value = (value * 31) ^ hash(self.request)
- return value
-
- def __repr__(self):
- L = ['%s=%r' % (key, value)
- for key, value in self.__dict__.iteritems()]
- return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
-
- def __eq__(self, other):
- return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
-
- def __ne__(self, other):
- return not (self == other)
-
-class get_primary_keys_result:
- """
- Attributes:
- - success
- - o1
- - o2
- """
-
- thrift_spec = (
- (0, TType.STRUCT, 'success', (PrimaryKeysResponse, PrimaryKeysResponse.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
- )
-
- def __init__(self, success=None, o1=None, o2=None,):
- self.success = success
- self.o1 = o1
- self.o2 = o2
-
- def read(self, iprot):
- if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
- fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
- return
- iprot.readStructBegin()
- while True:
- (fname, ftype, fid) = iprot.readFieldBegin()
- if ftype == TType.STOP:
- break
- if fid == 0:
- if ftype == TType.STRUCT:
- self.success = PrimaryKeysResponse()
- self.success.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 1:
- if ftype == TType.STRUCT:
- self.o1 = MetaException()
- self.o1.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 2:
- if ftype == TType.STRUCT:
- self.o2 = NoSuchObjectException()
- self.o2.read(iprot)
- else:
- iprot.skip(ftype)
- else:
- iprot.skip(ftype)
- iprot.readFieldEnd()
- iprot.readStructEnd()
-
- def write(self, oprot):
- if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
- oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
- return
- oprot.writeStructBegin('get_primary_keys_result')
- if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
- oprot.writeFieldEnd()
if self.o1 is not None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
self.o1.write(oprot)
@@ -27640,7 +27722,184 @@ class get_primary_keys_result:
def __ne__(self, other):
return not (self == other)
-class get_foreign_keys_args:
+class get_index_names_args:
+ """
+ Attributes:
+ - db_name
+ - tbl_name
+ - max_indexes
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ (3, TType.I16, 'max_indexes', None, -1, ), # 3
+ )
+
+ def __init__(self, db_name=None, tbl_name=None, max_indexes=thrift_spec[3][4],):
+ self.db_name = db_name
+ self.tbl_name = tbl_name
+ self.max_indexes = max_indexes
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.db_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.tbl_name = iprot.r
<TRUNCATED>