You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kg...@apache.org on 2018/03/07 08:19:26 UTC
[09/22] hive git commit: HIVE-18715: Remove index support from
metastore (Zoltan Haindrich reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/7c22d74c/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 392e8ca..516be77 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -757,61 +757,6 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def add_index(self, new_index, index_table):
- """
- Parameters:
- - new_index
- - index_table
- """
- pass
-
- def alter_index(self, dbname, base_tbl_name, idx_name, new_idx):
- """
- Parameters:
- - dbname
- - base_tbl_name
- - idx_name
- - new_idx
- """
- pass
-
- def drop_index_by_name(self, db_name, tbl_name, index_name, deleteData):
- """
- Parameters:
- - db_name
- - tbl_name
- - index_name
- - deleteData
- """
- pass
-
- def get_index_by_name(self, db_name, tbl_name, index_name):
- """
- Parameters:
- - db_name
- - tbl_name
- - index_name
- """
- pass
-
- def get_indexes(self, db_name, tbl_name, max_indexes):
- """
- Parameters:
- - db_name
- - tbl_name
- - max_indexes
- """
- pass
-
- def get_index_names(self, db_name, tbl_name, max_indexes):
- """
- Parameters:
- - db_name
- - tbl_name
- - max_indexes
- """
- pass
-
def get_primary_keys(self, request):
"""
Parameters:
@@ -4740,240 +4685,6 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o6
raise TApplicationException(TApplicationException.MISSING_RESULT, "isPartitionMarkedForEvent failed: unknown result")
- def add_index(self, new_index, index_table):
- """
- Parameters:
- - new_index
- - index_table
- """
- self.send_add_index(new_index, index_table)
- return self.recv_add_index()
-
- def send_add_index(self, new_index, index_table):
- self._oprot.writeMessageBegin('add_index', TMessageType.CALL, self._seqid)
- args = add_index_args()
- args.new_index = new_index
- args.index_table = index_table
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_add_index(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = add_index_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.o1 is not None:
- raise result.o1
- if result.o2 is not None:
- raise result.o2
- if result.o3 is not None:
- raise result.o3
- raise TApplicationException(TApplicationException.MISSING_RESULT, "add_index failed: unknown result")
-
- def alter_index(self, dbname, base_tbl_name, idx_name, new_idx):
- """
- Parameters:
- - dbname
- - base_tbl_name
- - idx_name
- - new_idx
- """
- self.send_alter_index(dbname, base_tbl_name, idx_name, new_idx)
- self.recv_alter_index()
-
- def send_alter_index(self, dbname, base_tbl_name, idx_name, new_idx):
- self._oprot.writeMessageBegin('alter_index', TMessageType.CALL, self._seqid)
- args = alter_index_args()
- args.dbname = dbname
- args.base_tbl_name = base_tbl_name
- args.idx_name = idx_name
- args.new_idx = new_idx
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_alter_index(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = alter_index_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.o1 is not None:
- raise result.o1
- if result.o2 is not None:
- raise result.o2
- return
-
- def drop_index_by_name(self, db_name, tbl_name, index_name, deleteData):
- """
- Parameters:
- - db_name
- - tbl_name
- - index_name
- - deleteData
- """
- self.send_drop_index_by_name(db_name, tbl_name, index_name, deleteData)
- return self.recv_drop_index_by_name()
-
- def send_drop_index_by_name(self, db_name, tbl_name, index_name, deleteData):
- self._oprot.writeMessageBegin('drop_index_by_name', TMessageType.CALL, self._seqid)
- args = drop_index_by_name_args()
- args.db_name = db_name
- args.tbl_name = tbl_name
- args.index_name = index_name
- args.deleteData = deleteData
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_drop_index_by_name(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = drop_index_by_name_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, "drop_index_by_name failed: unknown result")
-
- def get_index_by_name(self, db_name, tbl_name, index_name):
- """
- Parameters:
- - db_name
- - tbl_name
- - index_name
- """
- self.send_get_index_by_name(db_name, tbl_name, index_name)
- return self.recv_get_index_by_name()
-
- def send_get_index_by_name(self, db_name, tbl_name, index_name):
- self._oprot.writeMessageBegin('get_index_by_name', TMessageType.CALL, self._seqid)
- args = get_index_by_name_args()
- args.db_name = db_name
- args.tbl_name = tbl_name
- args.index_name = index_name
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_index_by_name(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = get_index_by_name_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_index_by_name failed: unknown result")
-
- def get_indexes(self, db_name, tbl_name, max_indexes):
- """
- Parameters:
- - db_name
- - tbl_name
- - max_indexes
- """
- self.send_get_indexes(db_name, tbl_name, max_indexes)
- return self.recv_get_indexes()
-
- def send_get_indexes(self, db_name, tbl_name, max_indexes):
- self._oprot.writeMessageBegin('get_indexes', TMessageType.CALL, self._seqid)
- args = get_indexes_args()
- args.db_name = db_name
- args.tbl_name = tbl_name
- args.max_indexes = max_indexes
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_indexes(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = get_indexes_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_indexes failed: unknown result")
-
- def get_index_names(self, db_name, tbl_name, max_indexes):
- """
- Parameters:
- - db_name
- - tbl_name
- - max_indexes
- """
- self.send_get_index_names(db_name, tbl_name, max_indexes)
- return self.recv_get_index_names()
-
- def send_get_index_names(self, db_name, tbl_name, max_indexes):
- self._oprot.writeMessageBegin('get_index_names', TMessageType.CALL, self._seqid)
- args = get_index_names_args()
- args.db_name = db_name
- args.tbl_name = tbl_name
- args.max_indexes = max_indexes
- args.write(self._oprot)
- self._oprot.writeMessageEnd()
- self._oprot.trans.flush()
-
- def recv_get_index_names(self):
- iprot = self._iprot
- (fname, mtype, rseqid) = iprot.readMessageBegin()
- if mtype == TMessageType.EXCEPTION:
- x = TApplicationException()
- x.read(iprot)
- iprot.readMessageEnd()
- raise x
- result = get_index_names_result()
- result.read(iprot)
- iprot.readMessageEnd()
- if result.success is not None:
- return result.success
- if result.o2 is not None:
- raise result.o2
- raise TApplicationException(TApplicationException.MISSING_RESULT, "get_index_names failed: unknown result")
-
def get_primary_keys(self, request):
"""
Parameters:
@@ -8267,12 +7978,6 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["partition_name_to_spec"] = Processor.process_partition_name_to_spec
self._processMap["markPartitionForEvent"] = Processor.process_markPartitionForEvent
self._processMap["isPartitionMarkedForEvent"] = Processor.process_isPartitionMarkedForEvent
- self._processMap["add_index"] = Processor.process_add_index
- self._processMap["alter_index"] = Processor.process_alter_index
- self._processMap["drop_index_by_name"] = Processor.process_drop_index_by_name
- 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["get_unique_constraints"] = Processor.process_get_unique_constraints
@@ -10596,156 +10301,6 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
- def process_add_index(self, seqid, iprot, oprot):
- args = add_index_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = add_index_result()
- try:
- result.success = self._handler.add_index(args.new_index, args.index_table)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except InvalidObjectException as o1:
- msg_type = TMessageType.REPLY
- result.o1 = o1
- except AlreadyExistsException as o2:
- msg_type = TMessageType.REPLY
- result.o2 = o2
- except MetaException as o3:
- msg_type = TMessageType.REPLY
- result.o3 = o3
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("add_index", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_alter_index(self, seqid, iprot, oprot):
- args = alter_index_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = alter_index_result()
- try:
- self._handler.alter_index(args.dbname, args.base_tbl_name, args.idx_name, args.new_idx)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except InvalidOperationException as o1:
- msg_type = TMessageType.REPLY
- result.o1 = o1
- except MetaException as o2:
- msg_type = TMessageType.REPLY
- result.o2 = o2
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("alter_index", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_drop_index_by_name(self, seqid, iprot, oprot):
- args = drop_index_by_name_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = drop_index_by_name_result()
- try:
- result.success = self._handler.drop_index_by_name(args.db_name, args.tbl_name, args.index_name, args.deleteData)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except NoSuchObjectException as o1:
- msg_type = TMessageType.REPLY
- result.o1 = o1
- except MetaException as o2:
- msg_type = TMessageType.REPLY
- result.o2 = o2
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("drop_index_by_name", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_index_by_name(self, seqid, iprot, oprot):
- args = get_index_by_name_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_index_by_name_result()
- try:
- result.success = self._handler.get_index_by_name(args.db_name, args.tbl_name, args.index_name)
- 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_index_by_name", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_indexes(self, seqid, iprot, oprot):
- args = get_indexes_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_indexes_result()
- try:
- result.success = self._handler.get_indexes(args.db_name, args.tbl_name, args.max_indexes)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except NoSuchObjectException as o1:
- msg_type = TMessageType.REPLY
- result.o1 = o1
- except MetaException as o2:
- msg_type = TMessageType.REPLY
- result.o2 = o2
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("get_indexes", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
- def process_get_index_names(self, seqid, iprot, oprot):
- args = get_index_names_args()
- args.read(iprot)
- iprot.readMessageEnd()
- result = get_index_names_result()
- try:
- result.success = self._handler.get_index_names(args.db_name, args.tbl_name, args.max_indexes)
- msg_type = TMessageType.REPLY
- except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
- raise
- except MetaException as o2:
- msg_type = TMessageType.REPLY
- result.o2 = o2
- except Exception as ex:
- msg_type = TMessageType.EXCEPTION
- logging.exception(ex)
- result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
- oprot.writeMessageBegin("get_index_names", msg_type, seqid)
- result.write(oprot)
- oprot.writeMessageEnd()
- oprot.trans.flush()
-
def process_get_primary_keys(self, seqid, iprot, oprot):
args = get_primary_keys_args()
args.read(iprot)
@@ -13865,10 +13420,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype772, _size769) = iprot.readListBegin()
- for _i773 in xrange(_size769):
- _elem774 = iprot.readString()
- self.success.append(_elem774)
+ (_etype763, _size760) = iprot.readListBegin()
+ for _i764 in xrange(_size760):
+ _elem765 = iprot.readString()
+ self.success.append(_elem765)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13891,8 +13446,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 iter775 in self.success:
- oprot.writeString(iter775)
+ for iter766 in self.success:
+ oprot.writeString(iter766)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13997,10 +13552,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype779, _size776) = iprot.readListBegin()
- for _i780 in xrange(_size776):
- _elem781 = iprot.readString()
- self.success.append(_elem781)
+ (_etype770, _size767) = iprot.readListBegin()
+ for _i771 in xrange(_size767):
+ _elem772 = iprot.readString()
+ self.success.append(_elem772)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14023,8 +13578,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 iter782 in self.success:
- oprot.writeString(iter782)
+ for iter773 in self.success:
+ oprot.writeString(iter773)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14794,12 +14349,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype784, _vtype785, _size783 ) = iprot.readMapBegin()
- for _i787 in xrange(_size783):
- _key788 = iprot.readString()
- _val789 = Type()
- _val789.read(iprot)
- self.success[_key788] = _val789
+ (_ktype775, _vtype776, _size774 ) = iprot.readMapBegin()
+ for _i778 in xrange(_size774):
+ _key779 = iprot.readString()
+ _val780 = Type()
+ _val780.read(iprot)
+ self.success[_key779] = _val780
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -14822,9 +14377,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 kiter790,viter791 in self.success.items():
- oprot.writeString(kiter790)
- viter791.write(oprot)
+ for kiter781,viter782 in self.success.items():
+ oprot.writeString(kiter781)
+ viter782.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -14967,11 +14522,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype795, _size792) = iprot.readListBegin()
- for _i796 in xrange(_size792):
- _elem797 = FieldSchema()
- _elem797.read(iprot)
- self.success.append(_elem797)
+ (_etype786, _size783) = iprot.readListBegin()
+ for _i787 in xrange(_size783):
+ _elem788 = FieldSchema()
+ _elem788.read(iprot)
+ self.success.append(_elem788)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15006,8 +14561,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 iter798 in self.success:
- iter798.write(oprot)
+ for iter789 in self.success:
+ iter789.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15174,11 +14729,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype802, _size799) = iprot.readListBegin()
- for _i803 in xrange(_size799):
- _elem804 = FieldSchema()
- _elem804.read(iprot)
- self.success.append(_elem804)
+ (_etype793, _size790) = iprot.readListBegin()
+ for _i794 in xrange(_size790):
+ _elem795 = FieldSchema()
+ _elem795.read(iprot)
+ self.success.append(_elem795)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15213,8 +14768,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 iter805 in self.success:
- iter805.write(oprot)
+ for iter796 in self.success:
+ iter796.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15367,11 +14922,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype809, _size806) = iprot.readListBegin()
- for _i810 in xrange(_size806):
- _elem811 = FieldSchema()
- _elem811.read(iprot)
- self.success.append(_elem811)
+ (_etype800, _size797) = iprot.readListBegin()
+ for _i801 in xrange(_size797):
+ _elem802 = FieldSchema()
+ _elem802.read(iprot)
+ self.success.append(_elem802)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15406,8 +14961,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 iter812 in self.success:
- iter812.write(oprot)
+ for iter803 in self.success:
+ iter803.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15574,11 +15129,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype816, _size813) = iprot.readListBegin()
- for _i817 in xrange(_size813):
- _elem818 = FieldSchema()
- _elem818.read(iprot)
- self.success.append(_elem818)
+ (_etype807, _size804) = iprot.readListBegin()
+ for _i808 in xrange(_size804):
+ _elem809 = FieldSchema()
+ _elem809.read(iprot)
+ self.success.append(_elem809)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15613,8 +15168,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 iter819 in self.success:
- iter819.write(oprot)
+ for iter810 in self.success:
+ iter810.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16064,55 +15619,55 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype823, _size820) = iprot.readListBegin()
- for _i824 in xrange(_size820):
- _elem825 = SQLPrimaryKey()
- _elem825.read(iprot)
- self.primaryKeys.append(_elem825)
+ (_etype814, _size811) = iprot.readListBegin()
+ for _i815 in xrange(_size811):
+ _elem816 = SQLPrimaryKey()
+ _elem816.read(iprot)
+ self.primaryKeys.append(_elem816)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype829, _size826) = iprot.readListBegin()
- for _i830 in xrange(_size826):
- _elem831 = SQLForeignKey()
- _elem831.read(iprot)
- self.foreignKeys.append(_elem831)
+ (_etype820, _size817) = iprot.readListBegin()
+ for _i821 in xrange(_size817):
+ _elem822 = SQLForeignKey()
+ _elem822.read(iprot)
+ self.foreignKeys.append(_elem822)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype835, _size832) = iprot.readListBegin()
- for _i836 in xrange(_size832):
- _elem837 = SQLUniqueConstraint()
- _elem837.read(iprot)
- self.uniqueConstraints.append(_elem837)
+ (_etype826, _size823) = iprot.readListBegin()
+ for _i827 in xrange(_size823):
+ _elem828 = SQLUniqueConstraint()
+ _elem828.read(iprot)
+ self.uniqueConstraints.append(_elem828)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype841, _size838) = iprot.readListBegin()
- for _i842 in xrange(_size838):
- _elem843 = SQLNotNullConstraint()
- _elem843.read(iprot)
- self.notNullConstraints.append(_elem843)
+ (_etype832, _size829) = iprot.readListBegin()
+ for _i833 in xrange(_size829):
+ _elem834 = SQLNotNullConstraint()
+ _elem834.read(iprot)
+ self.notNullConstraints.append(_elem834)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.LIST:
self.defaultConstraints = []
- (_etype847, _size844) = iprot.readListBegin()
- for _i848 in xrange(_size844):
- _elem849 = SQLDefaultConstraint()
- _elem849.read(iprot)
- self.defaultConstraints.append(_elem849)
+ (_etype838, _size835) = iprot.readListBegin()
+ for _i839 in xrange(_size835):
+ _elem840 = SQLDefaultConstraint()
+ _elem840.read(iprot)
+ self.defaultConstraints.append(_elem840)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16133,36 +15688,36 @@ class create_table_with_constraints_args:
if self.primaryKeys is not None:
oprot.writeFieldBegin('primaryKeys', TType.LIST, 2)
oprot.writeListBegin(TType.STRUCT, len(self.primaryKeys))
- for iter850 in self.primaryKeys:
- iter850.write(oprot)
+ for iter841 in self.primaryKeys:
+ iter841.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 iter851 in self.foreignKeys:
- iter851.write(oprot)
+ for iter842 in self.foreignKeys:
+ iter842.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.uniqueConstraints is not None:
oprot.writeFieldBegin('uniqueConstraints', TType.LIST, 4)
oprot.writeListBegin(TType.STRUCT, len(self.uniqueConstraints))
- for iter852 in self.uniqueConstraints:
- iter852.write(oprot)
+ for iter843 in self.uniqueConstraints:
+ iter843.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.notNullConstraints is not None:
oprot.writeFieldBegin('notNullConstraints', TType.LIST, 5)
oprot.writeListBegin(TType.STRUCT, len(self.notNullConstraints))
- for iter853 in self.notNullConstraints:
- iter853.write(oprot)
+ for iter844 in self.notNullConstraints:
+ iter844.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.defaultConstraints is not None:
oprot.writeFieldBegin('defaultConstraints', TType.LIST, 6)
oprot.writeListBegin(TType.STRUCT, len(self.defaultConstraints))
- for iter854 in self.defaultConstraints:
- iter854.write(oprot)
+ for iter845 in self.defaultConstraints:
+ iter845.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17575,10 +17130,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype858, _size855) = iprot.readListBegin()
- for _i859 in xrange(_size855):
- _elem860 = iprot.readString()
- self.partNames.append(_elem860)
+ (_etype849, _size846) = iprot.readListBegin()
+ for _i850 in xrange(_size846):
+ _elem851 = iprot.readString()
+ self.partNames.append(_elem851)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17603,8 +17158,8 @@ class truncate_table_args:
if self.partNames is not None:
oprot.writeFieldBegin('partNames', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.partNames))
- for iter861 in self.partNames:
- oprot.writeString(iter861)
+ for iter852 in self.partNames:
+ oprot.writeString(iter852)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17804,10 +17359,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype865, _size862) = iprot.readListBegin()
- for _i866 in xrange(_size862):
- _elem867 = iprot.readString()
- self.success.append(_elem867)
+ (_etype856, _size853) = iprot.readListBegin()
+ for _i857 in xrange(_size853):
+ _elem858 = iprot.readString()
+ self.success.append(_elem858)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17830,8 +17385,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 iter868 in self.success:
- oprot.writeString(iter868)
+ for iter859 in self.success:
+ oprot.writeString(iter859)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17981,10 +17536,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype872, _size869) = iprot.readListBegin()
- for _i873 in xrange(_size869):
- _elem874 = iprot.readString()
- self.success.append(_elem874)
+ (_etype863, _size860) = iprot.readListBegin()
+ for _i864 in xrange(_size860):
+ _elem865 = iprot.readString()
+ self.success.append(_elem865)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18007,8 +17562,8 @@ class get_tables_by_type_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter875 in self.success:
- oprot.writeString(iter875)
+ for iter866 in self.success:
+ oprot.writeString(iter866)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18132,10 +17687,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype879, _size876) = iprot.readListBegin()
- for _i880 in xrange(_size876):
- _elem881 = iprot.readString()
- self.success.append(_elem881)
+ (_etype870, _size867) = iprot.readListBegin()
+ for _i871 in xrange(_size867):
+ _elem872 = iprot.readString()
+ self.success.append(_elem872)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18158,8 +17713,8 @@ class get_materialized_views_for_rewriting_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter882 in self.success:
- oprot.writeString(iter882)
+ for iter873 in self.success:
+ oprot.writeString(iter873)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18232,10 +17787,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype886, _size883) = iprot.readListBegin()
- for _i887 in xrange(_size883):
- _elem888 = iprot.readString()
- self.tbl_types.append(_elem888)
+ (_etype877, _size874) = iprot.readListBegin()
+ for _i878 in xrange(_size874):
+ _elem879 = iprot.readString()
+ self.tbl_types.append(_elem879)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18260,8 +17815,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 iter889 in self.tbl_types:
- oprot.writeString(iter889)
+ for iter880 in self.tbl_types:
+ oprot.writeString(iter880)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18317,11 +17872,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype893, _size890) = iprot.readListBegin()
- for _i894 in xrange(_size890):
- _elem895 = TableMeta()
- _elem895.read(iprot)
- self.success.append(_elem895)
+ (_etype884, _size881) = iprot.readListBegin()
+ for _i885 in xrange(_size881):
+ _elem886 = TableMeta()
+ _elem886.read(iprot)
+ self.success.append(_elem886)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18344,8 +17899,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 iter896 in self.success:
- iter896.write(oprot)
+ for iter887 in self.success:
+ iter887.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18469,10 +18024,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype900, _size897) = iprot.readListBegin()
- for _i901 in xrange(_size897):
- _elem902 = iprot.readString()
- self.success.append(_elem902)
+ (_etype891, _size888) = iprot.readListBegin()
+ for _i892 in xrange(_size888):
+ _elem893 = iprot.readString()
+ self.success.append(_elem893)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18495,8 +18050,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 iter903 in self.success:
- oprot.writeString(iter903)
+ for iter894 in self.success:
+ oprot.writeString(iter894)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18732,10 +18287,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype907, _size904) = iprot.readListBegin()
- for _i908 in xrange(_size904):
- _elem909 = iprot.readString()
- self.tbl_names.append(_elem909)
+ (_etype898, _size895) = iprot.readListBegin()
+ for _i899 in xrange(_size895):
+ _elem900 = iprot.readString()
+ self.tbl_names.append(_elem900)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18756,8 +18311,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 iter910 in self.tbl_names:
- oprot.writeString(iter910)
+ for iter901 in self.tbl_names:
+ oprot.writeString(iter901)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -18809,11 +18364,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype914, _size911) = iprot.readListBegin()
- for _i915 in xrange(_size911):
- _elem916 = Table()
- _elem916.read(iprot)
- self.success.append(_elem916)
+ (_etype905, _size902) = iprot.readListBegin()
+ for _i906 in xrange(_size902):
+ _elem907 = Table()
+ _elem907.read(iprot)
+ self.success.append(_elem907)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18830,8 +18385,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 iter917 in self.success:
- iter917.write(oprot)
+ for iter908 in self.success:
+ iter908.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19223,10 +18778,10 @@ class get_materialization_invalidation_info_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype921, _size918) = iprot.readListBegin()
- for _i922 in xrange(_size918):
- _elem923 = iprot.readString()
- self.tbl_names.append(_elem923)
+ (_etype912, _size909) = iprot.readListBegin()
+ for _i913 in xrange(_size909):
+ _elem914 = iprot.readString()
+ self.tbl_names.append(_elem914)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19247,8 +18802,8 @@ class get_materialization_invalidation_info_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter924 in self.tbl_names:
- oprot.writeString(iter924)
+ for iter915 in self.tbl_names:
+ oprot.writeString(iter915)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19309,12 +18864,12 @@ class get_materialization_invalidation_info_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype926, _vtype927, _size925 ) = iprot.readMapBegin()
- for _i929 in xrange(_size925):
- _key930 = iprot.readString()
- _val931 = Materialization()
- _val931.read(iprot)
- self.success[_key930] = _val931
+ (_ktype917, _vtype918, _size916 ) = iprot.readMapBegin()
+ for _i920 in xrange(_size916):
+ _key921 = iprot.readString()
+ _val922 = Materialization()
+ _val922.read(iprot)
+ self.success[_key921] = _val922
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -19349,9 +18904,9 @@ class get_materialization_invalidation_info_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter932,viter933 in self.success.items():
- oprot.writeString(kiter932)
- viter933.write(oprot)
+ for kiter923,viter924 in self.success.items():
+ oprot.writeString(kiter923)
+ viter924.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19703,10 +19258,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype937, _size934) = iprot.readListBegin()
- for _i938 in xrange(_size934):
- _elem939 = iprot.readString()
- self.success.append(_elem939)
+ (_etype928, _size925) = iprot.readListBegin()
+ for _i929 in xrange(_size925):
+ _elem930 = iprot.readString()
+ self.success.append(_elem930)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19741,8 +19296,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 iter940 in self.success:
- oprot.writeString(iter940)
+ for iter931 in self.success:
+ oprot.writeString(iter931)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20712,11 +20267,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype944, _size941) = iprot.readListBegin()
- for _i945 in xrange(_size941):
- _elem946 = Partition()
- _elem946.read(iprot)
- self.new_parts.append(_elem946)
+ (_etype935, _size932) = iprot.readListBegin()
+ for _i936 in xrange(_size932):
+ _elem937 = Partition()
+ _elem937.read(iprot)
+ self.new_parts.append(_elem937)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20733,8 +20288,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 iter947 in self.new_parts:
- iter947.write(oprot)
+ for iter938 in self.new_parts:
+ iter938.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20892,11 +20447,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype951, _size948) = iprot.readListBegin()
- for _i952 in xrange(_size948):
- _elem953 = PartitionSpec()
- _elem953.read(iprot)
- self.new_parts.append(_elem953)
+ (_etype942, _size939) = iprot.readListBegin()
+ for _i943 in xrange(_size939):
+ _elem944 = PartitionSpec()
+ _elem944.read(iprot)
+ self.new_parts.append(_elem944)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20913,8 +20468,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 iter954 in self.new_parts:
- iter954.write(oprot)
+ for iter945 in self.new_parts:
+ iter945.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21088,10 +20643,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype958, _size955) = iprot.readListBegin()
- for _i959 in xrange(_size955):
- _elem960 = iprot.readString()
- self.part_vals.append(_elem960)
+ (_etype949, _size946) = iprot.readListBegin()
+ for _i950 in xrange(_size946):
+ _elem951 = iprot.readString()
+ self.part_vals.append(_elem951)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21116,8 +20671,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 iter961 in self.part_vals:
- oprot.writeString(iter961)
+ for iter952 in self.part_vals:
+ oprot.writeString(iter952)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21470,10 +21025,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype965, _size962) = iprot.readListBegin()
- for _i966 in xrange(_size962):
- _elem967 = iprot.readString()
- self.part_vals.append(_elem967)
+ (_etype956, _size953) = iprot.readListBegin()
+ for _i957 in xrange(_size953):
+ _elem958 = iprot.readString()
+ self.part_vals.append(_elem958)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21504,8 +21059,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 iter968 in self.part_vals:
- oprot.writeString(iter968)
+ for iter959 in self.part_vals:
+ oprot.writeString(iter959)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -22100,10 +21655,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype972, _size969) = iprot.readListBegin()
- for _i973 in xrange(_size969):
- _elem974 = iprot.readString()
- self.part_vals.append(_elem974)
+ (_etype963, _size960) = iprot.readListBegin()
+ for _i964 in xrange(_size960):
+ _elem965 = iprot.readString()
+ self.part_vals.append(_elem965)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22133,8 +21688,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 iter975 in self.part_vals:
- oprot.writeString(iter975)
+ for iter966 in self.part_vals:
+ oprot.writeString(iter966)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -22307,10 +21862,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype979, _size976) = iprot.readListBegin()
- for _i980 in xrange(_size976):
- _elem981 = iprot.readString()
- self.part_vals.append(_elem981)
+ (_etype970, _size967) = iprot.readListBegin()
+ for _i971 in xrange(_size967):
+ _elem972 = iprot.readString()
+ self.part_vals.append(_elem972)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22346,8 +21901,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 iter982 in self.part_vals:
- oprot.writeString(iter982)
+ for iter973 in self.part_vals:
+ oprot.writeString(iter973)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -23084,10 +22639,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype986, _size983) = iprot.readListBegin()
- for _i987 in xrange(_size983):
- _elem988 = iprot.readString()
- self.part_vals.append(_elem988)
+ (_etype977, _size974) = iprot.readListBegin()
+ for _i978 in xrange(_size974):
+ _elem979 = iprot.readString()
+ self.part_vals.append(_elem979)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23112,8 +22667,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 iter989 in self.part_vals:
- oprot.writeString(iter989)
+ for iter980 in self.part_vals:
+ oprot.writeString(iter980)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23272,6 +22827,254 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
+ (_ktype982, _vtype983, _size981 ) = iprot.readMapBegin()
+ for _i985 in xrange(_size981):
+ _key986 = iprot.readString()
+ _val987 = iprot.readString()
+ self.partitionSpecs[_key986] = _val987
+ iprot.readMapEnd()
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.source_db = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.source_table_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.dest_db = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.STRING:
+ self.dest_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('exchange_partition_args')
+ if self.partitionSpecs is not None:
+ oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
+ oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
+ for kiter988,viter989 in self.partitionSpecs.items():
+ oprot.writeString(kiter988)
+ oprot.writeString(viter989)
+ oprot.writeMapEnd()
+ oprot.writeFieldEnd()
+ if self.source_db is not None:
+ oprot.writeFieldBegin('source_db', TType.STRING, 2)
+ oprot.writeString(self.source_db)
+ oprot.writeFieldEnd()
+ if self.source_table_name is not None:
+ oprot.writeFieldBegin('source_table_name', TType.STRING, 3)
+ oprot.writeString(self.source_table_name)
+ oprot.writeFieldEnd()
+ if self.dest_db is not None:
+ oprot.writeFieldBegin('dest_db', TType.STRING, 4)
+ oprot.writeString(self.dest_db)
+ oprot.writeFieldEnd()
+ if self.dest_table_name is not None:
+ oprot.writeFieldBegin('dest_table_name', TType.STRING, 5)
+ oprot.writeString(self.dest_table_name)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.partitionSpecs)
+ value = (value * 31) ^ hash(self.source_db)
+ value = (value * 31) ^ hash(self.source_table_name)
+ value = (value * 31) ^ hash(self.dest_db)
+ value = (value * 31) ^ hash(self.dest_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 exchange_partition_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ - o3
+ - o4
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
+ (3, TType.STRUCT, 'o3', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 3
+ (4, TType.STRUCT, 'o4', (InvalidInputException, InvalidInputException.thrift_spec), None, ), # 4
+ )
+
+ def __init__(self, success=None, o1=None, o2=None, o3=None, o4=None,):
+ self.success = success
+ 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 == 0:
+ if ftype == TType.STRUCT:
+ self.success = Partition()
+ 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)
+ elif fid == 3:
+ if ftype == TType.STRUCT:
+ self.o3 = InvalidObjectException()
+ self.o3.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRUCT:
+ self.o4 = InvalidInputException()
+ 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('exchange_partition_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()
+ 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.success)
+ 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 exchange_partitions_args:
+ """
+ Attributes:
+ - partitionSpecs
+ - source_db
+ - source_table_name
+ - dest_db
+ - dest_table_name
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.MAP, 'partitionSpecs', (TType.STRING,None,TType.STRING,None), None, ), # 1
+ (2, TType.STRING, 'source_db', None, None, ), # 2
+ (3, TType.STRING, 'source_table_name', None, None, ), # 3
+ (4, TType.STRING, 'dest_db', None, None, ), # 4
+ (5, TType.STRING, 'dest_table_name', None, None, ), # 5
+ )
+
+ def __init__(self, partitionSpecs=None, source_db=None, source_table_name=None, dest_db=None, dest_table_name=None,):
+ self.partitionSpecs = partitionSpecs
+ self.source_db = source_db
+ self.source_table_name = source_table_name
+ self.dest_db = dest_db
+ self.dest_table_name = dest_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.MAP:
+ self.partitionSpecs = {}
(_ktype991, _vtype992, _size990 ) = iprot.readMapBegin()
for _i994 in xrange(_size990):
_key995 = iprot.readString()
@@ -23309,7 +23112,7 @@ class exchange_partition_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('exchange_partition_args')
+ oprot.writeStructBegin('exchange_partitions_args')
if self.partitionSpecs is not None:
oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1)
oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs))
@@ -23361,7 +23164,7 @@ class exchange_partition_args:
def __ne__(self, other):
return not (self == other)
-class exchange_partition_result:
+class exchange_partitions_result:
"""
Attributes:
- success
@@ -23372,7 +23175,7 @@ class exchange_partition_result:
"""
thrift_spec = (
- (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0
+ (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0
(1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
(2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
(3, TType.STRUCT, 'o3', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 3
@@ -23396,9 +23199,14 @@ class exchange_partition_result:
if ftype == TType.STOP:
break
if fid == 0:
- if ftype == TType.STRUCT:
- self.success = Partition()
- self.success.read(iprot)
+ if ftype == TType.LIST:
+ self.success = []
+ (_etype1002, _size999) = iprot.readListBegin()
+ for _i1003 in xrange(_size999):
+ _elem1004 = Partition()
+ _elem1004.read(iprot)
+ self.success.append(_elem1004)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 1:
@@ -23434,10 +23242,13 @@ class exchange_partition_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('exchange_partition_result')
+ oprot.writeStructBegin('exchange_partitions_result')
if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRUCT, len(self.success))
+ for iter1005 in self.success:
+ iter1005.write(oprot)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
@@ -23482,31 +23293,31 @@ class exchange_partition_result:
def __ne__(self, other):
return not (self == other)
-class exchange_partitions_args:
+class get_partition_with_auth_args:
"""
Attributes:
- - partitionSpecs
- - source_db
- - source_table_name
- - dest_db
- - dest_table_name
+ - db_name
+ - tbl_name
+ - part_vals
+ - user_name
+ - group_names
"""
thrift_spec = (
None, # 0
- (1, TType.MAP, 'partitionSpecs', (TType.STRING,None,TType.STRING,None), None, ), # 1
- (2, TType.STRING, 'source_db', None, None, ), # 2
- (3, TType.STRING, 'source_table_name', None, None, ), # 3
- (4, TType.STRING, 'dest_db', None, None, ), # 4
- (5, TType.STRING, 'dest_table_name', None, None, ), # 5
+ (1, TType.STRING, 'db_name', None, None, ), # 1
+ (2, TType.STRING, 'tbl_name', None, None, ), # 2
+ (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3
+ (4, TType.STRING, 'user_name', None, None, ), # 4
+ (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5
)
- def __init__(self, partitionSpecs=None, source_db=None, source_table_name=None, dest_db=None, dest_table_name=None,):
- self.partitionSpecs = partitionSpecs
- self.source_db = source_db
- self.source_table_name = source_table_name
- self.dest_db = dest_db
- self.dest_table_name = dest_table_name
+ def __init__(self, db_name=None, tbl_name=None, part_vals=None, user_name=None, group_names=None,):
+ self.db_name = db_name
+ self.tbl_name = tbl_name
+ self.part_vals = part_vals
+ self.user_name = user_name
+ self.group_names = group_names
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:
@@ -23518,34 +23329,38 @@ class exchange_partitions_args:
if ftype == TType.STOP:
break
if fid == 1:
- if ftype == TType.MAP:
- self.partitionSpecs = {}
- (_ktype1000, _vtype1001, _size999 ) = iprot.readMapBegin()
- for _i1003 in xrange(_size999):
- _key1004 = iprot.readString()
- _val1005 = iprot.readString()
- self.partitionSpecs[_key1004] = _val1005
- iprot.readMapEnd()
+ if ftype == TType.STRING:
+ self.db_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRING:
- self.source_db = iprot.readString()
+ self.tbl_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 3:
- if ftype == TType.STRING:
- self.source_table_name = iprot.readString()
+ if ftype == TType.LIST:
+ self.part_vals = []
+ (_etype1009, _size1006) = iprot.readListBegin()
+ for _i1010 in xrange(_size1006):
+ _elem1011 = iprot.readString()
+ self.part_vals.append(_elem1011)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.STRING:
- self.dest_db = iprot.readString()
+ self.user_name = iprot.readString()
else:
iprot.skip(ftype)
elif fid == 5:
- if ftype == TType.STRING:
- self.dest_table_name = iprot.readString()
+ if ftype == TType.LIST:
+ self.group_names = []
+ (_etype1015, _size1012) = iprot.readListBegin()
+ for _i1016 in xrange(_size1012):
+ _elem1017 = iprot.readString()
+ self.group_names.append(_elem1017)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
else:
@@ -23557,30 +23372,32 @@ class exchange_partitions_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('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 kiter1006,viter1007 in self.partitionSpecs.items():
- oprot.writeString(kiter1006)
- oprot.writeString(viter1007)
- oprot.writeMapEnd()
+ oprot.writeStructBegin('get_partition_with_auth_args')
+ if self.db_name is not None:
+ oprot.writeFieldBegin('db_name', TType.STRING, 1)
+ oprot.writeString(self.db_name)
oprot.writeFieldEnd()
- if self.source_db is not None:
- oprot.writeFieldBegin('source_db', TType.STRING, 2)
- oprot.writeString(self.source_db)
+ if self.tbl_name is not None:
+ oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
+ oprot.writeString(self.tbl_name)
oprot.writeFieldEnd()
- if self.source_table_name is not None:
- oprot.writeFieldBegin('source_table_name', TType.STRING, 3)
- oprot.writeString(self.source_table_name)
+ if self.part_vals is not None:
+ oprot.writeFieldBegin('part_vals', TType.LIST, 3)
+ oprot.writeListBegin(TType.STRING, len(self.part_vals))
+ for iter1018 in self.part_vals:
+ oprot.writeString(iter1018)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
- if self.dest_db is not None:
- oprot.writeFieldBegin('dest_db', TType.STRING, 4)
- oprot.writeString(self.dest_db)
+ if self.user_name is not None:
+ oprot.writeFieldBegin('user_name', TType.STRING, 4)
+ oprot.writeString(self.user_name)
oprot.writeFieldEnd()
- if self.dest_table_name is not None:
- oprot.writeFieldBegin('dest_table_name', TType.STRING, 5)
- oprot.writeString(self.dest_table_name)
+ if self.group_names is not None:
+ oprot.writeFieldBegin('group_names', TType.LIST, 5)
+ oprot.writeListBegin(TType.STRING, len(self.group_names))
+ for iter1019 in self.group_names:
+ oprot.writeString(iter1019)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -23591,11 +23408,11 @@ class exchange_partitions_args:
def __hash__(self):
value = 17
- value = (value * 31) ^ hash(self.partitionSpecs)
- value = (value * 31) ^ hash(self.source_db)
- value = (value * 31) ^ hash(self.source_table_name)
- value = (value * 31) ^ hash(self.dest_db)
- value = (value * 31) ^ hash(self.dest_table_name)
+ value = (value * 31) ^ hash(self.db_name)
+ value = (value * 31) ^ hash(self.tbl_name)
+ value = (value * 31) ^ hash(self.part_vals)
+ value = (value * 31) ^ hash(self.user_name)
+ value = (value * 31) ^ hash(self.group_names)
return value
def __repr__(self):
@@ -23609,30 +23426,24 @@ class exchange_partitions_args:
def __ne__(self, other):
return not (self == other)
-class exchange_partitions_result:
+class get_partition_with_auth_result:
"""
Attributes:
- success
- o1
- o2
- - o3
- - o4
"""
thrift_spec = (
- (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 0
+ (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0
(1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
(2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
- (3, TType.STRUCT, 'o3', (InvalidObjectException, InvalidObjectException.thrift_spec), None, ), # 3
- (4, TType.STRUCT, 'o4', (InvalidInputException, InvalidInputException.thrift_spec), None, ), # 4
)
- def __init__(self, success=None, o1=None, o2=None, o3=None, o4=None,):
+ def __init__(self, success=None, o1=None, o2=None,):
self.success = success
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:
@@ -23644,14 +23455,9 @@ class exchange_partitions_result:
if ftype == TType.STOP:
break
if fid == 0:
- if ftype == TType.LIST:
- self.success = []
- (_etype1011, _size1008) = iprot.readListBegin()
- for _i1012 in xrange(_size1008):
- _elem1013 = Partition()
- _elem1013.read(iprot)
- self.success.append(_elem1013)
- iprot.readListEnd()
+ if ftype == TType.STRUCT:
+ self.success = Partition()
+ self.success.read(iprot)
else:
iprot.skip(ftype)
elif fid == 1:
@@ -23666,18 +23472,6 @@ class exchange_partitions_result:
self.o2.read(iprot)
else:
iprot.skip(ftype)
- elif fid == 3:
- if ftype == TType.STRUCT:
- self.o3 = InvalidObjectException()
- self.o3.read(iprot)
- else:
- iprot.skip(ftype)
- elif fid == 4:
- if ftype == TType.STRUCT:
- self.o4 = InvalidInputException()
- self.o4.read(iprot)
- else:
- iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -23687,13 +23481,10 @@ class exchange_partitions_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('exchange_partitions_result')
+ oprot.writeStructBegin('get_partition_with_auth_result')
if self.success is not None:
- oprot.writeFieldBegin('success', TType.LIST, 0)
- oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1014 in self.success:
- iter1014.write(oprot)
- oprot.writeListEnd()
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
oprot.writeFieldEnd()
if self.o1 is not None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
@@ -23703,14 +23494,6 @@ class exchange_partitions_result:
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()
@@ -23723,8 +23506,6 @@ class exchange_partitions_result:
value = (value * 31) ^ hash(self.success)
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):
@@ -23738,31 +23519,25 @@ class exchange_partitions_result:
def __ne__(self, other):
return not (self == other)
-class get_partition_with_auth_args:
+class get_partition_by_name_args:
"""
Attributes:
- db_name
- tbl_name
- - part_vals
- - user_name
- - group_names
+ - part_name
"""
thrift_spec = (
None, # 0
(1, TType.STRING, 'db_name', None, None, ), # 1
(2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.LIST, 'part_vals', (TType.STRING,None), None, ), # 3
- (4, TType.STRING, 'user_name', None, None, ), # 4
- (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5
+ (3, TType.STRING, 'part_name', None, None, ), # 3
)
- def __init__(self, db_name=None, tbl_name=None, part_vals=None, user_name=None, group_names=None,):
+ def __init__(self, db_name=None, tbl_name=None, part_name=None,):
self.db_name = db_name
self.tbl_name = tbl_name
- self.part_vals = part_vals
- self.user_name = user_name
- self.group_names = group_names
+ self.part_name = part_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:
@@ -23784,28 +23559,8 @@ class get_partition_with_auth_args:
else:
iprot.skip(ftype)
elif fid == 3:
- if ftype == TType.LIST:
- self.part_vals = []
- (_etype1018, _size1015) = iprot.readListBegin()
- for _i1019 in xrange(_size1015):
- _elem1020 = iprot.readString()
- self.part_vals.append(_elem1020)
- iprot.readListEnd()
- else:
- iprot.skip(ftype)
- elif fid == 4:
if ftype == TType.STRING:
- self.user_name = iprot.readString()
- else:
- iprot.skip(ftype)
- elif fid == 5:
- if ftype == TType.LIST:
- self.group_names = []
- (_etype1024, _size1021) = iprot.readListBegin()
- for _i1025 in xrange(_size1021):
- _elem1026 = iprot.readString()
- self.group_names.append(_elem1026)
- iprot.readListEnd()
+ self.part_name = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -23817,7 +23572,7 @@ class get_partition_with_auth_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_partition_with_auth_args')
+ oprot.writeStructBegin('get_partition_by_name_args')
if self.db_name is not None:
oprot.writeFieldBegin('db_name', TType.STRING, 1)
oprot.writeString(self.db_name)
@@ -23826,23 +23581,9 @@ class get_partition_with_auth_args:
oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
oprot.writeString(self.tbl_name)
oprot.writeFieldEnd()
- if self.part_vals is not None:
- oprot.writeFieldBegin('part_vals', TType.LIST, 3)
- oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter1027 in self.part_vals:
- oprot.writeString(iter1027)
- oprot.writeListEnd()
- oprot.writeFieldEnd()
- if self.user_name is not None:
- oprot.writeFieldBegin('user_name', TType.STRING, 4)
- oprot.writeString(self.user_name)
- oprot.writeFieldEnd()
- if self.group_names is not None:
- oprot.writeFieldBegin('group_names', TType.LIST, 5)
- oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1028 in self.group_names:
- oprot.writeString(iter1028)
- oprot.writeListEnd()
+ if self.part_name is not None:
+ oprot.writeFieldBegin('part_name', TType.STRING, 3)
+ oprot.writeString(self.part_name)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -23855,9 +23596,7 @@ class get_partition_with_auth_args:
value = 17
value = (value * 31) ^ hash(self.db_name)
value = (value * 31) ^ hash(self.tbl_name)
- value = (value * 31) ^ hash(self.part_vals)
- value = (value * 31) ^ hash(self.user_name)
- value = (value * 31) ^ hash(self.group_names)
+ value = (value * 31) ^ hash(self.part_name)
return value
def __repr__(self):
@@ -23871,7 +23610,7 @@ class get_partition_with_auth_args:
def __ne__(self, other):
return not (self == other)
-class get_partition_with_auth_result:
+class get_partition_by_name_result:
"""
Attributes:
- success
@@ -23926,7 +23665,7 @@ class get_partition_with_auth_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_partition_with_auth_result')
+ oprot.writeStructBegin('get_partition_by_name_result')
if self.success is not None:
oprot.writeFieldBegin('success', TType.STRUCT, 0)
self.success.write(oprot)
@@ -23964,25 +23703,25 @@ class get_partition_with_auth_result:
def __ne__(self, other):
return not (self == other)
-class get_partition_by_name_args:
+class get_partitions_args:
"""
Attributes:
- db_name
- tbl_name
- - part_name
+ - max_parts
"""
thrift_spec = (
None, # 0
(1, TType.STRING, 'db_name', None, None, ), # 1
(2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.STRING, 'part_name', None, None, ), # 3
+ (3, TType.I16, 'max_parts', None, -1, ), # 3
)
- def __init__(self, db_name=None, tbl_name=None, part_name=None,):
+ def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],):
self.db_name = db_name
self.tbl_name = tbl_name
- self.part_name = part_name
+ self.max_parts = max_parts
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:
@@ -24004,8 +23743,8 @@ class get_partition_by_name_args:
else:
iprot.skip(ftype)
elif fid == 3:
- if ftype == TType.STRING:
- self.part_name = iprot.readString()
+ if ftype == TType.I16:
+ self.max_parts = iprot.readI16()
else:
iprot.skip(ftype)
else:
@@ -24017,7 +23756,7 @@ class get_partition_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_partition_by_name_args')
+ oprot.writeStructBegin('get_partitions_args')
if self.db_name is not None:
oprot.writeFieldBegin('db_name', TType.STRING, 1)
oprot.writeString(self.db_name)
@@ -24026,9 +23765,9 @@ class get_partition_by_name_args:
oprot.writeFieldBegin('tbl_name', TType.STRING, 2)
oprot.writeString(self.tbl_name)
oprot.writeFieldEnd()
- if self.part_name is not None:
- oprot.writeFieldBegin('part_name', TType.STRING, 3)
- oprot.writeString(self.part_name)
+ if self.max_parts is not None:
+ oprot.writeFieldBegin('max_parts', TType.I16, 3)
+ oprot.writeI16(self.max_parts)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -24041,7 +23780,7 @@ class get_partition_by_name_args:
value = 17
value = (value * 31) ^ hash(self.db_name)
value = (value * 31) ^ hash(self.tbl_name)
- value = (value * 31) ^ hash(self.part_name)
+ value = (value * 31) ^ hash(self.max_parts)
return value
def __repr__(self):
@@ -24055,7 +23794,7 @@ class get_partition_by_name_args:
def __ne__(self, other):
return not (self == other)
-class get_partition_by_name_result:
+class get_partitions_result:
"""
Attributes:
- success
@@ -24064,9 +23803,9 @@ class get_partition_by_name_result:
"""
thrift_spec = (
- (0, TType.STRUCT, 'success', (Partition, Partition.thrift_spec), None, ), # 0
- (1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
- (2, TType.STRUCT, 'o2', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 2
+ (0, TType.LIST, 'success', (TType.STRUCT,(Partition, Partition.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,):
@@ -24084,20 +23823,25 @@ class get_partition_by_name_result:
if ftype == TType.STOP:
break
if fid == 0:
- if ftype == TType.STRUCT:
- self.success = Partition()
- self.success.read(iprot)
+ if ftype == TType.LIST:
+ self.success = []
+ (_etype1023, _size1020) = iprot.readListBegin()
+ for _i1024 in xrange(_size1020):
+ _elem1025 = Partition()
+ _elem1025.read(iprot)
+ self.success.append(_elem1025)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 1:
if ftype == TType.STRUCT:
- self.o1 = MetaException()
+ self.o1 = NoSuchObjectException()
self.o1.read(iprot)
else:
iprot.skip(ftype)
elif fid == 2:
if ftype == TType.STRUCT:
- self.o2 = NoSuchObjectException()
+ self.o2 = MetaException()
self.o2.read(iprot)
else:
iprot.skip(ftype)
@@ -24110,10 +23854,13 @@ class get_partition_by_name_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_partition_by_name_result')
+ oprot.writeStructBegin('get_partitions_result')
if self.success is not None:
- oprot.writeFieldBegin('success', TType.STRUCT, 0)
- self.success.write(oprot)
+ oprot.writeFieldBegin('success', TType.LIST, 0)
+ oprot.writeListBegin(TType.STRUCT, len(self.success))
+ for iter1026 in self.success:
+ iter1026.write(oprot)
+ oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
@@ -24148,12 +23895,14 @@ class get_partition_by_name_result:
def __ne__(self, other):
return not (self == other)
-class get_partitions_args:
+class get_partitions_with_auth_args:
"""
Attributes:
- db_name
- tbl_name
- max_parts
+ - user_name
+ - group_names
"""
thrift_spec = (
@@ -24161,12 +23910,16 @@ class get_partitions_args:
(1, TType.STRING, 'db_name', None, None, ), # 1
(2, TType.STRING, 'tbl_name', None, None, ), # 2
(3, TType.I16, 'max_parts', None, -1, ), # 3
+ (4, TType.STRING, 'user_name', None, None, ), # 4
+ (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5
)
- def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],):
+ def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4], user_name=None, group_names=None,):
self.db_name = db_name
self.tbl_name = tbl_name
self.max_parts = max_parts
+ self.user_name = user_name
+ self.group_names = group_names
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:
@@ -24192,6 +23945,21 @@ class get_partitions_args:
self.max_parts = iprot.readI16()
else:
iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.user_name = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.LIST:
+ self.group_names = []
+ (_etype1030, _size1027) = iprot.readListBegin()
+ for _i1031 in xrange(_size1027):
+ _elem1032 = iprot.readString()
+ self.group_names.append(_elem1032)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -24201,7 +23969,7 @@ class get_partitions_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_partitions_args')
+ oprot.writeStructBegin('get_partitions_with_auth_args')
if self.db_name is not None:
oprot.writeFieldBegin('db_name', TType.STRING, 1)
oprot.writeString(self.db_name)
@@ -24214,6 +23982,17 @@ class get_partitions_args:
oprot.writeFieldBegin('max_parts', TType.I16, 3)
oprot.writeI16(self.max_parts)
oprot.writeFieldEnd()
+ if self.user_name is not None:
+ oprot.writeFieldBegin('user_name', TType.STRING, 4)
+ oprot.writeString(self.user_name)
+ oprot.writeFieldEnd()
+ if self.group_names is not None:
+ oprot.writeFieldBegin('group_names', TType.LIST, 5)
+ oprot.writeListBegin(TType.STRING, len(self.group_names))
+ for iter1033 in self.group_names:
+ oprot.writeString(iter1033)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -24226,6 +24005,8 @@ class get_partitions_args:
value = (value * 31) ^ hash(self.db_name)
value = (value * 31) ^ hash(self.tbl_name)
value = (value * 31) ^ hash(self.max_parts)
+ value = (value * 31) ^ hash(self.user_name)
+ value = (value * 31) ^ hash(self.group_names)
return value
def __repr__(self):
@@ -24239,7 +24020,7 @@ class get_partitions_args:
def __ne__(self, other):
return not (self == other)
-class get_partitions_result:
+class get_partitions_with_auth_result:
"""
Attributes:
- success
@@ -24270,11 +24051,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1032, _size1029) = iprot.readListBegin()
- for _i1033 in xrange(_size1029):
- _elem1034 = Partition()
- _elem1034.read(iprot)
- self.success.append(_elem1034)
+ (_etype1037, _size1034) = iprot.readListBegin()
+ for _i1038 in xrange(_size1034):
+ _elem1039 = Partition()
+ _elem1039.read(iprot)
+ self.success.append(_elem1039)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24299,12 +24080,12 @@ class get_partitions_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_partitions_result')
+ oprot.writeStructBegin('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 iter1035 in self.success:
- iter1035.write(oprot)
+ for iter1040 in self.success:
+ iter1040.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24340,31 +24121,25 @@ class get_partitions_result:
def __ne__(self, other):
return not (self == other)
-class get_partitions_with_auth_args:
+class get_partitions_pspec_args:
"""
Attributes:
- db_name
- tbl_name
- max_parts
- - user_name
- - group_names
"""
thrift_spec = (
None, # 0
(1, TType.STRING, 'db_name', None, None, ), # 1
(2, TType.STRING, 'tbl_name', None, None, ), # 2
- (3, TType.I16, 'max_parts', None, -1, ), # 3
- (4, TType.STRING, 'user_name', None, None, ), # 4
- (5, TType.LIST, 'group_names', (TType.STRING,None), None, ), # 5
+ (3, TType.I32, 'max_parts', None, -1, ), # 3
)
- def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4], user_name=None, group_names=None,):
+ def __init__(self, db_name=None, tbl_name=None, max_parts=thrift_spec[3][4],):
self.db_name = db_name
self.tbl_name = tbl_name
self.max_parts = max_parts
- self.user_name = user_name
- self.group_names = group_names
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:
@@ -24386,23 +24161,8 @@ class get_partitions_with_auth_args:
else:
iprot.skip(ftype)
elif fid == 3:
-
<TRUNCATED>