Modified: hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1657387&r1=1657386&r2=1657387&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php (original) +++ hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php Wed Feb 4 19:24:12 2015 @@ -12143,12 +12143,187 @@ class CurrentNotificationEventId { } +class InsertEventRequestData { + static $_TSPEC; + + public $filesAdded = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'filesAdded', + 'type' => TType::LST, + 'etype' => TType::STRING, + 'elem' => array( + 'type' => TType::STRING, + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['filesAdded'])) { + $this->filesAdded = $vals['filesAdded']; + } + } + } + + public function getName() { + return 'InsertEventRequestData'; + } + + 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->filesAdded = array(); + $_size444 = 0; + $_etype447 = 0; + $xfer += $input->readListBegin($_etype447, $_size444); + for ($_i448 = 0; $_i448 < $_size444; ++$_i448) + { + $elem449 = null; + $xfer += $input->readString($elem449); + $this->filesAdded []= $elem449; + } + $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('InsertEventRequestData'); + if ($this->filesAdded !== null) { + if (!is_array($this->filesAdded)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('filesAdded', TType::LST, 1); + { + $output->writeListBegin(TType::STRING, count($this->filesAdded)); + { + foreach ($this->filesAdded as $iter450) + { + $xfer += $output->writeString($iter450); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +class FireEventRequestData { + static $_TSPEC; + + public $insertData = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'insertData', + 'type' => TType::STRUCT, + 'class' => '\metastore\InsertEventRequestData', + ), + ); + } + if (is_array($vals)) { + if (isset($vals['insertData'])) { + $this->insertData = $vals['insertData']; + } + } + } + + public function getName() { + return 'FireEventRequestData'; + } + + 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::STRUCT) { + $this->insertData = new \metastore\InsertEventRequestData(); + $xfer += $this->insertData->read($input); + } 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('FireEventRequestData'); + if ($this->insertData !== null) { + if (!is_object($this->insertData)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('insertData', TType::STRUCT, 1); + $xfer += $this->insertData->write($output); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class FireEventRequest { static $_TSPEC; - public $eventType = null; - public $dbName = null; public $successful = null; + public $data = null; + public $dbName = null; public $tableName = null; public $partitionVals = null; @@ -12156,16 +12331,17 @@ class FireEventRequest { if (!isset(self::$_TSPEC)) { self::$_TSPEC = array( 1 => array( - 'var' => 'eventType', - 'type' => TType::I32, + 'var' => 'successful', + 'type' => TType::BOOL, ), 2 => array( - 'var' => 'dbName', - 'type' => TType::STRING, + 'var' => 'data', + 'type' => TType::STRUCT, + 'class' => '\metastore\FireEventRequestData', ), 3 => array( - 'var' => 'successful', - 'type' => TType::BOOL, + 'var' => 'dbName', + 'type' => TType::STRING, ), 4 => array( 'var' => 'tableName', @@ -12182,15 +12358,15 @@ class FireEventRequest { ); } if (is_array($vals)) { - if (isset($vals['eventType'])) { - $this->eventType = $vals['eventType']; + if (isset($vals['successful'])) { + $this->successful = $vals['successful']; + } + if (isset($vals['data'])) { + $this->data = $vals['data']; } if (isset($vals['dbName'])) { $this->dbName = $vals['dbName']; } - if (isset($vals['successful'])) { - $this->successful = $vals['successful']; - } if (isset($vals['tableName'])) { $this->tableName = $vals['tableName']; } @@ -12220,22 +12396,23 @@ class FireEventRequest { switch ($fid) { case 1: - if ($ftype == TType::I32) { - $xfer += $input->readI32($this->eventType); + if ($ftype == TType::BOOL) { + $xfer += $input->readBool($this->successful); } else { $xfer += $input->skip($ftype); } break; case 2: - if ($ftype == TType::STRING) { - $xfer += $input->readString($this->dbName); + if ($ftype == TType::STRUCT) { + $this->data = new \metastore\FireEventRequestData(); + $xfer += $this->data->read($input); } else { $xfer += $input->skip($ftype); } break; case 3: - if ($ftype == TType::BOOL) { - $xfer += $input->readBool($this->successful); + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->dbName); } else { $xfer += $input->skip($ftype); } @@ -12250,14 +12427,14 @@ class FireEventRequest { case 5: if ($ftype == TType::LST) { $this->partitionVals = array(); - $_size444 = 0; - $_etype447 = 0; - $xfer += $input->readListBegin($_etype447, $_size444); - for ($_i448 = 0; $_i448 < $_size444; ++$_i448) + $_size451 = 0; + $_etype454 = 0; + $xfer += $input->readListBegin($_etype454, $_size451); + for ($_i455 = 0; $_i455 < $_size451; ++$_i455) { - $elem449 = null; - $xfer += $input->readString($elem449); - $this->partitionVals []= $elem449; + $elem456 = null; + $xfer += $input->readString($elem456); + $this->partitionVals []= $elem456; } $xfer += $input->readListEnd(); } else { @@ -12277,19 +12454,22 @@ class FireEventRequest { public function write($output) { $xfer = 0; $xfer += $output->writeStructBegin('FireEventRequest'); - if ($this->eventType !== null) { - $xfer += $output->writeFieldBegin('eventType', TType::I32, 1); - $xfer += $output->writeI32($this->eventType); + if ($this->successful !== null) { + $xfer += $output->writeFieldBegin('successful', TType::BOOL, 1); + $xfer += $output->writeBool($this->successful); $xfer += $output->writeFieldEnd(); } - if ($this->dbName !== null) { - $xfer += $output->writeFieldBegin('dbName', TType::STRING, 2); - $xfer += $output->writeString($this->dbName); + if ($this->data !== null) { + if (!is_object($this->data)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('data', TType::STRUCT, 2); + $xfer += $this->data->write($output); $xfer += $output->writeFieldEnd(); } - if ($this->successful !== null) { - $xfer += $output->writeFieldBegin('successful', TType::BOOL, 3); - $xfer += $output->writeBool($this->successful); + if ($this->dbName !== null) { + $xfer += $output->writeFieldBegin('dbName', TType::STRING, 3); + $xfer += $output->writeString($this->dbName); $xfer += $output->writeFieldEnd(); } if ($this->tableName !== null) { @@ -12305,9 +12485,9 @@ class FireEventRequest { { $output->writeListBegin(TType::STRING, count($this->partitionVals)); { - foreach ($this->partitionVals as $iter450) + foreach ($this->partitionVals as $iter457) { - $xfer += $output->writeString($iter450); + $xfer += $output->writeString($iter457); } } $output->writeListEnd(); @@ -12317,6 +12497,56 @@ class FireEventRequest { $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; + } + +} + +class FireEventResponse { + static $_TSPEC; + + + public function __construct() { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + ); + } + } + + public function getName() { + return 'FireEventResponse'; + } + + 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) + { + default: + $xfer += $input->skip($ftype); + break; + } + $xfer += $input->readFieldEnd(); + } + $xfer += $input->readStructEnd(); + return $xfer; + } + + public function write($output) { + $xfer = 0; + $xfer += $output->writeStructBegin('FireEventResponse'); + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; } }
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1657387&r1=1657386&r2=1657387&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Wed Feb 4 19:24:12 2015 @@ -142,7 +142,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)' print ' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)' print ' CurrentNotificationEventId get_current_notificationEventId()' - print ' void fire_notification_event(FireEventRequest rqst)' + print ' FireEventResponse fire_listener_event(FireEventRequest rqst)' print '' sys.exit(0) @@ -908,11 +908,11 @@ elif cmd == 'get_current_notificationEve sys.exit(1) pp.pprint(client.get_current_notificationEventId()) -elif cmd == 'fire_notification_event': +elif cmd == 'fire_listener_event': if len(args) != 1: - print 'fire_notification_event requires 1 args' + print 'fire_listener_event requires 1 args' sys.exit(1) - pp.pprint(client.fire_notification_event(eval(args[0]),)) + pp.pprint(client.fire_listener_event(eval(args[0]),)) else: print 'Unrecognized method %s' % cmd Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1657387&r1=1657386&r2=1657387&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Wed Feb 4 19:24:12 2015 @@ -986,7 +986,7 @@ class Iface(fb303.FacebookService.Iface) def get_current_notificationEventId(self, ): pass - def fire_notification_event(self, rqst): + def fire_listener_event(self, rqst): """ Parameters: - rqst @@ -5268,33 +5268,35 @@ class Client(fb303.FacebookService.Clien return result.success raise TApplicationException(TApplicationException.MISSING_RESULT, "get_current_notificationEventId failed: unknown result"); - def fire_notification_event(self, rqst): + def fire_listener_event(self, rqst): """ Parameters: - rqst """ - self.send_fire_notification_event(rqst) - self.recv_fire_notification_event() + self.send_fire_listener_event(rqst) + return self.recv_fire_listener_event() - def send_fire_notification_event(self, rqst): - self._oprot.writeMessageBegin('fire_notification_event', TMessageType.CALL, self._seqid) - args = fire_notification_event_args() + def send_fire_listener_event(self, rqst): + self._oprot.writeMessageBegin('fire_listener_event', TMessageType.CALL, self._seqid) + args = fire_listener_event_args() args.rqst = rqst args.write(self._oprot) self._oprot.writeMessageEnd() self._oprot.trans.flush() - def recv_fire_notification_event(self, ): + def recv_fire_listener_event(self, ): (fname, mtype, rseqid) = self._iprot.readMessageBegin() if mtype == TMessageType.EXCEPTION: x = TApplicationException() x.read(self._iprot) self._iprot.readMessageEnd() raise x - result = fire_notification_event_result() + result = fire_listener_event_result() result.read(self._iprot) self._iprot.readMessageEnd() - return + if result.success is not None: + return result.success + raise TApplicationException(TApplicationException.MISSING_RESULT, "fire_listener_event failed: unknown result"); class Processor(fb303.FacebookService.Processor, Iface, TProcessor): @@ -5419,7 +5421,7 @@ class Processor(fb303.FacebookService.Pr 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 - self._processMap["fire_notification_event"] = Processor.process_fire_notification_event + self._processMap["fire_listener_event"] = Processor.process_fire_listener_event def process(self, iprot, oprot): (name, type, seqid) = iprot.readMessageBegin() @@ -7327,13 +7329,13 @@ class Processor(fb303.FacebookService.Pr oprot.writeMessageEnd() oprot.trans.flush() - def process_fire_notification_event(self, seqid, iprot, oprot): - args = fire_notification_event_args() + def process_fire_listener_event(self, seqid, iprot, oprot): + args = fire_listener_event_args() args.read(iprot) iprot.readMessageEnd() - result = fire_notification_event_result() - self._handler.fire_notification_event(args.rqst) - oprot.writeMessageBegin("fire_notification_event", TMessageType.REPLY, seqid) + result = fire_listener_event_result() + result.success = self._handler.fire_listener_event(args.rqst) + oprot.writeMessageBegin("fire_listener_event", TMessageType.REPLY, seqid) result.write(oprot) oprot.writeMessageEnd() oprot.trans.flush() @@ -8159,10 +8161,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype451, _size448) = iprot.readListBegin() - for _i452 in xrange(_size448): - _elem453 = iprot.readString(); - self.success.append(_elem453) + (_etype458, _size455) = iprot.readListBegin() + for _i459 in xrange(_size455): + _elem460 = iprot.readString(); + self.success.append(_elem460) iprot.readListEnd() else: iprot.skip(ftype) @@ -8185,8 +8187,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 iter454 in self.success: - oprot.writeString(iter454) + for iter461 in self.success: + oprot.writeString(iter461) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -8281,10 +8283,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype458, _size455) = iprot.readListBegin() - for _i459 in xrange(_size455): - _elem460 = iprot.readString(); - self.success.append(_elem460) + (_etype465, _size462) = iprot.readListBegin() + for _i466 in xrange(_size462): + _elem467 = iprot.readString(); + self.success.append(_elem467) iprot.readListEnd() else: iprot.skip(ftype) @@ -8307,8 +8309,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 iter461 in self.success: - oprot.writeString(iter461) + for iter468 in self.success: + oprot.writeString(iter468) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9018,12 +9020,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype463, _vtype464, _size462 ) = iprot.readMapBegin() - for _i466 in xrange(_size462): - _key467 = iprot.readString(); - _val468 = Type() - _val468.read(iprot) - self.success[_key467] = _val468 + (_ktype470, _vtype471, _size469 ) = iprot.readMapBegin() + for _i473 in xrange(_size469): + _key474 = iprot.readString(); + _val475 = Type() + _val475.read(iprot) + self.success[_key474] = _val475 iprot.readMapEnd() else: iprot.skip(ftype) @@ -9046,9 +9048,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 kiter469,viter470 in self.success.items(): - oprot.writeString(kiter469) - viter470.write(oprot) + for kiter476,viter477 in self.success.items(): + oprot.writeString(kiter476) + viter477.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -9179,11 +9181,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype474, _size471) = iprot.readListBegin() - for _i475 in xrange(_size471): - _elem476 = FieldSchema() - _elem476.read(iprot) - self.success.append(_elem476) + (_etype481, _size478) = iprot.readListBegin() + for _i482 in xrange(_size478): + _elem483 = FieldSchema() + _elem483.read(iprot) + self.success.append(_elem483) iprot.readListEnd() else: iprot.skip(ftype) @@ -9218,8 +9220,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 iter477 in self.success: - iter477.write(oprot) + for iter484 in self.success: + iter484.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9358,11 +9360,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype481, _size478) = iprot.readListBegin() - for _i482 in xrange(_size478): - _elem483 = FieldSchema() - _elem483.read(iprot) - self.success.append(_elem483) + (_etype488, _size485) = iprot.readListBegin() + for _i489 in xrange(_size485): + _elem490 = FieldSchema() + _elem490.read(iprot) + self.success.append(_elem490) iprot.readListEnd() else: iprot.skip(ftype) @@ -9397,8 +9399,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 iter484 in self.success: - iter484.write(oprot) + for iter491 in self.success: + iter491.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10195,10 +10197,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype488, _size485) = iprot.readListBegin() - for _i489 in xrange(_size485): - _elem490 = iprot.readString(); - self.success.append(_elem490) + (_etype495, _size492) = iprot.readListBegin() + for _i496 in xrange(_size492): + _elem497 = iprot.readString(); + self.success.append(_elem497) iprot.readListEnd() else: iprot.skip(ftype) @@ -10221,8 +10223,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 iter491 in self.success: - oprot.writeString(iter491) + for iter498 in self.success: + oprot.writeString(iter498) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10335,10 +10337,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype495, _size492) = iprot.readListBegin() - for _i496 in xrange(_size492): - _elem497 = iprot.readString(); - self.success.append(_elem497) + (_etype502, _size499) = iprot.readListBegin() + for _i503 in xrange(_size499): + _elem504 = iprot.readString(); + self.success.append(_elem504) iprot.readListEnd() else: iprot.skip(ftype) @@ -10361,8 +10363,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 iter498 in self.success: - oprot.writeString(iter498) + for iter505 in self.success: + oprot.writeString(iter505) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10579,10 +10581,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype502, _size499) = iprot.readListBegin() - for _i503 in xrange(_size499): - _elem504 = iprot.readString(); - self.tbl_names.append(_elem504) + (_etype509, _size506) = iprot.readListBegin() + for _i510 in xrange(_size506): + _elem511 = iprot.readString(); + self.tbl_names.append(_elem511) iprot.readListEnd() else: iprot.skip(ftype) @@ -10603,8 +10605,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 iter505 in self.tbl_names: - oprot.writeString(iter505) + for iter512 in self.tbl_names: + oprot.writeString(iter512) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -10659,11 +10661,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype509, _size506) = iprot.readListBegin() - for _i510 in xrange(_size506): - _elem511 = Table() - _elem511.read(iprot) - self.success.append(_elem511) + (_etype516, _size513) = iprot.readListBegin() + for _i517 in xrange(_size513): + _elem518 = Table() + _elem518.read(iprot) + self.success.append(_elem518) iprot.readListEnd() else: iprot.skip(ftype) @@ -10698,8 +10700,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 iter512 in self.success: - iter512.write(oprot) + for iter519 in self.success: + iter519.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10850,10 +10852,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype516, _size513) = iprot.readListBegin() - for _i517 in xrange(_size513): - _elem518 = iprot.readString(); - self.success.append(_elem518) + (_etype523, _size520) = iprot.readListBegin() + for _i524 in xrange(_size520): + _elem525 = iprot.readString(); + self.success.append(_elem525) iprot.readListEnd() else: iprot.skip(ftype) @@ -10888,8 +10890,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 iter519 in self.success: - oprot.writeString(iter519) + for iter526 in self.success: + oprot.writeString(iter526) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11783,11 +11785,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype523, _size520) = iprot.readListBegin() - for _i524 in xrange(_size520): - _elem525 = Partition() - _elem525.read(iprot) - self.new_parts.append(_elem525) + (_etype530, _size527) = iprot.readListBegin() + for _i531 in xrange(_size527): + _elem532 = Partition() + _elem532.read(iprot) + self.new_parts.append(_elem532) iprot.readListEnd() else: iprot.skip(ftype) @@ -11804,8 +11806,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 iter526 in self.new_parts: - iter526.write(oprot) + for iter533 in self.new_parts: + iter533.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -11950,11 +11952,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype530, _size527) = iprot.readListBegin() - for _i531 in xrange(_size527): - _elem532 = PartitionSpec() - _elem532.read(iprot) - self.new_parts.append(_elem532) + (_etype537, _size534) = iprot.readListBegin() + for _i538 in xrange(_size534): + _elem539 = PartitionSpec() + _elem539.read(iprot) + self.new_parts.append(_elem539) iprot.readListEnd() else: iprot.skip(ftype) @@ -11971,8 +11973,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 iter533 in self.new_parts: - iter533.write(oprot) + for iter540 in self.new_parts: + iter540.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12133,10 +12135,10 @@ class append_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) @@ -12161,8 +12163,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 iter540 in self.part_vals: - oprot.writeString(iter540) + for iter547 in self.part_vals: + oprot.writeString(iter547) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12487,10 +12489,10 @@ class append_partition_with_environment_ 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) @@ -12521,8 +12523,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 iter547 in self.part_vals: - oprot.writeString(iter547) + for iter554 in self.part_vals: + oprot.writeString(iter554) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -13070,10 +13072,10 @@ class drop_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) @@ -13103,8 +13105,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 iter554 in self.part_vals: - oprot.writeString(iter554) + for iter561 in self.part_vals: + oprot.writeString(iter561) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -13262,10 +13264,10 @@ class drop_partition_with_environment_co elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype558, _size555) = iprot.readListBegin() - for _i559 in xrange(_size555): - _elem560 = iprot.readString(); - self.part_vals.append(_elem560) + (_etype565, _size562) = iprot.readListBegin() + for _i566 in xrange(_size562): + _elem567 = iprot.readString(); + self.part_vals.append(_elem567) iprot.readListEnd() else: iprot.skip(ftype) @@ -13301,8 +13303,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 iter561 in self.part_vals: - oprot.writeString(iter561) + for iter568 in self.part_vals: + oprot.writeString(iter568) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -13980,10 +13982,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype565, _size562) = iprot.readListBegin() - for _i566 in xrange(_size562): - _elem567 = iprot.readString(); - self.part_vals.append(_elem567) + (_etype572, _size569) = iprot.readListBegin() + for _i573 in xrange(_size569): + _elem574 = iprot.readString(); + self.part_vals.append(_elem574) iprot.readListEnd() else: iprot.skip(ftype) @@ -14008,8 +14010,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 iter568 in self.part_vals: - oprot.writeString(iter568) + for iter575 in self.part_vals: + oprot.writeString(iter575) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14154,11 +14156,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype570, _vtype571, _size569 ) = iprot.readMapBegin() - for _i573 in xrange(_size569): - _key574 = iprot.readString(); - _val575 = iprot.readString(); - self.partitionSpecs[_key574] = _val575 + (_ktype577, _vtype578, _size576 ) = iprot.readMapBegin() + for _i580 in xrange(_size576): + _key581 = iprot.readString(); + _val582 = iprot.readString(); + self.partitionSpecs[_key581] = _val582 iprot.readMapEnd() else: iprot.skip(ftype) @@ -14195,9 +14197,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 kiter576,viter577 in self.partitionSpecs.items(): - oprot.writeString(kiter576) - oprot.writeString(viter577) + for kiter583,viter584 in self.partitionSpecs.items(): + oprot.writeString(kiter583) + oprot.writeString(viter584) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -14394,10 +14396,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype581, _size578) = iprot.readListBegin() - for _i582 in xrange(_size578): - _elem583 = iprot.readString(); - self.part_vals.append(_elem583) + (_etype588, _size585) = iprot.readListBegin() + for _i589 in xrange(_size585): + _elem590 = iprot.readString(); + self.part_vals.append(_elem590) iprot.readListEnd() else: iprot.skip(ftype) @@ -14409,10 +14411,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype587, _size584) = iprot.readListBegin() - for _i588 in xrange(_size584): - _elem589 = iprot.readString(); - self.group_names.append(_elem589) + (_etype594, _size591) = iprot.readListBegin() + for _i595 in xrange(_size591): + _elem596 = iprot.readString(); + self.group_names.append(_elem596) iprot.readListEnd() else: iprot.skip(ftype) @@ -14437,8 +14439,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 iter590 in self.part_vals: - oprot.writeString(iter590) + for iter597 in self.part_vals: + oprot.writeString(iter597) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -14448,8 +14450,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 iter591 in self.group_names: - oprot.writeString(iter591) + for iter598 in self.group_names: + oprot.writeString(iter598) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14841,11 +14843,11 @@ class get_partitions_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) @@ -14874,8 +14876,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 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: @@ -14962,10 +14964,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype602, _size599) = iprot.readListBegin() - for _i603 in xrange(_size599): - _elem604 = iprot.readString(); - self.group_names.append(_elem604) + (_etype609, _size606) = iprot.readListBegin() + for _i610 in xrange(_size606): + _elem611 = iprot.readString(); + self.group_names.append(_elem611) iprot.readListEnd() else: iprot.skip(ftype) @@ -14998,8 +15000,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 iter605 in self.group_names: - oprot.writeString(iter605) + for iter612 in self.group_names: + oprot.writeString(iter612) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15051,11 +15053,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype609, _size606) = iprot.readListBegin() - for _i610 in xrange(_size606): - _elem611 = Partition() - _elem611.read(iprot) - self.success.append(_elem611) + (_etype616, _size613) = iprot.readListBegin() + for _i617 in xrange(_size613): + _elem618 = Partition() + _elem618.read(iprot) + self.success.append(_elem618) iprot.readListEnd() else: iprot.skip(ftype) @@ -15084,8 +15086,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 iter612 in self.success: - iter612.write(oprot) + for iter619 in self.success: + iter619.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15229,11 +15231,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype616, _size613) = iprot.readListBegin() - for _i617 in xrange(_size613): - _elem618 = PartitionSpec() - _elem618.read(iprot) - self.success.append(_elem618) + (_etype623, _size620) = iprot.readListBegin() + for _i624 in xrange(_size620): + _elem625 = PartitionSpec() + _elem625.read(iprot) + self.success.append(_elem625) iprot.readListEnd() else: iprot.skip(ftype) @@ -15262,8 +15264,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 iter619 in self.success: - iter619.write(oprot) + for iter626 in self.success: + iter626.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15404,10 +15406,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype623, _size620) = iprot.readListBegin() - for _i624 in xrange(_size620): - _elem625 = iprot.readString(); - self.success.append(_elem625) + (_etype630, _size627) = iprot.readListBegin() + for _i631 in xrange(_size627): + _elem632 = iprot.readString(); + self.success.append(_elem632) iprot.readListEnd() else: iprot.skip(ftype) @@ -15430,8 +15432,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 iter626 in self.success: - oprot.writeString(iter626) + for iter633 in self.success: + oprot.writeString(iter633) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -15501,10 +15503,10 @@ class get_partitions_ps_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) @@ -15534,8 +15536,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 iter633 in self.part_vals: - oprot.writeString(iter633) + for iter640 in self.part_vals: + oprot.writeString(iter640) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -15591,11 +15593,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype637, _size634) = iprot.readListBegin() - for _i638 in xrange(_size634): - _elem639 = Partition() - _elem639.read(iprot) - self.success.append(_elem639) + (_etype644, _size641) = iprot.readListBegin() + for _i645 in xrange(_size641): + _elem646 = Partition() + _elem646.read(iprot) + self.success.append(_elem646) iprot.readListEnd() else: iprot.skip(ftype) @@ -15624,8 +15626,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 iter640 in self.success: - iter640.write(oprot) + for iter647 in self.success: + iter647.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15705,10 +15707,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype644, _size641) = iprot.readListBegin() - for _i645 in xrange(_size641): - _elem646 = iprot.readString(); - self.part_vals.append(_elem646) + (_etype651, _size648) = iprot.readListBegin() + for _i652 in xrange(_size648): + _elem653 = iprot.readString(); + self.part_vals.append(_elem653) iprot.readListEnd() else: iprot.skip(ftype) @@ -15725,10 +15727,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype650, _size647) = iprot.readListBegin() - for _i651 in xrange(_size647): - _elem652 = iprot.readString(); - self.group_names.append(_elem652) + (_etype657, _size654) = iprot.readListBegin() + for _i658 in xrange(_size654): + _elem659 = iprot.readString(); + self.group_names.append(_elem659) iprot.readListEnd() else: iprot.skip(ftype) @@ -15753,8 +15755,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 iter653 in self.part_vals: - oprot.writeString(iter653) + for iter660 in self.part_vals: + oprot.writeString(iter660) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -15768,8 +15770,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 iter654 in self.group_names: - oprot.writeString(iter654) + for iter661 in self.group_names: + oprot.writeString(iter661) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -15821,11 +15823,11 @@ class get_partitions_ps_with_auth_result if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype658, _size655) = iprot.readListBegin() - for _i659 in xrange(_size655): - _elem660 = Partition() - _elem660.read(iprot) - self.success.append(_elem660) + (_etype665, _size662) = iprot.readListBegin() + for _i666 in xrange(_size662): + _elem667 = Partition() + _elem667.read(iprot) + self.success.append(_elem667) iprot.readListEnd() else: iprot.skip(ftype) @@ -15854,8 +15856,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 iter661 in self.success: - iter661.write(oprot) + for iter668 in self.success: + iter668.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -15929,10 +15931,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype665, _size662) = iprot.readListBegin() - for _i666 in xrange(_size662): - _elem667 = iprot.readString(); - self.part_vals.append(_elem667) + (_etype672, _size669) = iprot.readListBegin() + for _i673 in xrange(_size669): + _elem674 = iprot.readString(); + self.part_vals.append(_elem674) iprot.readListEnd() else: iprot.skip(ftype) @@ -15962,8 +15964,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 iter668 in self.part_vals: - oprot.writeString(iter668) + for iter675 in self.part_vals: + oprot.writeString(iter675) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -16019,10 +16021,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype672, _size669) = iprot.readListBegin() - for _i673 in xrange(_size669): - _elem674 = iprot.readString(); - self.success.append(_elem674) + (_etype679, _size676) = iprot.readListBegin() + for _i680 in xrange(_size676): + _elem681 = iprot.readString(); + self.success.append(_elem681) iprot.readListEnd() else: iprot.skip(ftype) @@ -16051,8 +16053,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 iter675 in self.success: - oprot.writeString(iter675) + for iter682 in self.success: + oprot.writeString(iter682) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16208,11 +16210,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype679, _size676) = iprot.readListBegin() - for _i680 in xrange(_size676): - _elem681 = Partition() - _elem681.read(iprot) - self.success.append(_elem681) + (_etype686, _size683) = iprot.readListBegin() + for _i687 in xrange(_size683): + _elem688 = Partition() + _elem688.read(iprot) + self.success.append(_elem688) iprot.readListEnd() else: iprot.skip(ftype) @@ -16241,8 +16243,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 iter682 in self.success: - iter682.write(oprot) + for iter689 in self.success: + iter689.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16398,11 +16400,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype686, _size683) = iprot.readListBegin() - for _i687 in xrange(_size683): - _elem688 = PartitionSpec() - _elem688.read(iprot) - self.success.append(_elem688) + (_etype693, _size690) = iprot.readListBegin() + for _i694 in xrange(_size690): + _elem695 = PartitionSpec() + _elem695.read(iprot) + self.success.append(_elem695) iprot.readListEnd() else: iprot.skip(ftype) @@ -16431,8 +16433,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 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: @@ -16650,10 +16652,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype693, _size690) = iprot.readListBegin() - for _i694 in xrange(_size690): - _elem695 = iprot.readString(); - self.names.append(_elem695) + (_etype700, _size697) = iprot.readListBegin() + for _i701 in xrange(_size697): + _elem702 = iprot.readString(); + self.names.append(_elem702) iprot.readListEnd() else: iprot.skip(ftype) @@ -16678,8 +16680,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 iter696 in self.names: - oprot.writeString(iter696) + for iter703 in self.names: + oprot.writeString(iter703) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16731,11 +16733,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype700, _size697) = iprot.readListBegin() - for _i701 in xrange(_size697): - _elem702 = Partition() - _elem702.read(iprot) - self.success.append(_elem702) + (_etype707, _size704) = iprot.readListBegin() + for _i708 in xrange(_size704): + _elem709 = Partition() + _elem709.read(iprot) + self.success.append(_elem709) iprot.readListEnd() else: iprot.skip(ftype) @@ -16764,8 +16766,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 iter703 in self.success: - iter703.write(oprot) + for iter710 in self.success: + iter710.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -16995,11 +16997,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype707, _size704) = iprot.readListBegin() - for _i708 in xrange(_size704): - _elem709 = Partition() - _elem709.read(iprot) - self.new_parts.append(_elem709) + (_etype714, _size711) = iprot.readListBegin() + for _i715 in xrange(_size711): + _elem716 = Partition() + _elem716.read(iprot) + self.new_parts.append(_elem716) iprot.readListEnd() else: iprot.skip(ftype) @@ -17024,8 +17026,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 iter710 in self.new_parts: - iter710.write(oprot) + for iter717 in self.new_parts: + iter717.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17337,10 +17339,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype714, _size711) = iprot.readListBegin() - for _i715 in xrange(_size711): - _elem716 = iprot.readString(); - self.part_vals.append(_elem716) + (_etype721, _size718) = iprot.readListBegin() + for _i722 in xrange(_size718): + _elem723 = iprot.readString(); + self.part_vals.append(_elem723) iprot.readListEnd() else: iprot.skip(ftype) @@ -17371,8 +17373,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 iter717 in self.part_vals: - oprot.writeString(iter717) + for iter724 in self.part_vals: + oprot.writeString(iter724) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -17500,10 +17502,10 @@ class partition_name_has_valid_character if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype721, _size718) = iprot.readListBegin() - for _i722 in xrange(_size718): - _elem723 = iprot.readString(); - self.part_vals.append(_elem723) + (_etype728, _size725) = iprot.readListBegin() + for _i729 in xrange(_size725): + _elem730 = iprot.readString(); + self.part_vals.append(_elem730) iprot.readListEnd() else: iprot.skip(ftype) @@ -17525,8 +17527,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 iter724 in self.part_vals: - oprot.writeString(iter724) + for iter731 in self.part_vals: + oprot.writeString(iter731) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -17855,10 +17857,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype728, _size725) = iprot.readListBegin() - for _i729 in xrange(_size725): - _elem730 = iprot.readString(); - self.success.append(_elem730) + (_etype735, _size732) = iprot.readListBegin() + for _i736 in xrange(_size732): + _elem737 = iprot.readString(); + self.success.append(_elem737) iprot.readListEnd() else: iprot.skip(ftype) @@ -17881,8 +17883,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 iter731 in self.success: - oprot.writeString(iter731) + for iter738 in self.success: + oprot.writeString(iter738) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17995,11 +17997,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype733, _vtype734, _size732 ) = iprot.readMapBegin() - for _i736 in xrange(_size732): - _key737 = iprot.readString(); - _val738 = iprot.readString(); - self.success[_key737] = _val738 + (_ktype740, _vtype741, _size739 ) = iprot.readMapBegin() + for _i743 in xrange(_size739): + _key744 = iprot.readString(); + _val745 = iprot.readString(); + self.success[_key744] = _val745 iprot.readMapEnd() else: iprot.skip(ftype) @@ -18022,9 +18024,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 kiter739,viter740 in self.success.items(): - oprot.writeString(kiter739) - oprot.writeString(viter740) + for kiter746,viter747 in self.success.items(): + oprot.writeString(kiter746) + oprot.writeString(viter747) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18094,11 +18096,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype742, _vtype743, _size741 ) = iprot.readMapBegin() - for _i745 in xrange(_size741): - _key746 = iprot.readString(); - _val747 = iprot.readString(); - self.part_vals[_key746] = _val747 + (_ktype749, _vtype750, _size748 ) = iprot.readMapBegin() + for _i752 in xrange(_size748): + _key753 = iprot.readString(); + _val754 = iprot.readString(); + self.part_vals[_key753] = _val754 iprot.readMapEnd() else: iprot.skip(ftype) @@ -18128,9 +18130,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 kiter748,viter749 in self.part_vals.items(): - oprot.writeString(kiter748) - oprot.writeString(viter749) + for kiter755,viter756 in self.part_vals.items(): + oprot.writeString(kiter755) + oprot.writeString(viter756) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -18326,11 +18328,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype751, _vtype752, _size750 ) = iprot.readMapBegin() - for _i754 in xrange(_size750): - _key755 = iprot.readString(); - _val756 = iprot.readString(); - self.part_vals[_key755] = _val756 + (_ktype758, _vtype759, _size757 ) = iprot.readMapBegin() + for _i761 in xrange(_size757): + _key762 = iprot.readString(); + _val763 = iprot.readString(); + self.part_vals[_key762] = _val763 iprot.readMapEnd() else: iprot.skip(ftype) @@ -18360,9 +18362,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 kiter757,viter758 in self.part_vals.items(): - oprot.writeString(kiter757) - oprot.writeString(viter758) + for kiter764,viter765 in self.part_vals.items(): + oprot.writeString(kiter764) + oprot.writeString(viter765) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -19334,11 +19336,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype762, _size759) = iprot.readListBegin() - for _i763 in xrange(_size759): - _elem764 = Index() - _elem764.read(iprot) - self.success.append(_elem764) + (_etype769, _size766) = iprot.readListBegin() + for _i770 in xrange(_size766): + _elem771 = Index() + _elem771.read(iprot) + self.success.append(_elem771) iprot.readListEnd() else: iprot.skip(ftype) @@ -19367,8 +19369,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 iter765 in self.success: - iter765.write(oprot) + for iter772 in self.success: + iter772.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19509,10 +19511,10 @@ class get_index_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) @@ -19535,8 +19537,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 iter772 in self.success: - oprot.writeString(iter772) + for iter779 in self.success: + oprot.writeString(iter779) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -21890,10 +21892,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype776, _size773) = iprot.readListBegin() - for _i777 in xrange(_size773): - _elem778 = iprot.readString(); - self.success.append(_elem778) + (_etype783, _size780) = iprot.readListBegin() + for _i784 in xrange(_size780): + _elem785 = iprot.readString(); + self.success.append(_elem785) iprot.readListEnd() else: iprot.skip(ftype) @@ -21916,8 +21918,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 iter779 in self.success: - oprot.writeString(iter779) + for iter786 in self.success: + oprot.writeString(iter786) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22435,10 +22437,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype783, _size780) = iprot.readListBegin() - for _i784 in xrange(_size780): - _elem785 = iprot.readString(); - self.success.append(_elem785) + (_etype790, _size787) = iprot.readListBegin() + for _i791 in xrange(_size787): + _elem792 = iprot.readString(); + self.success.append(_elem792) iprot.readListEnd() else: iprot.skip(ftype) @@ -22461,8 +22463,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 iter786 in self.success: - oprot.writeString(iter786) + for iter793 in self.success: + oprot.writeString(iter793) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22935,11 +22937,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype790, _size787) = iprot.readListBegin() - for _i791 in xrange(_size787): - _elem792 = Role() - _elem792.read(iprot) - self.success.append(_elem792) + (_etype797, _size794) = iprot.readListBegin() + for _i798 in xrange(_size794): + _elem799 = Role() + _elem799.read(iprot) + self.success.append(_elem799) iprot.readListEnd() else: iprot.skip(ftype) @@ -22962,8 +22964,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 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: @@ -23433,10 +23435,10 @@ class get_privilege_set_args: elif fid == 3: 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) @@ -23461,8 +23463,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 iter800 in self.group_names: - oprot.writeString(iter800) + for iter807 in self.group_names: + oprot.writeString(iter807) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -23669,11 +23671,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype804, _size801) = iprot.readListBegin() - for _i805 in xrange(_size801): - _elem806 = HiveObjectPrivilege() - _elem806.read(iprot) - self.success.append(_elem806) + (_etype811, _size808) = iprot.readListBegin() + for _i812 in xrange(_size808): + _elem813 = HiveObjectPrivilege() + _elem813.read(iprot) + self.success.append(_elem813) iprot.readListEnd() else: iprot.skip(ftype) @@ -23696,8 +23698,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 iter807 in self.success: - iter807.write(oprot) + for iter814 in self.success: + iter814.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -24156,10 +24158,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype811, _size808) = iprot.readListBegin() - for _i812 in xrange(_size808): - _elem813 = iprot.readString(); - self.group_names.append(_elem813) + (_etype818, _size815) = iprot.readListBegin() + for _i819 in xrange(_size815): + _elem820 = iprot.readString(); + self.group_names.append(_elem820) iprot.readListEnd() else: iprot.skip(ftype) @@ -24180,8 +24182,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 iter814 in self.group_names: - oprot.writeString(iter814) + for iter821 in self.group_names: + oprot.writeString(iter821) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -24230,10 +24232,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype818, _size815) = iprot.readListBegin() - for _i819 in xrange(_size815): - _elem820 = iprot.readString(); - self.success.append(_elem820) + (_etype825, _size822) = iprot.readListBegin() + for _i826 in xrange(_size822): + _elem827 = iprot.readString(); + self.success.append(_elem827) iprot.readListEnd() else: iprot.skip(ftype) @@ -24256,8 +24258,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 iter821 in self.success: - oprot.writeString(iter821) + for iter828 in self.success: + oprot.writeString(iter828) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26540,7 +26542,7 @@ class get_current_notificationEventId_re def __ne__(self, other): return not (self == other) -class fire_notification_event_args: +class fire_listener_event_args: """ Attributes: - rqst @@ -26578,7 +26580,7 @@ class fire_notification_event_args: 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('fire_notification_event_args') + oprot.writeStructBegin('fire_listener_event_args') if self.rqst is not None: oprot.writeFieldBegin('rqst', TType.STRUCT, 1) self.rqst.write(oprot) @@ -26601,11 +26603,19 @@ class fire_notification_event_args: def __ne__(self, other): return not (self == other) -class fire_notification_event_result: +class fire_listener_event_result: + """ + Attributes: + - success + """ thrift_spec = ( + (0, TType.STRUCT, 'success', (FireEventResponse, FireEventResponse.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)) @@ -26615,6 +26625,12 @@ class fire_notification_event_result: (fname, ftype, fid) = iprot.readFieldBegin() if ftype == TType.STOP: break + if fid == 0: + if ftype == TType.STRUCT: + self.success = FireEventResponse() + self.success.read(iprot) + else: + iprot.skip(ftype) else: iprot.skip(ftype) iprot.readFieldEnd() @@ -26624,7 +26640,11 @@ class fire_notification_event_result: 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('fire_notification_event_result') + oprot.writeStructBegin('fire_listener_event_result') + if self.success is not None: + oprot.writeFieldBegin('success', TType.STRUCT, 0) + self.success.write(oprot) + oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py?rev=1657387&r1=1657386&r2=1657387&view=diff ============================================================================== --- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (original) +++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py Wed Feb 4 19:24:12 2015 @@ -8495,29 +8495,160 @@ class CurrentNotificationEventId: def __ne__(self, other): return not (self == other) +class InsertEventRequestData: + """ + Attributes: + - filesAdded + """ + + thrift_spec = ( + None, # 0 + (1, TType.LIST, 'filesAdded', (TType.STRING,None), None, ), # 1 + ) + + def __init__(self, filesAdded=None,): + self.filesAdded = filesAdded + + 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.LIST: + self.filesAdded = [] + (_etype444, _size441) = iprot.readListBegin() + for _i445 in xrange(_size441): + _elem446 = iprot.readString(); + self.filesAdded.append(_elem446) + iprot.readListEnd() + 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('InsertEventRequestData') + if self.filesAdded is not None: + oprot.writeFieldBegin('filesAdded', TType.LIST, 1) + oprot.writeListBegin(TType.STRING, len(self.filesAdded)) + for iter447 in self.filesAdded: + oprot.writeString(iter447) + oprot.writeListEnd() + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + if self.filesAdded is None: + raise TProtocol.TProtocolException(message='Required field filesAdded is unset!') + 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 FireEventRequestData: + """ + Attributes: + - insertData + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'insertData', (InsertEventRequestData, InsertEventRequestData.thrift_spec), None, ), # 1 + ) + + def __init__(self, insertData=None,): + self.insertData = insertData + + 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.insertData = InsertEventRequestData() + self.insertData.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('FireEventRequestData') + if self.insertData is not None: + oprot.writeFieldBegin('insertData', TType.STRUCT, 1) + self.insertData.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 FireEventRequest: """ Attributes: - - eventType - - dbName - successful + - data + - dbName - tableName - partitionVals """ thrift_spec = ( None, # 0 - (1, TType.I32, 'eventType', None, None, ), # 1 - (2, TType.STRING, 'dbName', None, None, ), # 2 - (3, TType.BOOL, 'successful', None, None, ), # 3 + (1, TType.BOOL, 'successful', None, None, ), # 1 + (2, TType.STRUCT, 'data', (FireEventRequestData, FireEventRequestData.thrift_spec), None, ), # 2 + (3, TType.STRING, 'dbName', None, None, ), # 3 (4, TType.STRING, 'tableName', None, None, ), # 4 (5, TType.LIST, 'partitionVals', (TType.STRING,None), None, ), # 5 ) - def __init__(self, eventType=None, dbName=None, successful=None, tableName=None, partitionVals=None,): - self.eventType = eventType - self.dbName = dbName + def __init__(self, successful=None, data=None, dbName=None, tableName=None, partitionVals=None,): self.successful = successful + self.data = data + self.dbName = dbName self.tableName = tableName self.partitionVals = partitionVals @@ -8531,18 +8662,19 @@ class FireEventRequest: if ftype == TType.STOP: break if fid == 1: - if ftype == TType.I32: - self.eventType = iprot.readI32(); + if ftype == TType.BOOL: + self.successful = iprot.readBool(); else: iprot.skip(ftype) elif fid == 2: - if ftype == TType.STRING: - self.dbName = iprot.readString(); + if ftype == TType.STRUCT: + self.data = FireEventRequestData() + self.data.read(iprot) else: iprot.skip(ftype) elif fid == 3: - if ftype == TType.BOOL: - self.successful = iprot.readBool(); + if ftype == TType.STRING: + self.dbName = iprot.readString(); else: iprot.skip(ftype) elif fid == 4: @@ -8553,10 +8685,10 @@ class FireEventRequest: elif fid == 5: if ftype == TType.LIST: self.partitionVals = [] - (_etype444, _size441) = iprot.readListBegin() - for _i445 in xrange(_size441): - _elem446 = iprot.readString(); - self.partitionVals.append(_elem446) + (_etype451, _size448) = iprot.readListBegin() + for _i452 in xrange(_size448): + _elem453 = iprot.readString(); + self.partitionVals.append(_elem453) iprot.readListEnd() else: iprot.skip(ftype) @@ -8570,18 +8702,18 @@ class FireEventRequest: oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec))) return oprot.writeStructBegin('FireEventRequest') - if self.eventType is not None: - oprot.writeFieldBegin('eventType', TType.I32, 1) - oprot.writeI32(self.eventType) + if self.successful is not None: + oprot.writeFieldBegin('successful', TType.BOOL, 1) + oprot.writeBool(self.successful) + oprot.writeFieldEnd() + if self.data is not None: + oprot.writeFieldBegin('data', TType.STRUCT, 2) + self.data.write(oprot) oprot.writeFieldEnd() if self.dbName is not None: - oprot.writeFieldBegin('dbName', TType.STRING, 2) + oprot.writeFieldBegin('dbName', TType.STRING, 3) oprot.writeString(self.dbName) oprot.writeFieldEnd() - if self.successful is not None: - oprot.writeFieldBegin('successful', TType.BOOL, 3) - oprot.writeBool(self.successful) - oprot.writeFieldEnd() if self.tableName is not None: oprot.writeFieldBegin('tableName', TType.STRING, 4) oprot.writeString(self.tableName) @@ -8589,20 +8721,60 @@ class FireEventRequest: if self.partitionVals is not None: oprot.writeFieldBegin('partitionVals', TType.LIST, 5) oprot.writeListBegin(TType.STRING, len(self.partitionVals)) - for iter447 in self.partitionVals: - oprot.writeString(iter447) + for iter454 in self.partitionVals: + oprot.writeString(iter454) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() oprot.writeStructEnd() def validate(self): - if self.eventType is None: - raise TProtocol.TProtocolException(message='Required field eventType is unset!') - if self.dbName is None: - raise TProtocol.TProtocolException(message='Required field dbName is unset!') if self.successful is None: raise TProtocol.TProtocolException(message='Required field successful is unset!') + if self.data is None: + raise TProtocol.TProtocolException(message='Required field data is unset!') + 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 FireEventResponse: + + 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('FireEventResponse') + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): return
