You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jd...@apache.org on 2016/04/20 22:05:32 UTC
[15/30] hive git commit: HIVE-13349: Metastore Changes : API calls
for retrieving primary keys and foreign keys information (Hari Subramaniyan,
reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/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 ac8d8a4..119a5f1 100644
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -156,6 +156,15 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def create_table_with_constraints(self, tbl, primaryKeys, foreignKeys):
+ """
+ Parameters:
+ - tbl
+ - primaryKeys
+ - foreignKeys
+ """
+ pass
+
def drop_table(self, dbname, name, deleteData):
"""
Parameters:
@@ -695,6 +704,20 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
+ def get_primary_keys(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
+ def get_foreign_keys(self, request):
+ """
+ Parameters:
+ - request
+ """
+ pass
+
def update_table_column_statistics(self, stats_obj):
"""
Parameters:
@@ -1811,6 +1834,47 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o4
return
+ def create_table_with_constraints(self, tbl, primaryKeys, foreignKeys):
+ """
+ Parameters:
+ - tbl
+ - primaryKeys
+ - foreignKeys
+ """
+ self.send_create_table_with_constraints(tbl, primaryKeys, foreignKeys)
+ self.recv_create_table_with_constraints()
+
+ def send_create_table_with_constraints(self, tbl, primaryKeys, foreignKeys):
+ self._oprot.writeMessageBegin('create_table_with_constraints', TMessageType.CALL, self._seqid)
+ args = create_table_with_constraints_args()
+ args.tbl = tbl
+ args.primaryKeys = primaryKeys
+ args.foreignKeys = foreignKeys
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_create_table_with_constraints(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = create_table_with_constraints_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ if result.o3 is not None:
+ raise result.o3
+ if result.o4 is not None:
+ raise result.o4
+ return
+
def drop_table(self, dbname, name, deleteData):
"""
Parameters:
@@ -4134,6 +4198,76 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result")
+ def get_primary_keys(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_primary_keys(request)
+ return self.recv_get_primary_keys()
+
+ def send_get_primary_keys(self, request):
+ self._oprot.writeMessageBegin('get_primary_keys', TMessageType.CALL, self._seqid)
+ args = get_primary_keys_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_primary_keys(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_primary_keys_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_primary_keys failed: unknown result")
+
+ def get_foreign_keys(self, request):
+ """
+ Parameters:
+ - request
+ """
+ self.send_get_foreign_keys(request)
+ return self.recv_get_foreign_keys()
+
+ def send_get_foreign_keys(self, request):
+ self._oprot.writeMessageBegin('get_foreign_keys', TMessageType.CALL, self._seqid)
+ args = get_foreign_keys_args()
+ args.request = request
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_get_foreign_keys(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = get_foreign_keys_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "get_foreign_keys failed: unknown result")
+
def update_table_column_statistics(self, stats_obj):
"""
Parameters:
@@ -6364,6 +6498,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["get_schema_with_environment_context"] = Processor.process_get_schema_with_environment_context
self._processMap["create_table"] = Processor.process_create_table
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_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
@@ -6423,6 +6558,8 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["get_index_by_name"] = Processor.process_get_index_by_name
self._processMap["get_indexes"] = Processor.process_get_indexes
self._processMap["get_index_names"] = Processor.process_get_index_names
+ self._processMap["get_primary_keys"] = Processor.process_get_primary_keys
+ self._processMap["get_foreign_keys"] = Processor.process_get_foreign_keys
self._processMap["update_table_column_statistics"] = Processor.process_update_table_column_statistics
self._processMap["update_partition_column_statistics"] = Processor.process_update_partition_column_statistics
self._processMap["get_table_column_statistics"] = Processor.process_get_table_column_statistics
@@ -6973,6 +7110,37 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_create_table_with_constraints(self, seqid, iprot, oprot):
+ args = create_table_with_constraints_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = create_table_with_constraints_result()
+ try:
+ self._handler.create_table_with_constraints(args.tbl, args.primaryKeys, args.foreignKeys)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except AlreadyExistsException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except InvalidObjectException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except MetaException as o3:
+ msg_type = TMessageType.REPLY
+ result.o3 = o3
+ except NoSuchObjectException as o4:
+ msg_type = TMessageType.REPLY
+ result.o4 = o4
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("create_table_with_constraints", 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)
@@ -8493,6 +8661,56 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_get_primary_keys(self, seqid, iprot, oprot):
+ args = get_primary_keys_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_primary_keys_result()
+ try:
+ result.success = self._handler.get_primary_keys(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except MetaException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except NoSuchObjectException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("get_primary_keys", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
+ def process_get_foreign_keys(self, seqid, iprot, oprot):
+ args = get_foreign_keys_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = get_foreign_keys_result()
+ try:
+ result.success = self._handler.get_foreign_keys(args.request)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except MetaException as o1:
+ msg_type = TMessageType.REPLY
+ result.o1 = o1
+ except NoSuchObjectException as o2:
+ msg_type = TMessageType.REPLY
+ result.o2 = o2
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("get_foreign_keys", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_update_table_column_statistics(self, seqid, iprot, oprot):
args = update_table_column_statistics_args()
args.read(iprot)
@@ -10879,10 +11097,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype525, _size522) = iprot.readListBegin()
- for _i526 in xrange(_size522):
- _elem527 = iprot.readString()
- self.success.append(_elem527)
+ (_etype539, _size536) = iprot.readListBegin()
+ for _i540 in xrange(_size536):
+ _elem541 = iprot.readString()
+ self.success.append(_elem541)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10905,8 +11123,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 iter528 in self.success:
- oprot.writeString(iter528)
+ for iter542 in self.success:
+ oprot.writeString(iter542)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11011,10 +11229,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype532, _size529) = iprot.readListBegin()
- for _i533 in xrange(_size529):
- _elem534 = iprot.readString()
- self.success.append(_elem534)
+ (_etype546, _size543) = iprot.readListBegin()
+ for _i547 in xrange(_size543):
+ _elem548 = iprot.readString()
+ self.success.append(_elem548)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11037,8 +11255,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 iter535 in self.success:
- oprot.writeString(iter535)
+ for iter549 in self.success:
+ oprot.writeString(iter549)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11808,12 +12026,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype537, _vtype538, _size536 ) = iprot.readMapBegin()
- for _i540 in xrange(_size536):
- _key541 = iprot.readString()
- _val542 = Type()
- _val542.read(iprot)
- self.success[_key541] = _val542
+ (_ktype551, _vtype552, _size550 ) = iprot.readMapBegin()
+ for _i554 in xrange(_size550):
+ _key555 = iprot.readString()
+ _val556 = Type()
+ _val556.read(iprot)
+ self.success[_key555] = _val556
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -11836,9 +12054,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 kiter543,viter544 in self.success.items():
- oprot.writeString(kiter543)
- viter544.write(oprot)
+ for kiter557,viter558 in self.success.items():
+ oprot.writeString(kiter557)
+ viter558.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -11981,11 +12199,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype548, _size545) = iprot.readListBegin()
- for _i549 in xrange(_size545):
- _elem550 = FieldSchema()
- _elem550.read(iprot)
- self.success.append(_elem550)
+ (_etype562, _size559) = iprot.readListBegin()
+ for _i563 in xrange(_size559):
+ _elem564 = FieldSchema()
+ _elem564.read(iprot)
+ self.success.append(_elem564)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12020,8 +12238,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 iter551 in self.success:
- iter551.write(oprot)
+ for iter565 in self.success:
+ iter565.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12188,11 +12406,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype555, _size552) = iprot.readListBegin()
- for _i556 in xrange(_size552):
- _elem557 = FieldSchema()
- _elem557.read(iprot)
- self.success.append(_elem557)
+ (_etype569, _size566) = iprot.readListBegin()
+ for _i570 in xrange(_size566):
+ _elem571 = FieldSchema()
+ _elem571.read(iprot)
+ self.success.append(_elem571)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12227,8 +12445,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 iter558 in self.success:
- iter558.write(oprot)
+ for iter572 in self.success:
+ iter572.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12381,11 +12599,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype562, _size559) = iprot.readListBegin()
- for _i563 in xrange(_size559):
- _elem564 = FieldSchema()
- _elem564.read(iprot)
- self.success.append(_elem564)
+ (_etype576, _size573) = iprot.readListBegin()
+ for _i577 in xrange(_size573):
+ _elem578 = FieldSchema()
+ _elem578.read(iprot)
+ self.success.append(_elem578)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12420,8 +12638,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 iter565 in self.success:
- iter565.write(oprot)
+ for iter579 in self.success:
+ iter579.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12588,11 +12806,11 @@ class get_schema_with_environment_context_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)
@@ -12627,8 +12845,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 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:
@@ -13031,25 +13249,25 @@ class create_table_with_environment_context_result:
def __ne__(self, other):
return not (self == other)
-class drop_table_args:
+class create_table_with_constraints_args:
"""
Attributes:
- - dbname
- - name
- - deleteData
+ - tbl
+ - primaryKeys
+ - foreignKeys
"""
thrift_spec = (
None, # 0
- (1, TType.STRING, 'dbname', None, None, ), # 1
- (2, TType.STRING, 'name', None, None, ), # 2
- (3, TType.BOOL, 'deleteData', None, None, ), # 3
+ (1, TType.STRUCT, 'tbl', (Table, Table.thrift_spec), None, ), # 1
+ (2, TType.LIST, 'primaryKeys', (TType.STRUCT,(SQLPrimaryKey, SQLPrimaryKey.thrift_spec)), None, ), # 2
+ (3, TType.LIST, 'foreignKeys', (TType.STRUCT,(SQLForeignKey, SQLForeignKey.thrift_spec)), None, ), # 3
)
- def __init__(self, dbname=None, name=None, deleteData=None,):
- self.dbname = dbname
- self.name = name
- self.deleteData = deleteData
+ def __init__(self, tbl=None, primaryKeys=None, foreignKeys=None,):
+ self.tbl = tbl
+ self.primaryKeys = primaryKeys
+ self.foreignKeys = foreignKeys
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:
@@ -13061,18 +13279,31 @@ class drop_table_args:
if ftype == TType.STOP:
break
if fid == 1:
- if ftype == TType.STRING:
- self.dbname = iprot.readString()
+ if ftype == TType.STRUCT:
+ self.tbl = Table()
+ self.tbl.read(iprot)
else:
iprot.skip(ftype)
elif fid == 2:
- if ftype == TType.STRING:
- self.name = iprot.readString()
+ if ftype == TType.LIST:
+ self.primaryKeys = []
+ (_etype590, _size587) = iprot.readListBegin()
+ for _i591 in xrange(_size587):
+ _elem592 = SQLPrimaryKey()
+ _elem592.read(iprot)
+ self.primaryKeys.append(_elem592)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
- if ftype == TType.BOOL:
- self.deleteData = iprot.readBool()
+ if ftype == TType.LIST:
+ self.foreignKeys = []
+ (_etype596, _size593) = iprot.readListBegin()
+ for _i597 in xrange(_size593):
+ _elem598 = SQLForeignKey()
+ _elem598.read(iprot)
+ self.foreignKeys.append(_elem598)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
else:
@@ -13084,18 +13315,24 @@ class drop_table_args:
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('drop_table_args')
- if self.dbname is not None:
- oprot.writeFieldBegin('dbname', TType.STRING, 1)
- oprot.writeString(self.dbname)
+ oprot.writeStructBegin('create_table_with_constraints_args')
+ if self.tbl is not None:
+ oprot.writeFieldBegin('tbl', TType.STRUCT, 1)
+ self.tbl.write(oprot)
oprot.writeFieldEnd()
- if self.name is not None:
- oprot.writeFieldBegin('name', TType.STRING, 2)
- oprot.writeString(self.name)
+ if self.primaryKeys is not None:
+ oprot.writeFieldBegin('primaryKeys', TType.LIST, 2)
+ oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys))
+ for iter599 in self.primaryKeys:
+ iter599.write(oprot)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.deleteData is not None:
- oprot.writeFieldBegin('deleteData', TType.BOOL, 3)
- oprot.writeBool(self.deleteData)
+ if self.foreignKeys is not None:
+ oprot.writeFieldBegin('foreignKeys', TType.LIST, 3)
+ oprot.writeListBegin(TType.STRUCT, len(self.foreignKeys))
+ for iter600 in self.foreignKeys:
+ iter600.write(oprot)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -13106,9 +13343,9 @@ class drop_table_args:
def __hash__(self):
value = 17
- value = (value * 31) ^ hash(self.dbname)
- value = (value * 31) ^ hash(self.name)
- value = (value * 31) ^ hash(self.deleteData)
+ value = (value * 31) ^ hash(self.tbl)
+ value = (value * 31) ^ hash(self.primaryKeys)
+ value = (value * 31) ^ hash(self.foreignKeys)
return value
def __repr__(self):
@@ -13122,18 +13359,217 @@ class drop_table_args:
def __ne__(self, other):
return not (self == other)
-class drop_table_result:
+class create_table_with_constraints_result:
"""
Attributes:
- o1
+ - o2
- o3
+ - o4
"""
thrift_spec = (
None, # 0
- (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 2
- )
+ (1, TType.STRUCT, 'o1', (AlreadyExistsException, AlreadyExistsException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 3
+ (4, TType.STRUCT, 'o4', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 4
+ )
+
+ def __init__(self, o1=None, o2=None, o3=None, o4=None,):
+ self.o1 = o1
+ self.o2 = o2
+ self.o3 = o3
+ self.o4 = o4
+
+ 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 = AlreadyExistsException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = InvalidObjectException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.o3 = MetaException()
+ self.o3.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRUCT:
+ self.o4 = NoSuchObjectException()
+ self.o4.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('create_table_with_constraints_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()
+ if self.o3 is not None:
+ oprot.writeFieldBegin('o3', TType.STRUCT, 3)
+ self.o3.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o4 is not None:
+ oprot.writeFieldBegin('o4', TType.STRUCT, 4)
+ self.o4.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)
+ value = (value * 31) ^ hash(self.o3)
+ value = (value * 31) ^ hash(self.o4)
+ 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:
+ - dbname
+ - name
+ - deleteData
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'dbname', None, None, ), # 1
+ (2, TType.STRING, 'name', None, None, ), # 2
+ (3, TType.BOOL, 'deleteData', None, None, ), # 3
+ )
+
+ def __init__(self, dbname=None, name=None, deleteData=None,):
+ self.dbname = dbname
+ self.name = name
+ self.deleteData = deleteData
+
+ 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.dbname = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.BOOL:
+ self.deleteData = iprot.readBool()
+ 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('drop_table_args')
+ if self.dbname is not None:
+ oprot.writeFieldBegin('dbname', TType.STRING, 1)
+ oprot.writeString(self.dbname)
+ oprot.writeFieldEnd()
+ if self.name is not None:
+ oprot.writeFieldBegin('name', TType.STRING, 2)
+ oprot.writeString(self.name)
+ oprot.writeFieldEnd()
+ if self.deleteData is not None:
+ oprot.writeFieldBegin('deleteData', TType.BOOL, 3)
+ oprot.writeBool(self.deleteData)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.dbname)
+ value = (value * 31) ^ hash(self.name)
+ value = (value * 31) ^ hash(self.deleteData)
+ 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_result:
+ """
+ Attributes:
+ - o1
+ - o3
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o3', (MetaException, MetaException.thrift_spec), None, ), # 2
+ )
def __init__(self, o1=None, o3=None,):
self.o1 = o1
@@ -13493,10 +13929,10 @@ class get_tables_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)
+ (_etype604, _size601) = iprot.readListBegin()
+ for _i605 in xrange(_size601):
+ _elem606 = iprot.readString()
+ self.success.append(_elem606)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13519,8 +13955,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 iter579 in self.success:
- oprot.writeString(iter579)
+ for iter607 in self.success:
+ oprot.writeString(iter607)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13593,10 +14029,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype583, _size580) = iprot.readListBegin()
- for _i584 in xrange(_size580):
- _elem585 = iprot.readString()
- self.tbl_types.append(_elem585)
+ (_etype611, _size608) = iprot.readListBegin()
+ for _i612 in xrange(_size608):
+ _elem613 = iprot.readString()
+ self.tbl_types.append(_elem613)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13621,8 +14057,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 iter586 in self.tbl_types:
- oprot.writeString(iter586)
+ for iter614 in self.tbl_types:
+ oprot.writeString(iter614)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13678,11 +14114,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype590, _size587) = iprot.readListBegin()
- for _i591 in xrange(_size587):
- _elem592 = TableMeta()
- _elem592.read(iprot)
- self.success.append(_elem592)
+ (_etype618, _size615) = iprot.readListBegin()
+ for _i619 in xrange(_size615):
+ _elem620 = TableMeta()
+ _elem620.read(iprot)
+ self.success.append(_elem620)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13705,8 +14141,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 iter593 in self.success:
- iter593.write(oprot)
+ for iter621 in self.success:
+ iter621.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13830,10 +14266,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype597, _size594) = iprot.readListBegin()
- for _i598 in xrange(_size594):
- _elem599 = iprot.readString()
- self.success.append(_elem599)
+ (_etype625, _size622) = iprot.readListBegin()
+ for _i626 in xrange(_size622):
+ _elem627 = iprot.readString()
+ self.success.append(_elem627)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13856,8 +14292,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 iter600 in self.success:
- oprot.writeString(iter600)
+ for iter628 in self.success:
+ oprot.writeString(iter628)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14093,10 +14529,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype604, _size601) = iprot.readListBegin()
- for _i605 in xrange(_size601):
- _elem606 = iprot.readString()
- self.tbl_names.append(_elem606)
+ (_etype632, _size629) = iprot.readListBegin()
+ for _i633 in xrange(_size629):
+ _elem634 = iprot.readString()
+ self.tbl_names.append(_elem634)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14117,8 +14553,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 iter607 in self.tbl_names:
- oprot.writeString(iter607)
+ for iter635 in self.tbl_names:
+ oprot.writeString(iter635)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14179,11 +14615,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype611, _size608) = iprot.readListBegin()
- for _i612 in xrange(_size608):
- _elem613 = Table()
- _elem613.read(iprot)
- self.success.append(_elem613)
+ (_etype639, _size636) = iprot.readListBegin()
+ for _i640 in xrange(_size636):
+ _elem641 = Table()
+ _elem641.read(iprot)
+ self.success.append(_elem641)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14218,8 +14654,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 iter614 in self.success:
- iter614.write(oprot)
+ for iter642 in self.success:
+ iter642.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14385,10 +14821,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype618, _size615) = iprot.readListBegin()
- for _i619 in xrange(_size615):
- _elem620 = iprot.readString()
- self.success.append(_elem620)
+ (_etype646, _size643) = iprot.readListBegin()
+ for _i647 in xrange(_size643):
+ _elem648 = iprot.readString()
+ self.success.append(_elem648)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14423,8 +14859,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 iter621 in self.success:
- oprot.writeString(iter621)
+ for iter649 in self.success:
+ oprot.writeString(iter649)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15394,11 +15830,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype625, _size622) = iprot.readListBegin()
- for _i626 in xrange(_size622):
- _elem627 = Partition()
- _elem627.read(iprot)
- self.new_parts.append(_elem627)
+ (_etype653, _size650) = iprot.readListBegin()
+ for _i654 in xrange(_size650):
+ _elem655 = Partition()
+ _elem655.read(iprot)
+ self.new_parts.append(_elem655)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15415,8 +15851,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 iter628 in self.new_parts:
- iter628.write(oprot)
+ for iter656 in self.new_parts:
+ iter656.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15574,11 +16010,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype632, _size629) = iprot.readListBegin()
- for _i633 in xrange(_size629):
- _elem634 = PartitionSpec()
- _elem634.read(iprot)
- self.new_parts.append(_elem634)
+ (_etype660, _size657) = iprot.readListBegin()
+ for _i661 in xrange(_size657):
+ _elem662 = PartitionSpec()
+ _elem662.read(iprot)
+ self.new_parts.append(_elem662)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15595,8 +16031,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 iter635 in self.new_parts:
- iter635.write(oprot)
+ for iter663 in self.new_parts:
+ iter663.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15770,10 +16206,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype639, _size636) = iprot.readListBegin()
- for _i640 in xrange(_size636):
- _elem641 = iprot.readString()
- self.part_vals.append(_elem641)
+ (_etype667, _size664) = iprot.readListBegin()
+ for _i668 in xrange(_size664):
+ _elem669 = iprot.readString()
+ self.part_vals.append(_elem669)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15798,8 +16234,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 iter642 in self.part_vals:
- oprot.writeString(iter642)
+ for iter670 in self.part_vals:
+ oprot.writeString(iter670)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16152,10 +16588,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype646, _size643) = iprot.readListBegin()
- for _i647 in xrange(_size643):
- _elem648 = iprot.readString()
- self.part_vals.append(_elem648)
+ (_etype674, _size671) = iprot.readListBegin()
+ for _i675 in xrange(_size671):
+ _elem676 = iprot.readString()
+ self.part_vals.append(_elem676)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16186,8 +16622,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 iter649 in self.part_vals:
- oprot.writeString(iter649)
+ for iter677 in self.part_vals:
+ oprot.writeString(iter677)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -16782,10 +17218,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype653, _size650) = iprot.readListBegin()
- for _i654 in xrange(_size650):
- _elem655 = iprot.readString()
- self.part_vals.append(_elem655)
+ (_etype681, _size678) = iprot.readListBegin()
+ for _i682 in xrange(_size678):
+ _elem683 = iprot.readString()
+ self.part_vals.append(_elem683)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16815,8 +17251,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 iter656 in self.part_vals:
- oprot.writeString(iter656)
+ for iter684 in self.part_vals:
+ oprot.writeString(iter684)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -16989,10 +17425,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype660, _size657) = iprot.readListBegin()
- for _i661 in xrange(_size657):
- _elem662 = iprot.readString()
- self.part_vals.append(_elem662)
+ (_etype688, _size685) = iprot.readListBegin()
+ for _i689 in xrange(_size685):
+ _elem690 = iprot.readString()
+ self.part_vals.append(_elem690)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17028,8 +17464,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 iter663 in self.part_vals:
- oprot.writeString(iter663)
+ for iter691 in self.part_vals:
+ oprot.writeString(iter691)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -17766,10 +18202,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype667, _size664) = iprot.readListBegin()
- for _i668 in xrange(_size664):
- _elem669 = iprot.readString()
- self.part_vals.append(_elem669)
+ (_etype695, _size692) = iprot.readListBegin()
+ for _i696 in xrange(_size692):
+ _elem697 = iprot.readString()
+ self.part_vals.append(_elem697)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17794,8 +18230,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 iter670 in self.part_vals:
- oprot.writeString(iter670)
+ for iter698 in self.part_vals:
+ oprot.writeString(iter698)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17954,11 +18390,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype672, _vtype673, _size671 ) = iprot.readMapBegin()
- for _i675 in xrange(_size671):
- _key676 = iprot.readString()
- _val677 = iprot.readString()
- self.partitionSpecs[_key676] = _val677
+ (_ktype700, _vtype701, _size699 ) = iprot.readMapBegin()
+ for _i703 in xrange(_size699):
+ _key704 = iprot.readString()
+ _val705 = iprot.readString()
+ self.partitionSpecs[_key704] = _val705
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -17995,9 +18431,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 kiter678,viter679 in self.partitionSpecs.items():
- oprot.writeString(kiter678)
- oprot.writeString(viter679)
+ for kiter706,viter707 in self.partitionSpecs.items():
+ oprot.writeString(kiter706)
+ oprot.writeString(viter707)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -18202,11 +18638,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype681, _vtype682, _size680 ) = iprot.readMapBegin()
- for _i684 in xrange(_size680):
- _key685 = iprot.readString()
- _val686 = iprot.readString()
- self.partitionSpecs[_key685] = _val686
+ (_ktype709, _vtype710, _size708 ) = iprot.readMapBegin()
+ for _i712 in xrange(_size708):
+ _key713 = iprot.readString()
+ _val714 = iprot.readString()
+ self.partitionSpecs[_key713] = _val714
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18243,9 +18679,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 kiter687,viter688 in self.partitionSpecs.items():
- oprot.writeString(kiter687)
- oprot.writeString(viter688)
+ for kiter715,viter716 in self.partitionSpecs.items():
+ oprot.writeString(kiter715)
+ oprot.writeString(viter716)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -18328,11 +18764,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype692, _size689) = iprot.readListBegin()
- for _i693 in xrange(_size689):
- _elem694 = Partition()
- _elem694.read(iprot)
- self.success.append(_elem694)
+ (_etype720, _size717) = iprot.readListBegin()
+ for _i721 in xrange(_size717):
+ _elem722 = Partition()
+ _elem722.read(iprot)
+ self.success.append(_elem722)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18373,8 +18809,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 iter695 in self.success:
- iter695.write(oprot)
+ for iter723 in self.success:
+ iter723.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18468,10 +18904,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype699, _size696) = iprot.readListBegin()
- for _i700 in xrange(_size696):
- _elem701 = iprot.readString()
- self.part_vals.append(_elem701)
+ (_etype727, _size724) = iprot.readListBegin()
+ for _i728 in xrange(_size724):
+ _elem729 = iprot.readString()
+ self.part_vals.append(_elem729)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18483,10 +18919,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype705, _size702) = iprot.readListBegin()
- for _i706 in xrange(_size702):
- _elem707 = iprot.readString()
- self.group_names.append(_elem707)
+ (_etype733, _size730) = iprot.readListBegin()
+ for _i734 in xrange(_size730):
+ _elem735 = iprot.readString()
+ self.group_names.append(_elem735)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18511,8 +18947,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 iter708 in self.part_vals:
- oprot.writeString(iter708)
+ for iter736 in self.part_vals:
+ oprot.writeString(iter736)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -18522,8 +18958,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 iter709 in self.group_names:
- oprot.writeString(iter709)
+ for iter737 in self.group_names:
+ oprot.writeString(iter737)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18952,11 +19388,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype713, _size710) = iprot.readListBegin()
- for _i714 in xrange(_size710):
- _elem715 = Partition()
- _elem715.read(iprot)
- self.success.append(_elem715)
+ (_etype741, _size738) = iprot.readListBegin()
+ for _i742 in xrange(_size738):
+ _elem743 = Partition()
+ _elem743.read(iprot)
+ self.success.append(_elem743)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18985,8 +19421,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 iter716 in self.success:
- iter716.write(oprot)
+ for iter744 in self.success:
+ iter744.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19080,10 +19516,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype720, _size717) = iprot.readListBegin()
- for _i721 in xrange(_size717):
- _elem722 = iprot.readString()
- self.group_names.append(_elem722)
+ (_etype748, _size745) = iprot.readListBegin()
+ for _i749 in xrange(_size745):
+ _elem750 = iprot.readString()
+ self.group_names.append(_elem750)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19116,8 +19552,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 iter723 in self.group_names:
- oprot.writeString(iter723)
+ for iter751 in self.group_names:
+ oprot.writeString(iter751)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19178,11 +19614,11 @@ class get_partitions_with_auth_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)
+ (_etype755, _size752) = iprot.readListBegin()
+ for _i756 in xrange(_size752):
+ _elem757 = Partition()
+ _elem757.read(iprot)
+ self.success.append(_elem757)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19211,8 +19647,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 iter730 in self.success:
- iter730.write(oprot)
+ for iter758 in self.success:
+ iter758.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19370,11 +19806,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype734, _size731) = iprot.readListBegin()
- for _i735 in xrange(_size731):
- _elem736 = PartitionSpec()
- _elem736.read(iprot)
- self.success.append(_elem736)
+ (_etype762, _size759) = iprot.readListBegin()
+ for _i763 in xrange(_size759):
+ _elem764 = PartitionSpec()
+ _elem764.read(iprot)
+ self.success.append(_elem764)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19403,8 +19839,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 iter737 in self.success:
- iter737.write(oprot)
+ for iter765 in self.success:
+ iter765.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19559,10 +19995,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype741, _size738) = iprot.readListBegin()
- for _i742 in xrange(_size738):
- _elem743 = iprot.readString()
- self.success.append(_elem743)
+ (_etype769, _size766) = iprot.readListBegin()
+ for _i770 in xrange(_size766):
+ _elem771 = iprot.readString()
+ self.success.append(_elem771)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19585,8 +20021,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 iter744 in self.success:
- oprot.writeString(iter744)
+ for iter772 in self.success:
+ oprot.writeString(iter772)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -19662,10 +20098,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype748, _size745) = iprot.readListBegin()
- for _i749 in xrange(_size745):
- _elem750 = iprot.readString()
- self.part_vals.append(_elem750)
+ (_etype776, _size773) = iprot.readListBegin()
+ for _i777 in xrange(_size773):
+ _elem778 = iprot.readString()
+ self.part_vals.append(_elem778)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19695,8 +20131,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 iter751 in self.part_vals:
- oprot.writeString(iter751)
+ for iter779 in self.part_vals:
+ oprot.writeString(iter779)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -19760,11 +20196,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype755, _size752) = iprot.readListBegin()
- for _i756 in xrange(_size752):
- _elem757 = Partition()
- _elem757.read(iprot)
- self.success.append(_elem757)
+ (_etype783, _size780) = iprot.readListBegin()
+ for _i784 in xrange(_size780):
+ _elem785 = Partition()
+ _elem785.read(iprot)
+ self.success.append(_elem785)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19793,8 +20229,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 iter758 in self.success:
- iter758.write(oprot)
+ for iter786 in self.success:
+ iter786.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19881,10 +20317,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype762, _size759) = iprot.readListBegin()
- for _i763 in xrange(_size759):
- _elem764 = iprot.readString()
- self.part_vals.append(_elem764)
+ (_etype790, _size787) = iprot.readListBegin()
+ for _i791 in xrange(_size787):
+ _elem792 = iprot.readString()
+ self.part_vals.append(_elem792)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19901,10 +20337,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype768, _size765) = iprot.readListBegin()
- for _i769 in xrange(_size765):
- _elem770 = iprot.readString()
- self.group_names.append(_elem770)
+ (_etype796, _size793) = iprot.readListBegin()
+ for _i797 in xrange(_size793):
+ _elem798 = iprot.readString()
+ self.group_names.append(_elem798)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19929,8 +20365,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 iter771 in self.part_vals:
- oprot.writeString(iter771)
+ for iter799 in self.part_vals:
+ oprot.writeString(iter799)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -19944,8 +20380,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 iter772 in self.group_names:
- oprot.writeString(iter772)
+ for iter800 in self.group_names:
+ oprot.writeString(iter800)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20007,11 +20443,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype776, _size773) = iprot.readListBegin()
- for _i777 in xrange(_size773):
- _elem778 = Partition()
- _elem778.read(iprot)
- self.success.append(_elem778)
+ (_etype804, _size801) = iprot.readListBegin()
+ for _i805 in xrange(_size801):
+ _elem806 = Partition()
+ _elem806.read(iprot)
+ self.success.append(_elem806)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20040,8 +20476,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 iter779 in self.success:
- iter779.write(oprot)
+ for iter807 in self.success:
+ iter807.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20122,10 +20558,10 @@ class get_partition_names_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)
+ (_etype811, _size808) = iprot.readListBegin()
+ for _i812 in xrange(_size808):
+ _elem813 = iprot.readString()
+ self.part_vals.append(_elem813)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20155,8 +20591,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 iter786 in self.part_vals:
- oprot.writeString(iter786)
+ for iter814 in self.part_vals:
+ oprot.writeString(iter814)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -20220,10 +20656,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype790, _size787) = iprot.readListBegin()
- for _i791 in xrange(_size787):
- _elem792 = iprot.readString()
- self.success.append(_elem792)
+ (_etype818, _size815) = iprot.readListBegin()
+ for _i819 in xrange(_size815):
+ _elem820 = iprot.readString()
+ self.success.append(_elem820)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20252,8 +20688,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 iter793 in self.success:
- oprot.writeString(iter793)
+ for iter821 in self.success:
+ oprot.writeString(iter821)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20424,11 +20860,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype797, _size794) = iprot.readListBegin()
- for _i798 in xrange(_size794):
- _elem799 = Partition()
- _elem799.read(iprot)
- self.success.append(_elem799)
+ (_etype825, _size822) = iprot.readListBegin()
+ for _i826 in xrange(_size822):
+ _elem827 = Partition()
+ _elem827.read(iprot)
+ self.success.append(_elem827)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20457,8 +20893,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 iter800 in self.success:
- iter800.write(oprot)
+ for iter828 in self.success:
+ iter828.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20629,11 +21065,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype804, _size801) = iprot.readListBegin()
- for _i805 in xrange(_size801):
- _elem806 = PartitionSpec()
- _elem806.read(iprot)
- self.success.append(_elem806)
+ (_etype832, _size829) = iprot.readListBegin()
+ for _i833 in xrange(_size829):
+ _elem834 = PartitionSpec()
+ _elem834.read(iprot)
+ self.success.append(_elem834)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20662,8 +21098,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 iter807 in self.success:
- iter807.write(oprot)
+ for iter835 in self.success:
+ iter835.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21083,10 +21519,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype811, _size808) = iprot.readListBegin()
- for _i812 in xrange(_size808):
- _elem813 = iprot.readString()
- self.names.append(_elem813)
+ (_etype839, _size836) = iprot.readListBegin()
+ for _i840 in xrange(_size836):
+ _elem841 = iprot.readString()
+ self.names.append(_elem841)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21111,8 +21547,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 iter814 in self.names:
- oprot.writeString(iter814)
+ for iter842 in self.names:
+ oprot.writeString(iter842)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21171,11 +21607,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype818, _size815) = iprot.readListBegin()
- for _i819 in xrange(_size815):
- _elem820 = Partition()
- _elem820.read(iprot)
- self.success.append(_elem820)
+ (_etype846, _size843) = iprot.readListBegin()
+ for _i847 in xrange(_size843):
+ _elem848 = Partition()
+ _elem848.read(iprot)
+ self.success.append(_elem848)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21204,8 +21640,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 iter821 in self.success:
- iter821.write(oprot)
+ for iter849 in self.success:
+ iter849.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21455,11 +21891,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype825, _size822) = iprot.readListBegin()
- for _i826 in xrange(_size822):
- _elem827 = Partition()
- _elem827.read(iprot)
- self.new_parts.append(_elem827)
+ (_etype853, _size850) = iprot.readListBegin()
+ for _i854 in xrange(_size850):
+ _elem855 = Partition()
+ _elem855.read(iprot)
+ self.new_parts.append(_elem855)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21484,8 +21920,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 iter828 in self.new_parts:
- iter828.write(oprot)
+ for iter856 in self.new_parts:
+ iter856.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21638,11 +22074,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype832, _size829) = iprot.readListBegin()
- for _i833 in xrange(_size829):
- _elem834 = Partition()
- _elem834.read(iprot)
- self.new_parts.append(_elem834)
+ (_etype860, _size857) = iprot.readListBegin()
+ for _i861 in xrange(_size857):
+ _elem862 = Partition()
+ _elem862.read(iprot)
+ self.new_parts.append(_elem862)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21673,8 +22109,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 iter835 in self.new_parts:
- iter835.write(oprot)
+ for iter863 in self.new_parts:
+ iter863.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -22018,10 +22454,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype839, _size836) = iprot.readListBegin()
- for _i840 in xrange(_size836):
- _elem841 = iprot.readString()
- self.part_vals.append(_elem841)
+ (_etype867, _size864) = iprot.readListBegin()
+ for _i868 in xrange(_size864):
+ _elem869 = iprot.readString()
+ self.part_vals.append(_elem869)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22052,8 +22488,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 iter842 in self.part_vals:
- oprot.writeString(iter842)
+ for iter870 in self.part_vals:
+ oprot.writeString(iter870)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -22195,10 +22631,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype846, _size843) = iprot.readListBegin()
- for _i847 in xrange(_size843):
- _elem848 = iprot.readString()
- self.part_vals.append(_elem848)
+ (_etype874, _size871) = iprot.readListBegin()
+ for _i875 in xrange(_size871):
+ _elem876 = iprot.readString()
+ self.part_vals.append(_elem876)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22220,8 +22656,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 iter849 in self.part_vals:
- oprot.writeString(iter849)
+ for iter877 in self.part_vals:
+ oprot.writeString(iter877)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -22579,10 +23015,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype853, _size850) = iprot.readListBegin()
- for _i854 in xrange(_size850):
- _elem855 = iprot.readString()
- self.success.append(_elem855)
+ (_etype881, _size878) = iprot.readListBegin()
+ for _i882 in xrange(_size878):
+ _elem883 = iprot.readString()
+ self.success.append(_elem883)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22605,8 +23041,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 iter856 in self.success:
- oprot.writeString(iter856)
+ for iter884 in self.success:
+ oprot.writeString(iter884)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22730,11 +23166,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype858, _vtype859, _size857 ) = iprot.readMapBegin()
- for _i861 in xrange(_size857):
- _key862 = iprot.readString()
- _val863 = iprot.readString()
- self.success[_key862] = _val863
+ (_ktype886, _vtype887, _size885 ) = iprot.readMapBegin()
+ for _i889 in xrange(_size885):
+ _key890 = iprot.readString()
+ _val891 = iprot.readString()
+ self.success[_key890] = _val891
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -22757,9 +23193,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 kiter864,viter865 in self.success.items():
- oprot.writeString(kiter864)
- oprot.writeString(viter865)
+ for kiter892,viter893 in self.success.items():
+ oprot.writeString(kiter892)
+ oprot.writeString(viter893)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22835,11 +23271,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype867, _vtype868, _size866 ) = iprot.readMapBegin()
- for _i870 in xrange(_size866):
- _key871 = iprot.readString()
- _val872 = iprot.readString()
- self.part_vals[_key871] = _val872
+ (_ktype895, _vtype896, _size894 ) = iprot.readMapBegin()
+ for _i898 in xrange(_size894):
+ _key899 = iprot.readString()
+ _val900 = iprot.readString()
+ self.part_vals[_key899] = _val900
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -22869,9 +23305,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 kiter873,viter874 in self.part_vals.items():
- oprot.writeString(kiter873)
- oprot.writeString(viter874)
+ for kiter901,viter902 in self.part_vals.items():
+ oprot.writeString(kiter901)
+ oprot.writeString(viter902)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -23085,11 +23521,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype876, _vtype877, _size875 ) = iprot.readMapBegin()
- for _i879 in xrange(_size875):
- _key880 = iprot.readString()
- _val881 = iprot.readString()
- self.part_vals[_key880] = _val881
+ (_ktype904, _vtype905, _size903 ) = iprot.readMapBegin()
+ for _i907 in xrange(_size903):
+ _key908 = iprot.readString()
+ _val909 = iprot.readString()
+ self.part_vals[_key908] = _val909
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -23119,9 +23555,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 kiter882,viter883 in self.part_vals.items():
- oprot.writeString(kiter882)
- oprot.writeString(viter883)
+ for kiter910,viter911 in self.part_vals.items():
+ oprot.writeString(kiter910)
+ oprot.writeString(viter911)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -23923,7 +24359,383 @@ class get_index_by_name_args:
if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
return
- oprot.writeStructBegin('get_index_by_name_args')
+ oprot.writeStructBegin('get_index_by_name_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.tbl_name is not None:
+ oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
+ oprot.writeString(self.tbl_name)
+ oprot.writeFieldEnd()
+ if self.index_name is not None:
+ oprot.writeFieldBegin('index_name', TType.STRING, 3)
+ oprot.writeString(self.index_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.tbl_name)
+ value = (value * 31) ^ hash(self.index_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_index_by_name_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (Index, Index.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, success=None, o1=None, o2=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.STRUCT:
+ self.success = Index()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = MetaException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = NoSuchObjectException()
+ self.o2.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_index_by_name_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 2)
+ self.o2.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o1)
+ value = (value * 31) ^ hash(self.o2)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class get_indexes_args:
+ """
+ Attributes:
+ - db_name
+ - tbl_name
+ - max_indexes
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ (3, TType.I16, 'max_indexes', None, -1, ), # 3
+ )
+
+ def __init__(self, db_name=None, tbl_name=None, max_indexes=thrift_spec[3][4],):
+ self.db_name = db_name
+ self.tbl_name = tbl_name
+ self.max_indexes = max_indexes
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.db_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.tbl_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I16:
+ self.max_indexes = iprot.readI16()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_indexes_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
+ oprot.writeFieldEnd()
+ if self.tbl_name is not None:
+ oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
+ oprot.writeString(self.tbl_name)
+ oprot.writeFieldEnd()
+ if self.max_indexes is not None:
+ oprot.writeFieldBegin('max_indexes', TType.I16, 3)
+ oprot.writeI16(self.max_indexes)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.db_name)
+ value = (value * 31) ^ hash(self.tbl_name)
+ value = (value * 31) ^ hash(self.max_indexes)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class get_indexes_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.LIST, 'success', (TType.STRUCT,(Index, Index.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, success=None, o1=None, o2=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.LIST:
+ self.success = []
+ (_etype915, _size912) = iprot.readListBegin()
+ for _i916 in xrange(_size912):
+ _elem917 = Index()
+ _elem917.read(iprot)
+ self.success.append(_elem917)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ elif 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('get_indexes_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRUCT, len(self.success))
+ for iter918 in self.success:
+ iter918.write(oprot)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 2)
+ self.o2.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ value = (value * 31) ^ hash(self.o1)
+ value = (value * 31) ^ hash(self.o2)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class get_index_names_args:
+ """
+ Attributes:
+ - db_name
+ - tbl_name
+ - max_indexes
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ (3, TType.I16, 'max_indexes', None, -1, ), # 3
+ )
+
+ def __init__(self, db_name=None, tbl_name=None, max_indexes=thrift_spec[3][4],):
+ self.db_name = db_name
+ self.tbl_name = tbl_name
+ self.max_indexes = max_indexes
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 1:
+ if ftype == TType.STRING:
+ self.db_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.tbl_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I16:
+ self.max_indexes = iprot.readI16()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('get_index_names_args')
if self.db_name is not None:
oprot.writeFieldBegin('db_name', TType.STRING, 1)
oprot.writeString(self.db_name)
@@ -23932,9 +24744,9 @@ class get_index_by_name_args:
oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
oprot.writeString(self.tbl_name)
oprot.writeFieldEnd()
- if self.index_name is not None:
- oprot.writeFieldBegin('index_name', TType.STRING, 3)
- oprot.writeString(self.index_name)
+ if self.max_indexes is not None:
+ oprot.writeFieldBegin('max_indexes', TType.I16, 3)
+ oprot.writeI16(self.max_indexes)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@
<TRUNCATED>