You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2016/05/11 20:31:33 UTC
[03/12] hive git commit: HIVE-13350: Support Alter commands for
Rely/NoRely novalidate for PK/FK constraints (Hari Subramaniyan,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/b36f6a3a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 8eef585..0d70bb2 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -172,6 +172,20 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def add_primary_key(self, req):
+ """
+ Parameters:
+ - req
+ """
+ pass
+
+ def add_foreign_key(self, req):
+ """
+ Parameters:
+ - req
+ """
+ pass
+
def drop_table(self, dbname, name, deleteData):
"""
Parameters:
@@ -1915,6 +1929,72 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o3
return
+ def add_primary_key(self, req):
+ """
+ Parameters:
+ - req
+ """
+ self.send_add_primary_key(req)
+ self.recv_add_primary_key()
+
+ def send_add_primary_key(self, req):
+ self._oprot.writeMessageBegin('add_primary_key', TMessageType.CALL, self._seqid)
+ args = add_primary_key_args()
+ args.req = req
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_add_primary_key(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = add_primary_key_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 add_foreign_key(self, req):
+ """
+ Parameters:
+ - req
+ """
+ self.send_add_foreign_key(req)
+ self.recv_add_foreign_key()
+
+ def send_add_foreign_key(self, req):
+ self._oprot.writeMessageBegin('add_foreign_key', TMessageType.CALL, self._seqid)
+ args = add_foreign_key_args()
+ args.req = req
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_add_foreign_key(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = add_foreign_key_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 drop_table(self, dbname, name, deleteData):
"""
Parameters:
@@ -6540,6 +6620,8 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["create_table_with_environment_context"] = Processor.process_create_table_with_environment_context
self._processMap["create_table_with_constraints"] = Processor.process_create_table_with_constraints
self._processMap["drop_constraint"] = Processor.process_drop_constraint
+ self._processMap["add_primary_key"] = Processor.process_add_primary_key
+ self._processMap["add_foreign_key"] = Processor.process_add_foreign_key
self._processMap["drop_table"] = Processor.process_drop_table
self._processMap["drop_table_with_environment_context"] = Processor.process_drop_table_with_environment_context
self._processMap["get_tables"] = Processor.process_get_tables
@@ -7207,6 +7289,56 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_add_primary_key(self, seqid, iprot, oprot):
+ args = add_primary_key_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = add_primary_key_result()
+ try:
+ self._handler.add_primary_key(args.req)
+ 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("add_primary_key", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_add_foreign_key(self, seqid, iprot, oprot):
+ args = add_foreign_key_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = add_foreign_key_result()
+ try:
+ self._handler.add_foreign_key(args.req)
+ 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("add_foreign_key", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_drop_table(self, seqid, iprot, oprot):
args = drop_table_args()
args.read(iprot)
@@ -11166,10 +11298,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype546, _size543) = iprot.readListBegin()
- for _i547 in xrange(_size543):
- _elem548 = iprot.readString()
- self.success.append(_elem548)
+ (_etype560, _size557) = iprot.readListBegin()
+ for _i561 in xrange(_size557):
+ _elem562 = iprot.readString()
+ self.success.append(_elem562)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11192,8 +11324,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 iter549 in self.success:
- oprot.writeString(iter549)
+ for iter563 in self.success:
+ oprot.writeString(iter563)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11298,10 +11430,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype553, _size550) = iprot.readListBegin()
- for _i554 in xrange(_size550):
- _elem555 = iprot.readString()
- self.success.append(_elem555)
+ (_etype567, _size564) = iprot.readListBegin()
+ for _i568 in xrange(_size564):
+ _elem569 = iprot.readString()
+ self.success.append(_elem569)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11324,8 +11456,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 iter556 in self.success:
- oprot.writeString(iter556)
+ for iter570 in self.success:
+ oprot.writeString(iter570)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12095,12 +12227,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype558, _vtype559, _size557 ) = iprot.readMapBegin()
- for _i561 in xrange(_size557):
- _key562 = iprot.readString()
- _val563 = Type()
- _val563.read(iprot)
- self.success[_key562] = _val563
+ (_ktype572, _vtype573, _size571 ) = iprot.readMapBegin()
+ for _i575 in xrange(_size571):
+ _key576 = iprot.readString()
+ _val577 = Type()
+ _val577.read(iprot)
+ self.success[_key576] = _val577
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12123,9 +12255,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 kiter564,viter565 in self.success.items():
- oprot.writeString(kiter564)
- viter565.write(oprot)
+ for kiter578,viter579 in self.success.items():
+ oprot.writeString(kiter578)
+ viter579.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -12268,11 +12400,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype569, _size566) = iprot.readListBegin()
- for _i570 in xrange(_size566):
- _elem571 = FieldSchema()
- _elem571.read(iprot)
- self.success.append(_elem571)
+ (_etype583, _size580) = iprot.readListBegin()
+ for _i584 in xrange(_size580):
+ _elem585 = FieldSchema()
+ _elem585.read(iprot)
+ self.success.append(_elem585)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12307,8 +12439,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 iter572 in self.success:
- iter572.write(oprot)
+ for iter586 in self.success:
+ iter586.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12475,11 +12607,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype576, _size573) = iprot.readListBegin()
- for _i577 in xrange(_size573):
- _elem578 = FieldSchema()
- _elem578.read(iprot)
- self.success.append(_elem578)
+ (_etype590, _size587) = iprot.readListBegin()
+ for _i591 in xrange(_size587):
+ _elem592 = FieldSchema()
+ _elem592.read(iprot)
+ self.success.append(_elem592)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12514,8 +12646,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 iter579 in self.success:
- iter579.write(oprot)
+ for iter593 in self.success:
+ iter593.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12668,11 +12800,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype583, _size580) = iprot.readListBegin()
- for _i584 in xrange(_size580):
- _elem585 = FieldSchema()
- _elem585.read(iprot)
- self.success.append(_elem585)
+ (_etype597, _size594) = iprot.readListBegin()
+ for _i598 in xrange(_size594):
+ _elem599 = FieldSchema()
+ _elem599.read(iprot)
+ self.success.append(_elem599)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12707,8 +12839,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 iter586 in self.success:
- iter586.write(oprot)
+ for iter600 in self.success:
+ iter600.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12875,11 +13007,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype590, _size587) = iprot.readListBegin()
- for _i591 in xrange(_size587):
- _elem592 = FieldSchema()
- _elem592.read(iprot)
- self.success.append(_elem592)
+ (_etype604, _size601) = iprot.readListBegin()
+ for _i605 in xrange(_size601):
+ _elem606 = FieldSchema()
+ _elem606.read(iprot)
+ self.success.append(_elem606)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12914,8 +13046,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 iter593 in self.success:
- iter593.write(oprot)
+ for iter607 in self.success:
+ iter607.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13356,22 +13488,22 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype597, _size594) = iprot.readListBegin()
- for _i598 in xrange(_size594):
- _elem599 = SQLPrimaryKey()
- _elem599.read(iprot)
- self.primaryKeys.append(_elem599)
+ (_etype611, _size608) = iprot.readListBegin()
+ for _i612 in xrange(_size608):
+ _elem613 = SQLPrimaryKey()
+ _elem613.read(iprot)
+ self.primaryKeys.append(_elem613)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype603, _size600) = iprot.readListBegin()
- for _i604 in xrange(_size600):
- _elem605 = SQLForeignKey()
- _elem605.read(iprot)
- self.foreignKeys.append(_elem605)
+ (_etype617, _size614) = iprot.readListBegin()
+ for _i618 in xrange(_size614):
+ _elem619 = SQLForeignKey()
+ _elem619.read(iprot)
+ self.foreignKeys.append(_elem619)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13392,15 +13524,15 @@ 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 iter606 in self.primaryKeys:
- iter606.write(oprot)
+ for iter620 in self.primaryKeys:
+ iter620.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 iter607 in self.foreignKeys:
- iter607.write(oprot)
+ for iter621 in self.foreignKeys:
+ iter621.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13682,6 +13814,298 @@ class drop_constraint_result:
def __ne__(self, other):
return not (self == other)
+class add_primary_key_args:
+ """
+ Attributes:
+ - req
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'req', (AddPrimaryKeyRequest, AddPrimaryKeyRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, req=None,):
+ self.req = req
+
+ 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.req = AddPrimaryKeyRequest()
+ self.req.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('add_primary_key_args')
+ if self.req is not None:
+ oprot.writeFieldBegin('req', TType.STRUCT, 1)
+ self.req.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.req)
+ 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 add_primary_key_result:
+ """
+ Attributes:
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, o1=None, o2=None,):
+ 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 == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = NoSuchObjectException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ 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('add_primary_key_result')
+ 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.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 add_foreign_key_args:
+ """
+ Attributes:
+ - req
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'req', (AddForeignKeyRequest, AddForeignKeyRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, req=None,):
+ self.req = req
+
+ 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.req = AddForeignKeyRequest()
+ self.req.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('add_foreign_key_args')
+ if self.req is not None:
+ oprot.writeFieldBegin('req', TType.STRUCT, 1)
+ self.req.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.req)
+ 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 add_foreign_key_result:
+ """
+ Attributes:
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, o1=None, o2=None,):
+ 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 == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = NoSuchObjectException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ 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('add_foreign_key_result')
+ 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.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 drop_table_args:
"""
Attributes:
@@ -14144,10 +14568,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype611, _size608) = iprot.readListBegin()
- for _i612 in xrange(_size608):
- _elem613 = iprot.readString()
- self.success.append(_elem613)
+ (_etype625, _size622) = iprot.readListBegin()
+ for _i626 in xrange(_size622):
+ _elem627 = iprot.readString()
+ self.success.append(_elem627)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14170,8 +14594,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 iter614 in self.success:
- oprot.writeString(iter614)
+ for iter628 in self.success:
+ oprot.writeString(iter628)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14244,10 +14668,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype618, _size615) = iprot.readListBegin()
- for _i619 in xrange(_size615):
- _elem620 = iprot.readString()
- self.tbl_types.append(_elem620)
+ (_etype632, _size629) = iprot.readListBegin()
+ for _i633 in xrange(_size629):
+ _elem634 = iprot.readString()
+ self.tbl_types.append(_elem634)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14272,8 +14696,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 iter621 in self.tbl_types:
- oprot.writeString(iter621)
+ for iter635 in self.tbl_types:
+ oprot.writeString(iter635)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14329,11 +14753,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype625, _size622) = iprot.readListBegin()
- for _i626 in xrange(_size622):
- _elem627 = TableMeta()
- _elem627.read(iprot)
- self.success.append(_elem627)
+ (_etype639, _size636) = iprot.readListBegin()
+ for _i640 in xrange(_size636):
+ _elem641 = TableMeta()
+ _elem641.read(iprot)
+ self.success.append(_elem641)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14356,8 +14780,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 iter628 in self.success:
- iter628.write(oprot)
+ for iter642 in self.success:
+ iter642.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14481,10 +14905,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype632, _size629) = iprot.readListBegin()
- for _i633 in xrange(_size629):
- _elem634 = iprot.readString()
- self.success.append(_elem634)
+ (_etype646, _size643) = iprot.readListBegin()
+ for _i647 in xrange(_size643):
+ _elem648 = iprot.readString()
+ self.success.append(_elem648)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14507,8 +14931,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 iter635 in self.success:
- oprot.writeString(iter635)
+ for iter649 in self.success:
+ oprot.writeString(iter649)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14744,10 +15168,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype639, _size636) = iprot.readListBegin()
- for _i640 in xrange(_size636):
- _elem641 = iprot.readString()
- self.tbl_names.append(_elem641)
+ (_etype653, _size650) = iprot.readListBegin()
+ for _i654 in xrange(_size650):
+ _elem655 = iprot.readString()
+ self.tbl_names.append(_elem655)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14768,8 +15192,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 iter642 in self.tbl_names:
- oprot.writeString(iter642)
+ for iter656 in self.tbl_names:
+ oprot.writeString(iter656)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14830,11 +15254,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype646, _size643) = iprot.readListBegin()
- for _i647 in xrange(_size643):
- _elem648 = Table()
- _elem648.read(iprot)
- self.success.append(_elem648)
+ (_etype660, _size657) = iprot.readListBegin()
+ for _i661 in xrange(_size657):
+ _elem662 = Table()
+ _elem662.read(iprot)
+ self.success.append(_elem662)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14869,8 +15293,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 iter649 in self.success:
- iter649.write(oprot)
+ for iter663 in self.success:
+ iter663.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15036,10 +15460,10 @@ class get_table_names_by_filter_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)
+ (_etype667, _size664) = iprot.readListBegin()
+ for _i668 in xrange(_size664):
+ _elem669 = iprot.readString()
+ self.success.append(_elem669)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15074,8 +15498,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 iter656 in self.success:
- oprot.writeString(iter656)
+ for iter670 in self.success:
+ oprot.writeString(iter670)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16045,11 +16469,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = Partition()
- _elem662.read(iprot)
- self.new_parts.append(_elem662)
+ (_etype674, _size671) = iprot.readListBegin()
+ for _i675 in xrange(_size671):
+ _elem676 = Partition()
+ _elem676.read(iprot)
+ self.new_parts.append(_elem676)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16066,8 +16490,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 iter663 in self.new_parts:
- iter663.write(oprot)
+ for iter677 in self.new_parts:
+ iter677.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16225,11 +16649,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype667, _size664) = iprot.readListBegin()
- for _i668 in xrange(_size664):
- _elem669 = PartitionSpec()
- _elem669.read(iprot)
- self.new_parts.append(_elem669)
+ (_etype681, _size678) = iprot.readListBegin()
+ for _i682 in xrange(_size678):
+ _elem683 = PartitionSpec()
+ _elem683.read(iprot)
+ self.new_parts.append(_elem683)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16246,8 +16670,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 iter670 in self.new_parts:
- iter670.write(oprot)
+ for iter684 in self.new_parts:
+ iter684.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16421,10 +16845,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype674, _size671) = iprot.readListBegin()
- for _i675 in xrange(_size671):
- _elem676 = iprot.readString()
- self.part_vals.append(_elem676)
+ (_etype688, _size685) = iprot.readListBegin()
+ for _i689 in xrange(_size685):
+ _elem690 = iprot.readString()
+ self.part_vals.append(_elem690)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16449,8 +16873,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 iter677 in self.part_vals:
- oprot.writeString(iter677)
+ for iter691 in self.part_vals:
+ oprot.writeString(iter691)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16803,10 +17227,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype681, _size678) = iprot.readListBegin()
- for _i682 in xrange(_size678):
- _elem683 = iprot.readString()
- self.part_vals.append(_elem683)
+ (_etype695, _size692) = iprot.readListBegin()
+ for _i696 in xrange(_size692):
+ _elem697 = iprot.readString()
+ self.part_vals.append(_elem697)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16837,8 +17261,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 iter684 in self.part_vals:
- oprot.writeString(iter684)
+ for iter698 in self.part_vals:
+ oprot.writeString(iter698)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -17433,10 +17857,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype688, _size685) = iprot.readListBegin()
- for _i689 in xrange(_size685):
- _elem690 = iprot.readString()
- self.part_vals.append(_elem690)
+ (_etype702, _size699) = iprot.readListBegin()
+ for _i703 in xrange(_size699):
+ _elem704 = iprot.readString()
+ self.part_vals.append(_elem704)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17466,8 +17890,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 iter691 in self.part_vals:
- oprot.writeString(iter691)
+ for iter705 in self.part_vals:
+ oprot.writeString(iter705)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -17640,10 +18064,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype695, _size692) = iprot.readListBegin()
- for _i696 in xrange(_size692):
- _elem697 = iprot.readString()
- self.part_vals.append(_elem697)
+ (_etype709, _size706) = iprot.readListBegin()
+ for _i710 in xrange(_size706):
+ _elem711 = iprot.readString()
+ self.part_vals.append(_elem711)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17679,8 +18103,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 iter698 in self.part_vals:
- oprot.writeString(iter698)
+ for iter712 in self.part_vals:
+ oprot.writeString(iter712)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -18417,10 +18841,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype702, _size699) = iprot.readListBegin()
- for _i703 in xrange(_size699):
- _elem704 = iprot.readString()
- self.part_vals.append(_elem704)
+ (_etype716, _size713) = iprot.readListBegin()
+ for _i717 in xrange(_size713):
+ _elem718 = iprot.readString()
+ self.part_vals.append(_elem718)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18445,8 +18869,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 iter705 in self.part_vals:
- oprot.writeString(iter705)
+ for iter719 in self.part_vals:
+ oprot.writeString(iter719)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18605,11 +19029,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype707, _vtype708, _size706 ) = iprot.readMapBegin()
- for _i710 in xrange(_size706):
- _key711 = iprot.readString()
- _val712 = iprot.readString()
- self.partitionSpecs[_key711] = _val712
+ (_ktype721, _vtype722, _size720 ) = iprot.readMapBegin()
+ for _i724 in xrange(_size720):
+ _key725 = iprot.readString()
+ _val726 = iprot.readString()
+ self.partitionSpecs[_key725] = _val726
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18646,9 +19070,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 kiter713,viter714 in self.partitionSpecs.items():
- oprot.writeString(kiter713)
- oprot.writeString(viter714)
+ for kiter727,viter728 in self.partitionSpecs.items():
+ oprot.writeString(kiter727)
+ oprot.writeString(viter728)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -18853,11 +19277,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype716, _vtype717, _size715 ) = iprot.readMapBegin()
- for _i719 in xrange(_size715):
- _key720 = iprot.readString()
- _val721 = iprot.readString()
- self.partitionSpecs[_key720] = _val721
+ (_ktype730, _vtype731, _size729 ) = iprot.readMapBegin()
+ for _i733 in xrange(_size729):
+ _key734 = iprot.readString()
+ _val735 = iprot.readString()
+ self.partitionSpecs[_key734] = _val735
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18894,9 +19318,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 kiter722,viter723 in self.partitionSpecs.items():
- oprot.writeString(kiter722)
- oprot.writeString(viter723)
+ for kiter736,viter737 in self.partitionSpecs.items():
+ oprot.writeString(kiter736)
+ oprot.writeString(viter737)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -18979,11 +19403,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype727, _size724) = iprot.readListBegin()
- for _i728 in xrange(_size724):
- _elem729 = Partition()
- _elem729.read(iprot)
- self.success.append(_elem729)
+ (_etype741, _size738) = iprot.readListBegin()
+ for _i742 in xrange(_size738):
+ _elem743 = Partition()
+ _elem743.read(iprot)
+ self.success.append(_elem743)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19024,8 +19448,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 iter730 in self.success:
- iter730.write(oprot)
+ for iter744 in self.success:
+ iter744.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19119,10 +19543,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype734, _size731) = iprot.readListBegin()
- for _i735 in xrange(_size731):
- _elem736 = iprot.readString()
- self.part_vals.append(_elem736)
+ (_etype748, _size745) = iprot.readListBegin()
+ for _i749 in xrange(_size745):
+ _elem750 = iprot.readString()
+ self.part_vals.append(_elem750)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19134,10 +19558,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype740, _size737) = iprot.readListBegin()
- for _i741 in xrange(_size737):
- _elem742 = iprot.readString()
- self.group_names.append(_elem742)
+ (_etype754, _size751) = iprot.readListBegin()
+ for _i755 in xrange(_size751):
+ _elem756 = iprot.readString()
+ self.group_names.append(_elem756)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19162,8 +19586,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 iter743 in self.part_vals:
- oprot.writeString(iter743)
+ for iter757 in self.part_vals:
+ oprot.writeString(iter757)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -19173,8 +19597,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 iter744 in self.group_names:
- oprot.writeString(iter744)
+ for iter758 in self.group_names:
+ oprot.writeString(iter758)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19603,11 +20027,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype748, _size745) = iprot.readListBegin()
- for _i749 in xrange(_size745):
- _elem750 = Partition()
- _elem750.read(iprot)
- self.success.append(_elem750)
+ (_etype762, _size759) = iprot.readListBegin()
+ for _i763 in xrange(_size759):
+ _elem764 = Partition()
+ _elem764.read(iprot)
+ self.success.append(_elem764)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19636,8 +20060,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 iter751 in self.success:
- iter751.write(oprot)
+ for iter765 in self.success:
+ iter765.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19731,10 +20155,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype755, _size752) = iprot.readListBegin()
- for _i756 in xrange(_size752):
- _elem757 = iprot.readString()
- self.group_names.append(_elem757)
+ (_etype769, _size766) = iprot.readListBegin()
+ for _i770 in xrange(_size766):
+ _elem771 = iprot.readString()
+ self.group_names.append(_elem771)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19767,8 +20191,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 iter758 in self.group_names:
- oprot.writeString(iter758)
+ for iter772 in self.group_names:
+ oprot.writeString(iter772)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19829,11 +20253,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype762, _size759) = iprot.readListBegin()
- for _i763 in xrange(_size759):
- _elem764 = Partition()
- _elem764.read(iprot)
- self.success.append(_elem764)
+ (_etype776, _size773) = iprot.readListBegin()
+ for _i777 in xrange(_size773):
+ _elem778 = Partition()
+ _elem778.read(iprot)
+ self.success.append(_elem778)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19862,8 +20286,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 iter765 in self.success:
- iter765.write(oprot)
+ for iter779 in self.success:
+ iter779.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20021,11 +20445,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype769, _size766) = iprot.readListBegin()
- for _i770 in xrange(_size766):
- _elem771 = PartitionSpec()
- _elem771.read(iprot)
- self.success.append(_elem771)
+ (_etype783, _size780) = iprot.readListBegin()
+ for _i784 in xrange(_size780):
+ _elem785 = PartitionSpec()
+ _elem785.read(iprot)
+ self.success.append(_elem785)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20054,8 +20478,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 iter772 in self.success:
- iter772.write(oprot)
+ for iter786 in self.success:
+ iter786.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20210,10 +20634,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype776, _size773) = iprot.readListBegin()
- for _i777 in xrange(_size773):
- _elem778 = iprot.readString()
- self.success.append(_elem778)
+ (_etype790, _size787) = iprot.readListBegin()
+ for _i791 in xrange(_size787):
+ _elem792 = iprot.readString()
+ self.success.append(_elem792)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20236,8 +20660,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 iter779 in self.success:
- oprot.writeString(iter779)
+ for iter793 in self.success:
+ oprot.writeString(iter793)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -20313,10 +20737,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype783, _size780) = iprot.readListBegin()
- for _i784 in xrange(_size780):
- _elem785 = iprot.readString()
- self.part_vals.append(_elem785)
+ (_etype797, _size794) = iprot.readListBegin()
+ for _i798 in xrange(_size794):
+ _elem799 = iprot.readString()
+ self.part_vals.append(_elem799)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20346,8 +20770,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 iter786 in self.part_vals:
- oprot.writeString(iter786)
+ for iter800 in self.part_vals:
+ oprot.writeString(iter800)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -20411,11 +20835,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype790, _size787) = iprot.readListBegin()
- for _i791 in xrange(_size787):
- _elem792 = Partition()
- _elem792.read(iprot)
- self.success.append(_elem792)
+ (_etype804, _size801) = iprot.readListBegin()
+ for _i805 in xrange(_size801):
+ _elem806 = Partition()
+ _elem806.read(iprot)
+ self.success.append(_elem806)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20444,8 +20868,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 iter793 in self.success:
- iter793.write(oprot)
+ for iter807 in self.success:
+ iter807.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20532,10 +20956,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype797, _size794) = iprot.readListBegin()
- for _i798 in xrange(_size794):
- _elem799 = iprot.readString()
- self.part_vals.append(_elem799)
+ (_etype811, _size808) = iprot.readListBegin()
+ for _i812 in xrange(_size808):
+ _elem813 = iprot.readString()
+ self.part_vals.append(_elem813)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20552,10 +20976,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype803, _size800) = iprot.readListBegin()
- for _i804 in xrange(_size800):
- _elem805 = iprot.readString()
- self.group_names.append(_elem805)
+ (_etype817, _size814) = iprot.readListBegin()
+ for _i818 in xrange(_size814):
+ _elem819 = iprot.readString()
+ self.group_names.append(_elem819)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20580,8 +21004,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 iter806 in self.part_vals:
- oprot.writeString(iter806)
+ for iter820 in self.part_vals:
+ oprot.writeString(iter820)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -20595,8 +21019,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 iter807 in self.group_names:
- oprot.writeString(iter807)
+ for iter821 in self.group_names:
+ oprot.writeString(iter821)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20658,11 +21082,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype811, _size808) = iprot.readListBegin()
- for _i812 in xrange(_size808):
- _elem813 = Partition()
- _elem813.read(iprot)
- self.success.append(_elem813)
+ (_etype825, _size822) = iprot.readListBegin()
+ for _i826 in xrange(_size822):
+ _elem827 = Partition()
+ _elem827.read(iprot)
+ self.success.append(_elem827)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20691,8 +21115,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 iter814 in self.success:
- iter814.write(oprot)
+ for iter828 in self.success:
+ iter828.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20773,10 +21197,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype818, _size815) = iprot.readListBegin()
- for _i819 in xrange(_size815):
- _elem820 = iprot.readString()
- self.part_vals.append(_elem820)
+ (_etype832, _size829) = iprot.readListBegin()
+ for _i833 in xrange(_size829):
+ _elem834 = iprot.readString()
+ self.part_vals.append(_elem834)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20806,8 +21230,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 iter821 in self.part_vals:
- oprot.writeString(iter821)
+ for iter835 in self.part_vals:
+ oprot.writeString(iter835)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -20871,10 +21295,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype825, _size822) = iprot.readListBegin()
- for _i826 in xrange(_size822):
- _elem827 = iprot.readString()
- self.success.append(_elem827)
+ (_etype839, _size836) = iprot.readListBegin()
+ for _i840 in xrange(_size836):
+ _elem841 = iprot.readString()
+ self.success.append(_elem841)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20903,8 +21327,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 iter828 in self.success:
- oprot.writeString(iter828)
+ for iter842 in self.success:
+ oprot.writeString(iter842)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21075,11 +21499,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype832, _size829) = iprot.readListBegin()
- for _i833 in xrange(_size829):
- _elem834 = Partition()
- _elem834.read(iprot)
- self.success.append(_elem834)
+ (_etype846, _size843) = iprot.readListBegin()
+ for _i847 in xrange(_size843):
+ _elem848 = Partition()
+ _elem848.read(iprot)
+ self.success.append(_elem848)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21108,8 +21532,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 iter835 in self.success:
- iter835.write(oprot)
+ for iter849 in self.success:
+ iter849.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21280,11 +21704,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype839, _size836) = iprot.readListBegin()
- for _i840 in xrange(_size836):
- _elem841 = PartitionSpec()
- _elem841.read(iprot)
- self.success.append(_elem841)
+ (_etype853, _size850) = iprot.readListBegin()
+ for _i854 in xrange(_size850):
+ _elem855 = PartitionSpec()
+ _elem855.read(iprot)
+ self.success.append(_elem855)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21313,8 +21737,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 iter842 in self.success:
- iter842.write(oprot)
+ for iter856 in self.success:
+ iter856.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21734,10 +22158,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype846, _size843) = iprot.readListBegin()
- for _i847 in xrange(_size843):
- _elem848 = iprot.readString()
- self.names.append(_elem848)
+ (_etype860, _size857) = iprot.readListBegin()
+ for _i861 in xrange(_size857):
+ _elem862 = iprot.readString()
+ self.names.append(_elem862)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21762,8 +22186,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 iter849 in self.names:
- oprot.writeString(iter849)
+ for iter863 in self.names:
+ oprot.writeString(iter863)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21822,11 +22246,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype853, _size850) = iprot.readListBegin()
- for _i854 in xrange(_size850):
- _elem855 = Partition()
- _elem855.read(iprot)
- self.success.append(_elem855)
+ (_etype867, _size864) = iprot.readListBegin()
+ for _i868 in xrange(_size864):
+ _elem869 = Partition()
+ _elem869.read(iprot)
+ self.success.append(_elem869)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21855,8 +22279,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 iter856 in self.success:
- iter856.write(oprot)
+ for iter870 in self.success:
+ iter870.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22106,11 +22530,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype860, _size857) = iprot.readListBegin()
- for _i861 in xrange(_size857):
- _elem862 = Partition()
- _elem862.read(iprot)
- self.new_parts.append(_elem862)
+ (_etype874, _size871) = iprot.readListBegin()
+ for _i875 in xrange(_size871):
+ _elem876 = Partition()
+ _elem876.read(iprot)
+ self.new_parts.append(_elem876)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22135,8 +22559,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 iter863 in self.new_parts:
- iter863.write(oprot)
+ for iter877 in self.new_parts:
+ iter877.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22289,11 +22713,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype867, _size864) = iprot.readListBegin()
- for _i868 in xrange(_size864):
- _elem869 = Partition()
- _elem869.read(iprot)
- self.new_parts.append(_elem869)
+ (_etype881, _size878) = iprot.readListBegin()
+ for _i882 in xrange(_size878):
+ _elem883 = Partition()
+ _elem883.read(iprot)
+ self.new_parts.append(_elem883)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22324,8 +22748,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 iter870 in self.new_parts:
- iter870.write(oprot)
+ for iter884 in self.new_parts:
+ iter884.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -22669,10 +23093,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype874, _size871) = iprot.readListBegin()
- for _i875 in xrange(_size871):
- _elem876 = iprot.readString()
- self.part_vals.append(_elem876)
+ (_etype888, _size885) = iprot.readListBegin()
+ for _i889 in xrange(_size885):
+ _elem890 = iprot.readString()
+ self.part_vals.append(_elem890)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22703,8 +23127,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 iter877 in self.part_vals:
- oprot.writeString(iter877)
+ for iter891 in self.part_vals:
+ oprot.writeString(iter891)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -22846,10 +23270,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype881, _size878) = iprot.readListBegin()
- for _i882 in xrange(_size878):
- _elem883 = iprot.readString()
- self.part_vals.append(_elem883)
+ (_etype895, _size892) = iprot.readListBegin()
+ for _i896 in xrange(_size892):
+ _elem897 = iprot.readString()
+ self.part_vals.append(_elem897)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22871,8 +23295,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 iter884 in self.part_vals:
- oprot.writeString(iter884)
+ for iter898 in self.part_vals:
+ oprot.writeString(iter898)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -23230,10 +23654,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype888, _size885) = iprot.readListBegin()
- for _i889 in xrange(_size885):
- _elem890 = iprot.readString()
- self.success.append(_elem890)
+ (_etype902, _size899) = iprot.readListBegin()
+ for _i903 in xrange(_size899):
+ _elem904 = iprot.readString()
+ self.success.append(_elem904)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23256,8 +23680,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 iter891 in self.success:
- oprot.writeString(iter891)
+ for iter905 in self.success:
+ oprot.writeString(iter905)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23381,11 +23805,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype893, _vtype894, _size892 ) = iprot.readMapBegin()
- for _i896 in xrange(_size892):
- _key897 = iprot.readString()
- _val898 = iprot.readString()
- self.success[_key897] = _val898
+ (_ktype907, _vtype908, _size906 ) = iprot.readMapBegin()
+ for _i910 in xrange(_size906):
+ _key911 = iprot.readString()
+ _val912 = iprot.readString()
+ self.success[_key911] = _val912
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -23408,9 +23832,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 kiter899,viter900 in self.success.items():
- oprot.writeString(kiter899)
- oprot.writeString(viter900)
+ for kiter913,viter914 in self.success.items():
+ oprot.writeString(kiter913)
+ oprot.writeString(viter914)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23486,11 +23910,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype902, _vtype903, _size901 ) = iprot.readMapBegin()
- for _i905 in xrange(_size901):
- _key906 = iprot.readString()
- _val907 = iprot.readString()
- self.part_vals[_key906] = _val907
+ (_ktype916, _vtype917, _size915 ) = iprot.readMapBegin()
+ for _i919 in xrange(_size915):
+ _key920 = iprot.readString()
+ _val921 = iprot.readString()
+ self.part_vals[_key920] = _val921
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -23520,9 +23944,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 kiter908,viter909 in self.part_vals.items():
- oprot.writeString(kiter908)
- oprot.writeString(viter909)
+ for kiter922,viter923 in self.part_vals.items():
+ oprot.writeString(kiter922)
+ oprot.writeString(viter923)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -23736,11 +24160,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype911, _vtype912, _size910 ) = iprot.readMapBegin()
- for _i914 in xrange(_size910):
- _key915 = iprot.readString()
- _val916 = iprot.readString()
- self.part_vals[_key915] = _val916
+ (_ktype925, _vtype926, _size924 ) = iprot.readMapBegin()
+ for _i928 in xrange(_size924):
+ _key929 = iprot.readString()
+ _val930 = iprot.readString()
+ self.part_vals[_key929] = _val930
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -23770,9 +24194,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 kiter917,viter918 in self.part_vals.items():
- oprot.writeString(kiter917)
- oprot.writeString(viter918)
+ for kiter931,viter932 in self.part_vals.items():
+ oprot.writeString(kiter931)
+ oprot.writeString(viter932)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -24827,11 +25251,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype922, _size919) = iprot.readListBegin()
- for _i923 in xrange(_size919):
- _elem924 = Index()
- _elem924.read(iprot)
- self.success.append(_elem924)
+ (_etype936, _size933) = iprot.readListBegin()
+ for _i937 in xrange(_size933):
+ _elem938 = Index()
+ _elem938.read(iprot)
+ self.success.append(_elem938)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24860,8 +25284,8 @@ class get_indexes_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter925 in self.success:
- iter925.write(oprot)
+ for iter939 in self.success:
+ iter939.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25016,10 +25440,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype929, _size926) = iprot.readListBegin()
- for _i930 in xrange(_size926):
- _elem931 = iprot.readString()
- self.success.append(_elem931)
+ (_etype943, _size940) = iprot.readListBegin()
+ for _i944 in xrange(_size940):
+ _elem945 = iprot.readString()
+ self.success.append(_elem945)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25042,8 +25466,8 @@ class get_index_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter932 in self.success:
- oprot.writeString(iter932)
+ for iter946 in self.success:
+ oprot.writeString(iter946)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -27909,10 +28333,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype936, _size933) = iprot.readListBegin()
- for _i937 in xrange(_size933):
- _elem938 = iprot.readString()
- self.success.append(_elem938)
+ (_etype950, _size947) = iprot.readListBegin()
+ for _i951 in xrange(_size947):
+ _elem952 = iprot.readString()
+ self.success.append(_elem952)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27935,8 +28359,8 @@ class get_functions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter939 in self.success:
- oprot.writeString(iter939)
+ for iter953 in self.success:
+ oprot.writeString(iter953)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28624,10 +29048,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype943, _size940) = iprot.readListBegin()
- for _i944 in xrange(_size940):
- _elem945 = iprot.readString()
- self.success.append(_elem945)
+ (_etype957, _size954) = iprot.readListBegin()
+ for _i958 in xrange(_size954):
+ _elem959 = iprot.readString()
+ self.success.append(_elem959)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28650,8 +29074,8 @@ class get_role_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter946 in self.success:
- oprot.writeString(iter946)
+ for iter960 in self.success:
+ oprot.writeString(iter960)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29165,11 +29589,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype950, _size947) = iprot.readListBegin()
- for _i951 in xrange(_size947):
- _elem952 = Role()
- _elem952.read(iprot)
- self.success.append(_elem952)
+ (_etype964, _size961) = iprot.readListBegin()
+ for _i965 in xrange(_size961):
+ _elem966 = Role()
+ _elem966.read(iprot)
+ self.success.append(_elem966)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29192,8 +29616,8 @@ class list_roles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter953 in self.success:
- iter953.write(oprot)
+ for iter967 in self.success:
+ iter967.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29702,10 +30126,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype957, _size954) = iprot.readListBegin()
- for _i958 in xrange(_size954):
- _elem959 = iprot.readString()
- self.group_names.append(_elem959)
+ (_etype971, _size968) = iprot.readListBegin()
+ for _i972 in xrange(_size968):
+ _elem973 = iprot.readString()
+ self.group_names.append(_elem973)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29730,8 +30154,8 @@ class get_privilege_set_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter960 in self.group_names:
- oprot.writeString(iter960)
+ for iter974 in self.group_names:
+ oprot.writeString(iter974)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29958,11 +30382,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype964, _size961) = iprot.readListBegin()
- for _i965 in xrange(_size961):
- _elem966 = HiveObjectPrivilege()
- _elem966.read(iprot)
- self.success.append(_elem966)
+ (_etype978, _size975) = iprot.readListBegin()
+ for _i979 in xrange(_size975):
+ _elem980 = HiveObjectPrivilege()
+ _elem980.read(iprot)
+ self.success.append(_elem980)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29985,8 +30409,8 @@ class list_privileges_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter967 in self.success:
- iter967.write(oprot)
+ for iter981 in self.success:
+ iter981.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30484,10 +30908,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype971, _size968) = iprot.readListBegin()
- for _i972 in xrange(_size968):
- _elem973 = iprot.readString()
- self.group_names.append(_elem973)
+ (_etype985, _size982) = iprot.readListBegin()
+ for _i986 in xrange(_size982):
+ _elem987 = iprot.readString()
+ self.group_names.append(_elem987)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30508,8 +30932,8 @@ class set_ugi_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter974 in self.group_names:
- oprot.writeString(iter974)
+ for iter988 in self.group_names:
+ oprot.writeString(iter988)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -30564,10 +30988,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype978, _size975) = iprot.readListBegin()
- for _i979 in xrange(_size975):
- _elem980 = iprot.readString()
- self.success.append(_elem980)
+ (_etype992, _size989) = iprot.readListBegin()
+ for _i993 in xrange(_size989):
+ _elem994 = iprot.readString()
+ self.success.append(_elem994)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30590,8 +31014,8 @@ class set_ugi_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter981 in self.success:
- oprot.writeString(iter981)
+ for iter995 in self.success:
+ oprot.writeString(iter995)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -31523,10 +31947,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype985, _size982) = iprot.readListBegin()
- for _i986 in xrange(_size982):
- _elem987 = iprot.readString()
- self.success.append(_elem987)
+ (_etype999, _size996) = iprot.readListBegin()
+ for _i1000 in xrange(_size996):
+ _elem1001 = iprot.readString()
+ self.success.append(_elem1001)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31543,8 +31967,8 @@ class get_all_token_identifiers_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter988 in self.success:
- oprot.writeString(iter988)
+ for iter1002 in self.success:
+ oprot.writeString(iter1002)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -32071,10 +32495,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype992, _size989) = iprot.readListBegin()
- for _i993 in xrange(_size989):
- _elem994 = iprot.readString()
- self.success.append(_elem994)
+ (_etype1006, _size1003) = iprot.readListBegin()
+ for _i1007 in xrange(_size1003):
+ _elem1008 = iprot.readString()
+ self.success.append(_elem1008)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32091,8 +32515,8 @@ class get_master_keys_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter995 in self.success:
- oprot.writeString(iter995)
+ for iter1009 in self.success:
+ oprot.writeString(iter1009)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()