http://git-wip-us.apache.org/repos/asf/hive/blob/aecb0c02/metastore/src/gen/thrift/gen-php/metastore/Types.php ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-php/metastore/Types.php b/metastore/src/gen/thrift/gen-php/metastore/Types.php index 4fc2da6..fe25366 100644 --- a/metastore/src/gen/thrift/gen-php/metastore/Types.php +++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php @@ -10850,6 +10850,107 @@ class AbortTxnRequest { } +class AbortTxnsRequest { + static $_TSPEC; + + /** + * @var int[] + */ + public $txn_ids = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'txn_ids', + 'type' => TType::LST, + 'etype' => TType::I64, + 'elem' => array( + 'type' => TType::I64, + ), + ), + ); + } + if (is_array($vals)) { + if (isset($vals['txn_ids'])) { + $this->txn_ids = $vals['txn_ids']; + } + } + } + + public function getName() { + return 'AbortTxnsRequest'; + } + + 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->txn_ids = array(); + $_size400 = 0; + $_etype403 = 0; + $xfer += $input->readListBegin($_etype403, $_size400); + for ($_i404 = 0; $_i404 < $_size400; ++$_i404) + { + $elem405 = null; + $xfer += $input->readI64($elem405); + $this->txn_ids []= $elem405; + } + $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('AbortTxnsRequest'); + if ($this->txn_ids !== null) { + if (!is_array($this->txn_ids)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('txn_ids', TType::LST, 1); + { + $output->writeListBegin(TType::I64, count($this->txn_ids)); + { + foreach ($this->txn_ids as $iter406) + { + $xfer += $output->writeI64($iter406); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class CommitTxnRequest { static $_TSPEC; @@ -11187,15 +11288,15 @@ class LockRequest { case 1: if ($ftype == TType::LST) { $this->component = array(); - $_size400 = 0; - $_etype403 = 0; - $xfer += $input->readListBegin($_etype403, $_size400); - for ($_i404 = 0; $_i404 < $_size400; ++$_i404) + $_size407 = 0; + $_etype410 = 0; + $xfer += $input->readListBegin($_etype410, $_size407); + for ($_i411 = 0; $_i411 < $_size407; ++$_i411) { - $elem405 = null; - $elem405 = new \metastore\LockComponent(); - $xfer += $elem405->read($input); - $this->component []= $elem405; + $elem412 = null; + $elem412 = new \metastore\LockComponent(); + $xfer += $elem412->read($input); + $this->component []= $elem412; } $xfer += $input->readListEnd(); } else { @@ -11251,9 +11352,9 @@ class LockRequest { { $output->writeListBegin(TType::STRUCT, count($this->component)); { - foreach ($this->component as $iter406) + foreach ($this->component as $iter413) { - $xfer += $iter406->write($output); + $xfer += $iter413->write($output); } } $output->writeListEnd(); @@ -12196,15 +12297,15 @@ class ShowLocksResponse { case 1: if ($ftype == TType::LST) { $this->locks = array(); - $_size407 = 0; - $_etype410 = 0; - $xfer += $input->readListBegin($_etype410, $_size407); - for ($_i411 = 0; $_i411 < $_size407; ++$_i411) + $_size414 = 0; + $_etype417 = 0; + $xfer += $input->readListBegin($_etype417, $_size414); + for ($_i418 = 0; $_i418 < $_size414; ++$_i418) { - $elem412 = null; - $elem412 = new \metastore\ShowLocksResponseElement(); - $xfer += $elem412->read($input); - $this->locks []= $elem412; + $elem419 = null; + $elem419 = new \metastore\ShowLocksResponseElement(); + $xfer += $elem419->read($input); + $this->locks []= $elem419; } $xfer += $input->readListEnd(); } else { @@ -12232,9 +12333,9 @@ class ShowLocksResponse { { $output->writeListBegin(TType::STRUCT, count($this->locks)); { - foreach ($this->locks as $iter413) + foreach ($this->locks as $iter420) { - $xfer += $iter413->write($output); + $xfer += $iter420->write($output); } } $output->writeListEnd(); @@ -12509,17 +12610,17 @@ class HeartbeatTxnRangeResponse { case 1: if ($ftype == TType::SET) { $this->aborted = array(); - $_size414 = 0; - $_etype417 = 0; - $xfer += $input->readSetBegin($_etype417, $_size414); - for ($_i418 = 0; $_i418 < $_size414; ++$_i418) + $_size421 = 0; + $_etype424 = 0; + $xfer += $input->readSetBegin($_etype424, $_size421); + for ($_i425 = 0; $_i425 < $_size421; ++$_i425) { - $elem419 = null; - $xfer += $input->readI64($elem419); - if (is_scalar($elem419)) { - $this->aborted[$elem419] = true; + $elem426 = null; + $xfer += $input->readI64($elem426); + if (is_scalar($elem426)) { + $this->aborted[$elem426] = true; } else { - $this->aborted []= $elem419; + $this->aborted []= $elem426; } } $xfer += $input->readSetEnd(); @@ -12530,17 +12631,17 @@ class HeartbeatTxnRangeResponse { case 2: if ($ftype == TType::SET) { $this->nosuch = array(); - $_size420 = 0; - $_etype423 = 0; - $xfer += $input->readSetBegin($_etype423, $_size420); - for ($_i424 = 0; $_i424 < $_size420; ++$_i424) + $_size427 = 0; + $_etype430 = 0; + $xfer += $input->readSetBegin($_etype430, $_size427); + for ($_i431 = 0; $_i431 < $_size427; ++$_i431) { - $elem425 = null; - $xfer += $input->readI64($elem425); - if (is_scalar($elem425)) { - $this->nosuch[$elem425] = true; + $elem432 = null; + $xfer += $input->readI64($elem432); + if (is_scalar($elem432)) { + $this->nosuch[$elem432] = true; } else { - $this->nosuch []= $elem425; + $this->nosuch []= $elem432; } } $xfer += $input->readSetEnd(); @@ -12569,12 +12670,12 @@ class HeartbeatTxnRangeResponse { { $output->writeSetBegin(TType::I64, count($this->aborted)); { - foreach ($this->aborted as $iter426 => $iter427) + foreach ($this->aborted as $iter433 => $iter434) { - if (is_scalar($iter427)) { - $xfer += $output->writeI64($iter426); + if (is_scalar($iter434)) { + $xfer += $output->writeI64($iter433); } else { - $xfer += $output->writeI64($iter427); + $xfer += $output->writeI64($iter434); } } } @@ -12590,12 +12691,12 @@ class HeartbeatTxnRangeResponse { { $output->writeSetBegin(TType::I64, count($this->nosuch)); { - foreach ($this->nosuch as $iter428 => $iter429) + foreach ($this->nosuch as $iter435 => $iter436) { - if (is_scalar($iter429)) { - $xfer += $output->writeI64($iter428); + if (is_scalar($iter436)) { + $xfer += $output->writeI64($iter435); } else { - $xfer += $output->writeI64($iter429); + $xfer += $output->writeI64($iter436); } } } @@ -13206,15 +13307,15 @@ class ShowCompactResponse { case 1: if ($ftype == TType::LST) { $this->compacts = array(); - $_size430 = 0; - $_etype433 = 0; - $xfer += $input->readListBegin($_etype433, $_size430); - for ($_i434 = 0; $_i434 < $_size430; ++$_i434) + $_size437 = 0; + $_etype440 = 0; + $xfer += $input->readListBegin($_etype440, $_size437); + for ($_i441 = 0; $_i441 < $_size437; ++$_i441) { - $elem435 = null; - $elem435 = new \metastore\ShowCompactResponseElement(); - $xfer += $elem435->read($input); - $this->compacts []= $elem435; + $elem442 = null; + $elem442 = new \metastore\ShowCompactResponseElement(); + $xfer += $elem442->read($input); + $this->compacts []= $elem442; } $xfer += $input->readListEnd(); } else { @@ -13242,9 +13343,9 @@ class ShowCompactResponse { { $output->writeListBegin(TType::STRUCT, count($this->compacts)); { - foreach ($this->compacts as $iter436) + foreach ($this->compacts as $iter443) { - $xfer += $iter436->write($output); + $xfer += $iter443->write($output); } } $output->writeListEnd(); @@ -13362,14 +13463,14 @@ class AddDynamicPartitions { case 4: if ($ftype == TType::LST) { $this->partitionnames = array(); - $_size437 = 0; - $_etype440 = 0; - $xfer += $input->readListBegin($_etype440, $_size437); - for ($_i441 = 0; $_i441 < $_size437; ++$_i441) + $_size444 = 0; + $_etype447 = 0; + $xfer += $input->readListBegin($_etype447, $_size444); + for ($_i448 = 0; $_i448 < $_size444; ++$_i448) { - $elem442 = null; - $xfer += $input->readString($elem442); - $this->partitionnames []= $elem442; + $elem449 = null; + $xfer += $input->readString($elem449); + $this->partitionnames []= $elem449; } $xfer += $input->readListEnd(); } else { @@ -13412,9 +13513,9 @@ class AddDynamicPartitions { { $output->writeListBegin(TType::STRING, count($this->partitionnames)); { - foreach ($this->partitionnames as $iter443) + foreach ($this->partitionnames as $iter450) { - $xfer += $output->writeString($iter443); + $xfer += $output->writeString($iter450); } } $output->writeListEnd(); @@ -13767,15 +13868,15 @@ class NotificationEventResponse { case 1: if ($ftype == TType::LST) { $this->events = 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; - $elem449 = new \metastore\NotificationEvent(); - $xfer += $elem449->read($input); - $this->events []= $elem449; + $elem456 = null; + $elem456 = new \metastore\NotificationEvent(); + $xfer += $elem456->read($input); + $this->events []= $elem456; } $xfer += $input->readListEnd(); } else { @@ -13803,9 +13904,9 @@ class NotificationEventResponse { { $output->writeListBegin(TType::STRUCT, count($this->events)); { - foreach ($this->events as $iter450) + foreach ($this->events as $iter457) { - $xfer += $iter450->write($output); + $xfer += $iter457->write($output); } } $output->writeListEnd(); @@ -13944,14 +14045,14 @@ class InsertEventRequestData { case 1: if ($ftype == TType::LST) { $this->filesAdded = array(); - $_size451 = 0; - $_etype454 = 0; - $xfer += $input->readListBegin($_etype454, $_size451); - for ($_i455 = 0; $_i455 < $_size451; ++$_i455) + $_size458 = 0; + $_etype461 = 0; + $xfer += $input->readListBegin($_etype461, $_size458); + for ($_i462 = 0; $_i462 < $_size458; ++$_i462) { - $elem456 = null; - $xfer += $input->readString($elem456); - $this->filesAdded []= $elem456; + $elem463 = null; + $xfer += $input->readString($elem463); + $this->filesAdded []= $elem463; } $xfer += $input->readListEnd(); } else { @@ -13979,9 +14080,9 @@ class InsertEventRequestData { { $output->writeListBegin(TType::STRING, count($this->filesAdded)); { - foreach ($this->filesAdded as $iter457) + foreach ($this->filesAdded as $iter464) { - $xfer += $output->writeString($iter457); + $xfer += $output->writeString($iter464); } } $output->writeListEnd(); @@ -14199,14 +14300,14 @@ class FireEventRequest { case 5: if ($ftype == TType::LST) { $this->partitionVals = array(); - $_size458 = 0; - $_etype461 = 0; - $xfer += $input->readListBegin($_etype461, $_size458); - for ($_i462 = 0; $_i462 < $_size458; ++$_i462) + $_size465 = 0; + $_etype468 = 0; + $xfer += $input->readListBegin($_etype468, $_size465); + for ($_i469 = 0; $_i469 < $_size465; ++$_i469) { - $elem463 = null; - $xfer += $input->readString($elem463); - $this->partitionVals []= $elem463; + $elem470 = null; + $xfer += $input->readString($elem470); + $this->partitionVals []= $elem470; } $xfer += $input->readListEnd(); } else { @@ -14257,9 +14358,9 @@ class FireEventRequest { { $output->writeListBegin(TType::STRING, count($this->partitionVals)); { - foreach ($this->partitionVals as $iter464) + foreach ($this->partitionVals as $iter471) { - $xfer += $output->writeString($iter464); + $xfer += $output->writeString($iter471); } } $output->writeListEnd(); @@ -14374,15 +14475,15 @@ class GetAllFunctionsResponse { case 1: if ($ftype == TType::LST) { $this->functions = array(); - $_size465 = 0; - $_etype468 = 0; - $xfer += $input->readListBegin($_etype468, $_size465); - for ($_i469 = 0; $_i469 < $_size465; ++$_i469) + $_size472 = 0; + $_etype475 = 0; + $xfer += $input->readListBegin($_etype475, $_size472); + for ($_i476 = 0; $_i476 < $_size472; ++$_i476) { - $elem470 = null; - $elem470 = new \metastore\Function(); - $xfer += $elem470->read($input); - $this->functions []= $elem470; + $elem477 = null; + $elem477 = new \metastore\Function(); + $xfer += $elem477->read($input); + $this->functions []= $elem477; } $xfer += $input->readListEnd(); } else { @@ -14410,9 +14511,9 @@ class GetAllFunctionsResponse { { $output->writeListBegin(TType::STRUCT, count($this->functions)); { - foreach ($this->functions as $iter471) + foreach ($this->functions as $iter478) { - $xfer += $iter471->write($output); + $xfer += $iter478->write($output); } } $output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/aecb0c02/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote index b3182a8..36c4e3e 100755 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote @@ -136,6 +136,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help': print(' GetOpenTxnsInfoResponse get_open_txns_info()') print(' OpenTxnsResponse open_txns(OpenTxnRequest rqst)') print(' void abort_txn(AbortTxnRequest rqst)') + print(' void abort_txns(AbortTxnsRequest rqst)') print(' void commit_txn(CommitTxnRequest rqst)') print(' LockResponse lock(LockRequest rqst)') print(' LockResponse check_lock(CheckLockRequest rqst)') @@ -890,6 +891,12 @@ elif cmd == 'abort_txn': sys.exit(1) pp.pprint(client.abort_txn(eval(args[0]),)) +elif cmd == 'abort_txns': + if len(args) != 1: + print('abort_txns requires 1 args') + sys.exit(1) + pp.pprint(client.abort_txns(eval(args[0]),)) + elif cmd == 'commit_txn': if len(args) != 1: print('commit_txn requires 1 args') http://git-wip-us.apache.org/repos/asf/hive/blob/aecb0c02/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py index 1cc6acf..d739752 100644 --- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py +++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py @@ -946,6 +946,13 @@ class Iface(fb303.FacebookService.Iface): """ pass + def abort_txns(self, rqst): + """ + Parameters: + - rqst + """ + pass + def commit_txn(self, rqst): """ Parameters: @@ -5232,6 +5239,37 @@ class Client(fb303.FacebookService.Client, Iface): raise result.o1 return + def abort_txns(self, rqst): + """ + Parameters: + - rqst + """ + self.send_abort_txns(rqst) + self.recv_abort_txns() + + def send_abort_txns(self, rqst): + self._oprot.writeMessageBegin('abort_txns', TMessageType.CALL, self._seqid) + args = abort_txns_args() + args.rqst = rqst + args.write(self._oprot) + self._oprot.writeMessageEnd() + self._oprot.trans.flush() + + def recv_abort_txns(self): + iprot = self._iprot + (fname, mtype, rseqid) = iprot.readMessageBegin() + if mtype == TMessageType.EXCEPTION: + x = TApplicationException() + x.read(iprot) + iprot.readMessageEnd() + raise x + result = abort_txns_result() + result.read(iprot) + iprot.readMessageEnd() + if result.o1 is not None: + raise result.o1 + return + def commit_txn(self, rqst): """ Parameters: @@ -5764,6 +5802,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): self._processMap["get_open_txns_info"] = Processor.process_get_open_txns_info self._processMap["open_txns"] = Processor.process_open_txns self._processMap["abort_txn"] = Processor.process_abort_txn + self._processMap["abort_txns"] = Processor.process_abort_txns self._processMap["commit_txn"] = Processor.process_commit_txn self._processMap["lock"] = Processor.process_lock self._processMap["check_lock"] = Processor.process_check_lock @@ -8626,6 +8665,28 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor): oprot.writeMessageEnd() oprot.trans.flush() + def process_abort_txns(self, seqid, iprot, oprot): + args = abort_txns_args() + args.read(iprot) + iprot.readMessageEnd() + result = abort_txns_result() + try: + self._handler.abort_txns(args.rqst) + msg_type = TMessageType.REPLY + except (TTransport.TTransportException, KeyboardInterrupt, SystemExit): + raise + except NoSuchTxnException as o1: + msg_type = TMessageType.REPLY + result.o1 = o1 + except Exception as ex: + msg_type = TMessageType.EXCEPTION + logging.exception(ex) + result = TApplicationException(TApplicationException.INTERNAL_ERROR, 'Internal error') + oprot.writeMessageBegin("abort_txns", msg_type, seqid) + result.write(oprot) + oprot.writeMessageEnd() + oprot.trans.flush() + def process_commit_txn(self, seqid, iprot, oprot): args = commit_txn_args() args.read(iprot) @@ -9801,10 +9862,10 @@ class get_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype472, _size469) = iprot.readListBegin() - for _i473 in xrange(_size469): - _elem474 = iprot.readString() - self.success.append(_elem474) + (_etype479, _size476) = iprot.readListBegin() + for _i480 in xrange(_size476): + _elem481 = iprot.readString() + self.success.append(_elem481) iprot.readListEnd() else: iprot.skip(ftype) @@ -9827,8 +9888,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 iter475 in self.success: - oprot.writeString(iter475) + for iter482 in self.success: + oprot.writeString(iter482) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -9933,10 +9994,10 @@ class get_all_databases_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype479, _size476) = iprot.readListBegin() - for _i480 in xrange(_size476): - _elem481 = iprot.readString() - self.success.append(_elem481) + (_etype486, _size483) = iprot.readListBegin() + for _i487 in xrange(_size483): + _elem488 = iprot.readString() + self.success.append(_elem488) iprot.readListEnd() else: iprot.skip(ftype) @@ -9959,8 +10020,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 iter482 in self.success: - oprot.writeString(iter482) + for iter489 in self.success: + oprot.writeString(iter489) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -10730,12 +10791,12 @@ class get_type_all_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype484, _vtype485, _size483 ) = iprot.readMapBegin() - for _i487 in xrange(_size483): - _key488 = iprot.readString() - _val489 = Type() - _val489.read(iprot) - self.success[_key488] = _val489 + (_ktype491, _vtype492, _size490 ) = iprot.readMapBegin() + for _i494 in xrange(_size490): + _key495 = iprot.readString() + _val496 = Type() + _val496.read(iprot) + self.success[_key495] = _val496 iprot.readMapEnd() else: iprot.skip(ftype) @@ -10758,9 +10819,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 kiter490,viter491 in self.success.items(): - oprot.writeString(kiter490) - viter491.write(oprot) + for kiter497,viter498 in self.success.items(): + oprot.writeString(kiter497) + viter498.write(oprot) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -10903,11 +10964,11 @@ class get_fields_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype495, _size492) = iprot.readListBegin() - for _i496 in xrange(_size492): - _elem497 = FieldSchema() - _elem497.read(iprot) - self.success.append(_elem497) + (_etype502, _size499) = iprot.readListBegin() + for _i503 in xrange(_size499): + _elem504 = FieldSchema() + _elem504.read(iprot) + self.success.append(_elem504) iprot.readListEnd() else: iprot.skip(ftype) @@ -10942,8 +11003,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 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: @@ -11110,11 +11171,11 @@ class get_fields_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype502, _size499) = iprot.readListBegin() - for _i503 in xrange(_size499): - _elem504 = FieldSchema() - _elem504.read(iprot) - self.success.append(_elem504) + (_etype509, _size506) = iprot.readListBegin() + for _i510 in xrange(_size506): + _elem511 = FieldSchema() + _elem511.read(iprot) + self.success.append(_elem511) iprot.readListEnd() else: iprot.skip(ftype) @@ -11149,8 +11210,8 @@ class get_fields_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter505 in self.success: - iter505.write(oprot) + for iter512 in self.success: + iter512.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -11303,11 +11364,11 @@ class get_schema_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype509, _size506) = iprot.readListBegin() - for _i510 in xrange(_size506): - _elem511 = FieldSchema() - _elem511.read(iprot) - self.success.append(_elem511) + (_etype516, _size513) = iprot.readListBegin() + for _i517 in xrange(_size513): + _elem518 = FieldSchema() + _elem518.read(iprot) + self.success.append(_elem518) iprot.readListEnd() else: iprot.skip(ftype) @@ -11342,8 +11403,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 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: @@ -11510,11 +11571,11 @@ class get_schema_with_environment_context_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype516, _size513) = iprot.readListBegin() - for _i517 in xrange(_size513): - _elem518 = FieldSchema() - _elem518.read(iprot) - self.success.append(_elem518) + (_etype523, _size520) = iprot.readListBegin() + for _i524 in xrange(_size520): + _elem525 = FieldSchema() + _elem525.read(iprot) + self.success.append(_elem525) iprot.readListEnd() else: iprot.skip(ftype) @@ -11549,8 +11610,8 @@ class get_schema_with_environment_context_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter519 in self.success: - iter519.write(oprot) + for iter526 in self.success: + iter526.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -12415,10 +12476,10 @@ class get_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype523, _size520) = iprot.readListBegin() - for _i524 in xrange(_size520): - _elem525 = iprot.readString() - self.success.append(_elem525) + (_etype530, _size527) = iprot.readListBegin() + for _i531 in xrange(_size527): + _elem532 = iprot.readString() + self.success.append(_elem532) iprot.readListEnd() else: iprot.skip(ftype) @@ -12441,8 +12502,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 iter526 in self.success: - oprot.writeString(iter526) + for iter533 in self.success: + oprot.writeString(iter533) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -12566,10 +12627,10 @@ class get_all_tables_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype530, _size527) = iprot.readListBegin() - for _i531 in xrange(_size527): - _elem532 = iprot.readString() - self.success.append(_elem532) + (_etype537, _size534) = iprot.readListBegin() + for _i538 in xrange(_size534): + _elem539 = iprot.readString() + self.success.append(_elem539) iprot.readListEnd() else: iprot.skip(ftype) @@ -12592,8 +12653,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 iter533 in self.success: - oprot.writeString(iter533) + for iter540 in self.success: + oprot.writeString(iter540) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -12829,10 +12890,10 @@ class get_table_objects_by_name_args: elif fid == 2: if ftype == TType.LIST: self.tbl_names = [] - (_etype537, _size534) = iprot.readListBegin() - for _i538 in xrange(_size534): - _elem539 = iprot.readString() - self.tbl_names.append(_elem539) + (_etype544, _size541) = iprot.readListBegin() + for _i545 in xrange(_size541): + _elem546 = iprot.readString() + self.tbl_names.append(_elem546) iprot.readListEnd() else: iprot.skip(ftype) @@ -12853,8 +12914,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 iter540 in self.tbl_names: - oprot.writeString(iter540) + for iter547 in self.tbl_names: + oprot.writeString(iter547) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -12915,11 +12976,11 @@ class get_table_objects_by_name_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype544, _size541) = iprot.readListBegin() - for _i545 in xrange(_size541): - _elem546 = Table() - _elem546.read(iprot) - self.success.append(_elem546) + (_etype551, _size548) = iprot.readListBegin() + for _i552 in xrange(_size548): + _elem553 = Table() + _elem553.read(iprot) + self.success.append(_elem553) iprot.readListEnd() else: iprot.skip(ftype) @@ -12954,8 +13015,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 iter547 in self.success: - iter547.write(oprot) + for iter554 in self.success: + iter554.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -13121,10 +13182,10 @@ class get_table_names_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype551, _size548) = iprot.readListBegin() - for _i552 in xrange(_size548): - _elem553 = iprot.readString() - self.success.append(_elem553) + (_etype558, _size555) = iprot.readListBegin() + for _i559 in xrange(_size555): + _elem560 = iprot.readString() + self.success.append(_elem560) iprot.readListEnd() else: iprot.skip(ftype) @@ -13159,8 +13220,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 iter554 in self.success: - oprot.writeString(iter554) + for iter561 in self.success: + oprot.writeString(iter561) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -14130,11 +14191,11 @@ class add_partitions_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype558, _size555) = iprot.readListBegin() - for _i559 in xrange(_size555): - _elem560 = Partition() - _elem560.read(iprot) - self.new_parts.append(_elem560) + (_etype565, _size562) = iprot.readListBegin() + for _i566 in xrange(_size562): + _elem567 = Partition() + _elem567.read(iprot) + self.new_parts.append(_elem567) iprot.readListEnd() else: iprot.skip(ftype) @@ -14151,8 +14212,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 iter561 in self.new_parts: - iter561.write(oprot) + for iter568 in self.new_parts: + iter568.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14310,11 +14371,11 @@ class add_partitions_pspec_args: if fid == 1: if ftype == TType.LIST: self.new_parts = [] - (_etype565, _size562) = iprot.readListBegin() - for _i566 in xrange(_size562): - _elem567 = PartitionSpec() - _elem567.read(iprot) - self.new_parts.append(_elem567) + (_etype572, _size569) = iprot.readListBegin() + for _i573 in xrange(_size569): + _elem574 = PartitionSpec() + _elem574.read(iprot) + self.new_parts.append(_elem574) iprot.readListEnd() else: iprot.skip(ftype) @@ -14331,8 +14392,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 iter568 in self.new_parts: - iter568.write(oprot) + for iter575 in self.new_parts: + iter575.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14506,10 +14567,10 @@ class append_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype572, _size569) = iprot.readListBegin() - for _i573 in xrange(_size569): - _elem574 = iprot.readString() - self.part_vals.append(_elem574) + (_etype579, _size576) = iprot.readListBegin() + for _i580 in xrange(_size576): + _elem581 = iprot.readString() + self.part_vals.append(_elem581) iprot.readListEnd() else: iprot.skip(ftype) @@ -14534,8 +14595,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 iter575 in self.part_vals: - oprot.writeString(iter575) + for iter582 in self.part_vals: + oprot.writeString(iter582) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -14888,10 +14949,10 @@ class append_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype579, _size576) = iprot.readListBegin() - for _i580 in xrange(_size576): - _elem581 = iprot.readString() - self.part_vals.append(_elem581) + (_etype586, _size583) = iprot.readListBegin() + for _i587 in xrange(_size583): + _elem588 = iprot.readString() + self.part_vals.append(_elem588) iprot.readListEnd() else: iprot.skip(ftype) @@ -14922,8 +14983,8 @@ class append_partition_with_environment_context_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter582 in self.part_vals: - oprot.writeString(iter582) + for iter589 in self.part_vals: + oprot.writeString(iter589) oprot.writeListEnd() oprot.writeFieldEnd() if self.environment_context is not None: @@ -15518,10 +15579,10 @@ class drop_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype586, _size583) = iprot.readListBegin() - for _i587 in xrange(_size583): - _elem588 = iprot.readString() - self.part_vals.append(_elem588) + (_etype593, _size590) = iprot.readListBegin() + for _i594 in xrange(_size590): + _elem595 = iprot.readString() + self.part_vals.append(_elem595) iprot.readListEnd() else: iprot.skip(ftype) @@ -15551,8 +15612,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 iter589 in self.part_vals: - oprot.writeString(iter589) + for iter596 in self.part_vals: + oprot.writeString(iter596) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -15725,10 +15786,10 @@ class drop_partition_with_environment_context_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype593, _size590) = iprot.readListBegin() - for _i594 in xrange(_size590): - _elem595 = iprot.readString() - self.part_vals.append(_elem595) + (_etype600, _size597) = iprot.readListBegin() + for _i601 in xrange(_size597): + _elem602 = iprot.readString() + self.part_vals.append(_elem602) iprot.readListEnd() else: iprot.skip(ftype) @@ -15764,8 +15825,8 @@ class drop_partition_with_environment_context_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 3) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter596 in self.part_vals: - oprot.writeString(iter596) + for iter603 in self.part_vals: + oprot.writeString(iter603) oprot.writeListEnd() oprot.writeFieldEnd() if self.deleteData is not None: @@ -16502,10 +16563,10 @@ class get_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype600, _size597) = iprot.readListBegin() - for _i601 in xrange(_size597): - _elem602 = iprot.readString() - self.part_vals.append(_elem602) + (_etype607, _size604) = iprot.readListBegin() + for _i608 in xrange(_size604): + _elem609 = iprot.readString() + self.part_vals.append(_elem609) iprot.readListEnd() else: iprot.skip(ftype) @@ -16530,8 +16591,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 iter603 in self.part_vals: - oprot.writeString(iter603) + for iter610 in self.part_vals: + oprot.writeString(iter610) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -16690,11 +16751,11 @@ class exchange_partition_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype605, _vtype606, _size604 ) = iprot.readMapBegin() - for _i608 in xrange(_size604): - _key609 = iprot.readString() - _val610 = iprot.readString() - self.partitionSpecs[_key609] = _val610 + (_ktype612, _vtype613, _size611 ) = iprot.readMapBegin() + for _i615 in xrange(_size611): + _key616 = iprot.readString() + _val617 = iprot.readString() + self.partitionSpecs[_key616] = _val617 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16731,9 +16792,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 kiter611,viter612 in self.partitionSpecs.items(): - oprot.writeString(kiter611) - oprot.writeString(viter612) + for kiter618,viter619 in self.partitionSpecs.items(): + oprot.writeString(kiter618) + oprot.writeString(viter619) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -16938,11 +16999,11 @@ class exchange_partitions_args: if fid == 1: if ftype == TType.MAP: self.partitionSpecs = {} - (_ktype614, _vtype615, _size613 ) = iprot.readMapBegin() - for _i617 in xrange(_size613): - _key618 = iprot.readString() - _val619 = iprot.readString() - self.partitionSpecs[_key618] = _val619 + (_ktype621, _vtype622, _size620 ) = iprot.readMapBegin() + for _i624 in xrange(_size620): + _key625 = iprot.readString() + _val626 = iprot.readString() + self.partitionSpecs[_key625] = _val626 iprot.readMapEnd() else: iprot.skip(ftype) @@ -16979,9 +17040,9 @@ class exchange_partitions_args: if self.partitionSpecs is not None: oprot.writeFieldBegin('partitionSpecs', TType.MAP, 1) oprot.writeMapBegin(TType.STRING, TType.STRING, len(self.partitionSpecs)) - for kiter620,viter621 in self.partitionSpecs.items(): - oprot.writeString(kiter620) - oprot.writeString(viter621) + for kiter627,viter628 in self.partitionSpecs.items(): + oprot.writeString(kiter627) + oprot.writeString(viter628) oprot.writeMapEnd() oprot.writeFieldEnd() if self.source_db is not None: @@ -17064,11 +17125,11 @@ class exchange_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype625, _size622) = iprot.readListBegin() - for _i626 in xrange(_size622): - _elem627 = Partition() - _elem627.read(iprot) - self.success.append(_elem627) + (_etype632, _size629) = iprot.readListBegin() + for _i633 in xrange(_size629): + _elem634 = Partition() + _elem634.read(iprot) + self.success.append(_elem634) iprot.readListEnd() else: iprot.skip(ftype) @@ -17109,8 +17170,8 @@ class exchange_partitions_result: if self.success is not None: oprot.writeFieldBegin('success', TType.LIST, 0) oprot.writeListBegin(TType.STRUCT, len(self.success)) - for iter628 in self.success: - iter628.write(oprot) + for iter635 in self.success: + iter635.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17204,10 +17265,10 @@ class get_partition_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype632, _size629) = iprot.readListBegin() - for _i633 in xrange(_size629): - _elem634 = iprot.readString() - self.part_vals.append(_elem634) + (_etype639, _size636) = iprot.readListBegin() + for _i640 in xrange(_size636): + _elem641 = iprot.readString() + self.part_vals.append(_elem641) iprot.readListEnd() else: iprot.skip(ftype) @@ -17219,10 +17280,10 @@ class get_partition_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype638, _size635) = iprot.readListBegin() - for _i639 in xrange(_size635): - _elem640 = iprot.readString() - self.group_names.append(_elem640) + (_etype645, _size642) = iprot.readListBegin() + for _i646 in xrange(_size642): + _elem647 = iprot.readString() + self.group_names.append(_elem647) iprot.readListEnd() else: iprot.skip(ftype) @@ -17247,8 +17308,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 iter641 in self.part_vals: - oprot.writeString(iter641) + for iter648 in self.part_vals: + oprot.writeString(iter648) oprot.writeListEnd() oprot.writeFieldEnd() if self.user_name is not None: @@ -17258,8 +17319,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 iter642 in self.group_names: - oprot.writeString(iter642) + for iter649 in self.group_names: + oprot.writeString(iter649) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17688,11 +17749,11 @@ class get_partitions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype646, _size643) = iprot.readListBegin() - for _i647 in xrange(_size643): - _elem648 = Partition() - _elem648.read(iprot) - self.success.append(_elem648) + (_etype653, _size650) = iprot.readListBegin() + for _i654 in xrange(_size650): + _elem655 = Partition() + _elem655.read(iprot) + self.success.append(_elem655) iprot.readListEnd() else: iprot.skip(ftype) @@ -17721,8 +17782,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 iter649 in self.success: - iter649.write(oprot) + for iter656 in self.success: + iter656.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -17816,10 +17877,10 @@ class get_partitions_with_auth_args: elif fid == 5: if ftype == TType.LIST: self.group_names = [] - (_etype653, _size650) = iprot.readListBegin() - for _i654 in xrange(_size650): - _elem655 = iprot.readString() - self.group_names.append(_elem655) + (_etype660, _size657) = iprot.readListBegin() + for _i661 in xrange(_size657): + _elem662 = iprot.readString() + self.group_names.append(_elem662) iprot.readListEnd() else: iprot.skip(ftype) @@ -17852,8 +17913,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 iter656 in self.group_names: - oprot.writeString(iter656) + for iter663 in self.group_names: + oprot.writeString(iter663) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -17914,11 +17975,11 @@ class get_partitions_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype660, _size657) = iprot.readListBegin() - for _i661 in xrange(_size657): - _elem662 = Partition() - _elem662.read(iprot) - self.success.append(_elem662) + (_etype667, _size664) = iprot.readListBegin() + for _i668 in xrange(_size664): + _elem669 = Partition() + _elem669.read(iprot) + self.success.append(_elem669) iprot.readListEnd() else: iprot.skip(ftype) @@ -17947,8 +18008,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 iter663 in self.success: - iter663.write(oprot) + for iter670 in self.success: + iter670.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18106,11 +18167,11 @@ class get_partitions_pspec_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype667, _size664) = iprot.readListBegin() - for _i668 in xrange(_size664): - _elem669 = PartitionSpec() - _elem669.read(iprot) - self.success.append(_elem669) + (_etype674, _size671) = iprot.readListBegin() + for _i675 in xrange(_size671): + _elem676 = PartitionSpec() + _elem676.read(iprot) + self.success.append(_elem676) iprot.readListEnd() else: iprot.skip(ftype) @@ -18139,8 +18200,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 iter670 in self.success: - iter670.write(oprot) + for iter677 in self.success: + iter677.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18295,10 +18356,10 @@ class get_partition_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype674, _size671) = iprot.readListBegin() - for _i675 in xrange(_size671): - _elem676 = iprot.readString() - self.success.append(_elem676) + (_etype681, _size678) = iprot.readListBegin() + for _i682 in xrange(_size678): + _elem683 = iprot.readString() + self.success.append(_elem683) iprot.readListEnd() else: iprot.skip(ftype) @@ -18321,8 +18382,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 iter677 in self.success: - oprot.writeString(iter677) + for iter684 in self.success: + oprot.writeString(iter684) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -18398,10 +18459,10 @@ class get_partitions_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype681, _size678) = iprot.readListBegin() - for _i682 in xrange(_size678): - _elem683 = iprot.readString() - self.part_vals.append(_elem683) + (_etype688, _size685) = iprot.readListBegin() + for _i689 in xrange(_size685): + _elem690 = iprot.readString() + self.part_vals.append(_elem690) iprot.readListEnd() else: iprot.skip(ftype) @@ -18431,8 +18492,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 iter684 in self.part_vals: - oprot.writeString(iter684) + for iter691 in self.part_vals: + oprot.writeString(iter691) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -18496,11 +18557,11 @@ class get_partitions_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype688, _size685) = iprot.readListBegin() - for _i689 in xrange(_size685): - _elem690 = Partition() - _elem690.read(iprot) - self.success.append(_elem690) + (_etype695, _size692) = iprot.readListBegin() + for _i696 in xrange(_size692): + _elem697 = Partition() + _elem697.read(iprot) + self.success.append(_elem697) iprot.readListEnd() else: iprot.skip(ftype) @@ -18529,8 +18590,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 iter691 in self.success: - iter691.write(oprot) + for iter698 in self.success: + iter698.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18617,10 +18678,10 @@ class get_partitions_ps_with_auth_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype695, _size692) = iprot.readListBegin() - for _i696 in xrange(_size692): - _elem697 = iprot.readString() - self.part_vals.append(_elem697) + (_etype702, _size699) = iprot.readListBegin() + for _i703 in xrange(_size699): + _elem704 = iprot.readString() + self.part_vals.append(_elem704) iprot.readListEnd() else: iprot.skip(ftype) @@ -18637,10 +18698,10 @@ class get_partitions_ps_with_auth_args: elif fid == 6: if ftype == TType.LIST: self.group_names = [] - (_etype701, _size698) = iprot.readListBegin() - for _i702 in xrange(_size698): - _elem703 = iprot.readString() - self.group_names.append(_elem703) + (_etype708, _size705) = iprot.readListBegin() + for _i709 in xrange(_size705): + _elem710 = iprot.readString() + self.group_names.append(_elem710) iprot.readListEnd() else: iprot.skip(ftype) @@ -18665,8 +18726,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 iter704 in self.part_vals: - oprot.writeString(iter704) + for iter711 in self.part_vals: + oprot.writeString(iter711) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -18680,8 +18741,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 iter705 in self.group_names: - oprot.writeString(iter705) + for iter712 in self.group_names: + oprot.writeString(iter712) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -18743,11 +18804,11 @@ class get_partitions_ps_with_auth_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype709, _size706) = iprot.readListBegin() - for _i710 in xrange(_size706): - _elem711 = Partition() - _elem711.read(iprot) - self.success.append(_elem711) + (_etype716, _size713) = iprot.readListBegin() + for _i717 in xrange(_size713): + _elem718 = Partition() + _elem718.read(iprot) + self.success.append(_elem718) iprot.readListEnd() else: iprot.skip(ftype) @@ -18776,8 +18837,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 iter712 in self.success: - iter712.write(oprot) + for iter719 in self.success: + iter719.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -18858,10 +18919,10 @@ class get_partition_names_ps_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype716, _size713) = iprot.readListBegin() - for _i717 in xrange(_size713): - _elem718 = iprot.readString() - self.part_vals.append(_elem718) + (_etype723, _size720) = iprot.readListBegin() + for _i724 in xrange(_size720): + _elem725 = iprot.readString() + self.part_vals.append(_elem725) iprot.readListEnd() else: iprot.skip(ftype) @@ -18891,8 +18952,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 iter719 in self.part_vals: - oprot.writeString(iter719) + for iter726 in self.part_vals: + oprot.writeString(iter726) oprot.writeListEnd() oprot.writeFieldEnd() if self.max_parts is not None: @@ -18956,10 +19017,10 @@ class get_partition_names_ps_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype723, _size720) = iprot.readListBegin() - for _i724 in xrange(_size720): - _elem725 = iprot.readString() - self.success.append(_elem725) + (_etype730, _size727) = iprot.readListBegin() + for _i731 in xrange(_size727): + _elem732 = iprot.readString() + self.success.append(_elem732) iprot.readListEnd() else: iprot.skip(ftype) @@ -18988,8 +19049,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 iter726 in self.success: - oprot.writeString(iter726) + for iter733 in self.success: + oprot.writeString(iter733) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19160,11 +19221,11 @@ class get_partitions_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype730, _size727) = iprot.readListBegin() - for _i731 in xrange(_size727): - _elem732 = Partition() - _elem732.read(iprot) - self.success.append(_elem732) + (_etype737, _size734) = iprot.readListBegin() + for _i738 in xrange(_size734): + _elem739 = Partition() + _elem739.read(iprot) + self.success.append(_elem739) iprot.readListEnd() else: iprot.skip(ftype) @@ -19193,8 +19254,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 iter733 in self.success: - iter733.write(oprot) + for iter740 in self.success: + iter740.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19365,11 +19426,11 @@ class get_part_specs_by_filter_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype737, _size734) = iprot.readListBegin() - for _i738 in xrange(_size734): - _elem739 = PartitionSpec() - _elem739.read(iprot) - self.success.append(_elem739) + (_etype744, _size741) = iprot.readListBegin() + for _i745 in xrange(_size741): + _elem746 = PartitionSpec() + _elem746.read(iprot) + self.success.append(_elem746) iprot.readListEnd() else: iprot.skip(ftype) @@ -19398,8 +19459,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 iter740 in self.success: - iter740.write(oprot) + for iter747 in self.success: + iter747.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -19636,10 +19697,10 @@ class get_partitions_by_names_args: elif fid == 3: if ftype == TType.LIST: self.names = [] - (_etype744, _size741) = iprot.readListBegin() - for _i745 in xrange(_size741): - _elem746 = iprot.readString() - self.names.append(_elem746) + (_etype751, _size748) = iprot.readListBegin() + for _i752 in xrange(_size748): + _elem753 = iprot.readString() + self.names.append(_elem753) iprot.readListEnd() else: iprot.skip(ftype) @@ -19664,8 +19725,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 iter747 in self.names: - oprot.writeString(iter747) + for iter754 in self.names: + oprot.writeString(iter754) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -19724,11 +19785,11 @@ class get_partitions_by_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype751, _size748) = iprot.readListBegin() - for _i752 in xrange(_size748): - _elem753 = Partition() - _elem753.read(iprot) - self.success.append(_elem753) + (_etype758, _size755) = iprot.readListBegin() + for _i759 in xrange(_size755): + _elem760 = Partition() + _elem760.read(iprot) + self.success.append(_elem760) iprot.readListEnd() else: iprot.skip(ftype) @@ -19757,8 +19818,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 iter754 in self.success: - iter754.write(oprot) + for iter761 in self.success: + iter761.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -20008,11 +20069,11 @@ class alter_partitions_args: elif fid == 3: if ftype == TType.LIST: self.new_parts = [] - (_etype758, _size755) = iprot.readListBegin() - for _i759 in xrange(_size755): - _elem760 = Partition() - _elem760.read(iprot) - self.new_parts.append(_elem760) + (_etype765, _size762) = iprot.readListBegin() + for _i766 in xrange(_size762): + _elem767 = Partition() + _elem767.read(iprot) + self.new_parts.append(_elem767) iprot.readListEnd() else: iprot.skip(ftype) @@ -20037,8 +20098,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 iter761 in self.new_parts: - iter761.write(oprot) + for iter768 in self.new_parts: + iter768.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -20377,10 +20438,10 @@ class rename_partition_args: elif fid == 3: if ftype == TType.LIST: self.part_vals = [] - (_etype765, _size762) = iprot.readListBegin() - for _i766 in xrange(_size762): - _elem767 = iprot.readString() - self.part_vals.append(_elem767) + (_etype772, _size769) = iprot.readListBegin() + for _i773 in xrange(_size769): + _elem774 = iprot.readString() + self.part_vals.append(_elem774) iprot.readListEnd() else: iprot.skip(ftype) @@ -20411,8 +20472,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 iter768 in self.part_vals: - oprot.writeString(iter768) + for iter775 in self.part_vals: + oprot.writeString(iter775) oprot.writeListEnd() oprot.writeFieldEnd() if self.new_part is not None: @@ -20554,10 +20615,10 @@ class partition_name_has_valid_characters_args: if fid == 1: if ftype == TType.LIST: self.part_vals = [] - (_etype772, _size769) = iprot.readListBegin() - for _i773 in xrange(_size769): - _elem774 = iprot.readString() - self.part_vals.append(_elem774) + (_etype779, _size776) = iprot.readListBegin() + for _i780 in xrange(_size776): + _elem781 = iprot.readString() + self.part_vals.append(_elem781) iprot.readListEnd() else: iprot.skip(ftype) @@ -20579,8 +20640,8 @@ class partition_name_has_valid_characters_args: if self.part_vals is not None: oprot.writeFieldBegin('part_vals', TType.LIST, 1) oprot.writeListBegin(TType.STRING, len(self.part_vals)) - for iter775 in self.part_vals: - oprot.writeString(iter775) + for iter782 in self.part_vals: + oprot.writeString(iter782) oprot.writeListEnd() oprot.writeFieldEnd() if self.throw_exception is not None: @@ -20938,10 +20999,10 @@ class partition_name_to_vals_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype779, _size776) = iprot.readListBegin() - for _i780 in xrange(_size776): - _elem781 = iprot.readString() - self.success.append(_elem781) + (_etype786, _size783) = iprot.readListBegin() + for _i787 in xrange(_size783): + _elem788 = iprot.readString() + self.success.append(_elem788) iprot.readListEnd() else: iprot.skip(ftype) @@ -20964,8 +21025,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 iter782 in self.success: - oprot.writeString(iter782) + for iter789 in self.success: + oprot.writeString(iter789) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21089,11 +21150,11 @@ class partition_name_to_spec_result: if fid == 0: if ftype == TType.MAP: self.success = {} - (_ktype784, _vtype785, _size783 ) = iprot.readMapBegin() - for _i787 in xrange(_size783): - _key788 = iprot.readString() - _val789 = iprot.readString() - self.success[_key788] = _val789 + (_ktype791, _vtype792, _size790 ) = iprot.readMapBegin() + for _i794 in xrange(_size790): + _key795 = iprot.readString() + _val796 = iprot.readString() + self.success[_key795] = _val796 iprot.readMapEnd() else: iprot.skip(ftype) @@ -21116,9 +21177,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 kiter790,viter791 in self.success.items(): - oprot.writeString(kiter790) - oprot.writeString(viter791) + for kiter797,viter798 in self.success.items(): + oprot.writeString(kiter797) + oprot.writeString(viter798) oprot.writeMapEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -21194,11 +21255,11 @@ class markPartitionForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype793, _vtype794, _size792 ) = iprot.readMapBegin() - for _i796 in xrange(_size792): - _key797 = iprot.readString() - _val798 = iprot.readString() - self.part_vals[_key797] = _val798 + (_ktype800, _vtype801, _size799 ) = iprot.readMapBegin() + for _i803 in xrange(_size799): + _key804 = iprot.readString() + _val805 = iprot.readString() + self.part_vals[_key804] = _val805 iprot.readMapEnd() else: iprot.skip(ftype) @@ -21228,9 +21289,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 kiter799,viter800 in self.part_vals.items(): - oprot.writeString(kiter799) - oprot.writeString(viter800) + for kiter806,viter807 in self.part_vals.items(): + oprot.writeString(kiter806) + oprot.writeString(viter807) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -21444,11 +21505,11 @@ class isPartitionMarkedForEvent_args: elif fid == 3: if ftype == TType.MAP: self.part_vals = {} - (_ktype802, _vtype803, _size801 ) = iprot.readMapBegin() - for _i805 in xrange(_size801): - _key806 = iprot.readString() - _val807 = iprot.readString() - self.part_vals[_key806] = _val807 + (_ktype809, _vtype810, _size808 ) = iprot.readMapBegin() + for _i812 in xrange(_size808): + _key813 = iprot.readString() + _val814 = iprot.readString() + self.part_vals[_key813] = _val814 iprot.readMapEnd() else: iprot.skip(ftype) @@ -21478,9 +21539,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 kiter808,viter809 in self.part_vals.items(): - oprot.writeString(kiter808) - oprot.writeString(viter809) + for kiter815,viter816 in self.part_vals.items(): + oprot.writeString(kiter815) + oprot.writeString(viter816) oprot.writeMapEnd() oprot.writeFieldEnd() if self.eventType is not None: @@ -22535,11 +22596,11 @@ class get_indexes_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype813, _size810) = iprot.readListBegin() - for _i814 in xrange(_size810): - _elem815 = Index() - _elem815.read(iprot) - self.success.append(_elem815) + (_etype820, _size817) = iprot.readListBegin() + for _i821 in xrange(_size817): + _elem822 = Index() + _elem822.read(iprot) + self.success.append(_elem822) iprot.readListEnd() else: iprot.skip(ftype) @@ -22568,8 +22629,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 iter816 in self.success: - iter816.write(oprot) + for iter823 in self.success: + iter823.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -22724,10 +22785,10 @@ class get_index_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype820, _size817) = iprot.readListBegin() - for _i821 in xrange(_size817): - _elem822 = iprot.readString() - self.success.append(_elem822) + (_etype827, _size824) = iprot.readListBegin() + for _i828 in xrange(_size824): + _elem829 = iprot.readString() + self.success.append(_elem829) iprot.readListEnd() else: iprot.skip(ftype) @@ -22750,8 +22811,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 iter823 in self.success: - oprot.writeString(iter823) + for iter830 in self.success: + oprot.writeString(iter830) oprot.writeListEnd() oprot.writeFieldEnd() if self.o2 is not None: @@ -25299,10 +25360,10 @@ class get_functions_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype827, _size824) = iprot.readListBegin() - for _i828 in xrange(_size824): - _elem829 = iprot.readString() - self.success.append(_elem829) + (_etype834, _size831) = iprot.readListBegin() + for _i835 in xrange(_size831): + _elem836 = iprot.readString() + self.success.append(_elem836) iprot.readListEnd() else: iprot.skip(ftype) @@ -25325,8 +25386,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 iter830 in self.success: - oprot.writeString(iter830) + for iter837 in self.success: + oprot.writeString(iter837) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26014,10 +26075,10 @@ class get_role_names_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype834, _size831) = iprot.readListBegin() - for _i835 in xrange(_size831): - _elem836 = iprot.readString() - self.success.append(_elem836) + (_etype841, _size838) = iprot.readListBegin() + for _i842 in xrange(_size838): + _elem843 = iprot.readString() + self.success.append(_elem843) iprot.readListEnd() else: iprot.skip(ftype) @@ -26040,8 +26101,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 iter837 in self.success: - oprot.writeString(iter837) + for iter844 in self.success: + oprot.writeString(iter844) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -26555,11 +26616,11 @@ class list_roles_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype841, _size838) = iprot.readListBegin() - for _i842 in xrange(_size838): - _elem843 = Role() - _elem843.read(iprot) - self.success.append(_elem843) + (_etype848, _size845) = iprot.readListBegin() + for _i849 in xrange(_size845): + _elem850 = Role() + _elem850.read(iprot) + self.success.append(_elem850) iprot.readListEnd() else: iprot.skip(ftype) @@ -26582,8 +26643,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 iter844 in self.success: - iter844.write(oprot) + for iter851 in self.success: + iter851.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27092,10 +27153,10 @@ class get_privilege_set_args: elif fid == 3: if ftype == TType.LIST: self.group_names = [] - (_etype848, _size845) = iprot.readListBegin() - for _i849 in xrange(_size845): - _elem850 = iprot.readString() - self.group_names.append(_elem850) + (_etype855, _size852) = iprot.readListBegin() + for _i856 in xrange(_size852): + _elem857 = iprot.readString() + self.group_names.append(_elem857) iprot.readListEnd() else: iprot.skip(ftype) @@ -27120,8 +27181,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 iter851 in self.group_names: - oprot.writeString(iter851) + for iter858 in self.group_names: + oprot.writeString(iter858) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -27348,11 +27409,11 @@ class list_privileges_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype855, _size852) = iprot.readListBegin() - for _i856 in xrange(_size852): - _elem857 = HiveObjectPrivilege() - _elem857.read(iprot) - self.success.append(_elem857) + (_etype862, _size859) = iprot.readListBegin() + for _i863 in xrange(_size859): + _elem864 = HiveObjectPrivilege() + _elem864.read(iprot) + self.success.append(_elem864) iprot.readListEnd() else: iprot.skip(ftype) @@ -27375,8 +27436,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 iter858 in self.success: - iter858.write(oprot) + for iter865 in self.success: + iter865.write(oprot) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -27874,10 +27935,10 @@ class set_ugi_args: elif fid == 2: if ftype == TType.LIST: self.group_names = [] - (_etype862, _size859) = iprot.readListBegin() - for _i863 in xrange(_size859): - _elem864 = iprot.readString() - self.group_names.append(_elem864) + (_etype869, _size866) = iprot.readListBegin() + for _i870 in xrange(_size866): + _elem871 = iprot.readString() + self.group_names.append(_elem871) iprot.readListEnd() else: iprot.skip(ftype) @@ -27898,8 +27959,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 iter865 in self.group_names: - oprot.writeString(iter865) + for iter872 in self.group_names: + oprot.writeString(iter872) oprot.writeListEnd() oprot.writeFieldEnd() oprot.writeFieldStop() @@ -27954,10 +28015,10 @@ class set_ugi_result: if fid == 0: if ftype == TType.LIST: self.success = [] - (_etype869, _size866) = iprot.readListBegin() - for _i870 in xrange(_size866): - _elem871 = iprot.readString() - self.success.append(_elem871) + (_etype876, _size873) = iprot.readListBegin() + for _i877 in xrange(_size873): + _elem878 = iprot.readString() + self.success.append(_elem878) iprot.readListEnd() else: iprot.skip(ftype) @@ -27980,8 +28041,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 iter872 in self.success: - oprot.writeString(iter872) + for iter879 in self.success: + oprot.writeString(iter879) oprot.writeListEnd() oprot.writeFieldEnd() if self.o1 is not None: @@ -28927,6 +28988,138 @@ class abort_txn_result: def __ne__(self, other): return not (self == other) +class abort_txns_args: + """ + Attributes: + - rqst + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'rqst', (AbortTxnsRequest, AbortTxnsRequest.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 = AbortTxnsRequest() + 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('abort_txns_args') + if self.rqst is not None: + oprot.writeFieldBegin('rqst', TType.STRUCT, 1) + self.rqst.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.rqst) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + +class abort_txns_result: + """ + Attributes: + - o1 + """ + + thrift_spec = ( + None, # 0 + (1, TType.STRUCT, 'o1', (NoSuchTxnException, NoSuchTxnException.thrift_spec), None, ), # 1 + ) + + def __init__(self, o1=None,): + self.o1 = o1 + + 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.o1 = NoSuchTxnException() + self.o1.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('abort_txns_result') + if self.o1 is not None: + oprot.writeFieldBegin('o1', TType.STRUCT, 1) + self.o1.write(oprot) + oprot.writeFieldEnd() + oprot.writeFieldStop() + oprot.writeStructEnd() + + def validate(self): + return + + + def __hash__(self): + value = 17 + value = (value * 31) ^ hash(self.o1) + return value + + def __repr__(self): + L = ['%s=%r' % (key, value) + for key, value in self.__dict__.iteritems()] + return '%s(%s)' % (self.__class__.__name__, ', '.join(L)) + + def __eq__(self, other): + return isinstance(other, self.__class__) and self.__dict__ == other.__dict__ + + def __ne__(self, other): + return not (self == other) + class commit_txn_args: """ Attributes:
