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:
