You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2014/02/12 22:32:35 UTC
svn commit: r1567761 [7/8] - in /hive/trunk: metastore/if/
metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen/thrift/gen-php/metastore/
metastore/src/gen/thrift/gen-py/hive_me...
Modified: hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1567761&r1=1567760&r2=1567761&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php Wed Feb 12 21:32:34 2014
@@ -6090,6 +6090,566 @@ class AddPartitionsRequest {
}
+class DropPartitionsResult {
+ static $_TSPEC;
+
+ public $partitions = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'partitions',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Partition',
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['partitions'])) {
+ $this->partitions = $vals['partitions'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'DropPartitionsResult';
+ }
+
+ 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->partitions = array();
+ $_size292 = 0;
+ $_etype295 = 0;
+ $xfer += $input->readListBegin($_etype295, $_size292);
+ for ($_i296 = 0; $_i296 < $_size292; ++$_i296)
+ {
+ $elem297 = null;
+ $elem297 = new \metastore\Partition();
+ $xfer += $elem297->read($input);
+ $this->partitions []= $elem297;
+ }
+ $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('DropPartitionsResult');
+ if ($this->partitions !== null) {
+ if (!is_array($this->partitions)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('partitions', TType::LST, 1);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->partitions));
+ {
+ foreach ($this->partitions as $iter298)
+ {
+ $xfer += $iter298->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class DropPartitionsExpr {
+ static $_TSPEC;
+
+ public $expr = null;
+ public $partArchiveLevel = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'expr',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'partArchiveLevel',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['expr'])) {
+ $this->expr = $vals['expr'];
+ }
+ if (isset($vals['partArchiveLevel'])) {
+ $this->partArchiveLevel = $vals['partArchiveLevel'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'DropPartitionsExpr';
+ }
+
+ 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::STRING) {
+ $xfer += $input->readString($this->expr);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->partArchiveLevel);
+ } 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('DropPartitionsExpr');
+ if ($this->expr !== null) {
+ $xfer += $output->writeFieldBegin('expr', TType::STRING, 1);
+ $xfer += $output->writeString($this->expr);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->partArchiveLevel !== null) {
+ $xfer += $output->writeFieldBegin('partArchiveLevel', TType::I32, 2);
+ $xfer += $output->writeI32($this->partArchiveLevel);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class RequestPartsSpec {
+ static $_TSPEC;
+
+ public $names = null;
+ public $exprs = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'names',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 2 => array(
+ 'var' => 'exprs',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\DropPartitionsExpr',
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['names'])) {
+ $this->names = $vals['names'];
+ }
+ if (isset($vals['exprs'])) {
+ $this->exprs = $vals['exprs'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'RequestPartsSpec';
+ }
+
+ 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->names = array();
+ $_size299 = 0;
+ $_etype302 = 0;
+ $xfer += $input->readListBegin($_etype302, $_size299);
+ for ($_i303 = 0; $_i303 < $_size299; ++$_i303)
+ {
+ $elem304 = null;
+ $xfer += $input->readString($elem304);
+ $this->names []= $elem304;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::LST) {
+ $this->exprs = array();
+ $_size305 = 0;
+ $_etype308 = 0;
+ $xfer += $input->readListBegin($_etype308, $_size305);
+ for ($_i309 = 0; $_i309 < $_size305; ++$_i309)
+ {
+ $elem310 = null;
+ $elem310 = new \metastore\DropPartitionsExpr();
+ $xfer += $elem310->read($input);
+ $this->exprs []= $elem310;
+ }
+ $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('RequestPartsSpec');
+ if ($this->names !== null) {
+ if (!is_array($this->names)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('names', TType::LST, 1);
+ {
+ $output->writeListBegin(TType::STRING, count($this->names));
+ {
+ foreach ($this->names as $iter311)
+ {
+ $xfer += $output->writeString($iter311);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->exprs !== null) {
+ if (!is_array($this->exprs)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('exprs', TType::LST, 2);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->exprs));
+ {
+ foreach ($this->exprs as $iter312)
+ {
+ $xfer += $iter312->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class DropPartitionsRequest {
+ static $_TSPEC;
+
+ public $dbName = null;
+ public $tblName = null;
+ public $parts = null;
+ public $deleteData = null;
+ public $ifExists = true;
+ public $ignoreProtection = null;
+ public $environmentContext = null;
+ public $needResult = true;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'tblName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'parts',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\RequestPartsSpec',
+ ),
+ 4 => array(
+ 'var' => 'deleteData',
+ 'type' => TType::BOOL,
+ ),
+ 5 => array(
+ 'var' => 'ifExists',
+ 'type' => TType::BOOL,
+ ),
+ 6 => array(
+ 'var' => 'ignoreProtection',
+ 'type' => TType::BOOL,
+ ),
+ 7 => array(
+ 'var' => 'environmentContext',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\EnvironmentContext',
+ ),
+ 8 => array(
+ 'var' => 'needResult',
+ 'type' => TType::BOOL,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['tblName'])) {
+ $this->tblName = $vals['tblName'];
+ }
+ if (isset($vals['parts'])) {
+ $this->parts = $vals['parts'];
+ }
+ if (isset($vals['deleteData'])) {
+ $this->deleteData = $vals['deleteData'];
+ }
+ if (isset($vals['ifExists'])) {
+ $this->ifExists = $vals['ifExists'];
+ }
+ if (isset($vals['ignoreProtection'])) {
+ $this->ignoreProtection = $vals['ignoreProtection'];
+ }
+ if (isset($vals['environmentContext'])) {
+ $this->environmentContext = $vals['environmentContext'];
+ }
+ if (isset($vals['needResult'])) {
+ $this->needResult = $vals['needResult'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'DropPartitionsRequest';
+ }
+
+ 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::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->tblName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->parts = new \metastore\RequestPartsSpec();
+ $xfer += $this->parts->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->deleteData);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->ifExists);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->ignoreProtection);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::STRUCT) {
+ $this->environmentContext = new \metastore\EnvironmentContext();
+ $xfer += $this->environmentContext->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->needResult);
+ } 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('DropPartitionsRequest');
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 1);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->tblName !== null) {
+ $xfer += $output->writeFieldBegin('tblName', TType::STRING, 2);
+ $xfer += $output->writeString($this->tblName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->parts !== null) {
+ if (!is_object($this->parts)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('parts', TType::STRUCT, 3);
+ $xfer += $this->parts->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->deleteData !== null) {
+ $xfer += $output->writeFieldBegin('deleteData', TType::BOOL, 4);
+ $xfer += $output->writeBool($this->deleteData);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ifExists !== null) {
+ $xfer += $output->writeFieldBegin('ifExists', TType::BOOL, 5);
+ $xfer += $output->writeBool($this->ifExists);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ignoreProtection !== null) {
+ $xfer += $output->writeFieldBegin('ignoreProtection', TType::BOOL, 6);
+ $xfer += $output->writeBool($this->ignoreProtection);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->environmentContext !== null) {
+ if (!is_object($this->environmentContext)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('environmentContext', TType::STRUCT, 7);
+ $xfer += $this->environmentContext->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->needResult !== null) {
+ $xfer += $output->writeFieldBegin('needResult', TType::BOOL, 8);
+ $xfer += $output->writeBool($this->needResult);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class MetaException extends TException {
static $_TSPEC;
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1567761&r1=1567760&r2=1567761&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Wed Feb 12 21:32:34 2014
@@ -58,6 +58,7 @@ if len(sys.argv) <= 1 or sys.argv[1] ==
print ' bool drop_partition_with_environment_context(string db_name, string tbl_name, part_vals, bool deleteData, EnvironmentContext environment_context)'
print ' bool drop_partition_by_name(string db_name, string tbl_name, string part_name, bool deleteData)'
print ' bool drop_partition_by_name_with_environment_context(string db_name, string tbl_name, string part_name, bool deleteData, EnvironmentContext environment_context)'
+ print ' DropPartitionsResult drop_partitions_req(DropPartitionsRequest req)'
print ' Partition get_partition(string db_name, string tbl_name, part_vals)'
print ' Partition exchange_partition( partitionSpecs, string source_db, string source_table_name, string dest_db, string dest_table_name)'
print ' Partition get_partition_with_auth(string db_name, string tbl_name, part_vals, string user_name, group_names)'
@@ -370,6 +371,12 @@ elif cmd == 'drop_partition_by_name_with
sys.exit(1)
pp.pprint(client.drop_partition_by_name_with_environment_context(args[0],args[1],args[2],eval(args[3]),eval(args[4]),))
+elif cmd == 'drop_partitions_req':
+ if len(args) != 1:
+ print 'drop_partitions_req requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.drop_partitions_req(eval(args[0]),))
+
elif cmd == 'get_partition':
if len(args) != 3:
print 'get_partition requires 3 args'
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1567761&r1=1567760&r2=1567761&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Wed Feb 12 21:32:34 2014
@@ -309,6 +309,13 @@ class Iface(fb303.FacebookService.Iface)
"""
pass
+ def drop_partitions_req(self, req):
+ """
+ Parameters:
+ - req
+ """
+ pass
+
def get_partition(self, db_name, tbl_name, part_vals):
"""
Parameters:
@@ -2048,6 +2055,40 @@ class Client(fb303.FacebookService.Clien
raise result.o2
raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partition_by_name_with_environment_context failed: unknown result");
+ def drop_partitions_req(self, req):
+ """
+ Parameters:
+ - req
+ """
+ self.send_drop_partitions_req(req)
+ return self.recv_drop_partitions_req()
+
+ def send_drop_partitions_req(self, req):
+ self._oprot.writeMessageBegin('drop_partitions_req', TMessageType.CALL, self._seqid)
+ args = drop_partitions_req_args()
+ args.req = req
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_drop_partitions_req(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = drop_partitions_req_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.success is not None:
+ return result.success
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ raise TApplicationException(TApplicationException.MISSING_RESULT, "drop_partitions_req failed: unknown result");
+
def get_partition(self, db_name, tbl_name, part_vals):
"""
Parameters:
@@ -3990,6 +4031,7 @@ class Processor(fb303.FacebookService.Pr
self._processMap["drop_partition_with_environment_context"] = Processor.process_drop_partition_with_environment_context
self._processMap["drop_partition_by_name"] = Processor.process_drop_partition_by_name
self._processMap["drop_partition_by_name_with_environment_context"] = Processor.process_drop_partition_by_name_with_environment_context
+ self._processMap["drop_partitions_req"] = Processor.process_drop_partitions_req
self._processMap["get_partition"] = Processor.process_get_partition
self._processMap["exchange_partition"] = Processor.process_exchange_partition
self._processMap["get_partition_with_auth"] = Processor.process_get_partition_with_auth
@@ -4645,6 +4687,22 @@ class Processor(fb303.FacebookService.Pr
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_drop_partitions_req(self, seqid, iprot, oprot):
+ args = drop_partitions_req_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = drop_partitions_req_result()
+ try:
+ result.success = self._handler.drop_partitions_req(args.req)
+ except NoSuchObjectException as o1:
+ result.o1 = o1
+ except MetaException as o2:
+ result.o2 = o2
+ oprot.writeMessageBegin("drop_partitions_req", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_get_partition(self, seqid, iprot, oprot):
args = get_partition_args()
args.read(iprot)
@@ -6023,10 +6081,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype295, _size292) = iprot.readListBegin()
- for _i296 in xrange(_size292):
- _elem297 = iprot.readString();
- self.success.append(_elem297)
+ (_etype316, _size313) = iprot.readListBegin()
+ for _i317 in xrange(_size313):
+ _elem318 = iprot.readString();
+ self.success.append(_elem318)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6049,8 +6107,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 iter298 in self.success:
- oprot.writeString(iter298)
+ for iter319 in self.success:
+ oprot.writeString(iter319)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -6145,10 +6203,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype302, _size299) = iprot.readListBegin()
- for _i303 in xrange(_size299):
- _elem304 = iprot.readString();
- self.success.append(_elem304)
+ (_etype323, _size320) = iprot.readListBegin()
+ for _i324 in xrange(_size320):
+ _elem325 = iprot.readString();
+ self.success.append(_elem325)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -6171,8 +6229,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 iter305 in self.success:
- oprot.writeString(iter305)
+ for iter326 in self.success:
+ oprot.writeString(iter326)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -6882,12 +6940,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype307, _vtype308, _size306 ) = iprot.readMapBegin()
- for _i310 in xrange(_size306):
- _key311 = iprot.readString();
- _val312 = Type()
- _val312.read(iprot)
- self.success[_key311] = _val312
+ (_ktype328, _vtype329, _size327 ) = iprot.readMapBegin()
+ for _i331 in xrange(_size327):
+ _key332 = iprot.readString();
+ _val333 = Type()
+ _val333.read(iprot)
+ self.success[_key332] = _val333
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -6910,9 +6968,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 kiter313,viter314 in self.success.items():
- oprot.writeString(kiter313)
- viter314.write(oprot)
+ for kiter334,viter335 in self.success.items():
+ oprot.writeString(kiter334)
+ viter335.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -7043,11 +7101,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype318, _size315) = iprot.readListBegin()
- for _i319 in xrange(_size315):
- _elem320 = FieldSchema()
- _elem320.read(iprot)
- self.success.append(_elem320)
+ (_etype339, _size336) = iprot.readListBegin()
+ for _i340 in xrange(_size336):
+ _elem341 = FieldSchema()
+ _elem341.read(iprot)
+ self.success.append(_elem341)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7082,8 +7140,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 iter321 in self.success:
- iter321.write(oprot)
+ for iter342 in self.success:
+ iter342.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -7222,11 +7280,11 @@ class get_schema_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype325, _size322) = iprot.readListBegin()
- for _i326 in xrange(_size322):
- _elem327 = FieldSchema()
- _elem327.read(iprot)
- self.success.append(_elem327)
+ (_etype346, _size343) = iprot.readListBegin()
+ for _i347 in xrange(_size343):
+ _elem348 = FieldSchema()
+ _elem348.read(iprot)
+ self.success.append(_elem348)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -7261,8 +7319,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 iter328 in self.success:
- iter328.write(oprot)
+ for iter349 in self.success:
+ iter349.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8059,10 +8117,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype332, _size329) = iprot.readListBegin()
- for _i333 in xrange(_size329):
- _elem334 = iprot.readString();
- self.success.append(_elem334)
+ (_etype353, _size350) = iprot.readListBegin()
+ for _i354 in xrange(_size350):
+ _elem355 = iprot.readString();
+ self.success.append(_elem355)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8085,8 +8143,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 iter335 in self.success:
- oprot.writeString(iter335)
+ for iter356 in self.success:
+ oprot.writeString(iter356)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8199,10 +8257,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype339, _size336) = iprot.readListBegin()
- for _i340 in xrange(_size336):
- _elem341 = iprot.readString();
- self.success.append(_elem341)
+ (_etype360, _size357) = iprot.readListBegin()
+ for _i361 in xrange(_size357):
+ _elem362 = iprot.readString();
+ self.success.append(_elem362)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8225,8 +8283,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 iter342 in self.success:
- oprot.writeString(iter342)
+ for iter363 in self.success:
+ oprot.writeString(iter363)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8443,10 +8501,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype346, _size343) = iprot.readListBegin()
- for _i347 in xrange(_size343):
- _elem348 = iprot.readString();
- self.tbl_names.append(_elem348)
+ (_etype367, _size364) = iprot.readListBegin()
+ for _i368 in xrange(_size364):
+ _elem369 = iprot.readString();
+ self.tbl_names.append(_elem369)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8467,8 +8525,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 iter349 in self.tbl_names:
- oprot.writeString(iter349)
+ for iter370 in self.tbl_names:
+ oprot.writeString(iter370)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8523,11 +8581,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype353, _size350) = iprot.readListBegin()
- for _i354 in xrange(_size350):
- _elem355 = Table()
- _elem355.read(iprot)
- self.success.append(_elem355)
+ (_etype374, _size371) = iprot.readListBegin()
+ for _i375 in xrange(_size371):
+ _elem376 = Table()
+ _elem376.read(iprot)
+ self.success.append(_elem376)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8562,8 +8620,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 iter356 in self.success:
- iter356.write(oprot)
+ for iter377 in self.success:
+ iter377.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8714,10 +8772,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype360, _size357) = iprot.readListBegin()
- for _i361 in xrange(_size357):
- _elem362 = iprot.readString();
- self.success.append(_elem362)
+ (_etype381, _size378) = iprot.readListBegin()
+ for _i382 in xrange(_size378):
+ _elem383 = iprot.readString();
+ self.success.append(_elem383)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8752,8 +8810,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 iter363 in self.success:
- oprot.writeString(iter363)
+ for iter384 in self.success:
+ oprot.writeString(iter384)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9476,11 +9534,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype367, _size364) = iprot.readListBegin()
- for _i368 in xrange(_size364):
- _elem369 = Partition()
- _elem369.read(iprot)
- self.new_parts.append(_elem369)
+ (_etype388, _size385) = iprot.readListBegin()
+ for _i389 in xrange(_size385):
+ _elem390 = Partition()
+ _elem390.read(iprot)
+ self.new_parts.append(_elem390)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9497,8 +9555,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 iter370 in self.new_parts:
- iter370.write(oprot)
+ for iter391 in self.new_parts:
+ iter391.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -9659,10 +9717,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype374, _size371) = iprot.readListBegin()
- for _i375 in xrange(_size371):
- _elem376 = iprot.readString();
- self.part_vals.append(_elem376)
+ (_etype395, _size392) = iprot.readListBegin()
+ for _i396 in xrange(_size392):
+ _elem397 = iprot.readString();
+ self.part_vals.append(_elem397)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9687,8 +9745,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 iter377 in self.part_vals:
- oprot.writeString(iter377)
+ for iter398 in self.part_vals:
+ oprot.writeString(iter398)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -10013,10 +10071,10 @@ class append_partition_with_environment_
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype381, _size378) = iprot.readListBegin()
- for _i382 in xrange(_size378):
- _elem383 = iprot.readString();
- self.part_vals.append(_elem383)
+ (_etype402, _size399) = iprot.readListBegin()
+ for _i403 in xrange(_size399):
+ _elem404 = iprot.readString();
+ self.part_vals.append(_elem404)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10047,8 +10105,8 @@ class append_partition_with_environment_
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter384 in self.part_vals:
- oprot.writeString(iter384)
+ for iter405 in self.part_vals:
+ oprot.writeString(iter405)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -10596,10 +10654,10 @@ class drop_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype388, _size385) = iprot.readListBegin()
- for _i389 in xrange(_size385):
- _elem390 = iprot.readString();
- self.part_vals.append(_elem390)
+ (_etype409, _size406) = iprot.readListBegin()
+ for _i410 in xrange(_size406):
+ _elem411 = iprot.readString();
+ self.part_vals.append(_elem411)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10629,8 +10687,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 iter391 in self.part_vals:
- oprot.writeString(iter391)
+ for iter412 in self.part_vals:
+ oprot.writeString(iter412)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -10788,10 +10846,10 @@ class drop_partition_with_environment_co
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype395, _size392) = iprot.readListBegin()
- for _i396 in xrange(_size392):
- _elem397 = iprot.readString();
- self.part_vals.append(_elem397)
+ (_etype416, _size413) = iprot.readListBegin()
+ for _i417 in xrange(_size413):
+ _elem418 = iprot.readString();
+ self.part_vals.append(_elem418)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10827,8 +10885,8 @@ class drop_partition_with_environment_co
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 3)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter398 in self.part_vals:
- oprot.writeString(iter398)
+ for iter419 in self.part_vals:
+ oprot.writeString(iter419)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -11317,6 +11375,153 @@ class drop_partition_by_name_with_enviro
def __ne__(self, other):
return not (self == other)
+class drop_partitions_req_args:
+ """
+ Attributes:
+ - req
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'req', (DropPartitionsRequest, DropPartitionsRequest.thrift_spec), None, ), # 1
+ )
+
+ def __init__(self, req=None,):
+ self.req = req
+
+ 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.req = DropPartitionsRequest()
+ self.req.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('drop_partitions_req_args')
+ if self.req is not None:
+ oprot.writeFieldBegin('req', TType.STRUCT, 1)
+ self.req.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class drop_partitions_req_result:
+ """
+ Attributes:
+ - success
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ (0, TType.STRUCT, 'success', (DropPartitionsResult, DropPartitionsResult.thrift_spec), None, ), # 0
+ (1, TType.STRUCT, 'o1', (NoSuchObjectException, NoSuchObjectException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (MetaException, MetaException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, success=None, o1=None, o2=None,):
+ self.success = success
+ self.o1 = o1
+ self.o2 = o2
+
+ def read(self, iprot):
+ if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ if fid == 0:
+ if ftype == TType.STRUCT:
+ self.success = DropPartitionsResult()
+ self.success.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = NoSuchObjectException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = MetaException()
+ self.o2.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('drop_partitions_req_result')
+ if self.success is not None:
+ oprot.writeFieldBegin('success', TType.STRUCT, 0)
+ self.success.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o1 is not None:
+ oprot.writeFieldBegin('o1', TType.STRUCT, 1)
+ self.o1.write(oprot)
+ oprot.writeFieldEnd()
+ if self.o2 is not None:
+ oprot.writeFieldBegin('o2', TType.STRUCT, 2)
+ self.o2.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
class get_partition_args:
"""
Attributes:
@@ -11359,10 +11564,10 @@ class get_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype402, _size399) = iprot.readListBegin()
- for _i403 in xrange(_size399):
- _elem404 = iprot.readString();
- self.part_vals.append(_elem404)
+ (_etype423, _size420) = iprot.readListBegin()
+ for _i424 in xrange(_size420):
+ _elem425 = iprot.readString();
+ self.part_vals.append(_elem425)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11387,8 +11592,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 iter405 in self.part_vals:
- oprot.writeString(iter405)
+ for iter426 in self.part_vals:
+ oprot.writeString(iter426)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11533,11 +11738,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype407, _vtype408, _size406 ) = iprot.readMapBegin()
- for _i410 in xrange(_size406):
- _key411 = iprot.readString();
- _val412 = iprot.readString();
- self.partitionSpecs[_key411] = _val412
+ (_ktype428, _vtype429, _size427 ) = iprot.readMapBegin()
+ for _i431 in xrange(_size427):
+ _key432 = iprot.readString();
+ _val433 = iprot.readString();
+ self.partitionSpecs[_key432] = _val433
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -11574,9 +11779,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 kiter413,viter414 in self.partitionSpecs.items():
- oprot.writeString(kiter413)
- oprot.writeString(viter414)
+ for kiter434,viter435 in self.partitionSpecs.items():
+ oprot.writeString(kiter434)
+ oprot.writeString(viter435)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -11773,10 +11978,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype418, _size415) = iprot.readListBegin()
- for _i419 in xrange(_size415):
- _elem420 = iprot.readString();
- self.part_vals.append(_elem420)
+ (_etype439, _size436) = iprot.readListBegin()
+ for _i440 in xrange(_size436):
+ _elem441 = iprot.readString();
+ self.part_vals.append(_elem441)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11788,10 +11993,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype424, _size421) = iprot.readListBegin()
- for _i425 in xrange(_size421):
- _elem426 = iprot.readString();
- self.group_names.append(_elem426)
+ (_etype445, _size442) = iprot.readListBegin()
+ for _i446 in xrange(_size442):
+ _elem447 = iprot.readString();
+ self.group_names.append(_elem447)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11816,8 +12021,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 iter427 in self.part_vals:
- oprot.writeString(iter427)
+ for iter448 in self.part_vals:
+ oprot.writeString(iter448)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -11827,8 +12032,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 iter428 in self.group_names:
- oprot.writeString(iter428)
+ for iter449 in self.group_names:
+ oprot.writeString(iter449)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12220,11 +12425,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype432, _size429) = iprot.readListBegin()
- for _i433 in xrange(_size429):
- _elem434 = Partition()
- _elem434.read(iprot)
- self.success.append(_elem434)
+ (_etype453, _size450) = iprot.readListBegin()
+ for _i454 in xrange(_size450):
+ _elem455 = Partition()
+ _elem455.read(iprot)
+ self.success.append(_elem455)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12253,8 +12458,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 iter435 in self.success:
- iter435.write(oprot)
+ for iter456 in self.success:
+ iter456.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12341,10 +12546,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype439, _size436) = iprot.readListBegin()
- for _i440 in xrange(_size436):
- _elem441 = iprot.readString();
- self.group_names.append(_elem441)
+ (_etype460, _size457) = iprot.readListBegin()
+ for _i461 in xrange(_size457):
+ _elem462 = iprot.readString();
+ self.group_names.append(_elem462)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12377,8 +12582,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 iter442 in self.group_names:
- oprot.writeString(iter442)
+ for iter463 in self.group_names:
+ oprot.writeString(iter463)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12430,11 +12635,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype446, _size443) = iprot.readListBegin()
- for _i447 in xrange(_size443):
- _elem448 = Partition()
- _elem448.read(iprot)
- self.success.append(_elem448)
+ (_etype467, _size464) = iprot.readListBegin()
+ for _i468 in xrange(_size464):
+ _elem469 = Partition()
+ _elem469.read(iprot)
+ self.success.append(_elem469)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12463,8 +12668,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 iter449 in self.success:
- iter449.write(oprot)
+ for iter470 in self.success:
+ iter470.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12605,10 +12810,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype453, _size450) = iprot.readListBegin()
- for _i454 in xrange(_size450):
- _elem455 = iprot.readString();
- self.success.append(_elem455)
+ (_etype474, _size471) = iprot.readListBegin()
+ for _i475 in xrange(_size471):
+ _elem476 = iprot.readString();
+ self.success.append(_elem476)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12631,8 +12836,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 iter456 in self.success:
- oprot.writeString(iter456)
+ for iter477 in self.success:
+ oprot.writeString(iter477)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -12702,10 +12907,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype460, _size457) = iprot.readListBegin()
- for _i461 in xrange(_size457):
- _elem462 = iprot.readString();
- self.part_vals.append(_elem462)
+ (_etype481, _size478) = iprot.readListBegin()
+ for _i482 in xrange(_size478):
+ _elem483 = iprot.readString();
+ self.part_vals.append(_elem483)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12735,8 +12940,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 iter463 in self.part_vals:
- oprot.writeString(iter463)
+ for iter484 in self.part_vals:
+ oprot.writeString(iter484)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -12792,11 +12997,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype467, _size464) = iprot.readListBegin()
- for _i468 in xrange(_size464):
- _elem469 = Partition()
- _elem469.read(iprot)
- self.success.append(_elem469)
+ (_etype488, _size485) = iprot.readListBegin()
+ for _i489 in xrange(_size485):
+ _elem490 = Partition()
+ _elem490.read(iprot)
+ self.success.append(_elem490)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12825,8 +13030,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 iter470 in self.success:
- iter470.write(oprot)
+ for iter491 in self.success:
+ iter491.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12906,10 +13111,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype474, _size471) = iprot.readListBegin()
- for _i475 in xrange(_size471):
- _elem476 = iprot.readString();
- self.part_vals.append(_elem476)
+ (_etype495, _size492) = iprot.readListBegin()
+ for _i496 in xrange(_size492):
+ _elem497 = iprot.readString();
+ self.part_vals.append(_elem497)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12926,10 +13131,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype480, _size477) = iprot.readListBegin()
- for _i481 in xrange(_size477):
- _elem482 = iprot.readString();
- self.group_names.append(_elem482)
+ (_etype501, _size498) = iprot.readListBegin()
+ for _i502 in xrange(_size498):
+ _elem503 = iprot.readString();
+ self.group_names.append(_elem503)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12954,8 +13159,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 iter483 in self.part_vals:
- oprot.writeString(iter483)
+ for iter504 in self.part_vals:
+ oprot.writeString(iter504)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -12969,8 +13174,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 iter484 in self.group_names:
- oprot.writeString(iter484)
+ for iter505 in self.group_names:
+ oprot.writeString(iter505)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13022,11 +13227,11 @@ class get_partitions_ps_with_auth_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype488, _size485) = iprot.readListBegin()
- for _i489 in xrange(_size485):
- _elem490 = Partition()
- _elem490.read(iprot)
- self.success.append(_elem490)
+ (_etype509, _size506) = iprot.readListBegin()
+ for _i510 in xrange(_size506):
+ _elem511 = Partition()
+ _elem511.read(iprot)
+ self.success.append(_elem511)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13055,8 +13260,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 iter491 in self.success:
- iter491.write(oprot)
+ for iter512 in self.success:
+ iter512.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13130,10 +13335,10 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype495, _size492) = iprot.readListBegin()
- for _i496 in xrange(_size492):
- _elem497 = iprot.readString();
- self.part_vals.append(_elem497)
+ (_etype516, _size513) = iprot.readListBegin()
+ for _i517 in xrange(_size513):
+ _elem518 = iprot.readString();
+ self.part_vals.append(_elem518)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13163,8 +13368,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 iter498 in self.part_vals:
- oprot.writeString(iter498)
+ for iter519 in self.part_vals:
+ oprot.writeString(iter519)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -13220,10 +13425,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype502, _size499) = iprot.readListBegin()
- for _i503 in xrange(_size499):
- _elem504 = iprot.readString();
- self.success.append(_elem504)
+ (_etype523, _size520) = iprot.readListBegin()
+ for _i524 in xrange(_size520):
+ _elem525 = iprot.readString();
+ self.success.append(_elem525)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13252,8 +13457,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 iter505 in self.success:
- oprot.writeString(iter505)
+ for iter526 in self.success:
+ oprot.writeString(iter526)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13409,11 +13614,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype509, _size506) = iprot.readListBegin()
- for _i510 in xrange(_size506):
- _elem511 = Partition()
- _elem511.read(iprot)
- self.success.append(_elem511)
+ (_etype530, _size527) = iprot.readListBegin()
+ for _i531 in xrange(_size527):
+ _elem532 = Partition()
+ _elem532.read(iprot)
+ self.success.append(_elem532)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13442,8 +13647,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 iter512 in self.success:
- iter512.write(oprot)
+ for iter533 in self.success:
+ iter533.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -13661,10 +13866,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = iprot.readString();
- self.names.append(_elem518)
+ (_etype537, _size534) = iprot.readListBegin()
+ for _i538 in xrange(_size534):
+ _elem539 = iprot.readString();
+ self.names.append(_elem539)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13689,8 +13894,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 iter519 in self.names:
- oprot.writeString(iter519)
+ for iter540 in self.names:
+ oprot.writeString(iter540)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13742,11 +13947,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype523, _size520) = iprot.readListBegin()
- for _i524 in xrange(_size520):
- _elem525 = Partition()
- _elem525.read(iprot)
- self.success.append(_elem525)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = Partition()
+ _elem546.read(iprot)
+ self.success.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13775,8 +13980,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 iter526 in self.success:
- iter526.write(oprot)
+ for iter547 in self.success:
+ iter547.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -14006,11 +14211,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = Partition()
- _elem532.read(iprot)
- self.new_parts.append(_elem532)
+ (_etype551, _size548) = iprot.readListBegin()
+ for _i552 in xrange(_size548):
+ _elem553 = Partition()
+ _elem553.read(iprot)
+ self.new_parts.append(_elem553)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14035,8 +14240,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 iter533 in self.new_parts:
- iter533.write(oprot)
+ for iter554 in self.new_parts:
+ iter554.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14348,10 +14553,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = iprot.readString();
- self.part_vals.append(_elem539)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = iprot.readString();
+ self.part_vals.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14382,8 +14587,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 iter540 in self.part_vals:
- oprot.writeString(iter540)
+ for iter561 in self.part_vals:
+ oprot.writeString(iter561)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -14511,10 +14716,10 @@ class partition_name_has_valid_character
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype544, _size541) = iprot.readListBegin()
- for _i545 in xrange(_size541):
- _elem546 = iprot.readString();
- self.part_vals.append(_elem546)
+ (_etype565, _size562) = iprot.readListBegin()
+ for _i566 in xrange(_size562):
+ _elem567 = iprot.readString();
+ self.part_vals.append(_elem567)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14536,8 +14741,8 @@ class partition_name_has_valid_character
if self.part_vals is not None:
oprot.writeFieldBegin('part_vals', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.part_vals))
- for iter547 in self.part_vals:
- oprot.writeString(iter547)
+ for iter568 in self.part_vals:
+ oprot.writeString(iter568)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -14866,10 +15071,10 @@ class partition_name_to_vals_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)
+ (_etype572, _size569) = iprot.readListBegin()
+ for _i573 in xrange(_size569):
+ _elem574 = iprot.readString();
+ self.success.append(_elem574)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14892,8 +15097,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 iter554 in self.success:
- oprot.writeString(iter554)
+ for iter575 in self.success:
+ oprot.writeString(iter575)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15006,11 +15211,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype556, _vtype557, _size555 ) = iprot.readMapBegin()
- for _i559 in xrange(_size555):
- _key560 = iprot.readString();
- _val561 = iprot.readString();
- self.success[_key560] = _val561
+ (_ktype577, _vtype578, _size576 ) = iprot.readMapBegin()
+ for _i580 in xrange(_size576):
+ _key581 = iprot.readString();
+ _val582 = iprot.readString();
+ self.success[_key581] = _val582
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -15033,9 +15238,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 kiter562,viter563 in self.success.items():
- oprot.writeString(kiter562)
- oprot.writeString(viter563)
+ for kiter583,viter584 in self.success.items():
+ oprot.writeString(kiter583)
+ oprot.writeString(viter584)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15105,11 +15310,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype565, _vtype566, _size564 ) = iprot.readMapBegin()
- for _i568 in xrange(_size564):
- _key569 = iprot.readString();
- _val570 = iprot.readString();
- self.part_vals[_key569] = _val570
+ (_ktype586, _vtype587, _size585 ) = iprot.readMapBegin()
+ for _i589 in xrange(_size585):
+ _key590 = iprot.readString();
+ _val591 = iprot.readString();
+ self.part_vals[_key590] = _val591
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -15139,9 +15344,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 kiter571,viter572 in self.part_vals.items():
- oprot.writeString(kiter571)
- oprot.writeString(viter572)
+ for kiter592,viter593 in self.part_vals.items():
+ oprot.writeString(kiter592)
+ oprot.writeString(viter593)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -15337,11 +15542,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype574, _vtype575, _size573 ) = iprot.readMapBegin()
- for _i577 in xrange(_size573):
- _key578 = iprot.readString();
- _val579 = iprot.readString();
- self.part_vals[_key578] = _val579
+ (_ktype595, _vtype596, _size594 ) = iprot.readMapBegin()
+ for _i598 in xrange(_size594):
+ _key599 = iprot.readString();
+ _val600 = iprot.readString();
+ self.part_vals[_key599] = _val600
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -15371,9 +15576,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 kiter580,viter581 in self.part_vals.items():
- oprot.writeString(kiter580)
- oprot.writeString(viter581)
+ for kiter601,viter602 in self.part_vals.items():
+ oprot.writeString(kiter601)
+ oprot.writeString(viter602)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -16345,11 +16550,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype585, _size582) = iprot.readListBegin()
- for _i586 in xrange(_size582):
- _elem587 = Index()
- _elem587.read(iprot)
- self.success.append(_elem587)
+ (_etype606, _size603) = iprot.readListBegin()
+ for _i607 in xrange(_size603):
+ _elem608 = Index()
+ _elem608.read(iprot)
+ self.success.append(_elem608)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16378,8 +16583,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 iter588 in self.success:
- iter588.write(oprot)
+ for iter609 in self.success:
+ iter609.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16520,10 +16725,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype592, _size589) = iprot.readListBegin()
- for _i593 in xrange(_size589):
- _elem594 = iprot.readString();
- self.success.append(_elem594)
+ (_etype613, _size610) = iprot.readListBegin()
+ for _i614 in xrange(_size610):
+ _elem615 = iprot.readString();
+ self.success.append(_elem615)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16546,8 +16751,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 iter595 in self.success:
- oprot.writeString(iter595)
+ for iter616 in self.success:
+ oprot.writeString(iter616)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -18351,10 +18556,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype599, _size596) = iprot.readListBegin()
- for _i600 in xrange(_size596):
- _elem601 = iprot.readString();
- self.success.append(_elem601)
+ (_etype620, _size617) = iprot.readListBegin()
+ for _i621 in xrange(_size617):
+ _elem622 = iprot.readString();
+ self.success.append(_elem622)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18377,8 +18582,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 iter602 in self.success:
- oprot.writeString(iter602)
+ for iter623 in self.success:
+ oprot.writeString(iter623)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18851,11 +19056,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype606, _size603) = iprot.readListBegin()
- for _i607 in xrange(_size603):
- _elem608 = Role()
- _elem608.read(iprot)
- self.success.append(_elem608)
+ (_etype627, _size624) = iprot.readListBegin()
+ for _i628 in xrange(_size624):
+ _elem629 = Role()
+ _elem629.read(iprot)
+ self.success.append(_elem629)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18878,8 +19083,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 iter609 in self.success:
- iter609.write(oprot)
+ for iter630 in self.success:
+ iter630.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18947,10 +19152,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype613, _size610) = iprot.readListBegin()
- for _i614 in xrange(_size610):
- _elem615 = iprot.readString();
- self.group_names.append(_elem615)
+ (_etype634, _size631) = iprot.readListBegin()
+ for _i635 in xrange(_size631):
+ _elem636 = iprot.readString();
+ self.group_names.append(_elem636)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18975,8 +19180,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 iter616 in self.group_names:
- oprot.writeString(iter616)
+ for iter637 in self.group_names:
+ oprot.writeString(iter637)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19183,11 +19388,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype620, _size617) = iprot.readListBegin()
- for _i621 in xrange(_size617):
- _elem622 = HiveObjectPrivilege()
- _elem622.read(iprot)
- self.success.append(_elem622)
+ (_etype641, _size638) = iprot.readListBegin()
+ for _i642 in xrange(_size638):
+ _elem643 = HiveObjectPrivilege()
+ _elem643.read(iprot)
+ self.success.append(_elem643)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19210,8 +19415,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 iter623 in self.success:
- iter623.write(oprot)
+ for iter644 in self.success:
+ iter644.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -19536,10 +19741,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype627, _size624) = iprot.readListBegin()
- for _i628 in xrange(_size624):
- _elem629 = iprot.readString();
- self.group_names.append(_elem629)
+ (_etype648, _size645) = iprot.readListBegin()
+ for _i649 in xrange(_size645):
+ _elem650 = iprot.readString();
+ self.group_names.append(_elem650)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19560,8 +19765,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 iter630 in self.group_names:
- oprot.writeString(iter630)
+ for iter651 in self.group_names:
+ oprot.writeString(iter651)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -19610,10 +19815,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype634, _size631) = iprot.readListBegin()
- for _i635 in xrange(_size631):
- _elem636 = iprot.readString();
- self.success.append(_elem636)
+ (_etype655, _size652) = iprot.readListBegin()
+ for _i656 in xrange(_size652):
+ _elem657 = iprot.readString();
+ self.success.append(_elem657)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19636,8 +19841,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 iter637 in self.success:
- oprot.writeString(iter637)
+ for iter658 in self.success:
+ oprot.writeString(iter658)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None: