You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2015/03/28 01:22:27 UTC
svn commit: r1669718 [7/29] - in /hive/branches/llap: ./
ant/src/org/apache/hadoop/hive/ant/
common/src/java/org/apache/hadoop/hive/common/
common/src/java/org/apache/hadoop/hive/common/type/
common/src/java/org/apache/hadoop/hive/conf/ common/src/java...
Modified: hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php
URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1669718&r1=1669717&r2=1669718&view=diff
==============================================================================
--- hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php (original)
+++ hive/branches/llap/metastore/src/gen/thrift/gen-php/metastore/Types.php Sat Mar 28 00:22:15 2015
@@ -11707,6 +11707,164 @@ class ShowCompactResponse {
}
+class AddDynamicPartitions {
+ static $_TSPEC;
+
+ public $txnid = null;
+ public $dbname = null;
+ public $tablename = null;
+ public $partitionnames = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'txnid',
+ 'type' => TType::I64,
+ ),
+ 2 => array(
+ 'var' => 'dbname',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'tablename',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'partitionnames',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['txnid'])) {
+ $this->txnid = $vals['txnid'];
+ }
+ if (isset($vals['dbname'])) {
+ $this->dbname = $vals['dbname'];
+ }
+ if (isset($vals['tablename'])) {
+ $this->tablename = $vals['tablename'];
+ }
+ if (isset($vals['partitionnames'])) {
+ $this->partitionnames = $vals['partitionnames'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'AddDynamicPartitions';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnid);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbname);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->tablename);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->partitionnames = array();
+ $_size437 = 0;
+ $_etype440 = 0;
+ $xfer += $input->readListBegin($_etype440, $_size437);
+ for ($_i441 = 0; $_i441 < $_size437; ++$_i441)
+ {
+ $elem442 = null;
+ $xfer += $input->readString($elem442);
+ $this->partitionnames []= $elem442;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('AddDynamicPartitions');
+ if ($this->txnid !== null) {
+ $xfer += $output->writeFieldBegin('txnid', TType::I64, 1);
+ $xfer += $output->writeI64($this->txnid);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dbname !== null) {
+ $xfer += $output->writeFieldBegin('dbname', TType::STRING, 2);
+ $xfer += $output->writeString($this->dbname);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->tablename !== null) {
+ $xfer += $output->writeFieldBegin('tablename', TType::STRING, 3);
+ $xfer += $output->writeString($this->tablename);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->partitionnames !== null) {
+ if (!is_array($this->partitionnames)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('partitionnames', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRING, count($this->partitionnames));
+ {
+ foreach ($this->partitionnames as $iter443)
+ {
+ $xfer += $output->writeString($iter443);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class NotificationEventRequest {
static $_TSPEC;
@@ -12019,15 +12177,15 @@ class NotificationEventResponse {
case 1:
if ($ftype == TType::LST) {
$this->events = 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;
- $elem442 = new \metastore\NotificationEvent();
- $xfer += $elem442->read($input);
- $this->events []= $elem442;
+ $elem449 = null;
+ $elem449 = new \metastore\NotificationEvent();
+ $xfer += $elem449->read($input);
+ $this->events []= $elem449;
}
$xfer += $input->readListEnd();
} else {
@@ -12055,9 +12213,9 @@ class NotificationEventResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->events));
{
- foreach ($this->events as $iter443)
+ foreach ($this->events as $iter450)
{
- $xfer += $iter443->write($output);
+ $xfer += $iter450->write($output);
}
}
$output->writeListEnd();
@@ -12190,14 +12348,14 @@ class InsertEventRequestData {
case 1:
if ($ftype == TType::LST) {
$this->filesAdded = array();
- $_size444 = 0;
- $_etype447 = 0;
- $xfer += $input->readListBegin($_etype447, $_size444);
- for ($_i448 = 0; $_i448 < $_size444; ++$_i448)
+ $_size451 = 0;
+ $_etype454 = 0;
+ $xfer += $input->readListBegin($_etype454, $_size451);
+ for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
{
- $elem449 = null;
- $xfer += $input->readString($elem449);
- $this->filesAdded []= $elem449;
+ $elem456 = null;
+ $xfer += $input->readString($elem456);
+ $this->filesAdded []= $elem456;
}
$xfer += $input->readListEnd();
} else {
@@ -12225,9 +12383,9 @@ class InsertEventRequestData {
{
$output->writeListBegin(TType::STRING, count($this->filesAdded));
{
- foreach ($this->filesAdded as $iter450)
+ foreach ($this->filesAdded as $iter457)
{
- $xfer += $output->writeString($iter450);
+ $xfer += $output->writeString($iter457);
}
}
$output->writeListEnd();
@@ -12427,14 +12585,14 @@ class FireEventRequest {
case 5:
if ($ftype == TType::LST) {
$this->partitionVals = 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->partitionVals []= $elem456;
+ $elem463 = null;
+ $xfer += $input->readString($elem463);
+ $this->partitionVals []= $elem463;
}
$xfer += $input->readListEnd();
} else {
@@ -12485,9 +12643,9 @@ class FireEventRequest {
{
$output->writeListBegin(TType::STRING, count($this->partitionVals));
{
- foreach ($this->partitionVals as $iter457)
+ foreach ($this->partitionVals as $iter464)
{
- $xfer += $output->writeString($iter457);
+ $xfer += $output->writeString($iter464);
}
}
$output->writeListEnd();
Modified: hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1669718&r1=1669717&r2=1669718&view=diff
==============================================================================
--- hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original)
+++ hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Sat Mar 28 00:22:15 2015
@@ -142,6 +142,7 @@ if len(sys.argv) <= 1 or sys.argv[1] ==
print ' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)'
print ' void compact(CompactionRequest rqst)'
print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)'
+ print ' void add_dynamic_partitions(AddDynamicPartitions rqst)'
print ' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)'
print ' CurrentNotificationEventId get_current_notificationEventId()'
print ' FireEventResponse fire_listener_event(FireEventRequest rqst)'
@@ -910,6 +911,12 @@ elif cmd == 'show_compact':
sys.exit(1)
pp.pprint(client.show_compact(eval(args[0]),))
+elif cmd == 'add_dynamic_partitions':
+ if len(args) != 1:
+ print 'add_dynamic_partitions requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.add_dynamic_partitions(eval(args[0]),))
+
elif cmd == 'get_next_notification':
if len(args) != 1:
print 'get_next_notification requires 1 args'
Modified: hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py?rev=1669718&r1=1669717&r2=1669718&view=diff
==============================================================================
--- hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py (original)
+++ hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py Sat Mar 28 00:22:15 2015
@@ -994,6 +994,13 @@ class Iface(fb303.FacebookService.Iface)
"""
pass
+ def add_dynamic_partitions(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ pass
+
def get_next_notification(self, rqst):
"""
Parameters:
@@ -5311,6 +5318,38 @@ class Client(fb303.FacebookService.Clien
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "show_compact failed: unknown result");
+ def add_dynamic_partitions(self, rqst):
+ """
+ Parameters:
+ - rqst
+ """
+ self.send_add_dynamic_partitions(rqst)
+ self.recv_add_dynamic_partitions()
+
+ def send_add_dynamic_partitions(self, rqst):
+ self._oprot.writeMessageBegin('add_dynamic_partitions', TMessageType.CALL, self._seqid)
+ args = add_dynamic_partitions_args()
+ args.rqst = rqst
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
+ def recv_add_dynamic_partitions(self, ):
+ (fname, mtype, rseqid) = self._iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
+ x.read(self._iprot)
+ self._iprot.readMessageEnd()
+ raise x
+ result = add_dynamic_partitions_result()
+ result.read(self._iprot)
+ self._iprot.readMessageEnd()
+ if result.o1 is not None:
+ raise result.o1
+ if result.o2 is not None:
+ raise result.o2
+ return
+
def get_next_notification(self, rqst):
"""
Parameters:
@@ -5519,6 +5558,7 @@ class Processor(fb303.FacebookService.Pr
self._processMap["heartbeat_txn_range"] = Processor.process_heartbeat_txn_range
self._processMap["compact"] = Processor.process_compact
self._processMap["show_compact"] = Processor.process_show_compact
+ self._processMap["add_dynamic_partitions"] = Processor.process_add_dynamic_partitions
self._processMap["get_next_notification"] = Processor.process_get_next_notification
self._processMap["get_current_notificationEventId"] = Processor.process_get_current_notificationEventId
self._processMap["fire_listener_event"] = Processor.process_fire_listener_event
@@ -7443,6 +7483,22 @@ class Processor(fb303.FacebookService.Pr
oprot.writeMessageEnd()
oprot.trans.flush()
+ def process_add_dynamic_partitions(self, seqid, iprot, oprot):
+ args = add_dynamic_partitions_args()
+ args.read(iprot)
+ iprot.readMessageEnd()
+ result = add_dynamic_partitions_result()
+ try:
+ self._handler.add_dynamic_partitions(args.rqst)
+ except NoSuchTxnException as o1:
+ result.o1 = o1
+ except TxnAbortedException as o2:
+ result.o2 = o2
+ oprot.writeMessageBegin("add_dynamic_partitions", TMessageType.REPLY, seqid)
+ result.write(oprot)
+ oprot.writeMessageEnd()
+ oprot.trans.flush()
+
def process_get_next_notification(self, seqid, iprot, oprot):
args = get_next_notification_args()
args.read(iprot)
@@ -8297,10 +8353,10 @@ class get_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype458, _size455) = iprot.readListBegin()
- for _i459 in xrange(_size455):
- _elem460 = iprot.readString();
- self.success.append(_elem460)
+ (_etype465, _size462) = iprot.readListBegin()
+ for _i466 in xrange(_size462):
+ _elem467 = iprot.readString();
+ self.success.append(_elem467)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8323,8 +8379,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 iter461 in self.success:
- oprot.writeString(iter461)
+ for iter468 in self.success:
+ oprot.writeString(iter468)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -8419,10 +8475,10 @@ class get_all_databases_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype465, _size462) = iprot.readListBegin()
- for _i466 in xrange(_size462):
- _elem467 = iprot.readString();
- self.success.append(_elem467)
+ (_etype472, _size469) = iprot.readListBegin()
+ for _i473 in xrange(_size469):
+ _elem474 = iprot.readString();
+ self.success.append(_elem474)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8445,8 +8501,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 iter468 in self.success:
- oprot.writeString(iter468)
+ for iter475 in self.success:
+ oprot.writeString(iter475)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9156,12 +9212,12 @@ class get_type_all_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype470, _vtype471, _size469 ) = iprot.readMapBegin()
- for _i473 in xrange(_size469):
- _key474 = iprot.readString();
- _val475 = Type()
- _val475.read(iprot)
- self.success[_key474] = _val475
+ (_ktype477, _vtype478, _size476 ) = iprot.readMapBegin()
+ for _i480 in xrange(_size476):
+ _key481 = iprot.readString();
+ _val482 = Type()
+ _val482.read(iprot)
+ self.success[_key481] = _val482
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -9184,9 +9240,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 kiter476,viter477 in self.success.items():
- oprot.writeString(kiter476)
- viter477.write(oprot)
+ for kiter483,viter484 in self.success.items():
+ oprot.writeString(kiter483)
+ viter484.write(oprot)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -9317,11 +9373,11 @@ class get_fields_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype481, _size478) = iprot.readListBegin()
- for _i482 in xrange(_size478):
- _elem483 = FieldSchema()
- _elem483.read(iprot)
- self.success.append(_elem483)
+ (_etype488, _size485) = iprot.readListBegin()
+ for _i489 in xrange(_size485):
+ _elem490 = FieldSchema()
+ _elem490.read(iprot)
+ self.success.append(_elem490)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9356,8 +9412,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 iter484 in self.success:
- iter484.write(oprot)
+ for iter491 in self.success:
+ iter491.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9509,11 +9565,11 @@ class get_fields_with_environment_contex
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype488, _size485) = iprot.readListBegin()
- for _i489 in xrange(_size485):
- _elem490 = FieldSchema()
- _elem490.read(iprot)
- self.success.append(_elem490)
+ (_etype495, _size492) = iprot.readListBegin()
+ for _i496 in xrange(_size492):
+ _elem497 = FieldSchema()
+ _elem497.read(iprot)
+ self.success.append(_elem497)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -9548,8 +9604,8 @@ class get_fields_with_environment_contex
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 iter498 in self.success:
+ iter498.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -9688,11 +9744,11 @@ class get_schema_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)
@@ -9727,8 +9783,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 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:
@@ -9880,11 +9936,11 @@ class get_schema_with_environment_contex
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)
@@ -9919,8 +9975,8 @@ class get_schema_with_environment_contex
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:
@@ -10717,10 +10773,10 @@ class get_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype509, _size506) = iprot.readListBegin()
- for _i510 in xrange(_size506):
- _elem511 = iprot.readString();
- self.success.append(_elem511)
+ (_etype516, _size513) = iprot.readListBegin()
+ for _i517 in xrange(_size513):
+ _elem518 = iprot.readString();
+ self.success.append(_elem518)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10743,8 +10799,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 iter512 in self.success:
- oprot.writeString(iter512)
+ for iter519 in self.success:
+ oprot.writeString(iter519)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -10857,10 +10913,10 @@ class get_all_tables_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype516, _size513) = iprot.readListBegin()
- for _i517 in xrange(_size513):
- _elem518 = iprot.readString();
- self.success.append(_elem518)
+ (_etype523, _size520) = iprot.readListBegin()
+ for _i524 in xrange(_size520):
+ _elem525 = iprot.readString();
+ self.success.append(_elem525)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -10883,8 +10939,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 iter519 in self.success:
- oprot.writeString(iter519)
+ for iter526 in self.success:
+ oprot.writeString(iter526)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11101,10 +11157,10 @@ class get_table_objects_by_name_args:
elif fid == 2:
if ftype == TType.LIST:
self.tbl_names = []
- (_etype523, _size520) = iprot.readListBegin()
- for _i524 in xrange(_size520):
- _elem525 = iprot.readString();
- self.tbl_names.append(_elem525)
+ (_etype530, _size527) = iprot.readListBegin()
+ for _i531 in xrange(_size527):
+ _elem532 = iprot.readString();
+ self.tbl_names.append(_elem532)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11125,8 +11181,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 iter526 in self.tbl_names:
- oprot.writeString(iter526)
+ for iter533 in self.tbl_names:
+ oprot.writeString(iter533)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -11181,11 +11237,11 @@ class get_table_objects_by_name_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype530, _size527) = iprot.readListBegin()
- for _i531 in xrange(_size527):
- _elem532 = Table()
- _elem532.read(iprot)
- self.success.append(_elem532)
+ (_etype537, _size534) = iprot.readListBegin()
+ for _i538 in xrange(_size534):
+ _elem539 = Table()
+ _elem539.read(iprot)
+ self.success.append(_elem539)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11220,8 +11276,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 iter533 in self.success:
- iter533.write(oprot)
+ for iter540 in self.success:
+ iter540.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -11372,10 +11428,10 @@ class get_table_names_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype537, _size534) = iprot.readListBegin()
- for _i538 in xrange(_size534):
- _elem539 = iprot.readString();
- self.success.append(_elem539)
+ (_etype544, _size541) = iprot.readListBegin()
+ for _i545 in xrange(_size541):
+ _elem546 = iprot.readString();
+ self.success.append(_elem546)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -11410,8 +11466,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 iter540 in self.success:
- oprot.writeString(iter540)
+ for iter547 in self.success:
+ oprot.writeString(iter547)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -12305,11 +12361,11 @@ class add_partitions_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype544, _size541) = iprot.readListBegin()
- for _i545 in xrange(_size541):
- _elem546 = Partition()
- _elem546.read(iprot)
- self.new_parts.append(_elem546)
+ (_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)
@@ -12326,8 +12382,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 iter547 in self.new_parts:
- iter547.write(oprot)
+ for iter554 in self.new_parts:
+ iter554.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12472,11 +12528,11 @@ class add_partitions_pspec_args:
if fid == 1:
if ftype == TType.LIST:
self.new_parts = []
- (_etype551, _size548) = iprot.readListBegin()
- for _i552 in xrange(_size548):
- _elem553 = PartitionSpec()
- _elem553.read(iprot)
- self.new_parts.append(_elem553)
+ (_etype558, _size555) = iprot.readListBegin()
+ for _i559 in xrange(_size555):
+ _elem560 = PartitionSpec()
+ _elem560.read(iprot)
+ self.new_parts.append(_elem560)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12493,8 +12549,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 iter554 in self.new_parts:
- iter554.write(oprot)
+ for iter561 in self.new_parts:
+ iter561.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -12655,10 +12711,10 @@ class append_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype558, _size555) = iprot.readListBegin()
- for _i559 in xrange(_size555):
- _elem560 = iprot.readString();
- self.part_vals.append(_elem560)
+ (_etype565, _size562) = iprot.readListBegin()
+ for _i566 in xrange(_size562):
+ _elem567 = iprot.readString();
+ self.part_vals.append(_elem567)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -12683,8 +12739,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 iter561 in self.part_vals:
- oprot.writeString(iter561)
+ for iter568 in self.part_vals:
+ oprot.writeString(iter568)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -13009,10 +13065,10 @@ class append_partition_with_environment_
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype565, _size562) = iprot.readListBegin()
- for _i566 in xrange(_size562):
- _elem567 = iprot.readString();
- self.part_vals.append(_elem567)
+ (_etype572, _size569) = iprot.readListBegin()
+ for _i573 in xrange(_size569):
+ _elem574 = iprot.readString();
+ self.part_vals.append(_elem574)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -13043,8 +13099,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 iter568 in self.part_vals:
- oprot.writeString(iter568)
+ for iter575 in self.part_vals:
+ oprot.writeString(iter575)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.environment_context is not None:
@@ -13592,10 +13648,10 @@ class drop_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)
@@ -13625,8 +13681,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 iter575 in self.part_vals:
- oprot.writeString(iter575)
+ for iter582 in self.part_vals:
+ oprot.writeString(iter582)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -13784,10 +13840,10 @@ class drop_partition_with_environment_co
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)
@@ -13823,8 +13879,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 iter582 in self.part_vals:
- oprot.writeString(iter582)
+ for iter589 in self.part_vals:
+ oprot.writeString(iter589)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.deleteData is not None:
@@ -14502,10 +14558,10 @@ class get_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)
@@ -14530,8 +14586,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 iter589 in self.part_vals:
- oprot.writeString(iter589)
+ for iter596 in self.part_vals:
+ oprot.writeString(iter596)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -14676,11 +14732,11 @@ class exchange_partition_args:
if fid == 1:
if ftype == TType.MAP:
self.partitionSpecs = {}
- (_ktype591, _vtype592, _size590 ) = iprot.readMapBegin()
- for _i594 in xrange(_size590):
- _key595 = iprot.readString();
- _val596 = iprot.readString();
- self.partitionSpecs[_key595] = _val596
+ (_ktype598, _vtype599, _size597 ) = iprot.readMapBegin()
+ for _i601 in xrange(_size597):
+ _key602 = iprot.readString();
+ _val603 = iprot.readString();
+ self.partitionSpecs[_key602] = _val603
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -14717,9 +14773,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 kiter597,viter598 in self.partitionSpecs.items():
- oprot.writeString(kiter597)
- oprot.writeString(viter598)
+ for kiter604,viter605 in self.partitionSpecs.items():
+ oprot.writeString(kiter604)
+ oprot.writeString(viter605)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.source_db is not None:
@@ -14916,10 +14972,10 @@ class get_partition_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype602, _size599) = iprot.readListBegin()
- for _i603 in xrange(_size599):
- _elem604 = iprot.readString();
- self.part_vals.append(_elem604)
+ (_etype609, _size606) = iprot.readListBegin()
+ for _i610 in xrange(_size606):
+ _elem611 = iprot.readString();
+ self.part_vals.append(_elem611)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14931,10 +14987,10 @@ class get_partition_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype608, _size605) = iprot.readListBegin()
- for _i609 in xrange(_size605):
- _elem610 = iprot.readString();
- self.group_names.append(_elem610)
+ (_etype615, _size612) = iprot.readListBegin()
+ for _i616 in xrange(_size612):
+ _elem617 = iprot.readString();
+ self.group_names.append(_elem617)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -14959,8 +15015,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 iter611 in self.part_vals:
- oprot.writeString(iter611)
+ for iter618 in self.part_vals:
+ oprot.writeString(iter618)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.user_name is not None:
@@ -14970,8 +15026,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 iter612 in self.group_names:
- oprot.writeString(iter612)
+ for iter619 in self.group_names:
+ oprot.writeString(iter619)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15363,11 +15419,11 @@ class get_partitions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype616, _size613) = iprot.readListBegin()
- for _i617 in xrange(_size613):
- _elem618 = Partition()
- _elem618.read(iprot)
- self.success.append(_elem618)
+ (_etype623, _size620) = iprot.readListBegin()
+ for _i624 in xrange(_size620):
+ _elem625 = Partition()
+ _elem625.read(iprot)
+ self.success.append(_elem625)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15396,8 +15452,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 iter619 in self.success:
- iter619.write(oprot)
+ for iter626 in self.success:
+ iter626.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15484,10 +15540,10 @@ class get_partitions_with_auth_args:
elif fid == 5:
if ftype == TType.LIST:
self.group_names = []
- (_etype623, _size620) = iprot.readListBegin()
- for _i624 in xrange(_size620):
- _elem625 = iprot.readString();
- self.group_names.append(_elem625)
+ (_etype630, _size627) = iprot.readListBegin()
+ for _i631 in xrange(_size627):
+ _elem632 = iprot.readString();
+ self.group_names.append(_elem632)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15520,8 +15576,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 iter626 in self.group_names:
- oprot.writeString(iter626)
+ for iter633 in self.group_names:
+ oprot.writeString(iter633)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -15573,11 +15629,11 @@ class get_partitions_with_auth_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype630, _size627) = iprot.readListBegin()
- for _i631 in xrange(_size627):
- _elem632 = Partition()
- _elem632.read(iprot)
- self.success.append(_elem632)
+ (_etype637, _size634) = iprot.readListBegin()
+ for _i638 in xrange(_size634):
+ _elem639 = Partition()
+ _elem639.read(iprot)
+ self.success.append(_elem639)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15606,8 +15662,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 iter633 in self.success:
- iter633.write(oprot)
+ for iter640 in self.success:
+ iter640.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15751,11 +15807,11 @@ class get_partitions_pspec_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype637, _size634) = iprot.readListBegin()
- for _i638 in xrange(_size634):
- _elem639 = PartitionSpec()
- _elem639.read(iprot)
- self.success.append(_elem639)
+ (_etype644, _size641) = iprot.readListBegin()
+ for _i645 in xrange(_size641):
+ _elem646 = PartitionSpec()
+ _elem646.read(iprot)
+ self.success.append(_elem646)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15784,8 +15840,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 iter640 in self.success:
- iter640.write(oprot)
+ for iter647 in self.success:
+ iter647.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -15926,10 +15982,10 @@ class get_partition_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype644, _size641) = iprot.readListBegin()
- for _i645 in xrange(_size641):
- _elem646 = iprot.readString();
- self.success.append(_elem646)
+ (_etype651, _size648) = iprot.readListBegin()
+ for _i652 in xrange(_size648):
+ _elem653 = iprot.readString();
+ self.success.append(_elem653)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -15952,8 +16008,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 iter647 in self.success:
- oprot.writeString(iter647)
+ for iter654 in self.success:
+ oprot.writeString(iter654)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -16023,10 +16079,10 @@ class get_partitions_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype651, _size648) = iprot.readListBegin()
- for _i652 in xrange(_size648):
- _elem653 = iprot.readString();
- self.part_vals.append(_elem653)
+ (_etype658, _size655) = iprot.readListBegin()
+ for _i659 in xrange(_size655):
+ _elem660 = iprot.readString();
+ self.part_vals.append(_elem660)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16056,8 +16112,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 iter654 in self.part_vals:
- oprot.writeString(iter654)
+ for iter661 in self.part_vals:
+ oprot.writeString(iter661)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -16113,11 +16169,11 @@ class get_partitions_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype658, _size655) = iprot.readListBegin()
- for _i659 in xrange(_size655):
- _elem660 = Partition()
- _elem660.read(iprot)
- self.success.append(_elem660)
+ (_etype665, _size662) = iprot.readListBegin()
+ for _i666 in xrange(_size662):
+ _elem667 = Partition()
+ _elem667.read(iprot)
+ self.success.append(_elem667)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16146,8 +16202,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 iter661 in self.success:
- iter661.write(oprot)
+ for iter668 in self.success:
+ iter668.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16227,10 +16283,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype665, _size662) = iprot.readListBegin()
- for _i666 in xrange(_size662):
- _elem667 = iprot.readString();
- self.part_vals.append(_elem667)
+ (_etype672, _size669) = iprot.readListBegin()
+ for _i673 in xrange(_size669):
+ _elem674 = iprot.readString();
+ self.part_vals.append(_elem674)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16247,10 +16303,10 @@ class get_partitions_ps_with_auth_args:
elif fid == 6:
if ftype == TType.LIST:
self.group_names = []
- (_etype671, _size668) = iprot.readListBegin()
- for _i672 in xrange(_size668):
- _elem673 = iprot.readString();
- self.group_names.append(_elem673)
+ (_etype678, _size675) = iprot.readListBegin()
+ for _i679 in xrange(_size675):
+ _elem680 = iprot.readString();
+ self.group_names.append(_elem680)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16275,8 +16331,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 iter674 in self.part_vals:
- oprot.writeString(iter674)
+ for iter681 in self.part_vals:
+ oprot.writeString(iter681)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -16290,8 +16346,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 iter675 in self.group_names:
- oprot.writeString(iter675)
+ for iter682 in self.group_names:
+ oprot.writeString(iter682)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -16343,11 +16399,11 @@ class get_partitions_ps_with_auth_result
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype679, _size676) = iprot.readListBegin()
- for _i680 in xrange(_size676):
- _elem681 = Partition()
- _elem681.read(iprot)
- self.success.append(_elem681)
+ (_etype686, _size683) = iprot.readListBegin()
+ for _i687 in xrange(_size683):
+ _elem688 = Partition()
+ _elem688.read(iprot)
+ self.success.append(_elem688)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16376,8 +16432,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 iter682 in self.success:
- iter682.write(oprot)
+ for iter689 in self.success:
+ iter689.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16451,11 +16507,11 @@ class get_partition_names_ps_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype686, _size683) = iprot.readListBegin()
- for _i687 in xrange(_size683):
- _elem688 = iprot.readString();
- self.part_vals.append(_elem688)
- iprot.readListEnd()
+ (_etype693, _size690) = iprot.readListBegin()
+ for _i694 in xrange(_size690):
+ _elem695 = iprot.readString();
+ self.part_vals.append(_elem695)
+ iprot.readListEnd()
else:
iprot.skip(ftype)
elif fid == 4:
@@ -16484,8 +16540,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 iter689 in self.part_vals:
- oprot.writeString(iter689)
+ for iter696 in self.part_vals:
+ oprot.writeString(iter696)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.max_parts is not None:
@@ -16541,10 +16597,10 @@ class get_partition_names_ps_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype693, _size690) = iprot.readListBegin()
- for _i694 in xrange(_size690):
- _elem695 = iprot.readString();
- self.success.append(_elem695)
+ (_etype700, _size697) = iprot.readListBegin()
+ for _i701 in xrange(_size697):
+ _elem702 = iprot.readString();
+ self.success.append(_elem702)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16573,8 +16629,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 iter696 in self.success:
- oprot.writeString(iter696)
+ for iter703 in self.success:
+ oprot.writeString(iter703)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16730,11 +16786,11 @@ class get_partitions_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype700, _size697) = iprot.readListBegin()
- for _i701 in xrange(_size697):
- _elem702 = Partition()
- _elem702.read(iprot)
- self.success.append(_elem702)
+ (_etype707, _size704) = iprot.readListBegin()
+ for _i708 in xrange(_size704):
+ _elem709 = Partition()
+ _elem709.read(iprot)
+ self.success.append(_elem709)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16763,8 +16819,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 iter703 in self.success:
- iter703.write(oprot)
+ for iter710 in self.success:
+ iter710.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -16920,11 +16976,11 @@ class get_part_specs_by_filter_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype707, _size704) = iprot.readListBegin()
- for _i708 in xrange(_size704):
- _elem709 = PartitionSpec()
- _elem709.read(iprot)
- self.success.append(_elem709)
+ (_etype714, _size711) = iprot.readListBegin()
+ for _i715 in xrange(_size711):
+ _elem716 = PartitionSpec()
+ _elem716.read(iprot)
+ self.success.append(_elem716)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -16953,8 +17009,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 iter710 in self.success:
- iter710.write(oprot)
+ for iter717 in self.success:
+ iter717.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17172,10 +17228,10 @@ class get_partitions_by_names_args:
elif fid == 3:
if ftype == TType.LIST:
self.names = []
- (_etype714, _size711) = iprot.readListBegin()
- for _i715 in xrange(_size711):
- _elem716 = iprot.readString();
- self.names.append(_elem716)
+ (_etype721, _size718) = iprot.readListBegin()
+ for _i722 in xrange(_size718):
+ _elem723 = iprot.readString();
+ self.names.append(_elem723)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17200,8 +17256,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 iter717 in self.names:
- oprot.writeString(iter717)
+ for iter724 in self.names:
+ oprot.writeString(iter724)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17253,11 +17309,11 @@ class get_partitions_by_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype721, _size718) = iprot.readListBegin()
- for _i722 in xrange(_size718):
- _elem723 = Partition()
- _elem723.read(iprot)
- self.success.append(_elem723)
+ (_etype728, _size725) = iprot.readListBegin()
+ for _i729 in xrange(_size725):
+ _elem730 = Partition()
+ _elem730.read(iprot)
+ self.success.append(_elem730)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17286,8 +17342,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 iter724 in self.success:
- iter724.write(oprot)
+ for iter731 in self.success:
+ iter731.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -17517,11 +17573,11 @@ class alter_partitions_args:
elif fid == 3:
if ftype == TType.LIST:
self.new_parts = []
- (_etype728, _size725) = iprot.readListBegin()
- for _i729 in xrange(_size725):
- _elem730 = Partition()
- _elem730.read(iprot)
- self.new_parts.append(_elem730)
+ (_etype735, _size732) = iprot.readListBegin()
+ for _i736 in xrange(_size732):
+ _elem737 = Partition()
+ _elem737.read(iprot)
+ self.new_parts.append(_elem737)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17546,8 +17602,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 iter731 in self.new_parts:
- iter731.write(oprot)
+ for iter738 in self.new_parts:
+ iter738.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -17859,10 +17915,10 @@ class rename_partition_args:
elif fid == 3:
if ftype == TType.LIST:
self.part_vals = []
- (_etype735, _size732) = iprot.readListBegin()
- for _i736 in xrange(_size732):
- _elem737 = iprot.readString();
- self.part_vals.append(_elem737)
+ (_etype742, _size739) = iprot.readListBegin()
+ for _i743 in xrange(_size739):
+ _elem744 = iprot.readString();
+ self.part_vals.append(_elem744)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -17893,8 +17949,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 iter738 in self.part_vals:
- oprot.writeString(iter738)
+ for iter745 in self.part_vals:
+ oprot.writeString(iter745)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.new_part is not None:
@@ -18022,10 +18078,10 @@ class partition_name_has_valid_character
if fid == 1:
if ftype == TType.LIST:
self.part_vals = []
- (_etype742, _size739) = iprot.readListBegin()
- for _i743 in xrange(_size739):
- _elem744 = iprot.readString();
- self.part_vals.append(_elem744)
+ (_etype749, _size746) = iprot.readListBegin()
+ for _i750 in xrange(_size746):
+ _elem751 = iprot.readString();
+ self.part_vals.append(_elem751)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18047,8 +18103,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 iter745 in self.part_vals:
- oprot.writeString(iter745)
+ for iter752 in self.part_vals:
+ oprot.writeString(iter752)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.throw_exception is not None:
@@ -18377,10 +18433,10 @@ class partition_name_to_vals_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype749, _size746) = iprot.readListBegin()
- for _i750 in xrange(_size746):
- _elem751 = iprot.readString();
- self.success.append(_elem751)
+ (_etype756, _size753) = iprot.readListBegin()
+ for _i757 in xrange(_size753):
+ _elem758 = iprot.readString();
+ self.success.append(_elem758)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -18403,8 +18459,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 iter752 in self.success:
- oprot.writeString(iter752)
+ for iter759 in self.success:
+ oprot.writeString(iter759)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18517,11 +18573,11 @@ class partition_name_to_spec_result:
if fid == 0:
if ftype == TType.MAP:
self.success = {}
- (_ktype754, _vtype755, _size753 ) = iprot.readMapBegin()
- for _i757 in xrange(_size753):
- _key758 = iprot.readString();
- _val759 = iprot.readString();
- self.success[_key758] = _val759
+ (_ktype761, _vtype762, _size760 ) = iprot.readMapBegin()
+ for _i764 in xrange(_size760):
+ _key765 = iprot.readString();
+ _val766 = iprot.readString();
+ self.success[_key765] = _val766
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18544,9 +18600,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 kiter760,viter761 in self.success.items():
- oprot.writeString(kiter760)
- oprot.writeString(viter761)
+ for kiter767,viter768 in self.success.items():
+ oprot.writeString(kiter767)
+ oprot.writeString(viter768)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -18616,11 +18672,11 @@ class markPartitionForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype763, _vtype764, _size762 ) = iprot.readMapBegin()
- for _i766 in xrange(_size762):
- _key767 = iprot.readString();
- _val768 = iprot.readString();
- self.part_vals[_key767] = _val768
+ (_ktype770, _vtype771, _size769 ) = iprot.readMapBegin()
+ for _i773 in xrange(_size769):
+ _key774 = iprot.readString();
+ _val775 = iprot.readString();
+ self.part_vals[_key774] = _val775
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18650,9 +18706,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 kiter769,viter770 in self.part_vals.items():
- oprot.writeString(kiter769)
- oprot.writeString(viter770)
+ for kiter776,viter777 in self.part_vals.items():
+ oprot.writeString(kiter776)
+ oprot.writeString(viter777)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -18848,11 +18904,11 @@ class isPartitionMarkedForEvent_args:
elif fid == 3:
if ftype == TType.MAP:
self.part_vals = {}
- (_ktype772, _vtype773, _size771 ) = iprot.readMapBegin()
- for _i775 in xrange(_size771):
- _key776 = iprot.readString();
- _val777 = iprot.readString();
- self.part_vals[_key776] = _val777
+ (_ktype779, _vtype780, _size778 ) = iprot.readMapBegin()
+ for _i782 in xrange(_size778):
+ _key783 = iprot.readString();
+ _val784 = iprot.readString();
+ self.part_vals[_key783] = _val784
iprot.readMapEnd()
else:
iprot.skip(ftype)
@@ -18882,9 +18938,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 kiter778,viter779 in self.part_vals.items():
- oprot.writeString(kiter778)
- oprot.writeString(viter779)
+ for kiter785,viter786 in self.part_vals.items():
+ oprot.writeString(kiter785)
+ oprot.writeString(viter786)
oprot.writeMapEnd()
oprot.writeFieldEnd()
if self.eventType is not None:
@@ -19856,11 +19912,11 @@ class get_indexes_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype783, _size780) = iprot.readListBegin()
- for _i784 in xrange(_size780):
- _elem785 = Index()
- _elem785.read(iprot)
- self.success.append(_elem785)
+ (_etype790, _size787) = iprot.readListBegin()
+ for _i791 in xrange(_size787):
+ _elem792 = Index()
+ _elem792.read(iprot)
+ self.success.append(_elem792)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -19889,8 +19945,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 iter786 in self.success:
- iter786.write(oprot)
+ for iter793 in self.success:
+ iter793.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -20031,10 +20087,10 @@ class get_index_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype790, _size787) = iprot.readListBegin()
- for _i791 in xrange(_size787):
- _elem792 = iprot.readString();
- self.success.append(_elem792)
+ (_etype797, _size794) = iprot.readListBegin()
+ for _i798 in xrange(_size794):
+ _elem799 = iprot.readString();
+ self.success.append(_elem799)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -20057,8 +20113,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 iter793 in self.success:
- oprot.writeString(iter793)
+ for iter800 in self.success:
+ oprot.writeString(iter800)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o2 is not None:
@@ -22412,10 +22468,10 @@ class get_functions_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype797, _size794) = iprot.readListBegin()
- for _i798 in xrange(_size794):
- _elem799 = iprot.readString();
- self.success.append(_elem799)
+ (_etype804, _size801) = iprot.readListBegin()
+ for _i805 in xrange(_size801):
+ _elem806 = iprot.readString();
+ self.success.append(_elem806)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22438,8 +22494,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 iter800 in self.success:
- oprot.writeString(iter800)
+ for iter807 in self.success:
+ oprot.writeString(iter807)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -22957,10 +23013,10 @@ class get_role_names_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype804, _size801) = iprot.readListBegin()
- for _i805 in xrange(_size801):
- _elem806 = iprot.readString();
- self.success.append(_elem806)
+ (_etype811, _size808) = iprot.readListBegin()
+ for _i812 in xrange(_size808):
+ _elem813 = iprot.readString();
+ self.success.append(_elem813)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -22983,8 +23039,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 iter807 in self.success:
- oprot.writeString(iter807)
+ for iter814 in self.success:
+ oprot.writeString(iter814)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23457,11 +23513,11 @@ class list_roles_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype811, _size808) = iprot.readListBegin()
- for _i812 in xrange(_size808):
- _elem813 = Role()
- _elem813.read(iprot)
- self.success.append(_elem813)
+ (_etype818, _size815) = iprot.readListBegin()
+ for _i819 in xrange(_size815):
+ _elem820 = Role()
+ _elem820.read(iprot)
+ self.success.append(_elem820)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23484,8 +23540,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 iter814 in self.success:
- iter814.write(oprot)
+ for iter821 in self.success:
+ iter821.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -23955,10 +24011,10 @@ class get_privilege_set_args:
elif fid == 3:
if ftype == TType.LIST:
self.group_names = []
- (_etype818, _size815) = iprot.readListBegin()
- for _i819 in xrange(_size815):
- _elem820 = iprot.readString();
- self.group_names.append(_elem820)
+ (_etype825, _size822) = iprot.readListBegin()
+ for _i826 in xrange(_size822):
+ _elem827 = iprot.readString();
+ self.group_names.append(_elem827)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -23983,8 +24039,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 iter821 in self.group_names:
- oprot.writeString(iter821)
+ for iter828 in self.group_names:
+ oprot.writeString(iter828)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24191,11 +24247,11 @@ class list_privileges_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype825, _size822) = iprot.readListBegin()
- for _i826 in xrange(_size822):
- _elem827 = HiveObjectPrivilege()
- _elem827.read(iprot)
- self.success.append(_elem827)
+ (_etype832, _size829) = iprot.readListBegin()
+ for _i833 in xrange(_size829):
+ _elem834 = HiveObjectPrivilege()
+ _elem834.read(iprot)
+ self.success.append(_elem834)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24218,8 +24274,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 iter828 in self.success:
- iter828.write(oprot)
+ for iter835 in self.success:
+ iter835.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -24678,10 +24734,10 @@ class set_ugi_args:
elif fid == 2:
if ftype == TType.LIST:
self.group_names = []
- (_etype832, _size829) = iprot.readListBegin()
- for _i833 in xrange(_size829):
- _elem834 = iprot.readString();
- self.group_names.append(_elem834)
+ (_etype839, _size836) = iprot.readListBegin()
+ for _i840 in xrange(_size836):
+ _elem841 = iprot.readString();
+ self.group_names.append(_elem841)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24702,8 +24758,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 iter835 in self.group_names:
- oprot.writeString(iter835)
+ for iter842 in self.group_names:
+ oprot.writeString(iter842)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -24752,10 +24808,10 @@ class set_ugi_result:
if fid == 0:
if ftype == TType.LIST:
self.success = []
- (_etype839, _size836) = iprot.readListBegin()
- for _i840 in xrange(_size836):
- _elem841 = iprot.readString();
- self.success.append(_elem841)
+ (_etype846, _size843) = iprot.readListBegin()
+ for _i847 in xrange(_size843):
+ _elem848 = iprot.readString();
+ self.success.append(_elem848)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -24778,8 +24834,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 iter842 in self.success:
- oprot.writeString(iter842)
+ for iter849 in self.success:
+ oprot.writeString(iter849)
oprot.writeListEnd()
oprot.writeFieldEnd()
if self.o1 is not None:
@@ -26823,6 +26879,141 @@ class show_compact_result:
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 add_dynamic_partitions_args:
+ """
+ Attributes:
+ - rqst
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'rqst', (AddDynamicPartitions, AddDynamicPartitions.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 = AddDynamicPartitions()
+ 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('add_dynamic_partitions_args')
+ if self.rqst is not None:
+ oprot.writeFieldBegin('rqst', TType.STRUCT, 1)
+ self.rqst.write(oprot)
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class add_dynamic_partitions_result:
+ """
+ Attributes:
+ - o1
+ - o2
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.STRUCT, 'o1', (NoSuchTxnException, NoSuchTxnException.thrift_spec), None, ), # 1
+ (2, TType.STRUCT, 'o2', (TxnAbortedException, TxnAbortedException.thrift_spec), None, ), # 2
+ )
+
+ def __init__(self, o1=None, o2=None,):
+ 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 == 1:
+ if ftype == TType.STRUCT:
+ self.o1 = NoSuchTxnException()
+ self.o1.read(iprot)
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRUCT:
+ self.o2 = TxnAbortedException()
+ 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('add_dynamic_partitions_result')
+ 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
Modified: hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py?rev=1669718&r1=1669717&r2=1669718&view=diff
==============================================================================
--- hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py (original)
+++ hive/branches/llap/metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py Sat Mar 28 00:22:15 2015
@@ -8160,6 +8160,118 @@ class ShowCompactResponse:
def __ne__(self, other):
return not (self == other)
+class AddDynamicPartitions:
+ """
+ Attributes:
+ - txnid
+ - dbname
+ - tablename
+ - partitionnames
+ """
+
+ thrift_spec = (
+ None, # 0
+ (1, TType.I64, 'txnid', None, None, ), # 1
+ (2, TType.STRING, 'dbname', None, None, ), # 2
+ (3, TType.STRING, 'tablename', None, None, ), # 3
+ (4, TType.LIST, 'partitionnames', (TType.STRING,None), None, ), # 4
+ )
+
+ def __init__(self, txnid=None, dbname=None, tablename=None, partitionnames=None,):
+ self.txnid = txnid
+ self.dbname = dbname
+ self.tablename = tablename
+ self.partitionnames = partitionnames
+
+ 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.I64:
+ self.txnid = iprot.readI64();
+ else:
+ iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.STRING:
+ self.dbname = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.STRING:
+ self.tablename = iprot.readString();
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.LIST:
+ self.partitionnames = []
+ (_etype437, _size434) = iprot.readListBegin()
+ for _i438 in xrange(_size434):
+ _elem439 = iprot.readString();
+ self.partitionnames.append(_elem439)
+ iprot.readListEnd()
+ else:
+ iprot.skip(ftype)
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('AddDynamicPartitions')
+ if self.txnid is not None:
+ oprot.writeFieldBegin('txnid', TType.I64, 1)
+ oprot.writeI64(self.txnid)
+ oprot.writeFieldEnd()
+ if self.dbname is not None:
+ oprot.writeFieldBegin('dbname', TType.STRING, 2)
+ oprot.writeString(self.dbname)
+ oprot.writeFieldEnd()
+ if self.tablename is not None:
+ oprot.writeFieldBegin('tablename', TType.STRING, 3)
+ oprot.writeString(self.tablename)
+ oprot.writeFieldEnd()
+ if self.partitionnames is not None:
+ oprot.writeFieldBegin('partitionnames', TType.LIST, 4)
+ oprot.writeListBegin(TType.STRING, len(self.partitionnames))
+ for iter440 in self.partitionnames:
+ oprot.writeString(iter440)
+ oprot.writeListEnd()
+ oprot.writeFieldEnd()
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ if self.txnid is None:
+ raise TProtocol.TProtocolException(message='Required field txnid is unset!')
+ if self.dbname is None:
+ raise TProtocol.TProtocolException(message='Required field dbname is unset!')
+ if self.tablename is None:
+ raise TProtocol.TProtocolException(message='Required field tablename is unset!')
+ if self.partitionnames is None:
+ raise TProtocol.TProtocolException(message='Required field partitionnames is unset!')
+ return
+
+
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
class NotificationEventRequest:
"""
Attributes:
@@ -8388,11 +8500,11 @@ class NotificationEventResponse:
if fid == 1:
if ftype == TType.LIST:
self.events = []
- (_etype437, _size434) = iprot.readListBegin()
- for _i438 in xrange(_size434):
- _elem439 = NotificationEvent()
- _elem439.read(iprot)
- self.events.append(_elem439)
+ (_etype444, _size441) = iprot.readListBegin()
+ for _i445 in xrange(_size441):
+ _elem446 = NotificationEvent()
+ _elem446.read(iprot)
+ self.events.append(_elem446)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8409,8 +8521,8 @@ class NotificationEventResponse:
if self.events is not None:
oprot.writeFieldBegin('events', TType.LIST, 1)
oprot.writeListBegin(TType.STRUCT, len(self.events))
- for iter440 in self.events:
- iter440.write(oprot)
+ for iter447 in self.events:
+ iter447.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8521,10 +8633,10 @@ class InsertEventRequestData:
if fid == 1:
if ftype == TType.LIST:
self.filesAdded = []
- (_etype444, _size441) = iprot.readListBegin()
- for _i445 in xrange(_size441):
- _elem446 = iprot.readString();
- self.filesAdded.append(_elem446)
+ (_etype451, _size448) = iprot.readListBegin()
+ for _i452 in xrange(_size448):
+ _elem453 = iprot.readString();
+ self.filesAdded.append(_elem453)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8541,8 +8653,8 @@ class InsertEventRequestData:
if self.filesAdded is not None:
oprot.writeFieldBegin('filesAdded', TType.LIST, 1)
oprot.writeListBegin(TType.STRING, len(self.filesAdded))
- for iter447 in self.filesAdded:
- oprot.writeString(iter447)
+ for iter454 in self.filesAdded:
+ oprot.writeString(iter454)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
@@ -8685,10 +8797,10 @@ class FireEventRequest:
elif fid == 5:
if ftype == TType.LIST:
self.partitionVals = []
- (_etype451, _size448) = iprot.readListBegin()
- for _i452 in xrange(_size448):
- _elem453 = iprot.readString();
- self.partitionVals.append(_elem453)
+ (_etype458, _size455) = iprot.readListBegin()
+ for _i459 in xrange(_size455):
+ _elem460 = iprot.readString();
+ self.partitionVals.append(_elem460)
iprot.readListEnd()
else:
iprot.skip(ftype)
@@ -8721,8 +8833,8 @@ class FireEventRequest:
if self.partitionVals is not None:
oprot.writeFieldBegin('partitionVals', TType.LIST, 5)
oprot.writeListBegin(TType.STRING, len(self.partitionVals))
- for iter454 in self.partitionVals:
- oprot.writeString(iter454)
+ for iter461 in self.partitionVals:
+ oprot.writeString(iter461)
oprot.writeListEnd()
oprot.writeFieldEnd()
oprot.writeFieldStop()
Modified: hive/branches/llap/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb
URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb?rev=1669718&r1=1669717&r2=1669718&view=diff
==============================================================================
--- hive/branches/llap/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb (original)
+++ hive/branches/llap/metastore/src/gen/thrift/gen-rb/hive_metastore_types.rb Sat Mar 28 00:22:15 2015
@@ -1994,6 +1994,32 @@ class ShowCompactResponse
::Thrift::Struct.generate_accessors self
end
+class AddDynamicPartitions
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ TXNID = 1
+ DBNAME = 2
+ TABLENAME = 3
+ PARTITIONNAMES = 4
+
+ FIELDS = {
+ TXNID => {:type => ::Thrift::Types::I64, :name => 'txnid'},
+ DBNAME => {:type => ::Thrift::Types::STRING, :name => 'dbname'},
+ TABLENAME => {:type => ::Thrift::Types::STRING, :name => 'tablename'},
+ PARTITIONNAMES => {:type => ::Thrift::Types::LIST, :name => 'partitionnames', :element => {:type => ::Thrift::Types::STRING}}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field txnid is unset!') unless @txnid
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field dbname is unset!') unless @dbname
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field tablename is unset!') unless @tablename
+ raise ::Thrift::ProtocolException.new(::Thrift::ProtocolException::UNKNOWN, 'Required field partitionnames is unset!') unless @partitionnames
+ end
+
+ ::Thrift::Struct.generate_accessors self
+end
+
class NotificationEventRequest
include ::Thrift::Struct, ::Thrift::Struct_Union
LASTEVENT = 1
Modified: hive/branches/llap/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
URL: http://svn.apache.org/viewvc/hive/branches/llap/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb?rev=1669718&r1=1669717&r2=1669718&view=diff
==============================================================================
--- hive/branches/llap/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb (original)
+++ hive/branches/llap/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb Sat Mar 28 00:22:15 2015
@@ -2013,6 +2013,22 @@ module ThriftHiveMetastore
raise ::Thrift::ApplicationException.new(::Thrift::ApplicationException::MISSING_RESULT, 'show_compact failed: unknown result')
end
+ def add_dynamic_partitions(rqst)
+ send_add_dynamic_partitions(rqst)
+ recv_add_dynamic_partitions()
+ end
+
+ def send_add_dynamic_partitions(rqst)
+ send_message('add_dynamic_partitions', Add_dynamic_partitions_args, :rqst => rqst)
+ end
+
+ def recv_add_dynamic_partitions()
+ result = receive_message(Add_dynamic_partitions_result)
+ raise result.o1 unless result.o1.nil?
+ raise result.o2 unless result.o2.nil?
+ return
+ end
+
def get_next_notification(rqst)
send_get_next_notification(rqst)
return recv_get_next_notification()
@@ -3604,6 +3620,19 @@ module ThriftHiveMetastore
write_result(result, oprot, 'show_compact', seqid)
end
+ def process_add_dynamic_partitions(seqid, iprot, oprot)
+ args = read_args(iprot, Add_dynamic_partitions_args)
+ result = Add_dynamic_partitions_result.new()
+ begin
+ @handler.add_dynamic_partitions(args.rqst)
+ rescue ::NoSuchTxnException => o1
+ result.o1 = o1
+ rescue ::TxnAbortedException => o2
+ result.o2 = o2
+ end
+ write_result(result, oprot, 'add_dynamic_partitions', seqid)
+ end
+
def process_get_next_notification(seqid, iprot, oprot)
args = read_args(iprot, Get_next_notification_args)
result = Get_next_notification_result.new()
@@ -8190,6 +8219,40 @@ module ThriftHiveMetastore
}
def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Add_dynamic_partitions_args
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ RQST = 1
+
+ FIELDS = {
+ RQST => {:type => ::Thrift::Types::STRUCT, :name => 'rqst', :class => ::AddDynamicPartitions}
+ }
+
+ def struct_fields; FIELDS; end
+
+ def validate
+ end
+
+ ::Thrift::Struct.generate_accessors self
+ end
+
+ class Add_dynamic_partitions_result
+ include ::Thrift::Struct, ::Thrift::Struct_Union
+ O1 = 1
+ O2 = 2
+
+ FIELDS = {
+ O1 => {:type => ::Thrift::Types::STRUCT, :name => 'o1', :class => ::NoSuchTxnException},
+ O2 => {:type => ::Thrift::Types::STRUCT, :name => 'o2', :class => ::TxnAbortedException}
+ }
+
+ def struct_fields; FIELDS; end
def validate
end