You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jc...@apache.org on 2018/06/27 06:22:37 UTC
[03/12] hive git commit: HIVE-19027: Make materializations
invalidation cache work with multiple active remote metastores (Jesus Camacho
Rodriguez, reviewed by Ashutosh Chauhan)
http://git-wip-us.apache.org/repos/asf/hive/blob/774a8ef7/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 5a3f2c1..c4f3f02 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
@@ -347,11 +347,11 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def get_materialization_invalidation_info(self, dbname, tbl_names):
+ def get_materialization_invalidation_info(self, creation_metadata, validTxnList):
"""
Parameters:
- - dbname
- - tbl_names
+ - creation_metadata
+ - validTxnList
"""
pass
@@ -3134,20 +3134,20 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o3
raise TApplicationException(TApplicationException.MISSING_RESULT, "get_table_objects_by_name_req failed: unknown result")
- def get_materialization_invalidation_info(self, dbname, tbl_names):
+ def get_materialization_invalidation_info(self, creation_metadata, validTxnList):
"""
Parameters:
- - dbname
- - tbl_names
+ - creation_metadata
+ - validTxnList
"""
- self.send_get_materialization_invalidation_info(dbname, tbl_names)
+ self.send_get_materialization_invalidation_info(creation_metadata, validTxnList)
return self.recv_get_materialization_invalidation_info()
- def send_get_materialization_invalidation_info(self, dbname, tbl_names):
+ def send_get_materialization_invalidation_info(self, creation_metadata, validTxnList):
self._oprot.writeMessageBegin('get_materialization_invalidation_info', TMessageType.CALL, self._seqid)
args = get_materialization_invalidation_info_args()
- args.dbname = dbname
- args.tbl_names = tbl_names
+ args.creation_metadata = creation_metadata
+ args.validTxnList = validTxnList
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -10318,7 +10318,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
iprot.readMessageEnd()
result = get_materialization_invalidation_info_result()
try:
- result.success = self._handler.get_materialization_invalidation_info(args.dbname, args.tbl_names)
+ result.success = self._handler.get_materialization_invalidation_info(args.creation_metadata, args.validTxnList)
msg_type = TMessageType.REPLY
except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
raise
@@ -15987,10 +15987,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype819, _size816) = iprot.readListBegin()
- for _i820 in xrange(_size816):
- _elem821 = iprot.readString()
- self.success.append(_elem821)
+ (_etype812, _size809) = iprot.readListBegin()
+ for _i813 in xrange(_size809):
+ _elem814 = iprot.readString()
+ self.success.append(_elem814)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16013,8 +16013,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 iter822 in self.success:
- oprot.writeString(iter822)
+ for iter815 in self.success:
+ oprot.writeString(iter815)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16119,10 +16119,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype826, _size823) = iprot.readListBegin()
- for _i827 in xrange(_size823):
- _elem828 = iprot.readString()
- self.success.append(_elem828)
+ (_etype819, _size816) = iprot.readListBegin()
+ for _i820 in xrange(_size816):
+ _elem821 = iprot.readString()
+ self.success.append(_elem821)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16145,8 +16145,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 iter829 in self.success:
- oprot.writeString(iter829)
+ for iter822 in self.success:
+ oprot.writeString(iter822)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16916,12 +16916,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype831, _vtype832, _size830 ) = iprot.readMapBegin()
- for _i834 in xrange(_size830):
- _key835 = iprot.readString()
- _val836 = Type()
- _val836.read(iprot)
- self.success[_key835] = _val836
+ (_ktype824, _vtype825, _size823 ) = iprot.readMapBegin()
+ for _i827 in xrange(_size823):
+ _key828 = iprot.readString()
+ _val829 = Type()
+ _val829.read(iprot)
+ self.success[_key828] = _val829
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16944,9 +16944,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 kiter837,viter838 in self.success.items():
- oprot.writeString(kiter837)
- viter838.write(oprot)
+ for kiter830,viter831 in self.success.items():
+ oprot.writeString(kiter830)
+ viter831.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -17089,11 +17089,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype842, _size839) = iprot.readListBegin()
- for _i843 in xrange(_size839):
- _elem844 = FieldSchema()
- _elem844.read(iprot)
- self.success.append(_elem844)
+ (_etype835, _size832) = iprot.readListBegin()
+ for _i836 in xrange(_size832):
+ _elem837 = FieldSchema()
+ _elem837.read(iprot)
+ self.success.append(_elem837)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17128,8 +17128,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 iter845 in self.success:
- iter845.write(oprot)
+ for iter838 in self.success:
+ iter838.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17296,11 +17296,11 @@ class get_fields_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype849, _size846) = iprot.readListBegin()
- for _i850 in xrange(_size846):
- _elem851 = FieldSchema()
- _elem851.read(iprot)
- self.success.append(_elem851)
+ (_etype842, _size839) = iprot.readListBegin()
+ for _i843 in xrange(_size839):
+ _elem844 = FieldSchema()
+ _elem844.read(iprot)
+ self.success.append(_elem844)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17335,8 +17335,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 iter852 in self.success:
- iter852.write(oprot)
+ for iter845 in self.success:
+ iter845.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17489,11 +17489,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype856, _size853) = iprot.readListBegin()
- for _i857 in xrange(_size853):
- _elem858 = FieldSchema()
- _elem858.read(iprot)
- self.success.append(_elem858)
+ (_etype849, _size846) = iprot.readListBegin()
+ for _i850 in xrange(_size846):
+ _elem851 = FieldSchema()
+ _elem851.read(iprot)
+ self.success.append(_elem851)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17528,8 +17528,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 iter859 in self.success:
- iter859.write(oprot)
+ for iter852 in self.success:
+ iter852.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17696,11 +17696,11 @@ class get_schema_with_environment_context_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype863, _size860) = iprot.readListBegin()
- for _i864 in xrange(_size860):
- _elem865 = FieldSchema()
- _elem865.read(iprot)
- self.success.append(_elem865)
+ (_etype856, _size853) = iprot.readListBegin()
+ for _i857 in xrange(_size853):
+ _elem858 = FieldSchema()
+ _elem858.read(iprot)
+ self.success.append(_elem858)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17735,8 +17735,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 iter866 in self.success:
- iter866.write(oprot)
+ for iter859 in self.success:
+ iter859.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18189,66 +18189,66 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype870, _size867) = iprot.readListBegin()
- for _i871 in xrange(_size867):
- _elem872 = SQLPrimaryKey()
- _elem872.read(iprot)
- self.primaryKeys.append(_elem872)
+ (_etype863, _size860) = iprot.readListBegin()
+ for _i864 in xrange(_size860):
+ _elem865 = SQLPrimaryKey()
+ _elem865.read(iprot)
+ self.primaryKeys.append(_elem865)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype876, _size873) = iprot.readListBegin()
- for _i877 in xrange(_size873):
- _elem878 = SQLForeignKey()
- _elem878.read(iprot)
- self.foreignKeys.append(_elem878)
+ (_etype869, _size866) = iprot.readListBegin()
+ for _i870 in xrange(_size866):
+ _elem871 = SQLForeignKey()
+ _elem871.read(iprot)
+ self.foreignKeys.append(_elem871)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype882, _size879) = iprot.readListBegin()
- for _i883 in xrange(_size879):
- _elem884 = SQLUniqueConstraint()
- _elem884.read(iprot)
- self.uniqueConstraints.append(_elem884)
+ (_etype875, _size872) = iprot.readListBegin()
+ for _i876 in xrange(_size872):
+ _elem877 = SQLUniqueConstraint()
+ _elem877.read(iprot)
+ self.uniqueConstraints.append(_elem877)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype888, _size885) = iprot.readListBegin()
- for _i889 in xrange(_size885):
- _elem890 = SQLNotNullConstraint()
- _elem890.read(iprot)
- self.notNullConstraints.append(_elem890)
+ (_etype881, _size878) = iprot.readListBegin()
+ for _i882 in xrange(_size878):
+ _elem883 = SQLNotNullConstraint()
+ _elem883.read(iprot)
+ self.notNullConstraints.append(_elem883)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.LIST:
self.defaultConstraints = []
- (_etype894, _size891) = iprot.readListBegin()
- for _i895 in xrange(_size891):
- _elem896 = SQLDefaultConstraint()
- _elem896.read(iprot)
- self.defaultConstraints.append(_elem896)
+ (_etype887, _size884) = iprot.readListBegin()
+ for _i888 in xrange(_size884):
+ _elem889 = SQLDefaultConstraint()
+ _elem889.read(iprot)
+ self.defaultConstraints.append(_elem889)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.LIST:
self.checkConstraints = []
- (_etype900, _size897) = iprot.readListBegin()
- for _i901 in xrange(_size897):
- _elem902 = SQLCheckConstraint()
- _elem902.read(iprot)
- self.checkConstraints.append(_elem902)
+ (_etype893, _size890) = iprot.readListBegin()
+ for _i894 in xrange(_size890):
+ _elem895 = SQLCheckConstraint()
+ _elem895.read(iprot)
+ self.checkConstraints.append(_elem895)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18269,43 +18269,43 @@ 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 iter903 in self.primaryKeys:
- iter903.write(oprot)
+ for iter896 in self.primaryKeys:
+ iter896.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 iter904 in self.foreignKeys:
- iter904.write(oprot)
+ for iter897 in self.foreignKeys:
+ iter897.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 iter905 in self.uniqueConstraints:
- iter905.write(oprot)
+ for iter898 in self.uniqueConstraints:
+ iter898.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 iter906 in self.notNullConstraints:
- iter906.write(oprot)
+ for iter899 in self.notNullConstraints:
+ iter899.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 iter907 in self.defaultConstraints:
- iter907.write(oprot)
+ for iter900 in self.defaultConstraints:
+ iter900.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.checkConstraints is not None:
oprot.writeFieldBegin('checkConstraints', TType.LIST, 7)
oprot.writeListBegin(TType.STRUCT, len(self.checkConstraints))
- for iter908 in self.checkConstraints:
- iter908.write(oprot)
+ for iter901 in self.checkConstraints:
+ iter901.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19865,10 +19865,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype912, _size909) = iprot.readListBegin()
- for _i913 in xrange(_size909):
- _elem914 = iprot.readString()
- self.partNames.append(_elem914)
+ (_etype905, _size902) = iprot.readListBegin()
+ for _i906 in xrange(_size902):
+ _elem907 = iprot.readString()
+ self.partNames.append(_elem907)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19893,8 +19893,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 iter915 in self.partNames:
- oprot.writeString(iter915)
+ for iter908 in self.partNames:
+ oprot.writeString(iter908)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20094,10 +20094,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype919, _size916) = iprot.readListBegin()
- for _i920 in xrange(_size916):
- _elem921 = iprot.readString()
- self.success.append(_elem921)
+ (_etype912, _size909) = iprot.readListBegin()
+ for _i913 in xrange(_size909):
+ _elem914 = iprot.readString()
+ self.success.append(_elem914)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20120,8 +20120,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 iter922 in self.success:
- oprot.writeString(iter922)
+ for iter915 in self.success:
+ oprot.writeString(iter915)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20271,10 +20271,10 @@ class get_tables_by_type_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype926, _size923) = iprot.readListBegin()
- for _i927 in xrange(_size923):
- _elem928 = iprot.readString()
- self.success.append(_elem928)
+ (_etype919, _size916) = iprot.readListBegin()
+ for _i920 in xrange(_size916):
+ _elem921 = iprot.readString()
+ self.success.append(_elem921)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20297,8 +20297,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 iter929 in self.success:
- oprot.writeString(iter929)
+ for iter922 in self.success:
+ oprot.writeString(iter922)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20422,10 +20422,10 @@ class get_materialized_views_for_rewriting_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype933, _size930) = iprot.readListBegin()
- for _i934 in xrange(_size930):
- _elem935 = iprot.readString()
- self.success.append(_elem935)
+ (_etype926, _size923) = iprot.readListBegin()
+ for _i927 in xrange(_size923):
+ _elem928 = iprot.readString()
+ self.success.append(_elem928)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20448,8 +20448,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 iter936 in self.success:
- oprot.writeString(iter936)
+ for iter929 in self.success:
+ oprot.writeString(iter929)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20522,10 +20522,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype940, _size937) = iprot.readListBegin()
- for _i941 in xrange(_size937):
- _elem942 = iprot.readString()
- self.tbl_types.append(_elem942)
+ (_etype933, _size930) = iprot.readListBegin()
+ for _i934 in xrange(_size930):
+ _elem935 = iprot.readString()
+ self.tbl_types.append(_elem935)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20550,8 +20550,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 iter943 in self.tbl_types:
- oprot.writeString(iter943)
+ for iter936 in self.tbl_types:
+ oprot.writeString(iter936)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20607,11 +20607,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype947, _size944) = iprot.readListBegin()
- for _i948 in xrange(_size944):
- _elem949 = TableMeta()
- _elem949.read(iprot)
- self.success.append(_elem949)
+ (_etype940, _size937) = iprot.readListBegin()
+ for _i941 in xrange(_size937):
+ _elem942 = TableMeta()
+ _elem942.read(iprot)
+ self.success.append(_elem942)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20634,8 +20634,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 iter950 in self.success:
- iter950.write(oprot)
+ for iter943 in self.success:
+ iter943.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20759,10 +20759,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype954, _size951) = iprot.readListBegin()
- for _i955 in xrange(_size951):
- _elem956 = iprot.readString()
- self.success.append(_elem956)
+ (_etype947, _size944) = iprot.readListBegin()
+ for _i948 in xrange(_size944):
+ _elem949 = iprot.readString()
+ self.success.append(_elem949)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20785,8 +20785,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 iter957 in self.success:
- oprot.writeString(iter957)
+ for iter950 in self.success:
+ oprot.writeString(iter950)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21022,10 +21022,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype961, _size958) = iprot.readListBegin()
- for _i962 in xrange(_size958):
- _elem963 = iprot.readString()
- self.tbl_names.append(_elem963)
+ (_etype954, _size951) = iprot.readListBegin()
+ for _i955 in xrange(_size951):
+ _elem956 = iprot.readString()
+ self.tbl_names.append(_elem956)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21046,8 +21046,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 iter964 in self.tbl_names:
- oprot.writeString(iter964)
+ for iter957 in self.tbl_names:
+ oprot.writeString(iter957)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21099,11 +21099,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype968, _size965) = iprot.readListBegin()
- for _i969 in xrange(_size965):
- _elem970 = Table()
- _elem970.read(iprot)
- self.success.append(_elem970)
+ (_etype961, _size958) = iprot.readListBegin()
+ for _i962 in xrange(_size958):
+ _elem963 = Table()
+ _elem963.read(iprot)
+ self.success.append(_elem963)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21120,8 +21120,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 iter971 in self.success:
- iter971.write(oprot)
+ for iter964 in self.success:
+ iter964.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21482,19 +21482,19 @@ class get_table_objects_by_name_req_result:
class get_materialization_invalidation_info_args:
"""
Attributes:
- - dbname
- - tbl_names
+ - creation_metadata
+ - validTxnList
"""
thrift_spec = (
None, # 0
- (1, TType.STRING, 'dbname', None, None, ), # 1
- (2, TType.LIST, 'tbl_names', (TType.STRING,None), None, ), # 2
+ (1, TType.STRUCT, 'creation_metadata', (CreationMetadata, CreationMetadata.thrift_spec), None, ), # 1
+ (2, TType.STRING, 'validTxnList', None, None, ), # 2
)
- def __init__(self, dbname=None, tbl_names=None,):
- self.dbname = dbname
- self.tbl_names = tbl_names
+ def __init__(self, creation_metadata=None, validTxnList=None,):
+ self.creation_metadata = creation_metadata
+ self.validTxnList = validTxnList
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:
@@ -21506,18 +21506,14 @@ class get_materialization_invalidation_info_args:
if ftype == TType.STOP:
break
if fid == 1:
- if ftype == TType.STRING:
- self.dbname = iprot.readString()
+ if ftype == TType.STRUCT:
+ self.creation_metadata = CreationMetadata()
+ self.creation_metadata.read(iprot)
else:
iprot.skip(ftype)
elif fid == 2:
- if ftype == TType.LIST:
- self.tbl_names = []
- (_etype975, _size972) = iprot.readListBegin()
- for _i976 in xrange(_size972):
- _elem977 = iprot.readString()
- self.tbl_names.append(_elem977)
- iprot.readListEnd()
+ if ftype == TType.STRING:
+ self.validTxnList = iprot.readString()
else:
iprot.skip(ftype)
else:
@@ -21530,16 +21526,13 @@ class get_materialization_invalidation_info_args:
oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
return
oprot.writeStructBegin('get_materialization_invalidation_info_args')
- if self.dbname is not None:
- oprot.writeFieldBegin('dbname', TType.STRING, 1)
- oprot.writeString(self.dbname)
+ if self.creation_metadata is not None:
+ oprot.writeFieldBegin('creation_metadata', TType.STRUCT, 1)
+ self.creation_metadata.write(oprot)
oprot.writeFieldEnd()
- if self.tbl_names is not None:
- oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
- oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter978 in self.tbl_names:
- oprot.writeString(iter978)
- oprot.writeListEnd()
+ if self.validTxnList is not None:
+ oprot.writeFieldBegin('validTxnList', TType.STRING, 2)
+ oprot.writeString(self.validTxnList)
oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -21550,8 +21543,8 @@ class get_materialization_invalidation_info_args:
def __hash__(self):
value = 17
- value = (value * 31) ^ hash(self.dbname)
- value = (value * 31) ^ hash(self.tbl_names)
+ value = (value * 31) ^ hash(self.creation_metadata)
+ value = (value * 31) ^ hash(self.validTxnList)
return value
def __repr__(self):
@@ -21575,7 +21568,7 @@ class get_materialization_invalidation_info_result:
"""
thrift_spec = (
- (0, TType.MAP, 'success', (TType.STRING,None,TType.STRUCT,(Materialization, Materialization.thrift_spec)), None, ), # 0
+ (0, TType.STRUCT, 'success', (Materialization, Materialization.thrift_spec), None, ), # 0
(1, TType.STRUCT, 'o1', (MetaException, MetaException.thrift_spec), None, ), # 1
(2, TType.STRUCT, 'o2', (InvalidOperationException, InvalidOperationException.thrift_spec), None, ), # 2
(3, TType.STRUCT, 'o3', (UnknownDBException, UnknownDBException.thrift_spec), None, ), # 3
@@ -21597,15 +21590,9 @@ class get_materialization_invalidation_info_result:
if ftype == TType.STOP:
break
if fid == 0:
- if ftype == TType.MAP:
- self.success = {}
- (_ktype980, _vtype981, _size979 ) = iprot.readMapBegin()
- for _i983 in xrange(_size979):
- _key984 = iprot.readString()
- _val985 = Materialization()
- _val985.read(iprot)
- self.success[_key984] = _val985
- iprot.readMapEnd()
+ if ftype == TType.STRUCT:
+ self.success = Materialization()
+ self.success.read(iprot)
else:
iprot.skip(ftype)
elif fid == 1:
@@ -21637,12 +21624,8 @@ class get_materialization_invalidation_info_result:
return
oprot.writeStructBegin('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 kiter986,viter987 in self.success.items():
- oprot.writeString(kiter986)
- viter987.write(oprot)
- oprot.writeMapEnd()
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
oprot.writeFieldEnd()
if self.o1 is not None:
oprot.writeFieldBegin('o1', TType.STRUCT, 1)
@@ -22006,10 +21989,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype991, _size988) = iprot.readListBegin()
- for _i992 in xrange(_size988):
- _elem993 = iprot.readString()
- self.success.append(_elem993)
+ (_etype968, _size965) = iprot.readListBegin()
+ for _i969 in xrange(_size965):
+ _elem970 = iprot.readString()
+ self.success.append(_elem970)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22044,8 +22027,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 iter994 in self.success:
- oprot.writeString(iter994)
+ for iter971 in self.success:
+ oprot.writeString(iter971)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23015,11 +22998,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype998, _size995) = iprot.readListBegin()
- for _i999 in xrange(_size995):
- _elem1000 = Partition()
- _elem1000.read(iprot)
- self.new_parts.append(_elem1000)
+ (_etype975, _size972) = iprot.readListBegin()
+ for _i976 in xrange(_size972):
+ _elem977 = Partition()
+ _elem977.read(iprot)
+ self.new_parts.append(_elem977)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23036,8 +23019,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 iter1001 in self.new_parts:
- iter1001.write(oprot)
+ for iter978 in self.new_parts:
+ iter978.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23195,11 +23178,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1005, _size1002) = iprot.readListBegin()
- for _i1006 in xrange(_size1002):
- _elem1007 = PartitionSpec()
- _elem1007.read(iprot)
- self.new_parts.append(_elem1007)
+ (_etype982, _size979) = iprot.readListBegin()
+ for _i983 in xrange(_size979):
+ _elem984 = PartitionSpec()
+ _elem984.read(iprot)
+ self.new_parts.append(_elem984)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23216,8 +23199,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 iter1008 in self.new_parts:
- iter1008.write(oprot)
+ for iter985 in self.new_parts:
+ iter985.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23391,10 +23374,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1012, _size1009) = iprot.readListBegin()
- for _i1013 in xrange(_size1009):
- _elem1014 = iprot.readString()
- self.part_vals.append(_elem1014)
+ (_etype989, _size986) = iprot.readListBegin()
+ for _i990 in xrange(_size986):
+ _elem991 = iprot.readString()
+ self.part_vals.append(_elem991)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23419,8 +23402,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 iter1015 in self.part_vals:
- oprot.writeString(iter1015)
+ for iter992 in self.part_vals:
+ oprot.writeString(iter992)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23773,10 +23756,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1019, _size1016) = iprot.readListBegin()
- for _i1020 in xrange(_size1016):
- _elem1021 = iprot.readString()
- self.part_vals.append(_elem1021)
+ (_etype996, _size993) = iprot.readListBegin()
+ for _i997 in xrange(_size993):
+ _elem998 = iprot.readString()
+ self.part_vals.append(_elem998)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23807,8 +23790,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 iter1022 in self.part_vals:
- oprot.writeString(iter1022)
+ for iter999 in self.part_vals:
+ oprot.writeString(iter999)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -24403,10 +24386,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1026, _size1023) = iprot.readListBegin()
- for _i1027 in xrange(_size1023):
- _elem1028 = iprot.readString()
- self.part_vals.append(_elem1028)
+ (_etype1003, _size1000) = iprot.readListBegin()
+ for _i1004 in xrange(_size1000):
+ _elem1005 = iprot.readString()
+ self.part_vals.append(_elem1005)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24436,8 +24419,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 iter1029 in self.part_vals:
- oprot.writeString(iter1029)
+ for iter1006 in self.part_vals:
+ oprot.writeString(iter1006)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -24610,10 +24593,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1033, _size1030) = iprot.readListBegin()
- for _i1034 in xrange(_size1030):
- _elem1035 = iprot.readString()
- self.part_vals.append(_elem1035)
+ (_etype1010, _size1007) = iprot.readListBegin()
+ for _i1011 in xrange(_size1007):
+ _elem1012 = iprot.readString()
+ self.part_vals.append(_elem1012)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24649,8 +24632,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 iter1036 in self.part_vals:
- oprot.writeString(iter1036)
+ for iter1013 in self.part_vals:
+ oprot.writeString(iter1013)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -25387,10 +25370,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1040, _size1037) = iprot.readListBegin()
- for _i1041 in xrange(_size1037):
- _elem1042 = iprot.readString()
- self.part_vals.append(_elem1042)
+ (_etype1017, _size1014) = iprot.readListBegin()
+ for _i1018 in xrange(_size1014):
+ _elem1019 = iprot.readString()
+ self.part_vals.append(_elem1019)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25415,8 +25398,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 iter1043 in self.part_vals:
- oprot.writeString(iter1043)
+ for iter1020 in self.part_vals:
+ oprot.writeString(iter1020)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25575,11 +25558,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1045, _vtype1046, _size1044 ) = iprot.readMapBegin()
- for _i1048 in xrange(_size1044):
- _key1049 = iprot.readString()
- _val1050 = iprot.readString()
- self.partitionSpecs[_key1049] = _val1050
+ (_ktype1022, _vtype1023, _size1021 ) = iprot.readMapBegin()
+ for _i1025 in xrange(_size1021):
+ _key1026 = iprot.readString()
+ _val1027 = iprot.readString()
+ self.partitionSpecs[_key1026] = _val1027
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25616,9 +25599,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 kiter1051,viter1052 in self.partitionSpecs.items():
- oprot.writeString(kiter1051)
- oprot.writeString(viter1052)
+ for kiter1028,viter1029 in self.partitionSpecs.items():
+ oprot.writeString(kiter1028)
+ oprot.writeString(viter1029)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25823,11 +25806,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1054, _vtype1055, _size1053 ) = iprot.readMapBegin()
- for _i1057 in xrange(_size1053):
- _key1058 = iprot.readString()
- _val1059 = iprot.readString()
- self.partitionSpecs[_key1058] = _val1059
+ (_ktype1031, _vtype1032, _size1030 ) = iprot.readMapBegin()
+ for _i1034 in xrange(_size1030):
+ _key1035 = iprot.readString()
+ _val1036 = iprot.readString()
+ self.partitionSpecs[_key1035] = _val1036
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25864,9 +25847,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 kiter1060,viter1061 in self.partitionSpecs.items():
- oprot.writeString(kiter1060)
- oprot.writeString(viter1061)
+ for kiter1037,viter1038 in self.partitionSpecs.items():
+ oprot.writeString(kiter1037)
+ oprot.writeString(viter1038)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25949,11 +25932,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1065, _size1062) = iprot.readListBegin()
- for _i1066 in xrange(_size1062):
- _elem1067 = Partition()
- _elem1067.read(iprot)
- self.success.append(_elem1067)
+ (_etype1042, _size1039) = iprot.readListBegin()
+ for _i1043 in xrange(_size1039):
+ _elem1044 = Partition()
+ _elem1044.read(iprot)
+ self.success.append(_elem1044)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25994,8 +25977,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 iter1068 in self.success:
- iter1068.write(oprot)
+ for iter1045 in self.success:
+ iter1045.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26089,10 +26072,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1072, _size1069) = iprot.readListBegin()
- for _i1073 in xrange(_size1069):
- _elem1074 = iprot.readString()
- self.part_vals.append(_elem1074)
+ (_etype1049, _size1046) = iprot.readListBegin()
+ for _i1050 in xrange(_size1046):
+ _elem1051 = iprot.readString()
+ self.part_vals.append(_elem1051)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26104,10 +26087,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1078, _size1075) = iprot.readListBegin()
- for _i1079 in xrange(_size1075):
- _elem1080 = iprot.readString()
- self.group_names.append(_elem1080)
+ (_etype1055, _size1052) = iprot.readListBegin()
+ for _i1056 in xrange(_size1052):
+ _elem1057 = iprot.readString()
+ self.group_names.append(_elem1057)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26132,8 +26115,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 iter1081 in self.part_vals:
- oprot.writeString(iter1081)
+ for iter1058 in self.part_vals:
+ oprot.writeString(iter1058)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -26143,8 +26126,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 iter1082 in self.group_names:
- oprot.writeString(iter1082)
+ for iter1059 in self.group_names:
+ oprot.writeString(iter1059)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26573,11 +26556,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1086, _size1083) = iprot.readListBegin()
- for _i1087 in xrange(_size1083):
- _elem1088 = Partition()
- _elem1088.read(iprot)
- self.success.append(_elem1088)
+ (_etype1063, _size1060) = iprot.readListBegin()
+ for _i1064 in xrange(_size1060):
+ _elem1065 = Partition()
+ _elem1065.read(iprot)
+ self.success.append(_elem1065)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26606,8 +26589,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 iter1089 in self.success:
- iter1089.write(oprot)
+ for iter1066 in self.success:
+ iter1066.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26701,10 +26684,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1093, _size1090) = iprot.readListBegin()
- for _i1094 in xrange(_size1090):
- _elem1095 = iprot.readString()
- self.group_names.append(_elem1095)
+ (_etype1070, _size1067) = iprot.readListBegin()
+ for _i1071 in xrange(_size1067):
+ _elem1072 = iprot.readString()
+ self.group_names.append(_elem1072)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26737,8 +26720,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 iter1096 in self.group_names:
- oprot.writeString(iter1096)
+ for iter1073 in self.group_names:
+ oprot.writeString(iter1073)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26799,11 +26782,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1100, _size1097) = iprot.readListBegin()
- for _i1101 in xrange(_size1097):
- _elem1102 = Partition()
- _elem1102.read(iprot)
- self.success.append(_elem1102)
+ (_etype1077, _size1074) = iprot.readListBegin()
+ for _i1078 in xrange(_size1074):
+ _elem1079 = Partition()
+ _elem1079.read(iprot)
+ self.success.append(_elem1079)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26832,8 +26815,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 iter1103 in self.success:
- iter1103.write(oprot)
+ for iter1080 in self.success:
+ iter1080.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26991,11 +26974,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1107, _size1104) = iprot.readListBegin()
- for _i1108 in xrange(_size1104):
- _elem1109 = PartitionSpec()
- _elem1109.read(iprot)
- self.success.append(_elem1109)
+ (_etype1084, _size1081) = iprot.readListBegin()
+ for _i1085 in xrange(_size1081):
+ _elem1086 = PartitionSpec()
+ _elem1086.read(iprot)
+ self.success.append(_elem1086)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27024,8 +27007,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 iter1110 in self.success:
- iter1110.write(oprot)
+ for iter1087 in self.success:
+ iter1087.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27183,10 +27166,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1114, _size1111) = iprot.readListBegin()
- for _i1115 in xrange(_size1111):
- _elem1116 = iprot.readString()
- self.success.append(_elem1116)
+ (_etype1091, _size1088) = iprot.readListBegin()
+ for _i1092 in xrange(_size1088):
+ _elem1093 = iprot.readString()
+ self.success.append(_elem1093)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27215,8 +27198,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 iter1117 in self.success:
- oprot.writeString(iter1117)
+ for iter1094 in self.success:
+ oprot.writeString(iter1094)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27456,10 +27439,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1121, _size1118) = iprot.readListBegin()
- for _i1122 in xrange(_size1118):
- _elem1123 = iprot.readString()
- self.part_vals.append(_elem1123)
+ (_etype1098, _size1095) = iprot.readListBegin()
+ for _i1099 in xrange(_size1095):
+ _elem1100 = iprot.readString()
+ self.part_vals.append(_elem1100)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27489,8 +27472,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 iter1124 in self.part_vals:
- oprot.writeString(iter1124)
+ for iter1101 in self.part_vals:
+ oprot.writeString(iter1101)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27554,11 +27537,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1128, _size1125) = iprot.readListBegin()
- for _i1129 in xrange(_size1125):
- _elem1130 = Partition()
- _elem1130.read(iprot)
- self.success.append(_elem1130)
+ (_etype1105, _size1102) = iprot.readListBegin()
+ for _i1106 in xrange(_size1102):
+ _elem1107 = Partition()
+ _elem1107.read(iprot)
+ self.success.append(_elem1107)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27587,8 +27570,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 iter1131 in self.success:
- iter1131.write(oprot)
+ for iter1108 in self.success:
+ iter1108.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27675,10 +27658,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1135, _size1132) = iprot.readListBegin()
- for _i1136 in xrange(_size1132):
- _elem1137 = iprot.readString()
- self.part_vals.append(_elem1137)
+ (_etype1112, _size1109) = iprot.readListBegin()
+ for _i1113 in xrange(_size1109):
+ _elem1114 = iprot.readString()
+ self.part_vals.append(_elem1114)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27695,10 +27678,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1141, _size1138) = iprot.readListBegin()
- for _i1142 in xrange(_size1138):
- _elem1143 = iprot.readString()
- self.group_names.append(_elem1143)
+ (_etype1118, _size1115) = iprot.readListBegin()
+ for _i1119 in xrange(_size1115):
+ _elem1120 = iprot.readString()
+ self.group_names.append(_elem1120)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27723,8 +27706,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 iter1144 in self.part_vals:
- oprot.writeString(iter1144)
+ for iter1121 in self.part_vals:
+ oprot.writeString(iter1121)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27738,8 +27721,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 iter1145 in self.group_names:
- oprot.writeString(iter1145)
+ for iter1122 in self.group_names:
+ oprot.writeString(iter1122)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27801,11 +27784,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1149, _size1146) = iprot.readListBegin()
- for _i1150 in xrange(_size1146):
- _elem1151 = Partition()
- _elem1151.read(iprot)
- self.success.append(_elem1151)
+ (_etype1126, _size1123) = iprot.readListBegin()
+ for _i1127 in xrange(_size1123):
+ _elem1128 = Partition()
+ _elem1128.read(iprot)
+ self.success.append(_elem1128)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27834,8 +27817,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 iter1152 in self.success:
- iter1152.write(oprot)
+ for iter1129 in self.success:
+ iter1129.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27916,10 +27899,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1156, _size1153) = iprot.readListBegin()
- for _i1157 in xrange(_size1153):
- _elem1158 = iprot.readString()
- self.part_vals.append(_elem1158)
+ (_etype1133, _size1130) = iprot.readListBegin()
+ for _i1134 in xrange(_size1130):
+ _elem1135 = iprot.readString()
+ self.part_vals.append(_elem1135)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27949,8 +27932,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 iter1159 in self.part_vals:
- oprot.writeString(iter1159)
+ for iter1136 in self.part_vals:
+ oprot.writeString(iter1136)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28014,10 +27997,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1163, _size1160) = iprot.readListBegin()
- for _i1164 in xrange(_size1160):
- _elem1165 = iprot.readString()
- self.success.append(_elem1165)
+ (_etype1140, _size1137) = iprot.readListBegin()
+ for _i1141 in xrange(_size1137):
+ _elem1142 = iprot.readString()
+ self.success.append(_elem1142)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28046,8 +28029,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 iter1166 in self.success:
- oprot.writeString(iter1166)
+ for iter1143 in self.success:
+ oprot.writeString(iter1143)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28218,11 +28201,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1170, _size1167) = iprot.readListBegin()
- for _i1171 in xrange(_size1167):
- _elem1172 = Partition()
- _elem1172.read(iprot)
- self.success.append(_elem1172)
+ (_etype1147, _size1144) = iprot.readListBegin()
+ for _i1148 in xrange(_size1144):
+ _elem1149 = Partition()
+ _elem1149.read(iprot)
+ self.success.append(_elem1149)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28251,8 +28234,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 iter1173 in self.success:
- iter1173.write(oprot)
+ for iter1150 in self.success:
+ iter1150.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28423,11 +28406,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1177, _size1174) = iprot.readListBegin()
- for _i1178 in xrange(_size1174):
- _elem1179 = PartitionSpec()
- _elem1179.read(iprot)
- self.success.append(_elem1179)
+ (_etype1154, _size1151) = iprot.readListBegin()
+ for _i1155 in xrange(_size1151):
+ _elem1156 = PartitionSpec()
+ _elem1156.read(iprot)
+ self.success.append(_elem1156)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28456,8 +28439,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 iter1180 in self.success:
- iter1180.write(oprot)
+ for iter1157 in self.success:
+ iter1157.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28877,10 +28860,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1184, _size1181) = iprot.readListBegin()
- for _i1185 in xrange(_size1181):
- _elem1186 = iprot.readString()
- self.names.append(_elem1186)
+ (_etype1161, _size1158) = iprot.readListBegin()
+ for _i1162 in xrange(_size1158):
+ _elem1163 = iprot.readString()
+ self.names.append(_elem1163)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28905,8 +28888,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 iter1187 in self.names:
- oprot.writeString(iter1187)
+ for iter1164 in self.names:
+ oprot.writeString(iter1164)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28965,11 +28948,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1191, _size1188) = iprot.readListBegin()
- for _i1192 in xrange(_size1188):
- _elem1193 = Partition()
- _elem1193.read(iprot)
- self.success.append(_elem1193)
+ (_etype1168, _size1165) = iprot.readListBegin()
+ for _i1169 in xrange(_size1165):
+ _elem1170 = Partition()
+ _elem1170.read(iprot)
+ self.success.append(_elem1170)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28998,8 +28981,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 iter1194 in self.success:
- iter1194.write(oprot)
+ for iter1171 in self.success:
+ iter1171.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29249,11 +29232,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1198, _size1195) = iprot.readListBegin()
- for _i1199 in xrange(_size1195):
- _elem1200 = Partition()
- _elem1200.read(iprot)
- self.new_parts.append(_elem1200)
+ (_etype1175, _size1172) = iprot.readListBegin()
+ for _i1176 in xrange(_size1172):
+ _elem1177 = Partition()
+ _elem1177.read(iprot)
+ self.new_parts.append(_elem1177)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29278,8 +29261,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 iter1201 in self.new_parts:
- iter1201.write(oprot)
+ for iter1178 in self.new_parts:
+ iter1178.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29432,11 +29415,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1205, _size1202) = iprot.readListBegin()
- for _i1206 in xrange(_size1202):
- _elem1207 = Partition()
- _elem1207.read(iprot)
- self.new_parts.append(_elem1207)
+ (_etype1182, _size1179) = iprot.readListBegin()
+ for _i1183 in xrange(_size1179):
+ _elem1184 = Partition()
+ _elem1184.read(iprot)
+ self.new_parts.append(_elem1184)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29467,8 +29450,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 iter1208 in self.new_parts:
- iter1208.write(oprot)
+ for iter1185 in self.new_parts:
+ iter1185.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -29812,10 +29795,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1212, _size1209) = iprot.readListBegin()
- for _i1213 in xrange(_size1209):
- _elem1214 = iprot.readString()
- self.part_vals.append(_elem1214)
+ (_etype1189, _size1186) = iprot.readListBegin()
+ for _i1190 in xrange(_size1186):
+ _elem1191 = iprot.readString()
+ self.part_vals.append(_elem1191)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29846,8 +29829,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 iter1215 in self.part_vals:
- oprot.writeString(iter1215)
+ for iter1192 in self.part_vals:
+ oprot.writeString(iter1192)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -29989,10 +29972,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1219, _size1216) = iprot.readListBegin()
- for _i1220 in xrange(_size1216):
- _elem1221 = iprot.readString()
- self.part_vals.append(_elem1221)
+ (_etype1196, _size1193) = iprot.readListBegin()
+ for _i1197 in xrange(_size1193):
+ _elem1198 = iprot.readString()
+ self.part_vals.append(_elem1198)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30014,8 +29997,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 iter1222 in self.part_vals:
- oprot.writeString(iter1222)
+ for iter1199 in self.part_vals:
+ oprot.writeString(iter1199)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -30373,10 +30356,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1226, _size1223) = iprot.readListBegin()
- for _i1227 in xrange(_size1223):
- _elem1228 = iprot.readString()
- self.success.append(_elem1228)
+ (_etype1203, _size1200) = iprot.readListBegin()
+ for _i1204 in xrange(_size1200):
+ _elem1205 = iprot.readString()
+ self.success.append(_elem1205)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30399,8 +30382,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 iter1229 in self.success:
- oprot.writeString(iter1229)
+ for iter1206 in self.success:
+ oprot.writeString(iter1206)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30524,11 +30507,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1231, _vtype1232, _size1230 ) = iprot.readMapBegin()
- for _i1234 in xrange(_size1230):
- _key1235 = iprot.readString()
- _val1236 = iprot.readString()
- self.success[_key1235] = _val1236
+ (_ktype1208, _vtype1209, _size1207 ) = iprot.readMapBegin()
+ for _i1211 in xrange(_size1207):
+ _key1212 = iprot.readString()
+ _val1213 = iprot.readString()
+ self.success[_key1212] = _val1213
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30551,9 +30534,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 kiter1237,viter1238 in self.success.items():
- oprot.writeString(kiter1237)
- oprot.writeString(viter1238)
+ for kiter1214,viter1215 in self.success.items():
+ oprot.writeString(kiter1214)
+ oprot.writeString(viter1215)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30629,11 +30612,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1240, _vtype1241, _size1239 ) = iprot.readMapBegin()
- for _i1243 in xrange(_size1239):
- _key1244 = iprot.readString()
- _val1245 = iprot.readString()
- self.part_vals[_key1244] = _val1245
+ (_ktype1217, _vtype1218, _size1216 ) = iprot.readMapBegin()
+ for _i1220 in xrange(_size1216):
+ _key1221 = iprot.readString()
+ _val1222 = iprot.readString()
+ self.part_vals[_key1221] = _val1222
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30663,9 +30646,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 kiter1246,viter1247 in self.part_vals.items():
- oprot.writeString(kiter1246)
- oprot.writeString(viter1247)
+ for kiter1223,viter1224 in self.part_vals.items():
+ oprot.writeString(kiter1223)
+ oprot.writeString(viter1224)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -30879,11 +30862,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1249, _vtype1250, _size1248 ) = iprot.readMapBegin()
- for _i1252 in xrange(_size1248):
- _key1253 = iprot.readString()
- _val1254 = iprot.readString()
- self.part_vals[_key1253] = _val1254
+ (_ktype1226, _vtype1227, _size1225 ) = iprot.readMapBegin()
+ for _i1229 in xrange(_size1225):
+ _key1230 = iprot.readString()
+ _val1231 = iprot.readString()
+ self.part_vals[_key1230] = _val1231
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30913,9 +30896,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 kiter1255,viter1256 in self.part_vals.items():
- oprot.writeString(kiter1255)
- oprot.writeString(viter1256)
+ for kiter1232,viter1233 in self.part_vals.items():
+ oprot.writeString(kiter1232)
+ oprot.writeString(viter1233)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -34567,10 +34550,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1260, _size1257) = iprot.readListBegin()
- for _i1261 in xrange(_size1257):
- _elem1262 = iprot.readString()
- self.success.append(_elem1262)
+ (_etype1237, _size1234) = iprot.readListBegin()
+ for _i1238 in xrange(_size1234):
+ _elem1239 = iprot.readString()
+ self.success.append(_elem1239)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34593,8 +34576,8 @@ class get_functions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1263 in self.success:
- oprot.writeString(iter1263)
+ for iter1240 in self.success:
+ oprot.writeString(iter1240)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35282,10 +35265,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1267, _size1264) = iprot.readListBegin()
- for _i1268 in xrange(_size1264):
- _elem1269 = iprot.readString()
- self.success.append(_elem1269)
+ (_etype1244, _size1241) = iprot.readListBegin()
+ for _i1245 in xrange(_size1241):
+ _elem1246 = iprot.readString()
+ self.success.append(_elem1246)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35308,8 +35291,8 @@ class get_role_names_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1270 in self.success:
- oprot.writeString(iter1270)
+ for iter1247 in self.success:
+ oprot.writeString(iter1247)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35823,11 +35806,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1274, _size1271) = iprot.readListBegin()
- for _i1275 in xrange(_size1271):
- _elem1276 = Role()
- _elem1276.read(iprot)
- self.success.append(_elem1276)
+ (_etype1251, _size1248) = iprot.readListBegin()
+ for _i1252 in xrange(_size1248):
+ _elem1253 = Role()
+ _elem1253.read(iprot)
+ self.success.append(_elem1253)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35850,8 +35833,8 @@ class list_roles_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1277 in self.success:
- iter1277.write(oprot)
+ for iter1254 in self.success:
+ iter1254.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36360,10 +36343,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1281, _size1278) = iprot.readListBegin()
- for _i1282 in xrange(_size1278):
- _elem1283 = iprot.readString()
- self.group_names.append(_elem1283)
+ (_etype1258, _size1255) = iprot.readListBegin()
+ for _i1259 in xrange(_size1255):
+ _elem1260 = iprot.readString()
+ self.group_names.append(_elem1260)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36388,8 +36371,8 @@ class get_privilege_set_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1284 in self.group_names:
- oprot.writeString(iter1284)
+ for iter1261 in self.group_names:
+ oprot.writeString(iter1261)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36616,11 +36599,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1288, _size1285) = iprot.readListBegin()
- for _i1289 in xrange(_size1285):
- _elem1290 = HiveObjectPrivilege()
- _elem1290.read(iprot)
- self.success.append(_elem1290)
+ (_etype1265, _size1262) = iprot.readListBegin()
+ for _i1266 in xrange(_size1262):
+ _elem1267 = HiveObjectPrivilege()
+ _elem1267.read(iprot)
+ self.success.append(_elem1267)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36643,8 +36626,8 @@ class list_privileges_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1291 in self.success:
- iter1291.write(oprot)
+ for iter1268 in self.success:
+ iter1268.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37314,10 +37297,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1295, _size1292) = iprot.readListBegin()
- for _i1296 in xrange(_size1292):
- _elem1297 = iprot.readString()
- self.group_names.append(_elem1297)
+ (_etype1272, _size1269) = iprot.readListBegin()
+ for _i1273 in xrange(_size1269):
+ _elem1274 = iprot.readString()
+ self.group_names.append(_elem1274)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37338,8 +37321,8 @@ class set_ugi_args:
if self.group_names is not None:
oprot.writeFieldBegin('group_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.group_names))
- for iter1298 in self.group_names:
- oprot.writeString(iter1298)
+ for iter1275 in self.group_names:
+ oprot.writeString(iter1275)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -37394,10 +37377,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1302, _size1299) = iprot.readListBegin()
- for _i1303 in xrange(_size1299):
- _elem1304 = iprot.readString()
- self.success.append(_elem1304)
+ (_etype1279, _size1276) = iprot.readListBegin()
+ for _i1280 in xrange(_size1276):
+ _elem1281 = iprot.readString()
+ self.success.append(_elem1281)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37420,8 +37403,8 @@ class set_ugi_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1305 in self.success:
- oprot.writeString(iter1305)
+ for iter1282 in self.success:
+ oprot.writeString(iter1282)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -38353,10 +38336,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1309, _size1306) = iprot.readListBegin()
- for _i1310 in xrange(_size1306):
- _elem1311 = iprot.readString()
- self.success.append(_elem1311)
+ (_etype1286, _size1283) = iprot.readListBegin()
+ for _i1287 in xrange(_size1283):
+ _elem1288 = iprot.readString()
+ self.success.append(_elem1288)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38373,8 +38356,8 @@ class get_all_token_identifiers_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1312 in self.success:
- oprot.writeString(iter1312)
+ for iter1289 in self.success:
+ oprot.writeString(iter1289)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -38901,10 +38884,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1316, _size1313) = iprot.readListBegin()
- for _i1317 in xrange(_size1313):
- _elem1318 = iprot.readString()
- self.success.append(_elem1318)
+ (_etype1293, _size1290) = iprot.readListBegin()
+ for _i1294 in xrange(_size1290):
+ _elem1295 = iprot.readString()
+ self.success.append(_elem1295)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38921,8 +38904,8 @@ class get_master_keys_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRING, len(self.success))
- for iter1319 in self.success:
- oprot.writeString(iter1319)
+ for iter1296 in self.success:
+ oprot.writeString(iter1296)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -47202,11 +47185,11 @@ class get_schema_all_versions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1323, _size1320) = iprot.readListBegin()
- for _i1324 in xrange(_size1320):
- _elem1325 = SchemaVersion()
- _elem1325.read(iprot)
- self.success.append(_elem1325)
+ (_etype1300, _size1297) = iprot.readListBegin()
+ for _i1301 in xrange(_size1297):
+ _elem1302 = SchemaVersion()
+ _elem1302.read(iprot)
+ self.success.append(_elem1302)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -47235,8 +47218,8 @@ class get_schema_all_versions_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1326 in self.success:
- iter1326.write(oprot)
+ for iter1303 in self.success:
+ iter1303.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -48711,11 +48694,11 @@ class get_runtime_stats_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1330, _size1327) = iprot.readListBegin()
- for _i1331 in xrange(_size1327):
- _elem1332 = RuntimeStat()
- _elem1332.read(iprot)
- self.success.append(_elem1332)
+ (_etype1307, _size1304) = iprot.readListBegin()
+ for _i1308 in xrange(_size1304):
+ _elem1309 = RuntimeStat()
+ _elem1309.read(iprot)
+ self.success.append(_elem1309)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -48738,8 +48721,8 @@ class get_runtime_stats_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.LIST, 0)
oprot.writeListBegin(TType.STRUCT, len(self.success))
- for iter1333 in self.success:
- iter1333.write(oprot)
+ for iter1310 in self.success:
+ iter1310.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: