You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/07/24 11:43:03 UTC
[07/19] hive git commit: HIVE-19267: Replicate ACID/MM tables write
operations (Mahesh Kumar Behera, reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/bf5791cd/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 c4f3f02..2ae6d9a 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
@@ -1309,6 +1309,13 @@ class Iface(fb303.FacebookService.Iface):
def flushCache(self):
pass
+ def add_write_notification_log(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ pass
+
def cm_recycle(self, request):
"""
Parameters:
@@ -7546,6 +7553,37 @@ class Client(fb303.FacebookService.Client, Iface):
iprot.readMessageEnd()
return
+ def add_write_notification_log(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ self.send_add_write_notification_log(rqst)
+ return self.recv_add_write_notification_log()
+
+ def send_add_write_notification_log(self, rqst):
+ self._oprot.writeMessageBegin('add_write_notification_log', TMessageType.CALL, self._seqid)
+ args = add_write_notification_log_args()
+ args.rqst = rqst
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_add_write_notification_log(self):
+ iprot = self._iprot
+ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(iprot)
+ iprot.readMessageEnd()
+ raise x
+ result = add_write_notification_log_result()
+ result.read(iprot)
+ iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "add_write_notification_log failed: unknown result")
+
def cm_recycle(self, request):
"""
Parameters:
@@ -9170,6 +9208,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
self._processMap["get_notification_events_count"] = Processor.process_get_notification_events_count
self._processMap["fire_listener_event"] = Processor.process_fire_listener_event
self._processMap["flushCache"] = Processor.process_flushCache
+ self._processMap["add_write_notification_log"] = Processor.process_add_write_notification_log
self._processMap["cm_recycle"] = Processor.process_cm_recycle
self._processMap["get_file_metadata_by_expr"] = Processor.process_get_file_metadata_by_expr
self._processMap["get_file_metadata"] = Processor.process_get_file_metadata
@@ -13287,6 +13326,25 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_add_write_notification_log(self, seqid, iprot, oprot):
+ args = add_write_notification_log_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = add_write_notification_log_result()
+ try:
+ result.success = self._handler.add_write_notification_log(args.rqst)
+ msg_type = TMessageType.REPLY
+ except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
+ raise
+ except Exception as ex:
+ msg_type = TMessageType.EXCEPTION
+ logging.exception(ex)
+ result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error')
+ oprot.writeMessageBegin("add_write_notification_log", msg_type, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_cm_recycle(self, seqid, iprot, oprot):
args = cm_recycle_args()
args.read(iprot)
@@ -15987,10 +16045,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype812, _size809) = iprot.readListBegin()
- for _i813 in xrange(_size809):
- _elem814 = iprot.readString()
- self.success.append(_elem814)
+ (_etype833, _size830) = iprot.readListBegin()
+ for _i834 in xrange(_size830):
+ _elem835 = iprot.readString()
+ self.success.append(_elem835)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16013,8 +16071,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 iter815 in self.success:
- oprot.writeString(iter815)
+ for iter836 in self.success:
+ oprot.writeString(iter836)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16119,10 +16177,10 @@ class get_all_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)
+ (_etype840, _size837) = iprot.readListBegin()
+ for _i841 in xrange(_size837):
+ _elem842 = iprot.readString()
+ self.success.append(_elem842)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16145,8 +16203,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 iter822 in self.success:
- oprot.writeString(iter822)
+ for iter843 in self.success:
+ oprot.writeString(iter843)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16916,12 +16974,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype824, _vtype825, _size823 ) = iprot.readMapBegin()
- for _i827 in xrange(_size823):
- _key828 = iprot.readString()
- _val829 = Type()
- _val829.read(iprot)
- self.success[_key828] = _val829
+ (_ktype845, _vtype846, _size844 ) = iprot.readMapBegin()
+ for _i848 in xrange(_size844):
+ _key849 = iprot.readString()
+ _val850 = Type()
+ _val850.read(iprot)
+ self.success[_key849] = _val850
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -16944,9 +17002,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 kiter830,viter831 in self.success.items():
- oprot.writeString(kiter830)
- viter831.write(oprot)
+ for kiter851,viter852 in self.success.items():
+ oprot.writeString(kiter851)
+ viter852.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -17089,11 +17147,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype835, _size832) = iprot.readListBegin()
- for _i836 in xrange(_size832):
- _elem837 = FieldSchema()
- _elem837.read(iprot)
- self.success.append(_elem837)
+ (_etype856, _size853) = iprot.readListBegin()
+ for _i857 in xrange(_size853):
+ _elem858 = FieldSchema()
+ _elem858.read(iprot)
+ self.success.append(_elem858)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17128,8 +17186,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 iter838 in self.success:
- iter838.write(oprot)
+ for iter859 in self.success:
+ iter859.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17296,11 +17354,11 @@ class get_fields_with_environment_context_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)
+ (_etype863, _size860) = iprot.readListBegin()
+ for _i864 in xrange(_size860):
+ _elem865 = FieldSchema()
+ _elem865.read(iprot)
+ self.success.append(_elem865)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17335,8 +17393,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 iter845 in self.success:
- iter845.write(oprot)
+ for iter866 in self.success:
+ iter866.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17489,11 +17547,11 @@ class get_schema_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)
+ (_etype870, _size867) = iprot.readListBegin()
+ for _i871 in xrange(_size867):
+ _elem872 = FieldSchema()
+ _elem872.read(iprot)
+ self.success.append(_elem872)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17528,8 +17586,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 iter852 in self.success:
- iter852.write(oprot)
+ for iter873 in self.success:
+ iter873.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17696,11 +17754,11 @@ class get_schema_with_environment_context_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)
+ (_etype877, _size874) = iprot.readListBegin()
+ for _i878 in xrange(_size874):
+ _elem879 = FieldSchema()
+ _elem879.read(iprot)
+ self.success.append(_elem879)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17735,8 +17793,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 iter859 in self.success:
- iter859.write(oprot)
+ for iter880 in self.success:
+ iter880.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18189,66 +18247,66 @@ class create_table_with_constraints_args:
elif fid == 2:
if ftype == TType.LIST:
self.primaryKeys = []
- (_etype863, _size860) = iprot.readListBegin()
- for _i864 in xrange(_size860):
- _elem865 = SQLPrimaryKey()
- _elem865.read(iprot)
- self.primaryKeys.append(_elem865)
+ (_etype884, _size881) = iprot.readListBegin()
+ for _i885 in xrange(_size881):
+ _elem886 = SQLPrimaryKey()
+ _elem886.read(iprot)
+ self.primaryKeys.append(_elem886)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 3:
if ftype == TType.LIST:
self.foreignKeys = []
- (_etype869, _size866) = iprot.readListBegin()
- for _i870 in xrange(_size866):
- _elem871 = SQLForeignKey()
- _elem871.read(iprot)
- self.foreignKeys.append(_elem871)
+ (_etype890, _size887) = iprot.readListBegin()
+ for _i891 in xrange(_size887):
+ _elem892 = SQLForeignKey()
+ _elem892.read(iprot)
+ self.foreignKeys.append(_elem892)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
if ftype == TType.LIST:
self.uniqueConstraints = []
- (_etype875, _size872) = iprot.readListBegin()
- for _i876 in xrange(_size872):
- _elem877 = SQLUniqueConstraint()
- _elem877.read(iprot)
- self.uniqueConstraints.append(_elem877)
+ (_etype896, _size893) = iprot.readListBegin()
+ for _i897 in xrange(_size893):
+ _elem898 = SQLUniqueConstraint()
+ _elem898.read(iprot)
+ self.uniqueConstraints.append(_elem898)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 5:
if ftype == TType.LIST:
self.notNullConstraints = []
- (_etype881, _size878) = iprot.readListBegin()
- for _i882 in xrange(_size878):
- _elem883 = SQLNotNullConstraint()
- _elem883.read(iprot)
- self.notNullConstraints.append(_elem883)
+ (_etype902, _size899) = iprot.readListBegin()
+ for _i903 in xrange(_size899):
+ _elem904 = SQLNotNullConstraint()
+ _elem904.read(iprot)
+ self.notNullConstraints.append(_elem904)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 6:
if ftype == TType.LIST:
self.defaultConstraints = []
- (_etype887, _size884) = iprot.readListBegin()
- for _i888 in xrange(_size884):
- _elem889 = SQLDefaultConstraint()
- _elem889.read(iprot)
- self.defaultConstraints.append(_elem889)
+ (_etype908, _size905) = iprot.readListBegin()
+ for _i909 in xrange(_size905):
+ _elem910 = SQLDefaultConstraint()
+ _elem910.read(iprot)
+ self.defaultConstraints.append(_elem910)
iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 7:
if ftype == TType.LIST:
self.checkConstraints = []
- (_etype893, _size890) = iprot.readListBegin()
- for _i894 in xrange(_size890):
- _elem895 = SQLCheckConstraint()
- _elem895.read(iprot)
- self.checkConstraints.append(_elem895)
+ (_etype914, _size911) = iprot.readListBegin()
+ for _i915 in xrange(_size911):
+ _elem916 = SQLCheckConstraint()
+ _elem916.read(iprot)
+ self.checkConstraints.append(_elem916)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18269,43 +18327,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 iter896 in self.primaryKeys:
- iter896.write(oprot)
+ for iter917 in self.primaryKeys:
+ iter917.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 iter897 in self.foreignKeys:
- iter897.write(oprot)
+ for iter918 in self.foreignKeys:
+ iter918.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 iter898 in self.uniqueConstraints:
- iter898.write(oprot)
+ for iter919 in self.uniqueConstraints:
+ iter919.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 iter899 in self.notNullConstraints:
- iter899.write(oprot)
+ for iter920 in self.notNullConstraints:
+ iter920.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 iter900 in self.defaultConstraints:
- iter900.write(oprot)
+ for iter921 in self.defaultConstraints:
+ iter921.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 iter901 in self.checkConstraints:
- iter901.write(oprot)
+ for iter922 in self.checkConstraints:
+ iter922.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19865,10 +19923,10 @@ class truncate_table_args:
elif fid == 3:
if ftype == TType.LIST:
self.partNames = []
- (_etype905, _size902) = iprot.readListBegin()
- for _i906 in xrange(_size902):
- _elem907 = iprot.readString()
- self.partNames.append(_elem907)
+ (_etype926, _size923) = iprot.readListBegin()
+ for _i927 in xrange(_size923):
+ _elem928 = iprot.readString()
+ self.partNames.append(_elem928)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19893,8 +19951,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 iter908 in self.partNames:
- oprot.writeString(iter908)
+ for iter929 in self.partNames:
+ oprot.writeString(iter929)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20094,10 +20152,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype912, _size909) = iprot.readListBegin()
- for _i913 in xrange(_size909):
- _elem914 = iprot.readString()
- self.success.append(_elem914)
+ (_etype933, _size930) = iprot.readListBegin()
+ for _i934 in xrange(_size930):
+ _elem935 = iprot.readString()
+ self.success.append(_elem935)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20120,8 +20178,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 iter915 in self.success:
- oprot.writeString(iter915)
+ for iter936 in self.success:
+ oprot.writeString(iter936)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20271,10 +20329,10 @@ class get_tables_by_type_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)
+ (_etype940, _size937) = iprot.readListBegin()
+ for _i941 in xrange(_size937):
+ _elem942 = iprot.readString()
+ self.success.append(_elem942)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20297,8 +20355,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 iter922 in self.success:
- oprot.writeString(iter922)
+ for iter943 in self.success:
+ oprot.writeString(iter943)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20422,10 +20480,10 @@ class get_materialized_views_for_rewriting_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)
+ (_etype947, _size944) = iprot.readListBegin()
+ for _i948 in xrange(_size944):
+ _elem949 = iprot.readString()
+ self.success.append(_elem949)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20448,8 +20506,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 iter929 in self.success:
- oprot.writeString(iter929)
+ for iter950 in self.success:
+ oprot.writeString(iter950)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20522,10 +20580,10 @@ class get_table_meta_args:
elif fid == 3:
if ftype == TType.LIST:
self.tbl_types = []
- (_etype933, _size930) = iprot.readListBegin()
- for _i934 in xrange(_size930):
- _elem935 = iprot.readString()
- self.tbl_types.append(_elem935)
+ (_etype954, _size951) = iprot.readListBegin()
+ for _i955 in xrange(_size951):
+ _elem956 = iprot.readString()
+ self.tbl_types.append(_elem956)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20550,8 +20608,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 iter936 in self.tbl_types:
- oprot.writeString(iter936)
+ for iter957 in self.tbl_types:
+ oprot.writeString(iter957)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20607,11 +20665,11 @@ class get_table_meta_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype940, _size937) = iprot.readListBegin()
- for _i941 in xrange(_size937):
- _elem942 = TableMeta()
- _elem942.read(iprot)
- self.success.append(_elem942)
+ (_etype961, _size958) = iprot.readListBegin()
+ for _i962 in xrange(_size958):
+ _elem963 = TableMeta()
+ _elem963.read(iprot)
+ self.success.append(_elem963)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20634,8 +20692,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 iter943 in self.success:
- iter943.write(oprot)
+ for iter964 in self.success:
+ iter964.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20759,10 +20817,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype947, _size944) = iprot.readListBegin()
- for _i948 in xrange(_size944):
- _elem949 = iprot.readString()
- self.success.append(_elem949)
+ (_etype968, _size965) = iprot.readListBegin()
+ for _i969 in xrange(_size965):
+ _elem970 = iprot.readString()
+ self.success.append(_elem970)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20785,8 +20843,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 iter950 in self.success:
- oprot.writeString(iter950)
+ for iter971 in self.success:
+ oprot.writeString(iter971)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -21022,10 +21080,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype954, _size951) = iprot.readListBegin()
- for _i955 in xrange(_size951):
- _elem956 = iprot.readString()
- self.tbl_names.append(_elem956)
+ (_etype975, _size972) = iprot.readListBegin()
+ for _i976 in xrange(_size972):
+ _elem977 = iprot.readString()
+ self.tbl_names.append(_elem977)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21046,8 +21104,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 iter957 in self.tbl_names:
- oprot.writeString(iter957)
+ for iter978 in self.tbl_names:
+ oprot.writeString(iter978)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21099,11 +21157,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype961, _size958) = iprot.readListBegin()
- for _i962 in xrange(_size958):
- _elem963 = Table()
- _elem963.read(iprot)
- self.success.append(_elem963)
+ (_etype982, _size979) = iprot.readListBegin()
+ for _i983 in xrange(_size979):
+ _elem984 = Table()
+ _elem984.read(iprot)
+ self.success.append(_elem984)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21120,8 +21178,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 iter964 in self.success:
- iter964.write(oprot)
+ for iter985 in self.success:
+ iter985.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21989,10 +22047,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype968, _size965) = iprot.readListBegin()
- for _i969 in xrange(_size965):
- _elem970 = iprot.readString()
- self.success.append(_elem970)
+ (_etype989, _size986) = iprot.readListBegin()
+ for _i990 in xrange(_size986):
+ _elem991 = iprot.readString()
+ self.success.append(_elem991)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22027,8 +22085,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 iter971 in self.success:
- oprot.writeString(iter971)
+ for iter992 in self.success:
+ oprot.writeString(iter992)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22998,11 +23056,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype975, _size972) = iprot.readListBegin()
- for _i976 in xrange(_size972):
- _elem977 = Partition()
- _elem977.read(iprot)
- self.new_parts.append(_elem977)
+ (_etype996, _size993) = iprot.readListBegin()
+ for _i997 in xrange(_size993):
+ _elem998 = Partition()
+ _elem998.read(iprot)
+ self.new_parts.append(_elem998)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23019,8 +23077,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 iter978 in self.new_parts:
- iter978.write(oprot)
+ for iter999 in self.new_parts:
+ iter999.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23178,11 +23236,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype982, _size979) = iprot.readListBegin()
- for _i983 in xrange(_size979):
- _elem984 = PartitionSpec()
- _elem984.read(iprot)
- self.new_parts.append(_elem984)
+ (_etype1003, _size1000) = iprot.readListBegin()
+ for _i1004 in xrange(_size1000):
+ _elem1005 = PartitionSpec()
+ _elem1005.read(iprot)
+ self.new_parts.append(_elem1005)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23199,8 +23257,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 iter985 in self.new_parts:
- iter985.write(oprot)
+ for iter1006 in self.new_parts:
+ iter1006.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23374,10 +23432,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype989, _size986) = iprot.readListBegin()
- for _i990 in xrange(_size986):
- _elem991 = iprot.readString()
- self.part_vals.append(_elem991)
+ (_etype1010, _size1007) = iprot.readListBegin()
+ for _i1011 in xrange(_size1007):
+ _elem1012 = iprot.readString()
+ self.part_vals.append(_elem1012)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23402,8 +23460,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 iter992 in self.part_vals:
- oprot.writeString(iter992)
+ for iter1013 in self.part_vals:
+ oprot.writeString(iter1013)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23756,10 +23814,10 @@ class append_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype996, _size993) = iprot.readListBegin()
- for _i997 in xrange(_size993):
- _elem998 = iprot.readString()
- self.part_vals.append(_elem998)
+ (_etype1017, _size1014) = iprot.readListBegin()
+ for _i1018 in xrange(_size1014):
+ _elem1019 = iprot.readString()
+ self.part_vals.append(_elem1019)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23790,8 +23848,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 iter999 in self.part_vals:
- oprot.writeString(iter999)
+ for iter1020 in self.part_vals:
+ oprot.writeString(iter1020)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -24386,10 +24444,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1003, _size1000) = iprot.readListBegin()
- for _i1004 in xrange(_size1000):
- _elem1005 = iprot.readString()
- self.part_vals.append(_elem1005)
+ (_etype1024, _size1021) = iprot.readListBegin()
+ for _i1025 in xrange(_size1021):
+ _elem1026 = iprot.readString()
+ self.part_vals.append(_elem1026)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24419,8 +24477,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 iter1006 in self.part_vals:
- oprot.writeString(iter1006)
+ for iter1027 in self.part_vals:
+ oprot.writeString(iter1027)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -24593,10 +24651,10 @@ class drop_partition_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1010, _size1007) = iprot.readListBegin()
- for _i1011 in xrange(_size1007):
- _elem1012 = iprot.readString()
- self.part_vals.append(_elem1012)
+ (_etype1031, _size1028) = iprot.readListBegin()
+ for _i1032 in xrange(_size1028):
+ _elem1033 = iprot.readString()
+ self.part_vals.append(_elem1033)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24632,8 +24690,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 iter1013 in self.part_vals:
- oprot.writeString(iter1013)
+ for iter1034 in self.part_vals:
+ oprot.writeString(iter1034)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -25370,10 +25428,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1017, _size1014) = iprot.readListBegin()
- for _i1018 in xrange(_size1014):
- _elem1019 = iprot.readString()
- self.part_vals.append(_elem1019)
+ (_etype1038, _size1035) = iprot.readListBegin()
+ for _i1039 in xrange(_size1035):
+ _elem1040 = iprot.readString()
+ self.part_vals.append(_elem1040)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25398,8 +25456,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 iter1020 in self.part_vals:
- oprot.writeString(iter1020)
+ for iter1041 in self.part_vals:
+ oprot.writeString(iter1041)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25558,11 +25616,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1022, _vtype1023, _size1021 ) = iprot.readMapBegin()
- for _i1025 in xrange(_size1021):
- _key1026 = iprot.readString()
- _val1027 = iprot.readString()
- self.partitionSpecs[_key1026] = _val1027
+ (_ktype1043, _vtype1044, _size1042 ) = iprot.readMapBegin()
+ for _i1046 in xrange(_size1042):
+ _key1047 = iprot.readString()
+ _val1048 = iprot.readString()
+ self.partitionSpecs[_key1047] = _val1048
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25599,9 +25657,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 kiter1028,viter1029 in self.partitionSpecs.items():
- oprot.writeString(kiter1028)
- oprot.writeString(viter1029)
+ for kiter1049,viter1050 in self.partitionSpecs.items():
+ oprot.writeString(kiter1049)
+ oprot.writeString(viter1050)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25806,11 +25864,11 @@ class exchange_partitions_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype1031, _vtype1032, _size1030 ) = iprot.readMapBegin()
- for _i1034 in xrange(_size1030):
- _key1035 = iprot.readString()
- _val1036 = iprot.readString()
- self.partitionSpecs[_key1035] = _val1036
+ (_ktype1052, _vtype1053, _size1051 ) = iprot.readMapBegin()
+ for _i1055 in xrange(_size1051):
+ _key1056 = iprot.readString()
+ _val1057 = iprot.readString()
+ self.partitionSpecs[_key1056] = _val1057
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25847,9 +25905,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 kiter1037,viter1038 in self.partitionSpecs.items():
- oprot.writeString(kiter1037)
- oprot.writeString(viter1038)
+ for kiter1058,viter1059 in self.partitionSpecs.items():
+ oprot.writeString(kiter1058)
+ oprot.writeString(viter1059)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25932,11 +25990,11 @@ class exchange_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1042, _size1039) = iprot.readListBegin()
- for _i1043 in xrange(_size1039):
- _elem1044 = Partition()
- _elem1044.read(iprot)
- self.success.append(_elem1044)
+ (_etype1063, _size1060) = iprot.readListBegin()
+ for _i1064 in xrange(_size1060):
+ _elem1065 = Partition()
+ _elem1065.read(iprot)
+ self.success.append(_elem1065)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25977,8 +26035,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 iter1045 in self.success:
- iter1045.write(oprot)
+ for iter1066 in self.success:
+ iter1066.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26072,10 +26130,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1049, _size1046) = iprot.readListBegin()
- for _i1050 in xrange(_size1046):
- _elem1051 = iprot.readString()
- self.part_vals.append(_elem1051)
+ (_etype1070, _size1067) = iprot.readListBegin()
+ for _i1071 in xrange(_size1067):
+ _elem1072 = iprot.readString()
+ self.part_vals.append(_elem1072)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26087,10 +26145,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1055, _size1052) = iprot.readListBegin()
- for _i1056 in xrange(_size1052):
- _elem1057 = iprot.readString()
- self.group_names.append(_elem1057)
+ (_etype1076, _size1073) = iprot.readListBegin()
+ for _i1077 in xrange(_size1073):
+ _elem1078 = iprot.readString()
+ self.group_names.append(_elem1078)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26115,8 +26173,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 iter1058 in self.part_vals:
- oprot.writeString(iter1058)
+ for iter1079 in self.part_vals:
+ oprot.writeString(iter1079)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -26126,8 +26184,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 iter1059 in self.group_names:
- oprot.writeString(iter1059)
+ for iter1080 in self.group_names:
+ oprot.writeString(iter1080)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26556,11 +26614,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1063, _size1060) = iprot.readListBegin()
- for _i1064 in xrange(_size1060):
- _elem1065 = Partition()
- _elem1065.read(iprot)
- self.success.append(_elem1065)
+ (_etype1084, _size1081) = iprot.readListBegin()
+ for _i1085 in xrange(_size1081):
+ _elem1086 = Partition()
+ _elem1086.read(iprot)
+ self.success.append(_elem1086)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26589,8 +26647,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 iter1066 in self.success:
- iter1066.write(oprot)
+ for iter1087 in self.success:
+ iter1087.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26684,10 +26742,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype1070, _size1067) = iprot.readListBegin()
- for _i1071 in xrange(_size1067):
- _elem1072 = iprot.readString()
- self.group_names.append(_elem1072)
+ (_etype1091, _size1088) = iprot.readListBegin()
+ for _i1092 in xrange(_size1088):
+ _elem1093 = iprot.readString()
+ self.group_names.append(_elem1093)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26720,8 +26778,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 iter1073 in self.group_names:
- oprot.writeString(iter1073)
+ for iter1094 in self.group_names:
+ oprot.writeString(iter1094)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26782,11 +26840,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1077, _size1074) = iprot.readListBegin()
- for _i1078 in xrange(_size1074):
- _elem1079 = Partition()
- _elem1079.read(iprot)
- self.success.append(_elem1079)
+ (_etype1098, _size1095) = iprot.readListBegin()
+ for _i1099 in xrange(_size1095):
+ _elem1100 = Partition()
+ _elem1100.read(iprot)
+ self.success.append(_elem1100)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26815,8 +26873,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 iter1080 in self.success:
- iter1080.write(oprot)
+ for iter1101 in self.success:
+ iter1101.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26974,11 +27032,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1084, _size1081) = iprot.readListBegin()
- for _i1085 in xrange(_size1081):
- _elem1086 = PartitionSpec()
- _elem1086.read(iprot)
- self.success.append(_elem1086)
+ (_etype1105, _size1102) = iprot.readListBegin()
+ for _i1106 in xrange(_size1102):
+ _elem1107 = PartitionSpec()
+ _elem1107.read(iprot)
+ self.success.append(_elem1107)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27007,8 +27065,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 iter1087 in self.success:
- iter1087.write(oprot)
+ for iter1108 in self.success:
+ iter1108.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27166,10 +27224,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1091, _size1088) = iprot.readListBegin()
- for _i1092 in xrange(_size1088):
- _elem1093 = iprot.readString()
- self.success.append(_elem1093)
+ (_etype1112, _size1109) = iprot.readListBegin()
+ for _i1113 in xrange(_size1109):
+ _elem1114 = iprot.readString()
+ self.success.append(_elem1114)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27198,8 +27256,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 iter1094 in self.success:
- oprot.writeString(iter1094)
+ for iter1115 in self.success:
+ oprot.writeString(iter1115)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27439,10 +27497,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1098, _size1095) = iprot.readListBegin()
- for _i1099 in xrange(_size1095):
- _elem1100 = iprot.readString()
- self.part_vals.append(_elem1100)
+ (_etype1119, _size1116) = iprot.readListBegin()
+ for _i1120 in xrange(_size1116):
+ _elem1121 = iprot.readString()
+ self.part_vals.append(_elem1121)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27472,8 +27530,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 iter1101 in self.part_vals:
- oprot.writeString(iter1101)
+ for iter1122 in self.part_vals:
+ oprot.writeString(iter1122)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27537,11 +27595,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1105, _size1102) = iprot.readListBegin()
- for _i1106 in xrange(_size1102):
- _elem1107 = Partition()
- _elem1107.read(iprot)
- self.success.append(_elem1107)
+ (_etype1126, _size1123) = iprot.readListBegin()
+ for _i1127 in xrange(_size1123):
+ _elem1128 = Partition()
+ _elem1128.read(iprot)
+ self.success.append(_elem1128)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27570,8 +27628,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 iter1108 in self.success:
- iter1108.write(oprot)
+ for iter1129 in self.success:
+ iter1129.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27658,10 +27716,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1112, _size1109) = iprot.readListBegin()
- for _i1113 in xrange(_size1109):
- _elem1114 = iprot.readString()
- self.part_vals.append(_elem1114)
+ (_etype1133, _size1130) = iprot.readListBegin()
+ for _i1134 in xrange(_size1130):
+ _elem1135 = iprot.readString()
+ self.part_vals.append(_elem1135)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27678,10 +27736,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype1118, _size1115) = iprot.readListBegin()
- for _i1119 in xrange(_size1115):
- _elem1120 = iprot.readString()
- self.group_names.append(_elem1120)
+ (_etype1139, _size1136) = iprot.readListBegin()
+ for _i1140 in xrange(_size1136):
+ _elem1141 = iprot.readString()
+ self.group_names.append(_elem1141)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27706,8 +27764,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 iter1121 in self.part_vals:
- oprot.writeString(iter1121)
+ for iter1142 in self.part_vals:
+ oprot.writeString(iter1142)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27721,8 +27779,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 iter1122 in self.group_names:
- oprot.writeString(iter1122)
+ for iter1143 in self.group_names:
+ oprot.writeString(iter1143)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27784,11 +27842,11 @@ class get_partitions_ps_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1126, _size1123) = iprot.readListBegin()
- for _i1127 in xrange(_size1123):
- _elem1128 = Partition()
- _elem1128.read(iprot)
- self.success.append(_elem1128)
+ (_etype1147, _size1144) = iprot.readListBegin()
+ for _i1148 in xrange(_size1144):
+ _elem1149 = Partition()
+ _elem1149.read(iprot)
+ self.success.append(_elem1149)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27817,8 +27875,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 iter1129 in self.success:
- iter1129.write(oprot)
+ for iter1150 in self.success:
+ iter1150.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27899,10 +27957,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1133, _size1130) = iprot.readListBegin()
- for _i1134 in xrange(_size1130):
- _elem1135 = iprot.readString()
- self.part_vals.append(_elem1135)
+ (_etype1154, _size1151) = iprot.readListBegin()
+ for _i1155 in xrange(_size1151):
+ _elem1156 = iprot.readString()
+ self.part_vals.append(_elem1156)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27932,8 +27990,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 iter1136 in self.part_vals:
- oprot.writeString(iter1136)
+ for iter1157 in self.part_vals:
+ oprot.writeString(iter1157)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27997,10 +28055,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1140, _size1137) = iprot.readListBegin()
- for _i1141 in xrange(_size1137):
- _elem1142 = iprot.readString()
- self.success.append(_elem1142)
+ (_etype1161, _size1158) = iprot.readListBegin()
+ for _i1162 in xrange(_size1158):
+ _elem1163 = iprot.readString()
+ self.success.append(_elem1163)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28029,8 +28087,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 iter1143 in self.success:
- oprot.writeString(iter1143)
+ for iter1164 in self.success:
+ oprot.writeString(iter1164)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28201,11 +28259,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1147, _size1144) = iprot.readListBegin()
- for _i1148 in xrange(_size1144):
- _elem1149 = Partition()
- _elem1149.read(iprot)
- self.success.append(_elem1149)
+ (_etype1168, _size1165) = iprot.readListBegin()
+ for _i1169 in xrange(_size1165):
+ _elem1170 = Partition()
+ _elem1170.read(iprot)
+ self.success.append(_elem1170)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28234,8 +28292,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 iter1150 in self.success:
- iter1150.write(oprot)
+ for iter1171 in self.success:
+ iter1171.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28406,11 +28464,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1154, _size1151) = iprot.readListBegin()
- for _i1155 in xrange(_size1151):
- _elem1156 = PartitionSpec()
- _elem1156.read(iprot)
- self.success.append(_elem1156)
+ (_etype1175, _size1172) = iprot.readListBegin()
+ for _i1176 in xrange(_size1172):
+ _elem1177 = PartitionSpec()
+ _elem1177.read(iprot)
+ self.success.append(_elem1177)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28439,8 +28497,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 iter1157 in self.success:
- iter1157.write(oprot)
+ for iter1178 in self.success:
+ iter1178.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28860,10 +28918,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype1161, _size1158) = iprot.readListBegin()
- for _i1162 in xrange(_size1158):
- _elem1163 = iprot.readString()
- self.names.append(_elem1163)
+ (_etype1182, _size1179) = iprot.readListBegin()
+ for _i1183 in xrange(_size1179):
+ _elem1184 = iprot.readString()
+ self.names.append(_elem1184)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28888,8 +28946,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 iter1164 in self.names:
- oprot.writeString(iter1164)
+ for iter1185 in self.names:
+ oprot.writeString(iter1185)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28948,11 +29006,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1168, _size1165) = iprot.readListBegin()
- for _i1169 in xrange(_size1165):
- _elem1170 = Partition()
- _elem1170.read(iprot)
- self.success.append(_elem1170)
+ (_etype1189, _size1186) = iprot.readListBegin()
+ for _i1190 in xrange(_size1186):
+ _elem1191 = Partition()
+ _elem1191.read(iprot)
+ self.success.append(_elem1191)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28981,8 +29039,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 iter1171 in self.success:
- iter1171.write(oprot)
+ for iter1192 in self.success:
+ iter1192.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29232,11 +29290,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1175, _size1172) = iprot.readListBegin()
- for _i1176 in xrange(_size1172):
- _elem1177 = Partition()
- _elem1177.read(iprot)
- self.new_parts.append(_elem1177)
+ (_etype1196, _size1193) = iprot.readListBegin()
+ for _i1197 in xrange(_size1193):
+ _elem1198 = Partition()
+ _elem1198.read(iprot)
+ self.new_parts.append(_elem1198)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29261,8 +29319,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 iter1178 in self.new_parts:
- iter1178.write(oprot)
+ for iter1199 in self.new_parts:
+ iter1199.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29415,11 +29473,11 @@ class alter_partitions_with_environment_context_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype1182, _size1179) = iprot.readListBegin()
- for _i1183 in xrange(_size1179):
- _elem1184 = Partition()
- _elem1184.read(iprot)
- self.new_parts.append(_elem1184)
+ (_etype1203, _size1200) = iprot.readListBegin()
+ for _i1204 in xrange(_size1200):
+ _elem1205 = Partition()
+ _elem1205.read(iprot)
+ self.new_parts.append(_elem1205)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29450,8 +29508,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 iter1185 in self.new_parts:
- iter1185.write(oprot)
+ for iter1206 in self.new_parts:
+ iter1206.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -29795,10 +29853,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1189, _size1186) = iprot.readListBegin()
- for _i1190 in xrange(_size1186):
- _elem1191 = iprot.readString()
- self.part_vals.append(_elem1191)
+ (_etype1210, _size1207) = iprot.readListBegin()
+ for _i1211 in xrange(_size1207):
+ _elem1212 = iprot.readString()
+ self.part_vals.append(_elem1212)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29829,8 +29887,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 iter1192 in self.part_vals:
- oprot.writeString(iter1192)
+ for iter1213 in self.part_vals:
+ oprot.writeString(iter1213)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -29972,10 +30030,10 @@ class partition_name_has_valid_characters_args:
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype1196, _size1193) = iprot.readListBegin()
- for _i1197 in xrange(_size1193):
- _elem1198 = iprot.readString()
- self.part_vals.append(_elem1198)
+ (_etype1217, _size1214) = iprot.readListBegin()
+ for _i1218 in xrange(_size1214):
+ _elem1219 = iprot.readString()
+ self.part_vals.append(_elem1219)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29997,8 +30055,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 iter1199 in self.part_vals:
- oprot.writeString(iter1199)
+ for iter1220 in self.part_vals:
+ oprot.writeString(iter1220)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -30356,10 +30414,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1203, _size1200) = iprot.readListBegin()
- for _i1204 in xrange(_size1200):
- _elem1205 = iprot.readString()
- self.success.append(_elem1205)
+ (_etype1224, _size1221) = iprot.readListBegin()
+ for _i1225 in xrange(_size1221):
+ _elem1226 = iprot.readString()
+ self.success.append(_elem1226)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30382,8 +30440,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 iter1206 in self.success:
- oprot.writeString(iter1206)
+ for iter1227 in self.success:
+ oprot.writeString(iter1227)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30507,11 +30565,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype1208, _vtype1209, _size1207 ) = iprot.readMapBegin()
- for _i1211 in xrange(_size1207):
- _key1212 = iprot.readString()
- _val1213 = iprot.readString()
- self.success[_key1212] = _val1213
+ (_ktype1229, _vtype1230, _size1228 ) = iprot.readMapBegin()
+ for _i1232 in xrange(_size1228):
+ _key1233 = iprot.readString()
+ _val1234 = iprot.readString()
+ self.success[_key1233] = _val1234
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30534,9 +30592,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 kiter1214,viter1215 in self.success.items():
- oprot.writeString(kiter1214)
- oprot.writeString(viter1215)
+ for kiter1235,viter1236 in self.success.items():
+ oprot.writeString(kiter1235)
+ oprot.writeString(viter1236)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30612,11 +30670,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1217, _vtype1218, _size1216 ) = iprot.readMapBegin()
- for _i1220 in xrange(_size1216):
- _key1221 = iprot.readString()
- _val1222 = iprot.readString()
- self.part_vals[_key1221] = _val1222
+ (_ktype1238, _vtype1239, _size1237 ) = iprot.readMapBegin()
+ for _i1241 in xrange(_size1237):
+ _key1242 = iprot.readString()
+ _val1243 = iprot.readString()
+ self.part_vals[_key1242] = _val1243
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30646,9 +30704,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 kiter1223,viter1224 in self.part_vals.items():
- oprot.writeString(kiter1223)
- oprot.writeString(viter1224)
+ for kiter1244,viter1245 in self.part_vals.items():
+ oprot.writeString(kiter1244)
+ oprot.writeString(viter1245)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -30862,11 +30920,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype1226, _vtype1227, _size1225 ) = iprot.readMapBegin()
- for _i1229 in xrange(_size1225):
- _key1230 = iprot.readString()
- _val1231 = iprot.readString()
- self.part_vals[_key1230] = _val1231
+ (_ktype1247, _vtype1248, _size1246 ) = iprot.readMapBegin()
+ for _i1250 in xrange(_size1246):
+ _key1251 = iprot.readString()
+ _val1252 = iprot.readString()
+ self.part_vals[_key1251] = _val1252
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30896,9 +30954,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 kiter1232,viter1233 in self.part_vals.items():
- oprot.writeString(kiter1232)
- oprot.writeString(viter1233)
+ for kiter1253,viter1254 in self.part_vals.items():
+ oprot.writeString(kiter1253)
+ oprot.writeString(viter1254)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -34550,10 +34608,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1237, _size1234) = iprot.readListBegin()
- for _i1238 in xrange(_size1234):
- _elem1239 = iprot.readString()
- self.success.append(_elem1239)
+ (_etype1258, _size1255) = iprot.readListBegin()
+ for _i1259 in xrange(_size1255):
+ _elem1260 = iprot.readString()
+ self.success.append(_elem1260)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34576,8 +34634,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 iter1240 in self.success:
- oprot.writeString(iter1240)
+ for iter1261 in self.success:
+ oprot.writeString(iter1261)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35265,10 +35323,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1244, _size1241) = iprot.readListBegin()
- for _i1245 in xrange(_size1241):
- _elem1246 = iprot.readString()
- self.success.append(_elem1246)
+ (_etype1265, _size1262) = iprot.readListBegin()
+ for _i1266 in xrange(_size1262):
+ _elem1267 = iprot.readString()
+ self.success.append(_elem1267)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35291,8 +35349,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 iter1247 in self.success:
- oprot.writeString(iter1247)
+ for iter1268 in self.success:
+ oprot.writeString(iter1268)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35806,11 +35864,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1251, _size1248) = iprot.readListBegin()
- for _i1252 in xrange(_size1248):
- _elem1253 = Role()
- _elem1253.read(iprot)
- self.success.append(_elem1253)
+ (_etype1272, _size1269) = iprot.readListBegin()
+ for _i1273 in xrange(_size1269):
+ _elem1274 = Role()
+ _elem1274.read(iprot)
+ self.success.append(_elem1274)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35833,8 +35891,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 iter1254 in self.success:
- iter1254.write(oprot)
+ for iter1275 in self.success:
+ iter1275.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36343,10 +36401,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype1258, _size1255) = iprot.readListBegin()
- for _i1259 in xrange(_size1255):
- _elem1260 = iprot.readString()
- self.group_names.append(_elem1260)
+ (_etype1279, _size1276) = iprot.readListBegin()
+ for _i1280 in xrange(_size1276):
+ _elem1281 = iprot.readString()
+ self.group_names.append(_elem1281)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36371,8 +36429,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 iter1261 in self.group_names:
- oprot.writeString(iter1261)
+ for iter1282 in self.group_names:
+ oprot.writeString(iter1282)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36599,11 +36657,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1265, _size1262) = iprot.readListBegin()
- for _i1266 in xrange(_size1262):
- _elem1267 = HiveObjectPrivilege()
- _elem1267.read(iprot)
- self.success.append(_elem1267)
+ (_etype1286, _size1283) = iprot.readListBegin()
+ for _i1287 in xrange(_size1283):
+ _elem1288 = HiveObjectPrivilege()
+ _elem1288.read(iprot)
+ self.success.append(_elem1288)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36626,8 +36684,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 iter1268 in self.success:
- iter1268.write(oprot)
+ for iter1289 in self.success:
+ iter1289.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37297,10 +37355,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype1272, _size1269) = iprot.readListBegin()
- for _i1273 in xrange(_size1269):
- _elem1274 = iprot.readString()
- self.group_names.append(_elem1274)
+ (_etype1293, _size1290) = iprot.readListBegin()
+ for _i1294 in xrange(_size1290):
+ _elem1295 = iprot.readString()
+ self.group_names.append(_elem1295)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37321,8 +37379,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 iter1275 in self.group_names:
- oprot.writeString(iter1275)
+ for iter1296 in self.group_names:
+ oprot.writeString(iter1296)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -37377,10 +37435,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1279, _size1276) = iprot.readListBegin()
- for _i1280 in xrange(_size1276):
- _elem1281 = iprot.readString()
- self.success.append(_elem1281)
+ (_etype1300, _size1297) = iprot.readListBegin()
+ for _i1301 in xrange(_size1297):
+ _elem1302 = iprot.readString()
+ self.success.append(_elem1302)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37403,8 +37461,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 iter1282 in self.success:
- oprot.writeString(iter1282)
+ for iter1303 in self.success:
+ oprot.writeString(iter1303)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -38336,10 +38394,10 @@ class get_all_token_identifiers_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1286, _size1283) = iprot.readListBegin()
- for _i1287 in xrange(_size1283):
- _elem1288 = iprot.readString()
- self.success.append(_elem1288)
+ (_etype1307, _size1304) = iprot.readListBegin()
+ for _i1308 in xrange(_size1304):
+ _elem1309 = iprot.readString()
+ self.success.append(_elem1309)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38356,8 +38414,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 iter1289 in self.success:
- oprot.writeString(iter1289)
+ for iter1310 in self.success:
+ oprot.writeString(iter1310)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -38884,10 +38942,10 @@ class get_master_keys_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1293, _size1290) = iprot.readListBegin()
- for _i1294 in xrange(_size1290):
- _elem1295 = iprot.readString()
- self.success.append(_elem1295)
+ (_etype1314, _size1311) = iprot.readListBegin()
+ for _i1315 in xrange(_size1311):
+ _elem1316 = iprot.readString()
+ self.success.append(_elem1316)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38904,8 +38962,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 iter1296 in self.success:
- oprot.writeString(iter1296)
+ for iter1317 in self.success:
+ oprot.writeString(iter1317)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -42154,6 +42212,133 @@ class flushCache_result:
def __ne__(self, other):
return not (self == other)
+class add_write_notification_log_args:
+ """
+ Attributes:
+ - rqst
+ """
+
+ thrift_spec = None
+ def __init__(self, rqst=None,):
+ self.rqst = rqst
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == -1:
+ if ftype == TType.STRUCT:
+ self.rqst = WriteNotificationLogRequest()
+ self.rqst.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('add_write_notification_log_args')
+ if self.rqst is not None:
+ oprot.writeFieldBegin('rqst', TType.STRUCT, -1)
+ self.rqst.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.rqst)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class add_write_notification_log_result:
+ """
+ Attributes:
+ - success
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (WriteNotificationLogResponse, WriteNotificationLogResponse.thrift_spec), None, ), # 0
+ )
+
+ def __init__(self, success=None,):
+ self.success = success
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.STRUCT:
+ self.success = WriteNotificationLogResponse()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('add_write_notification_log_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __hash__(self):
+ value = 17
+ value = (value * 31) ^ hash(self.success)
+ return value
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
class cm_recycle_args:
"""
Attributes:
@@ -47185,11 +47370,11 @@ class get_schema_all_versions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1300, _size1297) = iprot.readListBegin()
- for _i1301 in xrange(_size1297):
- _elem1302 = SchemaVersion()
- _elem1302.read(iprot)
- self.success.append(_elem1302)
+ (_etype1321, _size1318) = iprot.readListBegin()
+ for _i1322 in xrange(_size1318):
+ _elem1323 = SchemaVersion()
+ _elem1323.read(iprot)
+ self.success.append(_elem1323)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -47218,8 +47403,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 iter1303 in self.success:
- iter1303.write(oprot)
+ for iter1324 in self.success:
+ iter1324.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -48694,11 +48879,11 @@ class get_runtime_stats_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype1307, _size1304) = iprot.readListBegin()
- for _i1308 in xrange(_size1304):
- _elem1309 = RuntimeStat()
- _elem1309.read(iprot)
- self.success.append(_elem1309)
+ (_etype1328, _size1325) = iprot.readListBegin()
+ for _i1329 in xrange(_size1325):
+ _elem1330 = RuntimeStat()
+ _elem1330.read(iprot)
+ self.success.append(_elem1330)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -48721,8 +48906,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 iter1310 in self.success:
- iter1310.write(oprot)
+ for iter1331 in self.success:
+ iter1331.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: