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 2016/09/12 20:24:57 UTC
[25/31] hive git commit: HIVE-14644 : use metastore information on
the read path appropriately (Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/3e481b47/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 1377648..22c0cc6 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -1221,6 +1221,13 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_valid_write_ids(self, req):
+ """
+ Parameters:
+ - req
+ """
+ pass
+
class Client(fb303.FacebookService.Client, Iface):
"""
@@ -6710,6 +6717,37 @@ class Client(fb303.FacebookService.Client, Iface):
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "heartbeat_write_id failed: unknown result")
+ def get_valid_write_ids(self, req):
+ """
+ Parameters:
+ - req
+ """
+ self.send_get_valid_write_ids(req)
+ return self.recv_get_valid_write_ids()
+
+ def send_get_valid_write_ids(self, req):
+ self._oprot.writeMessageBegin('get_valid_write_ids', TMessageType.CALL, self._seqid)
+ args = get_valid_write_ids_args()
+ args.req = req
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_valid_write_ids(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_valid_write_ids_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_valid_write_ids failed: unknown result")
+
class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
def __init__(self, handler):
@@ -6866,6 +6904,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["get_next_write_id"] = Processor.process_get_next_write_id
self._processMap["finalize_write_id"] = Processor.process_finalize_write_id
self._processMap["heartbeat_write_id"] = Processor.process_heartbeat_write_id
+ self._processMap["get_valid_write_ids"] = Processor.process_get_valid_write_ids
def process(self, iprot, oprot):
(name, type, seqid) = iprot.readMessageBegin()
@@ -10586,6 +10625,25 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_valid_write_ids(self, seqid, iprot, oprot):
+ args = get_valid_write_ids_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_valid_write_ids_result()
+ try:
+ result.success = self._handler.get_valid_write_ids(args.req)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("get_valid_write_ids", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
# HELPER FUNCTIONS AND STRUCTURES
@@ -11472,10 +11530,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype569, _size566) = iprot.readListBegin()
- for _i570 in xrange(_size566):
- _elem571 = iprot.readString()
- self.success.append(_elem571)
+ (_etype576, _size573) = iprot.readListBegin()
+ for _i577 in xrange(_size573):
+ _elem578 = iprot.readString()
+ self.success.append(_elem578)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11498,8 +11556,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 iter572 in self.success:
- oprot.writeString(iter572)
+ for iter579 in self.success:
+ oprot.writeString(iter579)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11604,10 +11662,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype576, _size573) = iprot.readListBegin()
- for _i577 in xrange(_size573):
- _elem578 = iprot.readString()
- self.success.append(_elem578)
+ (_etype583, _size580) = iprot.readListBegin()
+ for _i584 in xrange(_size580):
+ _elem585 = iprot.readString()
+ self.success.append(_elem585)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11630,8 +11688,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 iter579 in self.success:
- oprot.writeString(iter579)
+ for iter586 in self.success:
+ oprot.writeString(iter586)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12401,12 +12459,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype581, _vtype582, _size580 ) = iprot.readMapBegin()
- for _i584 in xrange(_size580):
- _key585 = iprot.readString()
- _val586 = Type()
- _val586.read(iprot)
- self.success[_key585] = _val586
+ (_ktype588, _vtype589, _size587 ) = iprot.readMapBegin()
+ for _i591 in xrange(_size587):
+ _key592 = iprot.readString()
+ _val593 = Type()
+ _val593.read(iprot)
+ self.success[_key592] = _val593
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -12429,9 +12487,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 kiter587,viter588 in self.success.items():
- oprot.writeString(kiter587)
- viter588.write(oprot)
+ for kiter594,viter595 in self.success.items():
+ oprot.writeString(kiter594)
+ viter595.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -12574,11 +12632,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype592, _size589) = iprot.readListBegin()
- for _i593 in xrange(_size589):
- _elem594 = FieldSchema()
- _elem594.read(iprot)
- self.success.append(_elem594)
+ (_etype599, _size596) = iprot.readListBegin()
+ for _i600 in xrange(_size596):
+ _elem601 = FieldSchema()
+ _elem601.read(iprot)
+ self.success.append(_elem601)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12613,8 +12671,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 iter595 in self.success:
- iter595.write(oprot)
+ for iter602 in self.success:
+ iter602.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12781,199 +12839,6 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype599, _size596) = iprot.readListBegin()
- for _i600 in xrange(_size596):
- _elem601 = FieldSchema()
- _elem601.read(iprot)
- self.success.append(_elem601)
- iprot.readListEnd()
- 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 = UnknownTableException()
- self.o2.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRUCT:
- self.o3 = UnknownDBException()
- self.o3.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_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 iter602 in self.success:
- iter602.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()
- if self.o3 is not None:
- oprot.writeFieldBegin('o3', TType.STRUCT, 3)
- self.o3.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)
- value = (value * 31) ^ hash(self.o3)
- 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_schema_args:
- """
- Attributes:
- - db_name
- - table_name
- """
-
- thrift_spec = (
- None, # 0
- (1, TType.STRING, 'db_name', None, None, ), # 1
- (2, TType.STRING, 'table_name', None, None, ), # 2
- )
-
- def __init__(self, db_name=None, table_name=None,):
- self.db_name = db_name
- self.table_name = table_name
-
- 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.table_name = iprot.readString()
- 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_schema_args')
- if self.db_name is not None:
- oprot.writeFieldBegin('db_name', TType.STRING, 1)
- oprot.writeString(self.db_name)
- oprot.writeFieldEnd()
- if self.table_name is not None:
- oprot.writeFieldBegin('table_name', TType.STRING, 2)
- oprot.writeString(self.table_name)
- 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.table_name)
- 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_schema_result:
- """
- Attributes:
- - success
- - o1
- - o2
- - o3
- """
-
- thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 0
- (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2
- (3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3
- )
-
- def __init__(self, success=None, o1=None, o2=None, o3=None,):
- self.success = success
- self.o1 = o1
- self.o2 = o2
- self.o3 = o3
-
- 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 = []
(_etype606, _size603) = iprot.readListBegin()
for _i607 in xrange(_size603):
_elem608 = FieldSchema()
@@ -13009,7 +12874,7 @@ class get_schema_result:
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_schema_result')
+ oprot.writeStructBegin('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))
@@ -13055,6 +12920,199 @@ class get_schema_result:
def __ne__(self, other):
return not (self == other)
+class get_schema_args:
+ """
+ Attributes:
+ - db_name
+ - table_name
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'table_name', None, None, ), # 2
+ )
+
+ def __init__(self, db_name=None, table_name=None,):
+ self.db_name = db_name
+ self.table_name = table_name
+
+ 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.table_name = iprot.readString()
+ 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_schema_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.table_name is not None:
+ oprot.writeFieldBegin('table_name', TType.STRING, 2)
+ oprot.writeString(self.table_name)
+ 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.table_name)
+ 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_schema_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ - o3
+ """
+
+ thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRUCT,(FieldSchema, FieldSchema.thrift_spec)), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (UnknownTableException, UnknownTableException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3
+ )
+
+ def __init__(self, success=None, o1=None, o2=None, o3=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+ self.o3 = o3
+
+ 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 = []
+ (_etype613, _size610) = iprot.readListBegin()
+ for _i614 in xrange(_size610):
+ _elem615 = FieldSchema()
+ _elem615.read(iprot)
+ self.success.append(_elem615)
+ iprot.readListEnd()
+ 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 = UnknownTableException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.o3 = UnknownDBException()
+ self.o3.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_schema_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRUCT, len(self.success))
+ for iter616 in self.success:
+ iter616.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()
+ if self.o3 is not None:
+ oprot.writeFieldBegin('o3', TType.STRUCT, 3)
+ self.o3.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)
+ value = (value * 31) ^ hash(self.o3)
+ 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_schema_with_environment_context_args:
"""
Attributes:
@@ -13181,11 +13239,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype613, _size610) = iprot.readListBegin()
- for _i614 in xrange(_size610):
- _elem615 = FieldSchema()
- _elem615.read(iprot)
- self.success.append(_elem615)
+ (_etype620, _size617) = iprot.readListBegin()
+ for _i621 in xrange(_size617):
+ _elem622 = FieldSchema()
+ _elem622.read(iprot)
+ self.success.append(_elem622)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13220,8 +13278,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 iter616 in self.success:
- iter616.write(oprot)
+ for iter623 in self.success:
+ iter623.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13662,22 +13720,22 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype620, _size617) = iprot.readListBegin()
- for _i621 in xrange(_size617):
- _elem622 = SQLPrimaryKey()
- _elem622.read(iprot)
- self.primaryKeys.append(_elem622)
+ (_etype627, _size624) = iprot.readListBegin()
+ for _i628 in xrange(_size624):
+ _elem629 = SQLPrimaryKey()
+ _elem629.read(iprot)
+ self.primaryKeys.append(_elem629)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype626, _size623) = iprot.readListBegin()
- for _i627 in xrange(_size623):
- _elem628 = SQLForeignKey()
- _elem628.read(iprot)
- self.foreignKeys.append(_elem628)
+ (_etype633, _size630) = iprot.readListBegin()
+ for _i634 in xrange(_size630):
+ _elem635 = SQLForeignKey()
+ _elem635.read(iprot)
+ self.foreignKeys.append(_elem635)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13698,15 +13756,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 iter629 in self.primaryKeys:
- iter629.write(oprot)
+ for iter636 in self.primaryKeys:
+ iter636.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 iter630 in self.foreignKeys:
- iter630.write(oprot)
+ for iter637 in self.foreignKeys:
+ iter637.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14742,10 +14800,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype634, _size631) = iprot.readListBegin()
- for _i635 in xrange(_size631):
- _elem636 = iprot.readString()
- self.success.append(_elem636)
+ (_etype641, _size638) = iprot.readListBegin()
+ for _i642 in xrange(_size638):
+ _elem643 = iprot.readString()
+ self.success.append(_elem643)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14768,8 +14826,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 iter637 in self.success:
- oprot.writeString(iter637)
+ for iter644 in self.success:
+ oprot.writeString(iter644)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14842,10 +14900,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype641, _size638) = iprot.readListBegin()
- for _i642 in xrange(_size638):
- _elem643 = iprot.readString()
- self.tbl_types.append(_elem643)
+ (_etype648, _size645) = iprot.readListBegin()
+ for _i649 in xrange(_size645):
+ _elem650 = iprot.readString()
+ self.tbl_types.append(_elem650)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14870,8 +14928,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 iter644 in self.tbl_types:
- oprot.writeString(iter644)
+ for iter651 in self.tbl_types:
+ oprot.writeString(iter651)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14927,11 +14985,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype648, _size645) = iprot.readListBegin()
- for _i649 in xrange(_size645):
- _elem650 = TableMeta()
- _elem650.read(iprot)
- self.success.append(_elem650)
+ (_etype655, _size652) = iprot.readListBegin()
+ for _i656 in xrange(_size652):
+ _elem657 = TableMeta()
+ _elem657.read(iprot)
+ self.success.append(_elem657)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14954,8 +15012,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 iter651 in self.success:
- iter651.write(oprot)
+ for iter658 in self.success:
+ iter658.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15079,10 +15137,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype655, _size652) = iprot.readListBegin()
- for _i656 in xrange(_size652):
- _elem657 = iprot.readString()
- self.success.append(_elem657)
+ (_etype662, _size659) = iprot.readListBegin()
+ for _i663 in xrange(_size659):
+ _elem664 = iprot.readString()
+ self.success.append(_elem664)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15105,8 +15163,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 iter658 in self.success:
- oprot.writeString(iter658)
+ for iter665 in self.success:
+ oprot.writeString(iter665)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15342,10 +15400,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype662, _size659) = iprot.readListBegin()
- for _i663 in xrange(_size659):
- _elem664 = iprot.readString()
- self.tbl_names.append(_elem664)
+ (_etype669, _size666) = iprot.readListBegin()
+ for _i670 in xrange(_size666):
+ _elem671 = iprot.readString()
+ self.tbl_names.append(_elem671)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15366,8 +15424,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 iter665 in self.tbl_names:
- oprot.writeString(iter665)
+ for iter672 in self.tbl_names:
+ oprot.writeString(iter672)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15428,11 +15486,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype669, _size666) = iprot.readListBegin()
- for _i670 in xrange(_size666):
- _elem671 = Table()
- _elem671.read(iprot)
- self.success.append(_elem671)
+ (_etype676, _size673) = iprot.readListBegin()
+ for _i677 in xrange(_size673):
+ _elem678 = Table()
+ _elem678.read(iprot)
+ self.success.append(_elem678)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15467,8 +15525,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 iter672 in self.success:
- iter672.write(oprot)
+ for iter679 in self.success:
+ iter679.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15634,10 +15692,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype676, _size673) = iprot.readListBegin()
- for _i677 in xrange(_size673):
- _elem678 = iprot.readString()
- self.success.append(_elem678)
+ (_etype683, _size680) = iprot.readListBegin()
+ for _i684 in xrange(_size680):
+ _elem685 = iprot.readString()
+ self.success.append(_elem685)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15672,8 +15730,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 iter679 in self.success:
- oprot.writeString(iter679)
+ for iter686 in self.success:
+ oprot.writeString(iter686)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16643,11 +16701,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype683, _size680) = iprot.readListBegin()
- for _i684 in xrange(_size680):
- _elem685 = Partition()
- _elem685.read(iprot)
- self.new_parts.append(_elem685)
+ (_etype690, _size687) = iprot.readListBegin()
+ for _i691 in xrange(_size687):
+ _elem692 = Partition()
+ _elem692.read(iprot)
+ self.new_parts.append(_elem692)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16664,8 +16722,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 iter686 in self.new_parts:
- iter686.write(oprot)
+ for iter693 in self.new_parts:
+ iter693.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16823,11 +16881,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype690, _size687) = iprot.readListBegin()
- for _i691 in xrange(_size687):
- _elem692 = PartitionSpec()
- _elem692.read(iprot)
- self.new_parts.append(_elem692)
+ (_etype697, _size694) = iprot.readListBegin()
+ for _i698 in xrange(_size694):
+ _elem699 = PartitionSpec()
+ _elem699.read(iprot)
+ self.new_parts.append(_elem699)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16844,8 +16902,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 iter693 in self.new_parts:
- iter693.write(oprot)
+ for iter700 in self.new_parts:
+ iter700.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17019,10 +17077,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype697, _size694) = iprot.readListBegin()
- for _i698 in xrange(_size694):
- _elem699 = iprot.readString()
- self.part_vals.append(_elem699)
+ (_etype704, _size701) = iprot.readListBegin()
+ for _i705 in xrange(_size701):
+ _elem706 = iprot.readString()
+ self.part_vals.append(_elem706)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17047,8 +17105,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 iter700 in self.part_vals:
- oprot.writeString(iter700)
+ for iter707 in self.part_vals:
+ oprot.writeString(iter707)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17401,10 +17459,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype704, _size701) = iprot.readListBegin()
- for _i705 in xrange(_size701):
- _elem706 = iprot.readString()
- self.part_vals.append(_elem706)
+ (_etype711, _size708) = iprot.readListBegin()
+ for _i712 in xrange(_size708):
+ _elem713 = iprot.readString()
+ self.part_vals.append(_elem713)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17435,8 +17493,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 iter707 in self.part_vals:
- oprot.writeString(iter707)
+ for iter714 in self.part_vals:
+ oprot.writeString(iter714)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -18031,10 +18089,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype711, _size708) = iprot.readListBegin()
- for _i712 in xrange(_size708):
- _elem713 = iprot.readString()
- self.part_vals.append(_elem713)
+ (_etype718, _size715) = iprot.readListBegin()
+ for _i719 in xrange(_size715):
+ _elem720 = iprot.readString()
+ self.part_vals.append(_elem720)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18064,8 +18122,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 iter714 in self.part_vals:
- oprot.writeString(iter714)
+ for iter721 in self.part_vals:
+ oprot.writeString(iter721)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -18238,10 +18296,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype718, _size715) = iprot.readListBegin()
- for _i719 in xrange(_size715):
- _elem720 = iprot.readString()
- self.part_vals.append(_elem720)
+ (_etype725, _size722) = iprot.readListBegin()
+ for _i726 in xrange(_size722):
+ _elem727 = iprot.readString()
+ self.part_vals.append(_elem727)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18277,8 +18335,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 iter721 in self.part_vals:
- oprot.writeString(iter721)
+ for iter728 in self.part_vals:
+ oprot.writeString(iter728)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -19015,10 +19073,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype725, _size722) = iprot.readListBegin()
- for _i726 in xrange(_size722):
- _elem727 = iprot.readString()
- self.part_vals.append(_elem727)
+ (_etype732, _size729) = iprot.readListBegin()
+ for _i733 in xrange(_size729):
+ _elem734 = iprot.readString()
+ self.part_vals.append(_elem734)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19043,8 +19101,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 iter728 in self.part_vals:
- oprot.writeString(iter728)
+ for iter735 in self.part_vals:
+ oprot.writeString(iter735)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19203,11 +19261,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype730, _vtype731, _size729 ) = iprot.readMapBegin()
- for _i733 in xrange(_size729):
- _key734 = iprot.readString()
- _val735 = iprot.readString()
- self.partitionSpecs[_key734] = _val735
+ (_ktype737, _vtype738, _size736 ) = iprot.readMapBegin()
+ for _i740 in xrange(_size736):
+ _key741 = iprot.readString()
+ _val742 = iprot.readString()
+ self.partitionSpecs[_key741] = _val742
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19244,9 +19302,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 kiter736,viter737 in self.partitionSpecs.items():
- oprot.writeString(kiter736)
- oprot.writeString(viter737)
+ for kiter743,viter744 in self.partitionSpecs.items():
+ oprot.writeString(kiter743)
+ oprot.writeString(viter744)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -19451,11 +19509,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype739, _vtype740, _size738 ) = iprot.readMapBegin()
- for _i742 in xrange(_size738):
- _key743 = iprot.readString()
- _val744 = iprot.readString()
- self.partitionSpecs[_key743] = _val744
+ (_ktype746, _vtype747, _size745 ) = iprot.readMapBegin()
+ for _i749 in xrange(_size745):
+ _key750 = iprot.readString()
+ _val751 = iprot.readString()
+ self.partitionSpecs[_key750] = _val751
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19492,9 +19550,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 kiter745,viter746 in self.partitionSpecs.items():
- oprot.writeString(kiter745)
- oprot.writeString(viter746)
+ for kiter752,viter753 in self.partitionSpecs.items():
+ oprot.writeString(kiter752)
+ oprot.writeString(viter753)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -19577,11 +19635,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype750, _size747) = iprot.readListBegin()
- for _i751 in xrange(_size747):
- _elem752 = Partition()
- _elem752.read(iprot)
- self.success.append(_elem752)
+ (_etype757, _size754) = iprot.readListBegin()
+ for _i758 in xrange(_size754):
+ _elem759 = Partition()
+ _elem759.read(iprot)
+ self.success.append(_elem759)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19622,8 +19680,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 iter753 in self.success:
- iter753.write(oprot)
+ for iter760 in self.success:
+ iter760.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19717,10 +19775,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype757, _size754) = iprot.readListBegin()
- for _i758 in xrange(_size754):
- _elem759 = iprot.readString()
- self.part_vals.append(_elem759)
+ (_etype764, _size761) = iprot.readListBegin()
+ for _i765 in xrange(_size761):
+ _elem766 = iprot.readString()
+ self.part_vals.append(_elem766)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19732,10 +19790,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype763, _size760) = iprot.readListBegin()
- for _i764 in xrange(_size760):
- _elem765 = iprot.readString()
- self.group_names.append(_elem765)
+ (_etype770, _size767) = iprot.readListBegin()
+ for _i771 in xrange(_size767):
+ _elem772 = iprot.readString()
+ self.group_names.append(_elem772)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19760,8 +19818,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 iter766 in self.part_vals:
- oprot.writeString(iter766)
+ for iter773 in self.part_vals:
+ oprot.writeString(iter773)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -19771,8 +19829,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 iter767 in self.group_names:
- oprot.writeString(iter767)
+ for iter774 in self.group_names:
+ oprot.writeString(iter774)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20201,11 +20259,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype771, _size768) = iprot.readListBegin()
- for _i772 in xrange(_size768):
- _elem773 = Partition()
- _elem773.read(iprot)
- self.success.append(_elem773)
+ (_etype778, _size775) = iprot.readListBegin()
+ for _i779 in xrange(_size775):
+ _elem780 = Partition()
+ _elem780.read(iprot)
+ self.success.append(_elem780)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20234,8 +20292,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 iter774 in self.success:
- iter774.write(oprot)
+ for iter781 in self.success:
+ iter781.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20329,10 +20387,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype778, _size775) = iprot.readListBegin()
- for _i779 in xrange(_size775):
- _elem780 = iprot.readString()
- self.group_names.append(_elem780)
+ (_etype785, _size782) = iprot.readListBegin()
+ for _i786 in xrange(_size782):
+ _elem787 = iprot.readString()
+ self.group_names.append(_elem787)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20365,8 +20423,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 iter781 in self.group_names:
- oprot.writeString(iter781)
+ for iter788 in self.group_names:
+ oprot.writeString(iter788)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20427,11 +20485,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype785, _size782) = iprot.readListBegin()
- for _i786 in xrange(_size782):
- _elem787 = Partition()
- _elem787.read(iprot)
- self.success.append(_elem787)
+ (_etype792, _size789) = iprot.readListBegin()
+ for _i793 in xrange(_size789):
+ _elem794 = Partition()
+ _elem794.read(iprot)
+ self.success.append(_elem794)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20460,8 +20518,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 iter788 in self.success:
- iter788.write(oprot)
+ for iter795 in self.success:
+ iter795.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20619,11 +20677,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype792, _size789) = iprot.readListBegin()
- for _i793 in xrange(_size789):
- _elem794 = PartitionSpec()
- _elem794.read(iprot)
- self.success.append(_elem794)
+ (_etype799, _size796) = iprot.readListBegin()
+ for _i800 in xrange(_size796):
+ _elem801 = PartitionSpec()
+ _elem801.read(iprot)
+ self.success.append(_elem801)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20652,8 +20710,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 iter795 in self.success:
- iter795.write(oprot)
+ for iter802 in self.success:
+ iter802.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20808,10 +20866,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype799, _size796) = iprot.readListBegin()
- for _i800 in xrange(_size796):
- _elem801 = iprot.readString()
- self.success.append(_elem801)
+ (_etype806, _size803) = iprot.readListBegin()
+ for _i807 in xrange(_size803):
+ _elem808 = iprot.readString()
+ self.success.append(_elem808)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20834,8 +20892,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 iter802 in self.success:
- oprot.writeString(iter802)
+ for iter809 in self.success:
+ oprot.writeString(iter809)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -20911,10 +20969,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype806, _size803) = iprot.readListBegin()
- for _i807 in xrange(_size803):
- _elem808 = iprot.readString()
- self.part_vals.append(_elem808)
+ (_etype813, _size810) = iprot.readListBegin()
+ for _i814 in xrange(_size810):
+ _elem815 = iprot.readString()
+ self.part_vals.append(_elem815)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20944,8 +21002,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 iter809 in self.part_vals:
- oprot.writeString(iter809)
+ for iter816 in self.part_vals:
+ oprot.writeString(iter816)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21009,11 +21067,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype813, _size810) = iprot.readListBegin()
- for _i814 in xrange(_size810):
- _elem815 = Partition()
- _elem815.read(iprot)
- self.success.append(_elem815)
+ (_etype820, _size817) = iprot.readListBegin()
+ for _i821 in xrange(_size817):
+ _elem822 = Partition()
+ _elem822.read(iprot)
+ self.success.append(_elem822)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21042,8 +21100,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 iter816 in self.success:
- iter816.write(oprot)
+ for iter823 in self.success:
+ iter823.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21130,10 +21188,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype820, _size817) = iprot.readListBegin()
- for _i821 in xrange(_size817):
- _elem822 = iprot.readString()
- self.part_vals.append(_elem822)
+ (_etype827, _size824) = iprot.readListBegin()
+ for _i828 in xrange(_size824):
+ _elem829 = iprot.readString()
+ self.part_vals.append(_elem829)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21150,10 +21208,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype826, _size823) = iprot.readListBegin()
- for _i827 in xrange(_size823):
- _elem828 = iprot.readString()
- self.group_names.append(_elem828)
+ (_etype833, _size830) = iprot.readListBegin()
+ for _i834 in xrange(_size830):
+ _elem835 = iprot.readString()
+ self.group_names.append(_elem835)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21178,8 +21236,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 iter829 in self.part_vals:
- oprot.writeString(iter829)
+ for iter836 in self.part_vals:
+ oprot.writeString(iter836)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21193,8 +21251,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 iter830 in self.group_names:
- oprot.writeString(iter830)
+ for iter837 in self.group_names:
+ oprot.writeString(iter837)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21256,11 +21314,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype834, _size831) = iprot.readListBegin()
- for _i835 in xrange(_size831):
- _elem836 = Partition()
- _elem836.read(iprot)
- self.success.append(_elem836)
+ (_etype841, _size838) = iprot.readListBegin()
+ for _i842 in xrange(_size838):
+ _elem843 = Partition()
+ _elem843.read(iprot)
+ self.success.append(_elem843)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21289,8 +21347,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 iter837 in self.success:
- iter837.write(oprot)
+ for iter844 in self.success:
+ iter844.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21371,10 +21429,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype841, _size838) = iprot.readListBegin()
- for _i842 in xrange(_size838):
- _elem843 = iprot.readString()
- self.part_vals.append(_elem843)
+ (_etype848, _size845) = iprot.readListBegin()
+ for _i849 in xrange(_size845):
+ _elem850 = iprot.readString()
+ self.part_vals.append(_elem850)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21404,8 +21462,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 iter844 in self.part_vals:
- oprot.writeString(iter844)
+ for iter851 in self.part_vals:
+ oprot.writeString(iter851)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -21469,10 +21527,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype848, _size845) = iprot.readListBegin()
- for _i849 in xrange(_size845):
- _elem850 = iprot.readString()
- self.success.append(_elem850)
+ (_etype855, _size852) = iprot.readListBegin()
+ for _i856 in xrange(_size852):
+ _elem857 = iprot.readString()
+ self.success.append(_elem857)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21501,8 +21559,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 iter851 in self.success:
- oprot.writeString(iter851)
+ for iter858 in self.success:
+ oprot.writeString(iter858)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21673,11 +21731,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype855, _size852) = iprot.readListBegin()
- for _i856 in xrange(_size852):
- _elem857 = Partition()
- _elem857.read(iprot)
- self.success.append(_elem857)
+ (_etype862, _size859) = iprot.readListBegin()
+ for _i863 in xrange(_size859):
+ _elem864 = Partition()
+ _elem864.read(iprot)
+ self.success.append(_elem864)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21706,8 +21764,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 iter858 in self.success:
- iter858.write(oprot)
+ for iter865 in self.success:
+ iter865.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21878,11 +21936,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype862, _size859) = iprot.readListBegin()
- for _i863 in xrange(_size859):
- _elem864 = PartitionSpec()
- _elem864.read(iprot)
- self.success.append(_elem864)
+ (_etype869, _size866) = iprot.readListBegin()
+ for _i870 in xrange(_size866):
+ _elem871 = PartitionSpec()
+ _elem871.read(iprot)
+ self.success.append(_elem871)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21911,8 +21969,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 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:
@@ -22332,10 +22390,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = iprot.readString()
- self.names.append(_elem871)
+ (_etype876, _size873) = iprot.readListBegin()
+ for _i877 in xrange(_size873):
+ _elem878 = iprot.readString()
+ self.names.append(_elem878)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22360,8 +22418,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 iter872 in self.names:
- oprot.writeString(iter872)
+ for iter879 in self.names:
+ oprot.writeString(iter879)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22420,11 +22478,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype876, _size873) = iprot.readListBegin()
- for _i877 in xrange(_size873):
- _elem878 = Partition()
- _elem878.read(iprot)
- self.success.append(_elem878)
+ (_etype883, _size880) = iprot.readListBegin()
+ for _i884 in xrange(_size880):
+ _elem885 = Partition()
+ _elem885.read(iprot)
+ self.success.append(_elem885)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22453,8 +22511,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 iter879 in self.success:
- iter879.write(oprot)
+ for iter886 in self.success:
+ iter886.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22704,11 +22762,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype883, _size880) = iprot.readListBegin()
- for _i884 in xrange(_size880):
- _elem885 = Partition()
- _elem885.read(iprot)
- self.new_parts.append(_elem885)
+ (_etype890, _size887) = iprot.readListBegin()
+ for _i891 in xrange(_size887):
+ _elem892 = Partition()
+ _elem892.read(iprot)
+ self.new_parts.append(_elem892)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22733,8 +22791,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 iter886 in self.new_parts:
- iter886.write(oprot)
+ for iter893 in self.new_parts:
+ iter893.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -22887,11 +22945,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype890, _size887) = iprot.readListBegin()
- for _i891 in xrange(_size887):
- _elem892 = Partition()
- _elem892.read(iprot)
- self.new_parts.append(_elem892)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = Partition()
+ _elem899.read(iprot)
+ self.new_parts.append(_elem899)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22922,8 +22980,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 iter893 in self.new_parts:
- iter893.write(oprot)
+ for iter900 in self.new_parts:
+ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -23267,10 +23325,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype897, _size894) = iprot.readListBegin()
- for _i898 in xrange(_size894):
- _elem899 = iprot.readString()
- self.part_vals.append(_elem899)
+ (_etype904, _size901) = iprot.readListBegin()
+ for _i905 in xrange(_size901):
+ _elem906 = iprot.readString()
+ self.part_vals.append(_elem906)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23301,8 +23359,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 iter900 in self.part_vals:
- oprot.writeString(iter900)
+ for iter907 in self.part_vals:
+ oprot.writeString(iter907)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -23444,10 +23502,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype904, _size901) = iprot.readListBegin()
- for _i905 in xrange(_size901):
- _elem906 = iprot.readString()
- self.part_vals.append(_elem906)
+ (_etype911, _size908) = iprot.readListBegin()
+ for _i912 in xrange(_size908):
+ _elem913 = iprot.readString()
+ self.part_vals.append(_elem913)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23469,8 +23527,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 iter907 in self.part_vals:
- oprot.writeString(iter907)
+ for iter914 in self.part_vals:
+ oprot.writeString(iter914)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -23828,10 +23886,10 @@ class partition_name_to_vals_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)
@@ -23854,8 +23912,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 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:
@@ -23979,11 +24037,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype916, _vtype917, _size915 ) = iprot.readMapBegin()
- for _i919 in xrange(_size915):
- _key920 = iprot.readString()
- _val921 = iprot.readString()
- self.success[_key920] = _val921
+ (_ktype923, _vtype924, _size922 ) = iprot.readMapBegin()
+ for _i926 in xrange(_size922):
+ _key927 = iprot.readString()
+ _val928 = iprot.readString()
+ self.success[_key927] = _val928
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24006,9 +24064,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 kiter922,viter923 in self.success.items():
- oprot.writeString(kiter922)
- oprot.writeString(viter923)
+ for kiter929,viter930 in self.success.items():
+ oprot.writeString(kiter929)
+ oprot.writeString(viter930)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24084,11 +24142,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype925, _vtype926, _size924 ) = iprot.readMapBegin()
- for _i928 in xrange(_size924):
- _key929 = iprot.readString()
- _val930 = iprot.readString()
- self.part_vals[_key929] = _val930
+ (_ktype932, _vtype933, _size931 ) = iprot.readMapBegin()
+ for _i935 in xrange(_size931):
+ _key936 = iprot.readString()
+ _val937 = iprot.readString()
+ self.part_vals[_key936] = _val937
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24118,9 +24176,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 kiter931,viter932 in self.part_vals.items():
- oprot.writeString(kiter931)
- oprot.writeString(viter932)
+ for kiter938,viter939 in self.part_vals.items():
+ oprot.writeString(kiter938)
+ oprot.writeString(viter939)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -24334,11 +24392,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype934, _vtype935, _size933 ) = iprot.readMapBegin()
- for _i937 in xrange(_size933):
- _key938 = iprot.readString()
- _val939 = iprot.readString()
- self.part_vals[_key938] = _val939
+ (_ktype941, _vtype942, _size940 ) = iprot.readMapBegin()
+ for _i944 in xrange(_size940):
+ _key945 = iprot.readString()
+ _val946 = iprot.readString()
+ self.part_vals[_key945] = _val946
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -24368,9 +24426,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 kiter940,viter941 in self.part_vals.items():
- oprot.writeString(kiter940)
- oprot.writeString(viter941)
+ for kiter947,viter948 in self.part_vals.items():
+ oprot.writeString(kiter947)
+ oprot.writeString(viter948)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -25425,11 +25483,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype945, _size942) = iprot.readListBegin()
- for _i946 in xrange(_size942):
- _elem947 = Index()
- _elem947.read(iprot)
- self.success.append(_elem947)
+ (_etype952, _size949) = iprot.readListBegin()
+ for _i953 in xrange(_size949):
+ _elem954 = Index()
+ _elem954.read(iprot)
+ self.success.append(_elem954)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25458,8 +25516,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 iter948 in self.success:
- iter948.write(oprot)
+ for iter955 in self.success:
+ iter955.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -25614,10 +25672,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype952, _size949) = iprot.readListBegin()
- for _i953 in xrange(_size949):
- _elem954 = iprot.readString()
- self.success.append(_elem954)
+ (_etype959, _size956) = iprot.readListBegin()
+ for _i960 in xrange(_size956):
+ _elem961 = iprot.readString()
+ self.success.append(_elem961)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25640,8 +25698,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 iter955 in self.success:
- oprot.writeString(iter955)
+ for iter962 in self.success:
+ oprot.writeString(iter962)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -28507,10 +28565,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype959, _size956) = iprot.readListBegin()
- for _i960 in xrange(_size956):
- _elem961 = iprot.readString()
- self.success.append(_elem961)
+ (_etype966, _size963) = iprot.readListBegin()
+ for _i967 in xrange(_size963):
+ _elem968 = iprot.readString()
+ self.success.append(_elem968)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28533,8 +28591,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 iter962 in self.success:
- oprot.writeString(iter962)
+ for iter969 in self.success:
+ oprot.writeString(iter969)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29222,10 +29280,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype966, _size963) = iprot.readListBegin()
- for _i967 in xrange(_size963):
- _elem968 = iprot.readString()
- self.success.append(_elem968)
+ (_etype973, _size970) = iprot.readListBegin()
+ for _i974 in xrange(_size970):
+ _elem975 = iprot.readString()
+ self.success.append(_elem975)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29248,8 +29306,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 iter969 in self.success:
- oprot.writeString(iter969)
+ for iter976 in self.success:
+ oprot.writeString(iter976)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29763,11 +29821,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype973, _size970) = iprot.readListBegin()
- for _i974 in xrange(_size970):
- _elem975 = Role()
- _elem975.read(iprot)
- self.success.append(_elem975)
+ (_etype980, _size977) = iprot.readListBegin()
+ for _i981 in xrange(_size977):
+ _elem982 = Role()
+ _elem982.read(iprot)
+ self.success.append(_elem982)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29790,8 +29848,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 iter976 in self.success:
- iter976.write(oprot)
+ for iter983 in self.success:
+ iter983.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30300,10 +30358,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype980, _size977) = iprot.readListBegin()
- for _i981 in xrange(_size977):
- _elem982 = iprot.readString()
- self.group_names.append(_elem982)
+ (_etype987, _size984) = iprot.readListBegin()
+ for _i988 in xrange(_size984):
+ _elem989 = iprot.readString()
+ self.group_names.append(_elem989)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30328,8 +30386,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 iter983 in self.group_names:
- oprot.writeString(iter983)
+ for iter990 in self.group_names:
+ oprot.writeString(iter990)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -30556,11 +30614,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype987, _size984) = iprot.readListBegin()
- for _i988 in xrange(_size984):
- _elem989 = HiveObjectPrivilege()
- _elem989.read(iprot)
- self.success.append(_elem989)
+ (_etype994, _size991) = iprot.readListBegin()
+ for _i995 in xrange(_size991):
+ _elem996 = HiveObjectPrivilege()
+ _elem996.read(iprot)
+ self.success.append(_elem996)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30583,8 +30641,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 iter990 in self.success:
- iter990.write(oprot)
+ for iter997 in self.success:
+ iter997.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -31082,10 +31140,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype994, _size991) = iprot.readListBegin()
- for _i995 in xrange(_size991):
- _elem996 = iprot.readString()
- self.group_names.append(_elem996)
+ (_etype1001, _size998) = iprot.readListBegin()
+ for _i1002 in xrange(_size998):
+ _elem1003 = iprot.readString()
+ self.group_names.append(_elem1003)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31106,8 +31164,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 iter997 in self.group_names:
- oprot.writeString(iter997)
+ for iter1004 in self.group_names:
+ oprot.writeString(iter1004)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -31162,10 +31220,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1001, _size998) = iprot.readListBegin()
- for _i1002 in xrange(_size998):
- _elem1003 = iprot.readString()
- self.success.append(_elem1003)
+ (_etype1008, _size1005) = iprot.readListBegin()
+ for _i1009 in xrange(_size1005):
+ _elem1010 = iprot.readString()
+ self.success.append(_elem1010)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -31188,8 +31246,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 iter1004 in self.success:
- oprot.writeString(iter1004)
+ for iter1011 in self.success:
+ oprot.writeString(iter1011)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -32121,10 +32179,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1008, _size1005) = iprot.readListBegin()
- for _i1009 in xrange(_size1005):
- _elem1010 = iprot.readString()
- self.success.append(_elem1010)
+ (_etype1015, _size1012) = iprot.readListBegin()
+ for _i1016 in xrange(_size1012):
+ _elem1017 = iprot.readString()
+ self.success.append(_elem1017)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32141,8 +32199,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 iter1011 in self.success:
- oprot.writeString(iter1011)
+ for iter1018 in self.success:
+ oprot.writeString(iter1018)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -32669,10 +32727,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1015, _size1012) = iprot.readListBegin()
- for _i1016 in xrange(_size1012):
- _elem1017 = iprot.readString()
- self.success.append(_elem1017)
+ (_etype1022, _size1019) = iprot.readListBegin()
+ for _i1023 in xrange(_size1019):
+ _elem1024 = iprot.readString()
+ self.success.append(_elem1024)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -32689,8 +32747,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 iter1018 in self.success:
- oprot.writeString(iter1018)
+ for iter1025 in self.success:
+ oprot.writeString(iter1025)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36280,3 +36338,134 @@ class heartbeat_write_id_result:
def __ne__(self, other):
return not (self == other)
+
+class get_valid_write_ids_args:
+ """
+ Attributes:
+ - req
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'req', (GetValidWriteIdsRequest, GetValidWriteIdsRequest.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 = GetValidWriteIdsRequest()
+ 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('get_valid_write_ids_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 get_valid_write_ids_result:
+ """
+ Attributes:
+ - success
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (GetValidWriteIdsResult, GetValidWriteIdsResult.thrift_spec), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+ 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 = GetValidWriteIdsResult()
+ self.success.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_valid_write_ids_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ 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)