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/03 10:02:43 UTC
[04/16] 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/f519db7e/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index 5402372..add9197 100755
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -189,6 +189,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' NotificationEventsCountResponse get_notification_events_count(NotificationEventsCountRequest rqst)')
print(' FireEventResponse fire_listener_event(FireEventRequest rqst)')
print(' void flushCache()')
+ print(' WriteNotificationLogResponse add_write_notification_log(WriteNotificationLogRequest rqst)')
print(' CmRecycleResponse cm_recycle(CmRecycleRequest request)')
print(' GetFileMetadataByExprResult get_file_metadata_by_expr(GetFileMetadataByExprRequest req)')
print(' GetFileMetadataResult get_file_metadata(GetFileMetadataRequest req)')
@@ -1290,6 +1291,12 @@ elif cmd == 'flushCache':
sys.exit(1)
pp.pprint(client.flushCache())
+elif cmd == 'add_write_notification_log':
+ if len(args) != 1:
+ print('add_write_notification_log requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.add_write_notification_log(eval(args[0]),))
+
elif cmd == 'cm_recycle':
if len(args) != 1:
print('cm_recycle requires 1 args')
http://git-wip-us.apache.org/repos/asf/hive/blob/f519db7e/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..a5bcc10 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 = []
- (_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)
@@ -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 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:
@@ -16119,10 +16177,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)
+ (_etype847, _size844) = iprot.readListBegin()
+ for _i848 in xrange(_size844):
+ _elem849 = iprot.readString()
+ self.success.append(_elem849)
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 iter829 in self.success:
- oprot.writeString(iter829)
+ for iter850 in self.success:
+ oprot.writeString(iter850)
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 = {}
- (_ktype831, _vtype832, _size830 ) = iprot.readMapBegin()
- for _i834 in xrange(_size830):
- _key835 = iprot.readString()
- _val836 = Type()
- _val836.read(iprot)
- self.success[_key835] = _val836
+ (_ktype852, _vtype853, _size851 ) = iprot.readMapBegin()
+ for _i855 in xrange(_size851):
+ _key856 = iprot.readString()
+ _val857 = Type()
+ _val857.read(iprot)
+ self.success[_key856] = _val857
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 kiter837,viter838 in self.success.items():
- oprot.writeString(kiter837)
- viter838.write(oprot)
+ for kiter858,viter859 in self.success.items():
+ oprot.writeString(kiter858)
+ viter859.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 = []
- (_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)
@@ -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 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:
@@ -17296,11 +17354,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)
+ (_etype870, _size867) = iprot.readListBegin()
+ for _i871 in xrange(_size867):
+ _elem872 = FieldSchema()
+ _elem872.read(iprot)
+ self.success.append(_elem872)
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 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:
@@ -17489,11 +17547,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)
+ (_etype877, _size874) = iprot.readListBegin()
+ for _i878 in xrange(_size874):
+ _elem879 = FieldSchema()
+ _elem879.read(iprot)
+ self.success.append(_elem879)
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 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:
@@ -17696,11 +17754,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)
+ (_etype884, _size881) = iprot.readListBegin()
+ for _i885 in xrange(_size881):
+ _elem886 = FieldSchema()
+ _elem886.read(iprot)
+ self.success.append(_elem886)
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 iter866 in self.success:
- iter866.write(oprot)
+ for iter887 in self.success:
+ iter887.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 = []
- (_etype870, _size867) = iprot.readListBegin()
- for _i871 in xrange(_size867):
- _elem872 = SQLPrimaryKey()
- _elem872.read(iprot)
- self.primaryKeys.append(_elem872)
+ (_etype891, _size888) = iprot.readListBegin()
+ for _i892 in xrange(_size888):
+ _elem893 = SQLPrimaryKey()
+ _elem893.read(iprot)
+ self.primaryKeys.append(_elem893)
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)
+ (_etype897, _size894) = iprot.readListBegin()
+ for _i898 in xrange(_size894):
+ _elem899 = SQLForeignKey()
+ _elem899.read(iprot)
+ self.foreignKeys.append(_elem899)
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)
+ (_etype903, _size900) = iprot.readListBegin()
+ for _i904 in xrange(_size900):
+ _elem905 = SQLUniqueConstraint()
+ _elem905.read(iprot)
+ self.uniqueConstraints.append(_elem905)
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)
+ (_etype909, _size906) = iprot.readListBegin()
+ for _i910 in xrange(_size906):
+ _elem911 = SQLNotNullConstraint()
+ _elem911.read(iprot)
+ self.notNullConstraints.append(_elem911)
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)
+ (_etype915, _size912) = iprot.readListBegin()
+ for _i916 in xrange(_size912):
+ _elem917 = SQLDefaultConstraint()
+ _elem917.read(iprot)
+ self.defaultConstraints.append(_elem917)
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)
+ (_etype921, _size918) = iprot.readListBegin()
+ for _i922 in xrange(_size918):
+ _elem923 = SQLCheckConstraint()
+ _elem923.read(iprot)
+ self.checkConstraints.append(_elem923)
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 iter903 in self.primaryKeys:
- iter903.write(oprot)
+ for iter924 in self.primaryKeys:
+ iter924.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 iter925 in self.foreignKeys:
+ iter925.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 iter926 in self.uniqueConstraints:
+ iter926.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 iter927 in self.notNullConstraints:
+ iter927.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 iter928 in self.defaultConstraints:
+ iter928.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 iter929 in self.checkConstraints:
+ iter929.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 = []
- (_etype912, _size909) = iprot.readListBegin()
- for _i913 in xrange(_size909):
- _elem914 = iprot.readString()
- self.partNames.append(_elem914)
+ (_etype933, _size930) = iprot.readListBegin()
+ for _i934 in xrange(_size930):
+ _elem935 = iprot.readString()
+ self.partNames.append(_elem935)
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 iter915 in self.partNames:
- oprot.writeString(iter915)
+ for iter936 in self.partNames:
+ oprot.writeString(iter936)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20094,10 +20152,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)
+ (_etype940, _size937) = iprot.readListBegin()
+ for _i941 in xrange(_size937):
+ _elem942 = iprot.readString()
+ self.success.append(_elem942)
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 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:
@@ -20271,10 +20329,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)
+ (_etype947, _size944) = iprot.readListBegin()
+ for _i948 in xrange(_size944):
+ _elem949 = iprot.readString()
+ self.success.append(_elem949)
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 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:
@@ -20422,10 +20480,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)
+ (_etype954, _size951) = iprot.readListBegin()
+ for _i955 in xrange(_size951):
+ _elem956 = iprot.readString()
+ self.success.append(_elem956)
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 iter936 in self.success:
- oprot.writeString(iter936)
+ for iter957 in self.success:
+ oprot.writeString(iter957)
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 = []
- (_etype940, _size937) = iprot.readListBegin()
- for _i941 in xrange(_size937):
- _elem942 = iprot.readString()
- self.tbl_types.append(_elem942)
+ (_etype961, _size958) = iprot.readListBegin()
+ for _i962 in xrange(_size958):
+ _elem963 = iprot.readString()
+ self.tbl_types.append(_elem963)
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 iter943 in self.tbl_types:
- oprot.writeString(iter943)
+ for iter964 in self.tbl_types:
+ oprot.writeString(iter964)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -20607,11 +20665,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)
+ (_etype968, _size965) = iprot.readListBegin()
+ for _i969 in xrange(_size965):
+ _elem970 = TableMeta()
+ _elem970.read(iprot)
+ self.success.append(_elem970)
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 iter950 in self.success:
- iter950.write(oprot)
+ for iter971 in self.success:
+ iter971.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 = []
- (_etype954, _size951) = iprot.readListBegin()
- for _i955 in xrange(_size951):
- _elem956 = iprot.readString()
- self.success.append(_elem956)
+ (_etype975, _size972) = iprot.readListBegin()
+ for _i976 in xrange(_size972):
+ _elem977 = iprot.readString()
+ self.success.append(_elem977)
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 iter957 in self.success:
- oprot.writeString(iter957)
+ for iter978 in self.success:
+ oprot.writeString(iter978)
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 = []
- (_etype961, _size958) = iprot.readListBegin()
- for _i962 in xrange(_size958):
- _elem963 = iprot.readString()
- self.tbl_names.append(_elem963)
+ (_etype982, _size979) = iprot.readListBegin()
+ for _i983 in xrange(_size979):
+ _elem984 = iprot.readString()
+ self.tbl_names.append(_elem984)
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 iter964 in self.tbl_names:
- oprot.writeString(iter964)
+ for iter985 in self.tbl_names:
+ oprot.writeString(iter985)
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 = []
- (_etype968, _size965) = iprot.readListBegin()
- for _i969 in xrange(_size965):
- _elem970 = Table()
- _elem970.read(iprot)
- self.success.append(_elem970)
+ (_etype989, _size986) = iprot.readListBegin()
+ for _i990 in xrange(_size986):
+ _elem991 = Table()
+ _elem991.read(iprot)
+ self.success.append(_elem991)
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 iter971 in self.success:
- iter971.write(oprot)
+ for iter992 in self.success:
+ iter992.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21513,10 +21571,10 @@ class get_materialization_invalidation_info_args:
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)
+ (_etype996, _size993) = iprot.readListBegin()
+ for _i997 in xrange(_size993):
+ _elem998 = iprot.readString()
+ self.tbl_names.append(_elem998)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -21537,8 +21595,8 @@ class get_materialization_invalidation_info_args:
if self.tbl_names is not None:
oprot.writeFieldBegin('tbl_names', TType.LIST, 2)
oprot.writeListBegin(TType.STRING, len(self.tbl_names))
- for iter978 in self.tbl_names:
- oprot.writeString(iter978)
+ for iter999 in self.tbl_names:
+ oprot.writeString(iter999)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -21599,12 +21657,12 @@ class get_materialization_invalidation_info_result:
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
+ (_ktype1001, _vtype1002, _size1000 ) = iprot.readMapBegin()
+ for _i1004 in xrange(_size1000):
+ _key1005 = iprot.readString()
+ _val1006 = Materialization()
+ _val1006.read(iprot)
+ self.success[_key1005] = _val1006
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -21639,9 +21697,9 @@ class get_materialization_invalidation_info_result:
if self.success is not None:
oprot.writeFieldBegin('success', TType.MAP, 0)
oprot.writeMapBegin(TType.STRING, TType.STRUCT, len(self.success))
- for kiter986,viter987 in self.success.items():
- oprot.writeString(kiter986)
- viter987.write(oprot)
+ for kiter1007,viter1008 in self.success.items():
+ oprot.writeString(kiter1007)
+ viter1008.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22006,10 +22064,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)
+ (_etype1012, _size1009) = iprot.readListBegin()
+ for _i1013 in xrange(_size1009):
+ _elem1014 = iprot.readString()
+ self.success.append(_elem1014)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22044,8 +22102,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 iter1015 in self.success:
+ oprot.writeString(iter1015)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23015,11 +23073,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)
+ (_etype1019, _size1016) = iprot.readListBegin()
+ for _i1020 in xrange(_size1016):
+ _elem1021 = Partition()
+ _elem1021.read(iprot)
+ self.new_parts.append(_elem1021)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23036,8 +23094,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 iter1022 in self.new_parts:
+ iter1022.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23195,11 +23253,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)
+ (_etype1026, _size1023) = iprot.readListBegin()
+ for _i1027 in xrange(_size1023):
+ _elem1028 = PartitionSpec()
+ _elem1028.read(iprot)
+ self.new_parts.append(_elem1028)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23216,8 +23274,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 iter1029 in self.new_parts:
+ iter1029.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23391,10 +23449,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)
+ (_etype1033, _size1030) = iprot.readListBegin()
+ for _i1034 in xrange(_size1030):
+ _elem1035 = iprot.readString()
+ self.part_vals.append(_elem1035)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23419,8 +23477,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 iter1036 in self.part_vals:
+ oprot.writeString(iter1036)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -23773,10 +23831,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)
+ (_etype1040, _size1037) = iprot.readListBegin()
+ for _i1041 in xrange(_size1037):
+ _elem1042 = iprot.readString()
+ self.part_vals.append(_elem1042)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23807,8 +23865,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 iter1043 in self.part_vals:
+ oprot.writeString(iter1043)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -24403,10 +24461,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)
+ (_etype1047, _size1044) = iprot.readListBegin()
+ for _i1048 in xrange(_size1044):
+ _elem1049 = iprot.readString()
+ self.part_vals.append(_elem1049)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24436,8 +24494,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 iter1050 in self.part_vals:
+ oprot.writeString(iter1050)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -24610,10 +24668,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)
+ (_etype1054, _size1051) = iprot.readListBegin()
+ for _i1055 in xrange(_size1051):
+ _elem1056 = iprot.readString()
+ self.part_vals.append(_elem1056)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24649,8 +24707,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 iter1057 in self.part_vals:
+ oprot.writeString(iter1057)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -25387,10 +25445,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)
+ (_etype1061, _size1058) = iprot.readListBegin()
+ for _i1062 in xrange(_size1058):
+ _elem1063 = iprot.readString()
+ self.part_vals.append(_elem1063)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25415,8 +25473,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 iter1064 in self.part_vals:
+ oprot.writeString(iter1064)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -25575,11 +25633,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
+ (_ktype1066, _vtype1067, _size1065 ) = iprot.readMapBegin()
+ for _i1069 in xrange(_size1065):
+ _key1070 = iprot.readString()
+ _val1071 = iprot.readString()
+ self.partitionSpecs[_key1070] = _val1071
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25616,9 +25674,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 kiter1072,viter1073 in self.partitionSpecs.items():
+ oprot.writeString(kiter1072)
+ oprot.writeString(viter1073)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25823,11 +25881,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
+ (_ktype1075, _vtype1076, _size1074 ) = iprot.readMapBegin()
+ for _i1078 in xrange(_size1074):
+ _key1079 = iprot.readString()
+ _val1080 = iprot.readString()
+ self.partitionSpecs[_key1079] = _val1080
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -25864,9 +25922,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 kiter1081,viter1082 in self.partitionSpecs.items():
+ oprot.writeString(kiter1081)
+ oprot.writeString(viter1082)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -25949,11 +26007,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)
+ (_etype1086, _size1083) = iprot.readListBegin()
+ for _i1087 in xrange(_size1083):
+ _elem1088 = Partition()
+ _elem1088.read(iprot)
+ self.success.append(_elem1088)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -25994,8 +26052,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 iter1089 in self.success:
+ iter1089.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26089,10 +26147,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)
+ (_etype1093, _size1090) = iprot.readListBegin()
+ for _i1094 in xrange(_size1090):
+ _elem1095 = iprot.readString()
+ self.part_vals.append(_elem1095)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26104,10 +26162,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)
+ (_etype1099, _size1096) = iprot.readListBegin()
+ for _i1100 in xrange(_size1096):
+ _elem1101 = iprot.readString()
+ self.group_names.append(_elem1101)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26132,8 +26190,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 iter1102 in self.part_vals:
+ oprot.writeString(iter1102)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -26143,8 +26201,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 iter1103 in self.group_names:
+ oprot.writeString(iter1103)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26573,11 +26631,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)
+ (_etype1107, _size1104) = iprot.readListBegin()
+ for _i1108 in xrange(_size1104):
+ _elem1109 = Partition()
+ _elem1109.read(iprot)
+ self.success.append(_elem1109)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26606,8 +26664,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 iter1110 in self.success:
+ iter1110.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26701,10 +26759,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)
+ (_etype1114, _size1111) = iprot.readListBegin()
+ for _i1115 in xrange(_size1111):
+ _elem1116 = iprot.readString()
+ self.group_names.append(_elem1116)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26737,8 +26795,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 iter1117 in self.group_names:
+ oprot.writeString(iter1117)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -26799,11 +26857,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)
+ (_etype1121, _size1118) = iprot.readListBegin()
+ for _i1122 in xrange(_size1118):
+ _elem1123 = Partition()
+ _elem1123.read(iprot)
+ self.success.append(_elem1123)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -26832,8 +26890,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 iter1124 in self.success:
+ iter1124.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26991,11 +27049,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)
+ (_etype1128, _size1125) = iprot.readListBegin()
+ for _i1129 in xrange(_size1125):
+ _elem1130 = PartitionSpec()
+ _elem1130.read(iprot)
+ self.success.append(_elem1130)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27024,8 +27082,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 iter1131 in self.success:
+ iter1131.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27183,10 +27241,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)
+ (_etype1135, _size1132) = iprot.readListBegin()
+ for _i1136 in xrange(_size1132):
+ _elem1137 = iprot.readString()
+ self.success.append(_elem1137)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27215,8 +27273,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 iter1138 in self.success:
+ oprot.writeString(iter1138)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27456,10 +27514,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)
+ (_etype1142, _size1139) = iprot.readListBegin()
+ for _i1143 in xrange(_size1139):
+ _elem1144 = iprot.readString()
+ self.part_vals.append(_elem1144)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27489,8 +27547,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 iter1145 in self.part_vals:
+ oprot.writeString(iter1145)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27554,11 +27612,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)
+ (_etype1149, _size1146) = iprot.readListBegin()
+ for _i1150 in xrange(_size1146):
+ _elem1151 = Partition()
+ _elem1151.read(iprot)
+ self.success.append(_elem1151)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27587,8 +27645,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 iter1152 in self.success:
+ iter1152.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27675,10 +27733,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)
+ (_etype1156, _size1153) = iprot.readListBegin()
+ for _i1157 in xrange(_size1153):
+ _elem1158 = iprot.readString()
+ self.part_vals.append(_elem1158)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27695,10 +27753,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)
+ (_etype1162, _size1159) = iprot.readListBegin()
+ for _i1163 in xrange(_size1159):
+ _elem1164 = iprot.readString()
+ self.group_names.append(_elem1164)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27723,8 +27781,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 iter1165 in self.part_vals:
+ oprot.writeString(iter1165)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -27738,8 +27796,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 iter1166 in self.group_names:
+ oprot.writeString(iter1166)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -27801,11 +27859,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)
+ (_etype1170, _size1167) = iprot.readListBegin()
+ for _i1171 in xrange(_size1167):
+ _elem1172 = Partition()
+ _elem1172.read(iprot)
+ self.success.append(_elem1172)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27834,8 +27892,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 iter1173 in self.success:
+ iter1173.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -27916,10 +27974,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)
+ (_etype1177, _size1174) = iprot.readListBegin()
+ for _i1178 in xrange(_size1174):
+ _elem1179 = iprot.readString()
+ self.part_vals.append(_elem1179)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -27949,8 +28007,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 iter1180 in self.part_vals:
+ oprot.writeString(iter1180)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -28014,10 +28072,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)
+ (_etype1184, _size1181) = iprot.readListBegin()
+ for _i1185 in xrange(_size1181):
+ _elem1186 = iprot.readString()
+ self.success.append(_elem1186)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28046,8 +28104,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 iter1187 in self.success:
+ oprot.writeString(iter1187)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28218,11 +28276,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)
+ (_etype1191, _size1188) = iprot.readListBegin()
+ for _i1192 in xrange(_size1188):
+ _elem1193 = Partition()
+ _elem1193.read(iprot)
+ self.success.append(_elem1193)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28251,8 +28309,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 iter1194 in self.success:
+ iter1194.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28423,11 +28481,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)
+ (_etype1198, _size1195) = iprot.readListBegin()
+ for _i1199 in xrange(_size1195):
+ _elem1200 = PartitionSpec()
+ _elem1200.read(iprot)
+ self.success.append(_elem1200)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28456,8 +28514,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 iter1201 in self.success:
+ iter1201.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -28877,10 +28935,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)
+ (_etype1205, _size1202) = iprot.readListBegin()
+ for _i1206 in xrange(_size1202):
+ _elem1207 = iprot.readString()
+ self.names.append(_elem1207)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28905,8 +28963,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 iter1208 in self.names:
+ oprot.writeString(iter1208)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -28965,11 +29023,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)
+ (_etype1212, _size1209) = iprot.readListBegin()
+ for _i1213 in xrange(_size1209):
+ _elem1214 = Partition()
+ _elem1214.read(iprot)
+ self.success.append(_elem1214)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -28998,8 +29056,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 iter1215 in self.success:
+ iter1215.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -29249,11 +29307,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)
+ (_etype1219, _size1216) = iprot.readListBegin()
+ for _i1220 in xrange(_size1216):
+ _elem1221 = Partition()
+ _elem1221.read(iprot)
+ self.new_parts.append(_elem1221)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29278,8 +29336,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 iter1222 in self.new_parts:
+ iter1222.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -29432,11 +29490,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)
+ (_etype1226, _size1223) = iprot.readListBegin()
+ for _i1227 in xrange(_size1223):
+ _elem1228 = Partition()
+ _elem1228.read(iprot)
+ self.new_parts.append(_elem1228)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29467,8 +29525,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 iter1229 in self.new_parts:
+ iter1229.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -29812,10 +29870,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)
+ (_etype1233, _size1230) = iprot.readListBegin()
+ for _i1234 in xrange(_size1230):
+ _elem1235 = iprot.readString()
+ self.part_vals.append(_elem1235)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -29846,8 +29904,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 iter1236 in self.part_vals:
+ oprot.writeString(iter1236)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -29989,10 +30047,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)
+ (_etype1240, _size1237) = iprot.readListBegin()
+ for _i1241 in xrange(_size1237):
+ _elem1242 = iprot.readString()
+ self.part_vals.append(_elem1242)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30014,8 +30072,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 iter1243 in self.part_vals:
+ oprot.writeString(iter1243)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -30373,10 +30431,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)
+ (_etype1247, _size1244) = iprot.readListBegin()
+ for _i1248 in xrange(_size1244):
+ _elem1249 = iprot.readString()
+ self.success.append(_elem1249)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -30399,8 +30457,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 iter1250 in self.success:
+ oprot.writeString(iter1250)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30524,11 +30582,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
+ (_ktype1252, _vtype1253, _size1251 ) = iprot.readMapBegin()
+ for _i1255 in xrange(_size1251):
+ _key1256 = iprot.readString()
+ _val1257 = iprot.readString()
+ self.success[_key1256] = _val1257
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30551,9 +30609,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 kiter1258,viter1259 in self.success.items():
+ oprot.writeString(kiter1258)
+ oprot.writeString(viter1259)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -30629,11 +30687,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
+ (_ktype1261, _vtype1262, _size1260 ) = iprot.readMapBegin()
+ for _i1264 in xrange(_size1260):
+ _key1265 = iprot.readString()
+ _val1266 = iprot.readString()
+ self.part_vals[_key1265] = _val1266
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30663,9 +30721,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 kiter1267,viter1268 in self.part_vals.items():
+ oprot.writeString(kiter1267)
+ oprot.writeString(viter1268)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -30879,11 +30937,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
+ (_ktype1270, _vtype1271, _size1269 ) = iprot.readMapBegin()
+ for _i1273 in xrange(_size1269):
+ _key1274 = iprot.readString()
+ _val1275 = iprot.readString()
+ self.part_vals[_key1274] = _val1275
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -30913,9 +30971,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 kiter1276,viter1277 in self.part_vals.items():
+ oprot.writeString(kiter1276)
+ oprot.writeString(viter1277)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -34567,10 +34625,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)
+ (_etype1281, _size1278) = iprot.readListBegin()
+ for _i1282 in xrange(_size1278):
+ _elem1283 = iprot.readString()
+ self.success.append(_elem1283)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -34593,8 +34651,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 iter1284 in self.success:
+ oprot.writeString(iter1284)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35282,10 +35340,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)
+ (_etype1288, _size1285) = iprot.readListBegin()
+ for _i1289 in xrange(_size1285):
+ _elem1290 = iprot.readString()
+ self.success.append(_elem1290)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35308,8 +35366,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 iter1291 in self.success:
+ oprot.writeString(iter1291)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -35823,11 +35881,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)
+ (_etype1295, _size1292) = iprot.readListBegin()
+ for _i1296 in xrange(_size1292):
+ _elem1297 = Role()
+ _elem1297.read(iprot)
+ self.success.append(_elem1297)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -35850,8 +35908,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 iter1298 in self.success:
+ iter1298.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -36360,10 +36418,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)
+ (_etype1302, _size1299) = iprot.readListBegin()
+ for _i1303 in xrange(_size1299):
+ _elem1304 = iprot.readString()
+ self.group_names.append(_elem1304)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36388,8 +36446,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 iter1305 in self.group_names:
+ oprot.writeString(iter1305)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -36616,11 +36674,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)
+ (_etype1309, _size1306) = iprot.readListBegin()
+ for _i1310 in xrange(_size1306):
+ _elem1311 = HiveObjectPrivilege()
+ _elem1311.read(iprot)
+ self.success.append(_elem1311)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -36643,8 +36701,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 iter1312 in self.success:
+ iter1312.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -37314,10 +37372,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)
+ (_etype1316, _size1313) = iprot.readListBegin()
+ for _i1317 in xrange(_size1313):
+ _elem1318 = iprot.readString()
+ self.group_names.append(_elem1318)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37338,8 +37396,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 iter1319 in self.group_names:
+ oprot.writeString(iter1319)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -37394,10 +37452,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)
+ (_etype1323, _size1320) = iprot.readListBegin()
+ for _i1324 in xrange(_size1320):
+ _elem1325 = iprot.readString()
+ self.success.append(_elem1325)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -37420,8 +37478,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 iter1326 in self.success:
+ oprot.writeString(iter1326)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -38353,10 +38411,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)
+ (_etype1330, _size1327) = iprot.readListBegin()
+ for _i1331 in xrange(_size1327):
+ _elem1332 = iprot.readString()
+ self.success.append(_elem1332)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38373,8 +38431,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 iter1333 in self.success:
+ oprot.writeString(iter1333)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -38901,10 +38959,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)
+ (_etype1337, _size1334) = iprot.readListBegin()
+ for _i1338 in xrange(_size1334):
+ _elem1339 = iprot.readString()
+ self.success.append(_elem1339)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -38921,8 +38979,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 iter1340 in self.success:
+ oprot.writeString(iter1340)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -42171,6 +42229,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:
@@ -47202,11 +47387,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)
+ (_etype1344, _size1341) = iprot.readListBegin()
+ for _i1345 in xrange(_size1341):
+ _elem1346 = SchemaVersion()
+ _elem1346.read(iprot)
+ self.success.append(_elem1346)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -47235,8 +47420,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 iter1347 in self.success:
+ iter1347.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -48711,11 +48896,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)
+ (_etype1351, _size1348) = iprot.readListBegin()
+ for _i1352 in xrange(_size1348):
+ _elem1353 = RuntimeStat()
+ _elem1353.read(iprot)
+ self.success.append(_elem1353)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -48738,8 +48923,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 iter1354 in self.success:
+ iter1354.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: