You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by we...@apache.org on 2016/05/10 18:05:55 UTC
[2/8] hive git commit: HIVE-12634 : Add command to kill an ACID
transacton (Wei Zheng, reviewed by Eugene Koifman)
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: