Return-Path: X-Original-To: apmail-hive-commits-archive@www.apache.org Delivered-To: apmail-hive-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 291E0109C4 for ; Fri, 23 Jan 2015 19:59:43 +0000 (UTC) Received: (qmail 12413 invoked by uid 500); 23 Jan 2015 19:59:37 -0000 Delivered-To: apmail-hive-commits-archive@hive.apache.org Received: (qmail 12090 invoked by uid 500); 23 Jan 2015 19:59:37 -0000 Mailing-List: contact commits-help@hive.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: hive-dev@hive.apache.org Delivered-To: mailing list commits@hive.apache.org Received: (qmail 11674 invoked by uid 99); 23 Jan 2015 19:59:36 -0000 Received: from eris.apache.org (HELO hades.apache.org) (140.211.11.105) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 23 Jan 2015 19:59:36 +0000 Received: from hades.apache.org (localhost [127.0.0.1]) by hades.apache.org (ASF Mail Server at hades.apache.org) with ESMTP id 4958BAC09EC; Fri, 23 Jan 2015 19:59:36 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1654355 [8/27] - in /hive/branches/llap: ./ beeline/src/java/org/apache/hive/beeline/ cli/src/java/org/apache/hadoop/hive/cli/ common/src/java/org/apache/hadoop/hive/common/ common/src/java/org/apache/hadoop/hive/conf/ data/conf/ data/conf... Date: Fri, 23 Jan 2015 19:59:24 -0000 To: commits@hive.apache.org From: sershe@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20150123195936.4958BAC09EC@hades.apache.org> Modified: hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1654355&r1=1654354&r2=1654355&view=diff ============================================================================== --- hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php (original) +++ hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php Fri Jan 23 19:59:11 2015 @@ -11696,6 +11696,442 @@ class ShowCompactResponse { } +class NotificationEventRequest { + static $_TSPEC; + + public $lastEvent = null; + public $maxEvents = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'lastEvent', + 'type' => TType::I64, + ), + 2 => array( + 'var' => 'maxEvents', + 'type' => TType::I32, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['lastEvent'])) { + $this->lastEvent = $vals['lastEvent']; + } + if (isset($vals['maxEvents'])) { + $this->maxEvents = $vals['maxEvents']; + } + } + } + + public function getName() { + return 'NotificationEventRequest'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->lastEvent); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->maxEvents); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('NotificationEventRequest'); + if ($this->lastEvent !== null) { + $xfer += $output->writeFieldBegin('lastEvent', TType::I64, 1); + $xfer += $output->writeI64($this->lastEvent); + $xfer += $output->writeFieldEnd(); + } + if ($this->maxEvents !== null) { + $xfer += $output->writeFieldBegin('maxEvents', TType::I32, 2); + $xfer += $output->writeI32($this->maxEvents); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class NotificationEvent { + static $_TSPEC; + + public $eventId = null; + public $eventTime = null; + public $eventType = null; + public $dbName = null; + public $tableName = null; + public $message = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'eventId', + 'type' => TType::I64, + ), + 2 => array( + 'var' => 'eventTime', + 'type' => TType::I32, + ), + 3 => array( + 'var' => 'eventType', + 'type' => TType::STRING, + ), + 4 => array( + 'var' => 'dbName', + 'type' => TType::STRING, + ), + 5 => array( + 'var' => 'tableName', + 'type' => TType::STRING, + ), + 6 => array( + 'var' => 'message', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['eventId'])) { + $this->eventId = $vals['eventId']; + } + if (isset($vals['eventTime'])) { + $this->eventTime = $vals['eventTime']; + } + if (isset($vals['eventType'])) { + $this->eventType = $vals['eventType']; + } + if (isset($vals['dbName'])) { + $this->dbName = $vals['dbName']; + } + if (isset($vals['tableName'])) { + $this->tableName = $vals['tableName']; + } + if (isset($vals['message'])) { + $this->message = $vals['message']; + } + } + } + + public function getName() { + return 'NotificationEvent'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->eventId); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->eventTime); + } else { + $xfer += $input->skip($ftype); + } + break; + case 3: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->eventType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 4: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->dbName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 5: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->tableName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->message); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('NotificationEvent'); + if ($this->eventId !== null) { + $xfer += $output->writeFieldBegin('eventId', TType::I64, 1); + $xfer += $output->writeI64($this->eventId); + $xfer += $output->writeFieldEnd(); + } + if ($this->eventTime !== null) { + $xfer += $output->writeFieldBegin('eventTime', TType::I32, 2); + $xfer += $output->writeI32($this->eventTime); + $xfer += $output->writeFieldEnd(); + } + if ($this->eventType !== null) { + $xfer += $output->writeFieldBegin('eventType', TType::STRING, 3); + $xfer += $output->writeString($this->eventType); + $xfer += $output->writeFieldEnd(); + } + if ($this->dbName !== null) { + $xfer += $output->writeFieldBegin('dbName', TType::STRING, 4); + $xfer += $output->writeString($this->dbName); + $xfer += $output->writeFieldEnd(); + } + if ($this->tableName !== null) { + $xfer += $output->writeFieldBegin('tableName', TType::STRING, 5); + $xfer += $output->writeString($this->tableName); + $xfer += $output->writeFieldEnd(); + } + if ($this->message !== null) { + $xfer += $output->writeFieldBegin('message', TType::STRING, 6); + $xfer += $output->writeString($this->message); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class NotificationEventResponse { + static $_TSPEC; + + public $events = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'events', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\metastore\NotificationEvent', + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['events'])) { + $this->events = $vals['events']; + } + } + } + + public function getName() { + return 'NotificationEventResponse'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::LST) { + $this->events = array(); + $_size437 = 0; + $_etype440 = 0; + $xfer += $input->readListBegin($_etype440, $_size437); + for ($_i441 = 0; $_i441 < $_size437; ++$_i441) + { + $elem442 = null; + $elem442 = new \metastore\NotificationEvent(); + $xfer += $elem442->read($input); + $this->events []= $elem442; + } + $xfer += $input->readListEnd(); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('NotificationEventResponse'); + if ($this->events !== null) { + if (!is_array($this->events)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('events', TType::LST, 1); + { + $output->writeListBegin(TType::STRUCT, count($this->events)); + { + foreach ($this->events as $iter443) + { + $xfer += $iter443->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class CurrentNotificationEventId { + static $_TSPEC; + + public $eventId = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'eventId', + 'type' => TType::I64, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['eventId'])) { + $this->eventId = $vals['eventId']; + } + } + } + + public function getName() { + return 'CurrentNotificationEventId'; + } + + public function read($input) + { + $xfer = 0; + $fname = null; + $ftype = 0; + $fid = 0; + $xfer += $input->readStructBegin($fname); + while (true) + { + $xfer += $input->readFieldBegin($fname, $ftype, $fid); + if ($ftype == TType::STOP) { + break; + } + switch ($fid) + { + case 1: + if ($ftype == TType::I64) { + $xfer += $input->readI64($this->eventId); + } else { + $xfer += $input->skip($ftype); + } + break; + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('CurrentNotificationEventId'); + if ($this->eventId !== null) { + $xfer += $output->writeFieldBegin('eventId', TType::I64, 1); + $xfer += $output->writeI64($this->eventId); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class MetaException extends TException { static $_TSPEC; Modified: hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1654355&r1=1654354&r2=1654355&view=diff ============================================================================== --- hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original) +++ hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Fri Jan 23 19:59:11 2015 @@ -140,6 +140,8 @@ if len(sys.argv) <= 1 or sys.argv[1] == print ' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)' print ' void compact(CompactionRequest rqst)' print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)' + print ' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)' + print ' CurrentNotificationEventId get_current_notificationEventId()' print '' sys.exit(0) @@ -893,6 +895,18 @@ elif cmd == 'show_compact': sys.exit(1) pp.pprint(client.show_compact(eval(args[0]),)) +elif cmd == 'get_next_notification': + if len(args) != 1: + print 'get_next_notification requires 1 args' + sys.exit(1) + pp.pprint(client.get_next_notification(eval(args[0]),)) + +elif cmd == 'get_current_notificationEventId': + if len(args) != 0: + print 'get_current_notificationEventId requires 0 args' + sys.exit(1) + pp.pprint(client.get_current_notificationEventId()) + else: print 'Unrecognized method %s' % cmd sys.exit(1) Modified: hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1654355&r1=1654354&r2=1654355&view=diff ============================================================================== --- hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original) +++ hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Fri Jan 23 19:59:11 2015 @@ -976,6 +976,16 @@ class Iface(fb303.FacebookService.Iface) """ pass + def get_next_notification(self, rqst): + """ + Parameters: + - rqst + """ + pass + + def get_current_notificationEventId(self, ): + pass + class Client(fb303.FacebookService.Client, Iface): """ @@ -5196,6 +5206,61 @@ class Client(fb303.FacebookService.Clien return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result"); + def get_next_notification(self, rqst): + """ + Parameters: + - rqst + """ + self.send_get_next_notification(rqst) + return self.recv_get_next_notification() + + def send_get_next_notification(self, rqst): + self._oprot.writeMessageBegin('get_next_notification', TMessageType.CALL, self._seqid) + args = get_next_notification_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_next_notification(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = get_next_notification_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_next_notification failed: unknown result"); + + def get_current_notificationEventId(self, ): + self.send_get_current_notificationEventId() + return self.recv_get_current_notificationEventId() + + def send_get_current_notificationEventId(self, ): + self._oprot.writeMessageBegin('get_current_notificationEventId', TMessageType.CALL, self._seqid) + args = get_current_notificationEventId_args() + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_get_current_notificationEventId(self, ): + (fname, mtype, rseqid) = self._iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(self._iprot) + self._iprot.readMessageEnd() + raise x + result = get_current_notificationEventId_result() + result.read(self._iprot) + self._iprot.readMessageEnd() + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); + class Processor(fb303.FacebookService.Processor, Iface, TProcessor): def __init__(self, handler): @@ -5317,6 +5382,8 @@ class Processor(fb303.FacebookService.Pr self._processMap["heartbeat_txn_range"] = Processor.process_heartbeat_txn_range self._processMap["compact"] = Processor.process_compact self._processMap["show_compact"] = Processor.process_show_compact + self._processMap["get_next_notification"] = Processor.process_get_next_notification + self._processMap["get_current_notificationEventId"] = Processor.process_get_current_notificationEventId def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -7202,6 +7269,28 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() + def process_get_next_notification(self, seqid, iprot, oprot): + args = get_next_notification_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_next_notification_result() + result.success = self._handler.get_next_notification(args.rqst) + oprot.writeMessageBegin("get_next_notification", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + + def process_get_current_notificationEventId(self, seqid, iprot, oprot): + args = get_current_notificationEventId_args() + args.read(iprot) + iprot.readMessageEnd() + result = get_current_notificationEventId_result() + result.success = self._handler.get_current_notificationEventId() + oprot.writeMessageBegin("get_current_notificationEventId", TMessageType.REPLY, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + # HELPER FUNCTIONS AND STRUCTURES @@ -8023,10 +8112,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype437, _size434) = iprot.readListBegin() - for _i438 in xrange(_size434): - _elem439 = iprot.readString(); - self.success.append(_elem439) + (_etype444, _size441) = iprot.readListBegin() + for _i445 in xrange(_size441): + _elem446 = iprot.readString(); + self.success.append(_elem446) iprot.readListEnd() else: iprot.skip(ftype) @@ -8049,8 +8138,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 iter440 in self.success: - oprot.writeString(iter440) + for iter447 in self.success: + oprot.writeString(iter447) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8145,10 +8234,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype444, _size441) = iprot.readListBegin() - for _i445 in xrange(_size441): - _elem446 = iprot.readString(); - self.success.append(_elem446) + (_etype451, _size448) = iprot.readListBegin() + for _i452 in xrange(_size448): + _elem453 = iprot.readString(); + self.success.append(_elem453) iprot.readListEnd() else: iprot.skip(ftype) @@ -8171,8 +8260,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 iter447 in self.success: - oprot.writeString(iter447) + for iter454 in self.success: + oprot.writeString(iter454) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8882,12 +8971,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype449, _vtype450, _size448 ) = iprot.readMapBegin() - for _i452 in xrange(_size448): - _key453 = iprot.readString(); - _val454 = Type() - _val454.read(iprot) - self.success[_key453] = _val454 + (_ktype456, _vtype457, _size455 ) = iprot.readMapBegin() + for _i459 in xrange(_size455): + _key460 = iprot.readString(); + _val461 = Type() + _val461.read(iprot) + self.success[_key460] = _val461 iprot.readMapEnd() else: iprot.skip(ftype) @@ -8910,9 +8999,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 kiter455,viter456 in self.success.items(): - oprot.writeString(kiter455) - viter456.write(oprot) + for kiter462,viter463 in self.success.items(): + oprot.writeString(kiter462) + viter463.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -9043,11 +9132,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype460, _size457) = iprot.readListBegin() - for _i461 in xrange(_size457): - _elem462 = FieldSchema() - _elem462.read(iprot) - self.success.append(_elem462) + (_etype467, _size464) = iprot.readListBegin() + for _i468 in xrange(_size464): + _elem469 = FieldSchema() + _elem469.read(iprot) + self.success.append(_elem469) iprot.readListEnd() else: iprot.skip(ftype) @@ -9082,8 +9171,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 iter463 in self.success: - iter463.write(oprot) + for iter470 in self.success: + iter470.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9222,11 +9311,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype467, _size464) = iprot.readListBegin() - for _i468 in xrange(_size464): - _elem469 = FieldSchema() - _elem469.read(iprot) - self.success.append(_elem469) + (_etype474, _size471) = iprot.readListBegin() + for _i475 in xrange(_size471): + _elem476 = FieldSchema() + _elem476.read(iprot) + self.success.append(_elem476) iprot.readListEnd() else: iprot.skip(ftype) @@ -9261,8 +9350,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 iter470 in self.success: - iter470.write(oprot) + for iter477 in self.success: + iter477.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10059,10 +10148,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype474, _size471) = iprot.readListBegin() - for _i475 in xrange(_size471): - _elem476 = iprot.readString(); - self.success.append(_elem476) + (_etype481, _size478) = iprot.readListBegin() + for _i482 in xrange(_size478): + _elem483 = iprot.readString(); + self.success.append(_elem483) iprot.readListEnd() else: iprot.skip(ftype) @@ -10085,8 +10174,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 iter477 in self.success: - oprot.writeString(iter477) + for iter484 in self.success: + oprot.writeString(iter484) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10199,10 +10288,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype481, _size478) = iprot.readListBegin() - for _i482 in xrange(_size478): - _elem483 = iprot.readString(); - self.success.append(_elem483) + (_etype488, _size485) = iprot.readListBegin() + for _i489 in xrange(_size485): + _elem490 = iprot.readString(); + self.success.append(_elem490) iprot.readListEnd() else: iprot.skip(ftype) @@ -10225,8 +10314,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 iter484 in self.success: - oprot.writeString(iter484) + for iter491 in self.success: + oprot.writeString(iter491) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10443,10 +10532,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype488, _size485) = iprot.readListBegin() - for _i489 in xrange(_size485): - _elem490 = iprot.readString(); - self.tbl_names.append(_elem490) + (_etype495, _size492) = iprot.readListBegin() + for _i496 in xrange(_size492): + _elem497 = iprot.readString(); + self.tbl_names.append(_elem497) iprot.readListEnd() else: iprot.skip(ftype) @@ -10467,8 +10556,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 iter491 in self.tbl_names: - oprot.writeString(iter491) + for iter498 in self.tbl_names: + oprot.writeString(iter498) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10523,11 +10612,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype495, _size492) = iprot.readListBegin() - for _i496 in xrange(_size492): - _elem497 = Table() - _elem497.read(iprot) - self.success.append(_elem497) + (_etype502, _size499) = iprot.readListBegin() + for _i503 in xrange(_size499): + _elem504 = Table() + _elem504.read(iprot) + self.success.append(_elem504) iprot.readListEnd() else: iprot.skip(ftype) @@ -10562,8 +10651,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 iter498 in self.success: - iter498.write(oprot) + for iter505 in self.success: + iter505.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10714,10 +10803,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype502, _size499) = iprot.readListBegin() - for _i503 in xrange(_size499): - _elem504 = iprot.readString(); - self.success.append(_elem504) + (_etype509, _size506) = iprot.readListBegin() + for _i510 in xrange(_size506): + _elem511 = iprot.readString(); + self.success.append(_elem511) iprot.readListEnd() else: iprot.skip(ftype) @@ -10752,8 +10841,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 iter505 in self.success: - oprot.writeString(iter505) + for iter512 in self.success: + oprot.writeString(iter512) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11647,11 +11736,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype509, _size506) = iprot.readListBegin() - for _i510 in xrange(_size506): - _elem511 = Partition() - _elem511.read(iprot) - self.new_parts.append(_elem511) + (_etype516, _size513) = iprot.readListBegin() + for _i517 in xrange(_size513): + _elem518 = Partition() + _elem518.read(iprot) + self.new_parts.append(_elem518) iprot.readListEnd() else: iprot.skip(ftype) @@ -11668,8 +11757,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 iter512 in self.new_parts: - iter512.write(oprot) + for iter519 in self.new_parts: + iter519.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11814,11 +11903,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype516, _size513) = iprot.readListBegin() - for _i517 in xrange(_size513): - _elem518 = PartitionSpec() - _elem518.read(iprot) - self.new_parts.append(_elem518) + (_etype523, _size520) = iprot.readListBegin() + for _i524 in xrange(_size520): + _elem525 = PartitionSpec() + _elem525.read(iprot) + self.new_parts.append(_elem525) iprot.readListEnd() else: iprot.skip(ftype) @@ -11835,8 +11924,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 iter519 in self.new_parts: - iter519.write(oprot) + for iter526 in self.new_parts: + iter526.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11997,10 +12086,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype523, _size520) = iprot.readListBegin() - for _i524 in xrange(_size520): - _elem525 = iprot.readString(); - self.part_vals.append(_elem525) + (_etype530, _size527) = iprot.readListBegin() + for _i531 in xrange(_size527): + _elem532 = iprot.readString(); + self.part_vals.append(_elem532) iprot.readListEnd() else: iprot.skip(ftype) @@ -12025,8 +12114,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 iter526 in self.part_vals: - oprot.writeString(iter526) + for iter533 in self.part_vals: + oprot.writeString(iter533) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12351,10 +12440,10 @@ class append_partition_with_environment_ elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype530, _size527) = iprot.readListBegin() - for _i531 in xrange(_size527): - _elem532 = iprot.readString(); - self.part_vals.append(_elem532) + (_etype537, _size534) = iprot.readListBegin() + for _i538 in xrange(_size534): + _elem539 = iprot.readString(); + self.part_vals.append(_elem539) iprot.readListEnd() else: iprot.skip(ftype) @@ -12385,8 +12474,8 @@ class append_partition_with_environment_ if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter533 in self.part_vals: - oprot.writeString(iter533) + for iter540 in self.part_vals: + oprot.writeString(iter540) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -12934,10 +13023,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype537, _size534) = iprot.readListBegin() - for _i538 in xrange(_size534): - _elem539 = iprot.readString(); - self.part_vals.append(_elem539) + (_etype544, _size541) = iprot.readListBegin() + for _i545 in xrange(_size541): + _elem546 = iprot.readString(); + self.part_vals.append(_elem546) iprot.readListEnd() else: iprot.skip(ftype) @@ -12967,8 +13056,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 iter540 in self.part_vals: - oprot.writeString(iter540) + for iter547 in self.part_vals: + oprot.writeString(iter547) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -13126,10 +13215,10 @@ class drop_partition_with_environment_co elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype544, _size541) = iprot.readListBegin() - for _i545 in xrange(_size541): - _elem546 = iprot.readString(); - self.part_vals.append(_elem546) + (_etype551, _size548) = iprot.readListBegin() + for _i552 in xrange(_size548): + _elem553 = iprot.readString(); + self.part_vals.append(_elem553) iprot.readListEnd() else: iprot.skip(ftype) @@ -13165,8 +13254,8 @@ class drop_partition_with_environment_co if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter547 in self.part_vals: - oprot.writeString(iter547) + for iter554 in self.part_vals: + oprot.writeString(iter554) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -13844,10 +13933,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype551, _size548) = iprot.readListBegin() - for _i552 in xrange(_size548): - _elem553 = iprot.readString(); - self.part_vals.append(_elem553) + (_etype558, _size555) = iprot.readListBegin() + for _i559 in xrange(_size555): + _elem560 = iprot.readString(); + self.part_vals.append(_elem560) iprot.readListEnd() else: iprot.skip(ftype) @@ -13872,8 +13961,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 iter554 in self.part_vals: - oprot.writeString(iter554) + for iter561 in self.part_vals: + oprot.writeString(iter561) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14018,11 +14107,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype556, _vtype557, _size555 ) = iprot.readMapBegin() - for _i559 in xrange(_size555): - _key560 = iprot.readString(); - _val561 = iprot.readString(); - self.partitionSpecs[_key560] = _val561 + (_ktype563, _vtype564, _size562 ) = iprot.readMapBegin() + for _i566 in xrange(_size562): + _key567 = iprot.readString(); + _val568 = iprot.readString(); + self.partitionSpecs[_key567] = _val568 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14059,9 +14148,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 kiter562,viter563 in self.partitionSpecs.items(): - oprot.writeString(kiter562) - oprot.writeString(viter563) + for kiter569,viter570 in self.partitionSpecs.items(): + oprot.writeString(kiter569) + oprot.writeString(viter570) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -14258,10 +14347,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype567, _size564) = iprot.readListBegin() - for _i568 in xrange(_size564): - _elem569 = iprot.readString(); - self.part_vals.append(_elem569) + (_etype574, _size571) = iprot.readListBegin() + for _i575 in xrange(_size571): + _elem576 = iprot.readString(); + self.part_vals.append(_elem576) iprot.readListEnd() else: iprot.skip(ftype) @@ -14273,10 +14362,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype573, _size570) = iprot.readListBegin() - for _i574 in xrange(_size570): - _elem575 = iprot.readString(); - self.group_names.append(_elem575) + (_etype580, _size577) = iprot.readListBegin() + for _i581 in xrange(_size577): + _elem582 = iprot.readString(); + self.group_names.append(_elem582) iprot.readListEnd() else: iprot.skip(ftype) @@ -14301,8 +14390,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 iter576 in self.part_vals: - oprot.writeString(iter576) + for iter583 in self.part_vals: + oprot.writeString(iter583) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -14312,8 +14401,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 iter577 in self.group_names: - oprot.writeString(iter577) + for iter584 in self.group_names: + oprot.writeString(iter584) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14705,11 +14794,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype581, _size578) = iprot.readListBegin() - for _i582 in xrange(_size578): - _elem583 = Partition() - _elem583.read(iprot) - self.success.append(_elem583) + (_etype588, _size585) = iprot.readListBegin() + for _i589 in xrange(_size585): + _elem590 = Partition() + _elem590.read(iprot) + self.success.append(_elem590) iprot.readListEnd() else: iprot.skip(ftype) @@ -14738,8 +14827,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 iter584 in self.success: - iter584.write(oprot) + for iter591 in self.success: + iter591.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14826,10 +14915,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype588, _size585) = iprot.readListBegin() - for _i589 in xrange(_size585): - _elem590 = iprot.readString(); - self.group_names.append(_elem590) + (_etype595, _size592) = iprot.readListBegin() + for _i596 in xrange(_size592): + _elem597 = iprot.readString(); + self.group_names.append(_elem597) iprot.readListEnd() else: iprot.skip(ftype) @@ -14862,8 +14951,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 iter591 in self.group_names: - oprot.writeString(iter591) + for iter598 in self.group_names: + oprot.writeString(iter598) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14915,11 +15004,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype595, _size592) = iprot.readListBegin() - for _i596 in xrange(_size592): - _elem597 = Partition() - _elem597.read(iprot) - self.success.append(_elem597) + (_etype602, _size599) = iprot.readListBegin() + for _i603 in xrange(_size599): + _elem604 = Partition() + _elem604.read(iprot) + self.success.append(_elem604) iprot.readListEnd() else: iprot.skip(ftype) @@ -14948,8 +15037,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 iter598 in self.success: - iter598.write(oprot) + for iter605 in self.success: + iter605.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15093,11 +15182,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype602, _size599) = iprot.readListBegin() - for _i603 in xrange(_size599): - _elem604 = PartitionSpec() - _elem604.read(iprot) - self.success.append(_elem604) + (_etype609, _size606) = iprot.readListBegin() + for _i610 in xrange(_size606): + _elem611 = PartitionSpec() + _elem611.read(iprot) + self.success.append(_elem611) iprot.readListEnd() else: iprot.skip(ftype) @@ -15126,8 +15215,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 iter605 in self.success: - iter605.write(oprot) + for iter612 in self.success: + iter612.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15268,10 +15357,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype609, _size606) = iprot.readListBegin() - for _i610 in xrange(_size606): - _elem611 = iprot.readString(); - self.success.append(_elem611) + (_etype616, _size613) = iprot.readListBegin() + for _i617 in xrange(_size613): + _elem618 = iprot.readString(); + self.success.append(_elem618) iprot.readListEnd() else: iprot.skip(ftype) @@ -15294,8 +15383,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 iter612 in self.success: - oprot.writeString(iter612) + for iter619 in self.success: + oprot.writeString(iter619) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -15365,10 +15454,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype616, _size613) = iprot.readListBegin() - for _i617 in xrange(_size613): - _elem618 = iprot.readString(); - self.part_vals.append(_elem618) + (_etype623, _size620) = iprot.readListBegin() + for _i624 in xrange(_size620): + _elem625 = iprot.readString(); + self.part_vals.append(_elem625) iprot.readListEnd() else: iprot.skip(ftype) @@ -15398,8 +15487,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 iter619 in self.part_vals: - oprot.writeString(iter619) + for iter626 in self.part_vals: + oprot.writeString(iter626) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -15455,11 +15544,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype623, _size620) = iprot.readListBegin() - for _i624 in xrange(_size620): - _elem625 = Partition() - _elem625.read(iprot) - self.success.append(_elem625) + (_etype630, _size627) = iprot.readListBegin() + for _i631 in xrange(_size627): + _elem632 = Partition() + _elem632.read(iprot) + self.success.append(_elem632) iprot.readListEnd() else: iprot.skip(ftype) @@ -15488,8 +15577,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 iter626 in self.success: - iter626.write(oprot) + for iter633 in self.success: + iter633.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15569,10 +15658,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype630, _size627) = iprot.readListBegin() - for _i631 in xrange(_size627): - _elem632 = iprot.readString(); - self.part_vals.append(_elem632) + (_etype637, _size634) = iprot.readListBegin() + for _i638 in xrange(_size634): + _elem639 = iprot.readString(); + self.part_vals.append(_elem639) iprot.readListEnd() else: iprot.skip(ftype) @@ -15589,10 +15678,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype636, _size633) = iprot.readListBegin() - for _i637 in xrange(_size633): - _elem638 = iprot.readString(); - self.group_names.append(_elem638) + (_etype643, _size640) = iprot.readListBegin() + for _i644 in xrange(_size640): + _elem645 = iprot.readString(); + self.group_names.append(_elem645) iprot.readListEnd() else: iprot.skip(ftype) @@ -15617,8 +15706,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 iter639 in self.part_vals: - oprot.writeString(iter639) + for iter646 in self.part_vals: + oprot.writeString(iter646) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -15632,8 +15721,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 iter640 in self.group_names: - oprot.writeString(iter640) + for iter647 in self.group_names: + oprot.writeString(iter647) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15685,11 +15774,11 @@ class get_partitions_ps_with_auth_result if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype644, _size641) = iprot.readListBegin() - for _i645 in xrange(_size641): - _elem646 = Partition() - _elem646.read(iprot) - self.success.append(_elem646) + (_etype651, _size648) = iprot.readListBegin() + for _i652 in xrange(_size648): + _elem653 = Partition() + _elem653.read(iprot) + self.success.append(_elem653) iprot.readListEnd() else: iprot.skip(ftype) @@ -15718,8 +15807,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 iter647 in self.success: - iter647.write(oprot) + for iter654 in self.success: + iter654.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15793,10 +15882,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype651, _size648) = iprot.readListBegin() - for _i652 in xrange(_size648): - _elem653 = iprot.readString(); - self.part_vals.append(_elem653) + (_etype658, _size655) = iprot.readListBegin() + for _i659 in xrange(_size655): + _elem660 = iprot.readString(); + self.part_vals.append(_elem660) iprot.readListEnd() else: iprot.skip(ftype) @@ -15826,8 +15915,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 iter654 in self.part_vals: - oprot.writeString(iter654) + for iter661 in self.part_vals: + oprot.writeString(iter661) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -15883,10 +15972,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype658, _size655) = iprot.readListBegin() - for _i659 in xrange(_size655): - _elem660 = iprot.readString(); - self.success.append(_elem660) + (_etype665, _size662) = iprot.readListBegin() + for _i666 in xrange(_size662): + _elem667 = iprot.readString(); + self.success.append(_elem667) iprot.readListEnd() else: iprot.skip(ftype) @@ -15915,8 +16004,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 iter661 in self.success: - oprot.writeString(iter661) + for iter668 in self.success: + oprot.writeString(iter668) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16072,11 +16161,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype665, _size662) = iprot.readListBegin() - for _i666 in xrange(_size662): - _elem667 = Partition() - _elem667.read(iprot) - self.success.append(_elem667) + (_etype672, _size669) = iprot.readListBegin() + for _i673 in xrange(_size669): + _elem674 = Partition() + _elem674.read(iprot) + self.success.append(_elem674) iprot.readListEnd() else: iprot.skip(ftype) @@ -16105,8 +16194,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 iter668 in self.success: - iter668.write(oprot) + for iter675 in self.success: + iter675.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16262,11 +16351,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype672, _size669) = iprot.readListBegin() - for _i673 in xrange(_size669): - _elem674 = PartitionSpec() - _elem674.read(iprot) - self.success.append(_elem674) + (_etype679, _size676) = iprot.readListBegin() + for _i680 in xrange(_size676): + _elem681 = PartitionSpec() + _elem681.read(iprot) + self.success.append(_elem681) iprot.readListEnd() else: iprot.skip(ftype) @@ -16295,8 +16384,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 iter675 in self.success: - iter675.write(oprot) + for iter682 in self.success: + iter682.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16514,10 +16603,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype679, _size676) = iprot.readListBegin() - for _i680 in xrange(_size676): - _elem681 = iprot.readString(); - self.names.append(_elem681) + (_etype686, _size683) = iprot.readListBegin() + for _i687 in xrange(_size683): + _elem688 = iprot.readString(); + self.names.append(_elem688) iprot.readListEnd() else: iprot.skip(ftype) @@ -16542,8 +16631,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 iter682 in self.names: - oprot.writeString(iter682) + for iter689 in self.names: + oprot.writeString(iter689) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16595,11 +16684,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype686, _size683) = iprot.readListBegin() - for _i687 in xrange(_size683): - _elem688 = Partition() - _elem688.read(iprot) - self.success.append(_elem688) + (_etype693, _size690) = iprot.readListBegin() + for _i694 in xrange(_size690): + _elem695 = Partition() + _elem695.read(iprot) + self.success.append(_elem695) iprot.readListEnd() else: iprot.skip(ftype) @@ -16628,8 +16717,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 iter689 in self.success: - iter689.write(oprot) + for iter696 in self.success: + iter696.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16859,11 +16948,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype693, _size690) = iprot.readListBegin() - for _i694 in xrange(_size690): - _elem695 = Partition() - _elem695.read(iprot) - self.new_parts.append(_elem695) + (_etype700, _size697) = iprot.readListBegin() + for _i701 in xrange(_size697): + _elem702 = Partition() + _elem702.read(iprot) + self.new_parts.append(_elem702) iprot.readListEnd() else: iprot.skip(ftype) @@ -16888,8 +16977,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 iter696 in self.new_parts: - iter696.write(oprot) + for iter703 in self.new_parts: + iter703.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17201,10 +17290,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype700, _size697) = iprot.readListBegin() - for _i701 in xrange(_size697): - _elem702 = iprot.readString(); - self.part_vals.append(_elem702) + (_etype707, _size704) = iprot.readListBegin() + for _i708 in xrange(_size704): + _elem709 = iprot.readString(); + self.part_vals.append(_elem709) iprot.readListEnd() else: iprot.skip(ftype) @@ -17235,8 +17324,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 iter703 in self.part_vals: - oprot.writeString(iter703) + for iter710 in self.part_vals: + oprot.writeString(iter710) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -17364,10 +17453,10 @@ class partition_name_has_valid_character if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype707, _size704) = iprot.readListBegin() - for _i708 in xrange(_size704): - _elem709 = iprot.readString(); - self.part_vals.append(_elem709) + (_etype714, _size711) = iprot.readListBegin() + for _i715 in xrange(_size711): + _elem716 = iprot.readString(); + self.part_vals.append(_elem716) iprot.readListEnd() else: iprot.skip(ftype) @@ -17389,8 +17478,8 @@ class partition_name_has_valid_character if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter710 in self.part_vals: - oprot.writeString(iter710) + for iter717 in self.part_vals: + oprot.writeString(iter717) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -17719,10 +17808,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype714, _size711) = iprot.readListBegin() - for _i715 in xrange(_size711): - _elem716 = iprot.readString(); - self.success.append(_elem716) + (_etype721, _size718) = iprot.readListBegin() + for _i722 in xrange(_size718): + _elem723 = iprot.readString(); + self.success.append(_elem723) iprot.readListEnd() else: iprot.skip(ftype) @@ -17745,8 +17834,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 iter717 in self.success: - oprot.writeString(iter717) + for iter724 in self.success: + oprot.writeString(iter724) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17859,11 +17948,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype719, _vtype720, _size718 ) = iprot.readMapBegin() - for _i722 in xrange(_size718): - _key723 = iprot.readString(); - _val724 = iprot.readString(); - self.success[_key723] = _val724 + (_ktype726, _vtype727, _size725 ) = iprot.readMapBegin() + for _i729 in xrange(_size725): + _key730 = iprot.readString(); + _val731 = iprot.readString(); + self.success[_key730] = _val731 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17886,9 +17975,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 kiter725,viter726 in self.success.items(): - oprot.writeString(kiter725) - oprot.writeString(viter726) + for kiter732,viter733 in self.success.items(): + oprot.writeString(kiter732) + oprot.writeString(viter733) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17958,11 +18047,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype728, _vtype729, _size727 ) = iprot.readMapBegin() - for _i731 in xrange(_size727): - _key732 = iprot.readString(); - _val733 = iprot.readString(); - self.part_vals[_key732] = _val733 + (_ktype735, _vtype736, _size734 ) = iprot.readMapBegin() + for _i738 in xrange(_size734): + _key739 = iprot.readString(); + _val740 = iprot.readString(); + self.part_vals[_key739] = _val740 iprot.readMapEnd() else: iprot.skip(ftype) @@ -17992,9 +18081,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 kiter734,viter735 in self.part_vals.items(): - oprot.writeString(kiter734) - oprot.writeString(viter735) + for kiter741,viter742 in self.part_vals.items(): + oprot.writeString(kiter741) + oprot.writeString(viter742) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -18190,11 +18279,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype737, _vtype738, _size736 ) = iprot.readMapBegin() - for _i740 in xrange(_size736): - _key741 = iprot.readString(); - _val742 = iprot.readString(); - self.part_vals[_key741] = _val742 + (_ktype744, _vtype745, _size743 ) = iprot.readMapBegin() + for _i747 in xrange(_size743): + _key748 = iprot.readString(); + _val749 = iprot.readString(); + self.part_vals[_key748] = _val749 iprot.readMapEnd() else: iprot.skip(ftype) @@ -18224,9 +18313,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 kiter743,viter744 in self.part_vals.items(): - oprot.writeString(kiter743) - oprot.writeString(viter744) + for kiter750,viter751 in self.part_vals.items(): + oprot.writeString(kiter750) + oprot.writeString(viter751) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -19198,11 +19287,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype748, _size745) = iprot.readListBegin() - for _i749 in xrange(_size745): - _elem750 = Index() - _elem750.read(iprot) - self.success.append(_elem750) + (_etype755, _size752) = iprot.readListBegin() + for _i756 in xrange(_size752): + _elem757 = Index() + _elem757.read(iprot) + self.success.append(_elem757) iprot.readListEnd() else: iprot.skip(ftype) @@ -19231,8 +19320,8 @@ class get_indexes_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter751 in self.success: - iter751.write(oprot) + for iter758 in self.success: + iter758.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19373,10 +19462,10 @@ class get_index_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype755, _size752) = iprot.readListBegin() - for _i756 in xrange(_size752): - _elem757 = iprot.readString(); - self.success.append(_elem757) + (_etype762, _size759) = iprot.readListBegin() + for _i763 in xrange(_size759): + _elem764 = iprot.readString(); + self.success.append(_elem764) iprot.readListEnd() else: iprot.skip(ftype) @@ -19399,8 +19488,8 @@ class get_index_names_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRING, len(self.success)) - for iter758 in self.success: - oprot.writeString(iter758) + for iter765 in self.success: + oprot.writeString(iter765) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -21754,10 +21843,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype762, _size759) = iprot.readListBegin() - for _i763 in xrange(_size759): - _elem764 = iprot.readString(); - self.success.append(_elem764) + (_etype769, _size766) = iprot.readListBegin() + for _i770 in xrange(_size766): + _elem771 = iprot.readString(); + self.success.append(_elem771) iprot.readListEnd() else: iprot.skip(ftype) @@ -21780,8 +21869,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 iter765 in self.success: - oprot.writeString(iter765) + for iter772 in self.success: + oprot.writeString(iter772) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22299,10 +22388,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype769, _size766) = iprot.readListBegin() - for _i770 in xrange(_size766): - _elem771 = iprot.readString(); - self.success.append(_elem771) + (_etype776, _size773) = iprot.readListBegin() + for _i777 in xrange(_size773): + _elem778 = iprot.readString(); + self.success.append(_elem778) iprot.readListEnd() else: iprot.skip(ftype) @@ -22325,8 +22414,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 iter772 in self.success: - oprot.writeString(iter772) + for iter779 in self.success: + oprot.writeString(iter779) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22799,11 +22888,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype776, _size773) = iprot.readListBegin() - for _i777 in xrange(_size773): - _elem778 = Role() - _elem778.read(iprot) - self.success.append(_elem778) + (_etype783, _size780) = iprot.readListBegin() + for _i784 in xrange(_size780): + _elem785 = Role() + _elem785.read(iprot) + self.success.append(_elem785) iprot.readListEnd() else: iprot.skip(ftype) @@ -22826,8 +22915,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 iter779 in self.success: - iter779.write(oprot) + for iter786 in self.success: + iter786.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -23297,10 +23386,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype783, _size780) = iprot.readListBegin() - for _i784 in xrange(_size780): - _elem785 = iprot.readString(); - self.group_names.append(_elem785) + (_etype790, _size787) = iprot.readListBegin() + for _i791 in xrange(_size787): + _elem792 = iprot.readString(); + self.group_names.append(_elem792) iprot.readListEnd() else: iprot.skip(ftype) @@ -23325,8 +23414,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 iter786 in self.group_names: - oprot.writeString(iter786) + for iter793 in self.group_names: + oprot.writeString(iter793) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23533,11 +23622,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype790, _size787) = iprot.readListBegin() - for _i791 in xrange(_size787): - _elem792 = HiveObjectPrivilege() - _elem792.read(iprot) - self.success.append(_elem792) + (_etype797, _size794) = iprot.readListBegin() + for _i798 in xrange(_size794): + _elem799 = HiveObjectPrivilege() + _elem799.read(iprot) + self.success.append(_elem799) iprot.readListEnd() else: iprot.skip(ftype) @@ -23560,8 +23649,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 iter793 in self.success: - iter793.write(oprot) + for iter800 in self.success: + iter800.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24020,10 +24109,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype797, _size794) = iprot.readListBegin() - for _i798 in xrange(_size794): - _elem799 = iprot.readString(); - self.group_names.append(_elem799) + (_etype804, _size801) = iprot.readListBegin() + for _i805 in xrange(_size801): + _elem806 = iprot.readString(); + self.group_names.append(_elem806) iprot.readListEnd() else: iprot.skip(ftype) @@ -24044,8 +24133,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 iter800 in self.group_names: - oprot.writeString(iter800) + for iter807 in self.group_names: + oprot.writeString(iter807) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24094,10 +24183,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype804, _size801) = iprot.readListBegin() - for _i805 in xrange(_size801): - _elem806 = iprot.readString(); - self.success.append(_elem806) + (_etype811, _size808) = iprot.readListBegin() + for _i812 in xrange(_size808): + _elem813 = iprot.readString(); + self.success.append(_elem813) iprot.readListEnd() else: iprot.skip(ftype) @@ -24120,8 +24209,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 iter807 in self.success: - oprot.writeString(iter807) + for iter814 in self.success: + oprot.writeString(iter814) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26162,6 +26251,229 @@ class show_compact_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 __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 get_next_notification_args: + """ + Attributes: + - rqst + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'rqst', (NotificationEventRequest, NotificationEventRequest.thrift_spec), None, ), # 1 + ) + + 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 = NotificationEventRequest() + 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('get_next_notification_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 __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 get_next_notification_result: + """ + Attributes: + - success + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (NotificationEventResponse, NotificationEventResponse.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 = NotificationEventResponse() + 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('get_next_notification_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 __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 get_current_notificationEventId_args: + + thrift_spec = ( + ) + + 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 + 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('get_current_notificationEventId_args') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + 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 get_current_notificationEventId_result: + """ + Attributes: + - success + """ + + thrift_spec = ( + (0, TType.STRUCT, 'success', (CurrentNotificationEventId, CurrentNotificationEventId.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 = CurrentNotificationEventId() + 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('get_current_notificationEventId_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd()