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/03/30 20:39:34 UTC
svn commit: r1583185 [6/7] - in /hive/trunk:
itests/hive-unit/src/test/java/org/apache/hadoop/hive/metastore/
metastore/if/ metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/
metastore/src/gen/...
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java Sun Mar 30 18:39:33 2014
@@ -618,7 +618,7 @@ public class Type implements org.apache.
struct.fields = new ArrayList<FieldSchema>(_list0.size);
for (int _i1 = 0; _i1 < _list0.size; ++_i1)
{
- FieldSchema _elem2; // optional
+ FieldSchema _elem2; // required
_elem2 = new FieldSchema();
_elem2.read(iprot);
struct.fields.add(_elem2);
@@ -749,7 +749,7 @@ public class Type implements org.apache.
struct.fields = new ArrayList<FieldSchema>(_list5.size);
for (int _i6 = 0; _i6 < _list5.size; ++_i6)
{
- FieldSchema _elem7; // optional
+ FieldSchema _elem7; // required
_elem7 = new FieldSchema();
_elem7.read(iprot);
struct.fields.add(_elem7);
Modified: hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php?rev=1583185&r1=1583184&r2=1583185&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php Sun Mar 30 18:39:33 2014
@@ -120,6 +120,7 @@ interface ThriftHiveMetastoreIf extends
public function unlock(\metastore\UnlockRequest $rqst);
public function show_locks(\metastore\ShowLocksRequest $rqst);
public function heartbeat(\metastore\HeartbeatRequest $ids);
+ public function heartbeat_txn_range(\metastore\HeartbeatTxnRangeRequest $txns);
public function compact(\metastore\CompactionRequest $rqst);
public function show_compact(\metastore\ShowCompactRequest $rqst);
}
@@ -6153,6 +6154,57 @@ class ThriftHiveMetastoreClient extends
return;
}
+ public function heartbeat_txn_range(\metastore\HeartbeatTxnRangeRequest $txns)
+ {
+ $this->send_heartbeat_txn_range($txns);
+ return $this->recv_heartbeat_txn_range();
+ }
+
+ public function send_heartbeat_txn_range(\metastore\HeartbeatTxnRangeRequest $txns)
+ {
+ $args = new \metastore\ThriftHiveMetastore_heartbeat_txn_range_args();
+ $args->txns = $txns;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'heartbeat_txn_range', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('heartbeat_txn_range', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_heartbeat_txn_range()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_heartbeat_txn_range_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_heartbeat_txn_range_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ throw new \Exception("heartbeat_txn_range failed: unknown result");
+ }
+
public function compact(\metastore\CompactionRequest $rqst)
{
$this->send_compact($rqst);
@@ -7002,14 +7054,14 @@ class ThriftHiveMetastore_get_databases_
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size377 = 0;
- $_etype380 = 0;
- $xfer += $input->readListBegin($_etype380, $_size377);
- for ($_i381 = 0; $_i381 < $_size377; ++$_i381)
+ $_size393 = 0;
+ $_etype396 = 0;
+ $xfer += $input->readListBegin($_etype396, $_size393);
+ for ($_i397 = 0; $_i397 < $_size393; ++$_i397)
{
- $elem382 = null;
- $xfer += $input->readString($elem382);
- $this->success []= $elem382;
+ $elem398 = null;
+ $xfer += $input->readString($elem398);
+ $this->success []= $elem398;
}
$xfer += $input->readListEnd();
} else {
@@ -7045,9 +7097,9 @@ class ThriftHiveMetastore_get_databases_
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter383)
+ foreach ($this->success as $iter399)
{
- $xfer += $output->writeString($iter383);
+ $xfer += $output->writeString($iter399);
}
}
$output->writeListEnd();
@@ -7172,14 +7224,14 @@ class ThriftHiveMetastore_get_all_databa
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size384 = 0;
- $_etype387 = 0;
- $xfer += $input->readListBegin($_etype387, $_size384);
- for ($_i388 = 0; $_i388 < $_size384; ++$_i388)
+ $_size400 = 0;
+ $_etype403 = 0;
+ $xfer += $input->readListBegin($_etype403, $_size400);
+ for ($_i404 = 0; $_i404 < $_size400; ++$_i404)
{
- $elem389 = null;
- $xfer += $input->readString($elem389);
- $this->success []= $elem389;
+ $elem405 = null;
+ $xfer += $input->readString($elem405);
+ $this->success []= $elem405;
}
$xfer += $input->readListEnd();
} else {
@@ -7215,9 +7267,9 @@ class ThriftHiveMetastore_get_all_databa
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter390)
+ foreach ($this->success as $iter406)
{
- $xfer += $output->writeString($iter390);
+ $xfer += $output->writeString($iter406);
}
}
$output->writeListEnd();
@@ -8158,18 +8210,18 @@ class ThriftHiveMetastore_get_type_all_r
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size391 = 0;
- $_ktype392 = 0;
- $_vtype393 = 0;
- $xfer += $input->readMapBegin($_ktype392, $_vtype393, $_size391);
- for ($_i395 = 0; $_i395 < $_size391; ++$_i395)
+ $_size407 = 0;
+ $_ktype408 = 0;
+ $_vtype409 = 0;
+ $xfer += $input->readMapBegin($_ktype408, $_vtype409, $_size407);
+ for ($_i411 = 0; $_i411 < $_size407; ++$_i411)
{
- $key396 = '';
- $val397 = new \metastore\Type();
- $xfer += $input->readString($key396);
- $val397 = new \metastore\Type();
- $xfer += $val397->read($input);
- $this->success[$key396] = $val397;
+ $key412 = '';
+ $val413 = new \metastore\Type();
+ $xfer += $input->readString($key412);
+ $val413 = new \metastore\Type();
+ $xfer += $val413->read($input);
+ $this->success[$key412] = $val413;
}
$xfer += $input->readMapEnd();
} else {
@@ -8205,10 +8257,10 @@ class ThriftHiveMetastore_get_type_all_r
{
$output->writeMapBegin(TType::STRING, TType::STRUCT, count($this->success));
{
- foreach ($this->success as $kiter398 => $viter399)
+ foreach ($this->success as $kiter414 => $viter415)
{
- $xfer += $output->writeString($kiter398);
- $xfer += $viter399->write($output);
+ $xfer += $output->writeString($kiter414);
+ $xfer += $viter415->write($output);
}
}
$output->writeMapEnd();
@@ -8394,15 +8446,15 @@ class ThriftHiveMetastore_get_fields_res
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size400 = 0;
- $_etype403 = 0;
- $xfer += $input->readListBegin($_etype403, $_size400);
- for ($_i404 = 0; $_i404 < $_size400; ++$_i404)
+ $_size416 = 0;
+ $_etype419 = 0;
+ $xfer += $input->readListBegin($_etype419, $_size416);
+ for ($_i420 = 0; $_i420 < $_size416; ++$_i420)
{
- $elem405 = null;
- $elem405 = new \metastore\FieldSchema();
- $xfer += $elem405->read($input);
- $this->success []= $elem405;
+ $elem421 = null;
+ $elem421 = new \metastore\FieldSchema();
+ $xfer += $elem421->read($input);
+ $this->success []= $elem421;
}
$xfer += $input->readListEnd();
} else {
@@ -8454,9 +8506,9 @@ class ThriftHiveMetastore_get_fields_res
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter406)
+ foreach ($this->success as $iter422)
{
- $xfer += $iter406->write($output);
+ $xfer += $iter422->write($output);
}
}
$output->writeListEnd();
@@ -8652,15 +8704,15 @@ class ThriftHiveMetastore_get_schema_res
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size407 = 0;
- $_etype410 = 0;
- $xfer += $input->readListBegin($_etype410, $_size407);
- for ($_i411 = 0; $_i411 < $_size407; ++$_i411)
+ $_size423 = 0;
+ $_etype426 = 0;
+ $xfer += $input->readListBegin($_etype426, $_size423);
+ for ($_i427 = 0; $_i427 < $_size423; ++$_i427)
{
- $elem412 = null;
- $elem412 = new \metastore\FieldSchema();
- $xfer += $elem412->read($input);
- $this->success []= $elem412;
+ $elem428 = null;
+ $elem428 = new \metastore\FieldSchema();
+ $xfer += $elem428->read($input);
+ $this->success []= $elem428;
}
$xfer += $input->readListEnd();
} else {
@@ -8712,9 +8764,9 @@ class ThriftHiveMetastore_get_schema_res
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter413)
+ foreach ($this->success as $iter429)
{
- $xfer += $iter413->write($output);
+ $xfer += $iter429->write($output);
}
}
$output->writeListEnd();
@@ -9791,14 +9843,14 @@ class ThriftHiveMetastore_get_tables_res
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size414 = 0;
- $_etype417 = 0;
- $xfer += $input->readListBegin($_etype417, $_size414);
- for ($_i418 = 0; $_i418 < $_size414; ++$_i418)
+ $_size430 = 0;
+ $_etype433 = 0;
+ $xfer += $input->readListBegin($_etype433, $_size430);
+ for ($_i434 = 0; $_i434 < $_size430; ++$_i434)
{
- $elem419 = null;
- $xfer += $input->readString($elem419);
- $this->success []= $elem419;
+ $elem435 = null;
+ $xfer += $input->readString($elem435);
+ $this->success []= $elem435;
}
$xfer += $input->readListEnd();
} else {
@@ -9834,9 +9886,9 @@ class ThriftHiveMetastore_get_tables_res
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter420)
+ foreach ($this->success as $iter436)
{
- $xfer += $output->writeString($iter420);
+ $xfer += $output->writeString($iter436);
}
}
$output->writeListEnd();
@@ -9983,14 +10035,14 @@ class ThriftHiveMetastore_get_all_tables
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size421 = 0;
- $_etype424 = 0;
- $xfer += $input->readListBegin($_etype424, $_size421);
- for ($_i425 = 0; $_i425 < $_size421; ++$_i425)
+ $_size437 = 0;
+ $_etype440 = 0;
+ $xfer += $input->readListBegin($_etype440, $_size437);
+ for ($_i441 = 0; $_i441 < $_size437; ++$_i441)
{
- $elem426 = null;
- $xfer += $input->readString($elem426);
- $this->success []= $elem426;
+ $elem442 = null;
+ $xfer += $input->readString($elem442);
+ $this->success []= $elem442;
}
$xfer += $input->readListEnd();
} else {
@@ -10026,9 +10078,9 @@ class ThriftHiveMetastore_get_all_tables
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter427)
+ foreach ($this->success as $iter443)
{
- $xfer += $output->writeString($iter427);
+ $xfer += $output->writeString($iter443);
}
}
$output->writeListEnd();
@@ -10322,14 +10374,14 @@ class ThriftHiveMetastore_get_table_obje
case 2:
if ($ftype == TType::LST) {
$this->tbl_names = array();
- $_size428 = 0;
- $_etype431 = 0;
- $xfer += $input->readListBegin($_etype431, $_size428);
- for ($_i432 = 0; $_i432 < $_size428; ++$_i432)
+ $_size444 = 0;
+ $_etype447 = 0;
+ $xfer += $input->readListBegin($_etype447, $_size444);
+ for ($_i448 = 0; $_i448 < $_size444; ++$_i448)
{
- $elem433 = null;
- $xfer += $input->readString($elem433);
- $this->tbl_names []= $elem433;
+ $elem449 = null;
+ $xfer += $input->readString($elem449);
+ $this->tbl_names []= $elem449;
}
$xfer += $input->readListEnd();
} else {
@@ -10362,9 +10414,9 @@ class ThriftHiveMetastore_get_table_obje
{
$output->writeListBegin(TType::STRING, count($this->tbl_names));
{
- foreach ($this->tbl_names as $iter434)
+ foreach ($this->tbl_names as $iter450)
{
- $xfer += $output->writeString($iter434);
+ $xfer += $output->writeString($iter450);
}
}
$output->writeListEnd();
@@ -10453,15 +10505,15 @@ class ThriftHiveMetastore_get_table_obje
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size435 = 0;
- $_etype438 = 0;
- $xfer += $input->readListBegin($_etype438, $_size435);
- for ($_i439 = 0; $_i439 < $_size435; ++$_i439)
+ $_size451 = 0;
+ $_etype454 = 0;
+ $xfer += $input->readListBegin($_etype454, $_size451);
+ for ($_i455 = 0; $_i455 < $_size451; ++$_i455)
{
- $elem440 = null;
- $elem440 = new \metastore\Table();
- $xfer += $elem440->read($input);
- $this->success []= $elem440;
+ $elem456 = null;
+ $elem456 = new \metastore\Table();
+ $xfer += $elem456->read($input);
+ $this->success []= $elem456;
}
$xfer += $input->readListEnd();
} else {
@@ -10513,9 +10565,9 @@ class ThriftHiveMetastore_get_table_obje
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter441)
+ foreach ($this->success as $iter457)
{
- $xfer += $iter441->write($output);
+ $xfer += $iter457->write($output);
}
}
$output->writeListEnd();
@@ -10730,14 +10782,14 @@ class ThriftHiveMetastore_get_table_name
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size442 = 0;
- $_etype445 = 0;
- $xfer += $input->readListBegin($_etype445, $_size442);
- for ($_i446 = 0; $_i446 < $_size442; ++$_i446)
+ $_size458 = 0;
+ $_etype461 = 0;
+ $xfer += $input->readListBegin($_etype461, $_size458);
+ for ($_i462 = 0; $_i462 < $_size458; ++$_i462)
{
- $elem447 = null;
- $xfer += $input->readString($elem447);
- $this->success []= $elem447;
+ $elem463 = null;
+ $xfer += $input->readString($elem463);
+ $this->success []= $elem463;
}
$xfer += $input->readListEnd();
} else {
@@ -10789,9 +10841,9 @@ class ThriftHiveMetastore_get_table_name
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter448)
+ foreach ($this->success as $iter464)
{
- $xfer += $output->writeString($iter448);
+ $xfer += $output->writeString($iter464);
}
}
$output->writeListEnd();
@@ -11784,15 +11836,15 @@ class ThriftHiveMetastore_add_partitions
case 1:
if ($ftype == TType::LST) {
$this->new_parts = array();
- $_size449 = 0;
- $_etype452 = 0;
- $xfer += $input->readListBegin($_etype452, $_size449);
- for ($_i453 = 0; $_i453 < $_size449; ++$_i453)
+ $_size465 = 0;
+ $_etype468 = 0;
+ $xfer += $input->readListBegin($_etype468, $_size465);
+ for ($_i469 = 0; $_i469 < $_size465; ++$_i469)
{
- $elem454 = null;
- $elem454 = new \metastore\Partition();
- $xfer += $elem454->read($input);
- $this->new_parts []= $elem454;
+ $elem470 = null;
+ $elem470 = new \metastore\Partition();
+ $xfer += $elem470->read($input);
+ $this->new_parts []= $elem470;
}
$xfer += $input->readListEnd();
} else {
@@ -11820,9 +11872,9 @@ class ThriftHiveMetastore_add_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->new_parts));
{
- foreach ($this->new_parts as $iter455)
+ foreach ($this->new_parts as $iter471)
{
- $xfer += $iter455->write($output);
+ $xfer += $iter471->write($output);
}
}
$output->writeListEnd();
@@ -12051,14 +12103,14 @@ class ThriftHiveMetastore_append_partiti
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size456 = 0;
- $_etype459 = 0;
- $xfer += $input->readListBegin($_etype459, $_size456);
- for ($_i460 = 0; $_i460 < $_size456; ++$_i460)
+ $_size472 = 0;
+ $_etype475 = 0;
+ $xfer += $input->readListBegin($_etype475, $_size472);
+ for ($_i476 = 0; $_i476 < $_size472; ++$_i476)
{
- $elem461 = null;
- $xfer += $input->readString($elem461);
- $this->part_vals []= $elem461;
+ $elem477 = null;
+ $xfer += $input->readString($elem477);
+ $this->part_vals []= $elem477;
}
$xfer += $input->readListEnd();
} else {
@@ -12096,9 +12148,9 @@ class ThriftHiveMetastore_append_partiti
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter462)
+ foreach ($this->part_vals as $iter478)
{
- $xfer += $output->writeString($iter462);
+ $xfer += $output->writeString($iter478);
}
}
$output->writeListEnd();
@@ -12561,14 +12613,14 @@ class ThriftHiveMetastore_append_partiti
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size463 = 0;
- $_etype466 = 0;
- $xfer += $input->readListBegin($_etype466, $_size463);
- for ($_i467 = 0; $_i467 < $_size463; ++$_i467)
+ $_size479 = 0;
+ $_etype482 = 0;
+ $xfer += $input->readListBegin($_etype482, $_size479);
+ for ($_i483 = 0; $_i483 < $_size479; ++$_i483)
{
- $elem468 = null;
- $xfer += $input->readString($elem468);
- $this->part_vals []= $elem468;
+ $elem484 = null;
+ $xfer += $input->readString($elem484);
+ $this->part_vals []= $elem484;
}
$xfer += $input->readListEnd();
} else {
@@ -12614,9 +12666,9 @@ class ThriftHiveMetastore_append_partiti
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter469)
+ foreach ($this->part_vals as $iter485)
{
- $xfer += $output->writeString($iter469);
+ $xfer += $output->writeString($iter485);
}
}
$output->writeListEnd();
@@ -13401,14 +13453,14 @@ class ThriftHiveMetastore_drop_partition
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size470 = 0;
- $_etype473 = 0;
- $xfer += $input->readListBegin($_etype473, $_size470);
- for ($_i474 = 0; $_i474 < $_size470; ++$_i474)
+ $_size486 = 0;
+ $_etype489 = 0;
+ $xfer += $input->readListBegin($_etype489, $_size486);
+ for ($_i490 = 0; $_i490 < $_size486; ++$_i490)
{
- $elem475 = null;
- $xfer += $input->readString($elem475);
- $this->part_vals []= $elem475;
+ $elem491 = null;
+ $xfer += $input->readString($elem491);
+ $this->part_vals []= $elem491;
}
$xfer += $input->readListEnd();
} else {
@@ -13453,9 +13505,9 @@ class ThriftHiveMetastore_drop_partition
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter476)
+ foreach ($this->part_vals as $iter492)
{
- $xfer += $output->writeString($iter476);
+ $xfer += $output->writeString($iter492);
}
}
$output->writeListEnd();
@@ -13684,14 +13736,14 @@ class ThriftHiveMetastore_drop_partition
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size477 = 0;
- $_etype480 = 0;
- $xfer += $input->readListBegin($_etype480, $_size477);
- for ($_i481 = 0; $_i481 < $_size477; ++$_i481)
+ $_size493 = 0;
+ $_etype496 = 0;
+ $xfer += $input->readListBegin($_etype496, $_size493);
+ for ($_i497 = 0; $_i497 < $_size493; ++$_i497)
{
- $elem482 = null;
- $xfer += $input->readString($elem482);
- $this->part_vals []= $elem482;
+ $elem498 = null;
+ $xfer += $input->readString($elem498);
+ $this->part_vals []= $elem498;
}
$xfer += $input->readListEnd();
} else {
@@ -13744,9 +13796,9 @@ class ThriftHiveMetastore_drop_partition
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter483)
+ foreach ($this->part_vals as $iter499)
{
- $xfer += $output->writeString($iter483);
+ $xfer += $output->writeString($iter499);
}
}
$output->writeListEnd();
@@ -14685,14 +14737,14 @@ class ThriftHiveMetastore_get_partition_
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size484 = 0;
- $_etype487 = 0;
- $xfer += $input->readListBegin($_etype487, $_size484);
- for ($_i488 = 0; $_i488 < $_size484; ++$_i488)
+ $_size500 = 0;
+ $_etype503 = 0;
+ $xfer += $input->readListBegin($_etype503, $_size500);
+ for ($_i504 = 0; $_i504 < $_size500; ++$_i504)
{
- $elem489 = null;
- $xfer += $input->readString($elem489);
- $this->part_vals []= $elem489;
+ $elem505 = null;
+ $xfer += $input->readString($elem505);
+ $this->part_vals []= $elem505;
}
$xfer += $input->readListEnd();
} else {
@@ -14730,9 +14782,9 @@ class ThriftHiveMetastore_get_partition_
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter490)
+ foreach ($this->part_vals as $iter506)
{
- $xfer += $output->writeString($iter490);
+ $xfer += $output->writeString($iter506);
}
}
$output->writeListEnd();
@@ -14950,17 +15002,17 @@ class ThriftHiveMetastore_exchange_parti
case 1:
if ($ftype == TType::MAP) {
$this->partitionSpecs = array();
- $_size491 = 0;
- $_ktype492 = 0;
- $_vtype493 = 0;
- $xfer += $input->readMapBegin($_ktype492, $_vtype493, $_size491);
- for ($_i495 = 0; $_i495 < $_size491; ++$_i495)
+ $_size507 = 0;
+ $_ktype508 = 0;
+ $_vtype509 = 0;
+ $xfer += $input->readMapBegin($_ktype508, $_vtype509, $_size507);
+ for ($_i511 = 0; $_i511 < $_size507; ++$_i511)
{
- $key496 = '';
- $val497 = '';
- $xfer += $input->readString($key496);
- $xfer += $input->readString($val497);
- $this->partitionSpecs[$key496] = $val497;
+ $key512 = '';
+ $val513 = '';
+ $xfer += $input->readString($key512);
+ $xfer += $input->readString($val513);
+ $this->partitionSpecs[$key512] = $val513;
}
$xfer += $input->readMapEnd();
} else {
@@ -15016,10 +15068,10 @@ class ThriftHiveMetastore_exchange_parti
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->partitionSpecs));
{
- foreach ($this->partitionSpecs as $kiter498 => $viter499)
+ foreach ($this->partitionSpecs as $kiter514 => $viter515)
{
- $xfer += $output->writeString($kiter498);
- $xfer += $output->writeString($viter499);
+ $xfer += $output->writeString($kiter514);
+ $xfer += $output->writeString($viter515);
}
}
$output->writeMapEnd();
@@ -15315,14 +15367,14 @@ class ThriftHiveMetastore_get_partition_
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size500 = 0;
- $_etype503 = 0;
- $xfer += $input->readListBegin($_etype503, $_size500);
- for ($_i504 = 0; $_i504 < $_size500; ++$_i504)
+ $_size516 = 0;
+ $_etype519 = 0;
+ $xfer += $input->readListBegin($_etype519, $_size516);
+ for ($_i520 = 0; $_i520 < $_size516; ++$_i520)
{
- $elem505 = null;
- $xfer += $input->readString($elem505);
- $this->part_vals []= $elem505;
+ $elem521 = null;
+ $xfer += $input->readString($elem521);
+ $this->part_vals []= $elem521;
}
$xfer += $input->readListEnd();
} else {
@@ -15339,14 +15391,14 @@ class ThriftHiveMetastore_get_partition_
case 5:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size506 = 0;
- $_etype509 = 0;
- $xfer += $input->readListBegin($_etype509, $_size506);
- for ($_i510 = 0; $_i510 < $_size506; ++$_i510)
+ $_size522 = 0;
+ $_etype525 = 0;
+ $xfer += $input->readListBegin($_etype525, $_size522);
+ for ($_i526 = 0; $_i526 < $_size522; ++$_i526)
{
- $elem511 = null;
- $xfer += $input->readString($elem511);
- $this->group_names []= $elem511;
+ $elem527 = null;
+ $xfer += $input->readString($elem527);
+ $this->group_names []= $elem527;
}
$xfer += $input->readListEnd();
} else {
@@ -15384,9 +15436,9 @@ class ThriftHiveMetastore_get_partition_
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter512)
+ foreach ($this->part_vals as $iter528)
{
- $xfer += $output->writeString($iter512);
+ $xfer += $output->writeString($iter528);
}
}
$output->writeListEnd();
@@ -15406,9 +15458,9 @@ class ThriftHiveMetastore_get_partition_
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter513)
+ foreach ($this->group_names as $iter529)
{
- $xfer += $output->writeString($iter513);
+ $xfer += $output->writeString($iter529);
}
}
$output->writeListEnd();
@@ -15954,15 +16006,15 @@ class ThriftHiveMetastore_get_partitions
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size514 = 0;
- $_etype517 = 0;
- $xfer += $input->readListBegin($_etype517, $_size514);
- for ($_i518 = 0; $_i518 < $_size514; ++$_i518)
+ $_size530 = 0;
+ $_etype533 = 0;
+ $xfer += $input->readListBegin($_etype533, $_size530);
+ for ($_i534 = 0; $_i534 < $_size530; ++$_i534)
{
- $elem519 = null;
- $elem519 = new \metastore\Partition();
- $xfer += $elem519->read($input);
- $this->success []= $elem519;
+ $elem535 = null;
+ $elem535 = new \metastore\Partition();
+ $xfer += $elem535->read($input);
+ $this->success []= $elem535;
}
$xfer += $input->readListEnd();
} else {
@@ -16006,9 +16058,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter520)
+ foreach ($this->success as $iter536)
{
- $xfer += $iter520->write($output);
+ $xfer += $iter536->write($output);
}
}
$output->writeListEnd();
@@ -16139,14 +16191,14 @@ class ThriftHiveMetastore_get_partitions
case 5:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size521 = 0;
- $_etype524 = 0;
- $xfer += $input->readListBegin($_etype524, $_size521);
- for ($_i525 = 0; $_i525 < $_size521; ++$_i525)
+ $_size537 = 0;
+ $_etype540 = 0;
+ $xfer += $input->readListBegin($_etype540, $_size537);
+ for ($_i541 = 0; $_i541 < $_size537; ++$_i541)
{
- $elem526 = null;
- $xfer += $input->readString($elem526);
- $this->group_names []= $elem526;
+ $elem542 = null;
+ $xfer += $input->readString($elem542);
+ $this->group_names []= $elem542;
}
$xfer += $input->readListEnd();
} else {
@@ -16194,9 +16246,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter527)
+ foreach ($this->group_names as $iter543)
{
- $xfer += $output->writeString($iter527);
+ $xfer += $output->writeString($iter543);
}
}
$output->writeListEnd();
@@ -16276,15 +16328,15 @@ class ThriftHiveMetastore_get_partitions
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size528 = 0;
- $_etype531 = 0;
- $xfer += $input->readListBegin($_etype531, $_size528);
- for ($_i532 = 0; $_i532 < $_size528; ++$_i532)
+ $_size544 = 0;
+ $_etype547 = 0;
+ $xfer += $input->readListBegin($_etype547, $_size544);
+ for ($_i548 = 0; $_i548 < $_size544; ++$_i548)
{
- $elem533 = null;
- $elem533 = new \metastore\Partition();
- $xfer += $elem533->read($input);
- $this->success []= $elem533;
+ $elem549 = null;
+ $elem549 = new \metastore\Partition();
+ $xfer += $elem549->read($input);
+ $this->success []= $elem549;
}
$xfer += $input->readListEnd();
} else {
@@ -16328,9 +16380,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter534)
+ foreach ($this->success as $iter550)
{
- $xfer += $iter534->write($output);
+ $xfer += $iter550->write($output);
}
}
$output->writeListEnd();
@@ -16522,14 +16574,14 @@ class ThriftHiveMetastore_get_partition_
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size535 = 0;
- $_etype538 = 0;
- $xfer += $input->readListBegin($_etype538, $_size535);
- for ($_i539 = 0; $_i539 < $_size535; ++$_i539)
+ $_size551 = 0;
+ $_etype554 = 0;
+ $xfer += $input->readListBegin($_etype554, $_size551);
+ for ($_i555 = 0; $_i555 < $_size551; ++$_i555)
{
- $elem540 = null;
- $xfer += $input->readString($elem540);
- $this->success []= $elem540;
+ $elem556 = null;
+ $xfer += $input->readString($elem556);
+ $this->success []= $elem556;
}
$xfer += $input->readListEnd();
} else {
@@ -16565,9 +16617,9 @@ class ThriftHiveMetastore_get_partition_
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter541)
+ foreach ($this->success as $iter557)
{
- $xfer += $output->writeString($iter541);
+ $xfer += $output->writeString($iter557);
}
}
$output->writeListEnd();
@@ -16671,14 +16723,14 @@ class ThriftHiveMetastore_get_partitions
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size542 = 0;
- $_etype545 = 0;
- $xfer += $input->readListBegin($_etype545, $_size542);
- for ($_i546 = 0; $_i546 < $_size542; ++$_i546)
+ $_size558 = 0;
+ $_etype561 = 0;
+ $xfer += $input->readListBegin($_etype561, $_size558);
+ for ($_i562 = 0; $_i562 < $_size558; ++$_i562)
{
- $elem547 = null;
- $xfer += $input->readString($elem547);
- $this->part_vals []= $elem547;
+ $elem563 = null;
+ $xfer += $input->readString($elem563);
+ $this->part_vals []= $elem563;
}
$xfer += $input->readListEnd();
} else {
@@ -16723,9 +16775,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter548)
+ foreach ($this->part_vals as $iter564)
{
- $xfer += $output->writeString($iter548);
+ $xfer += $output->writeString($iter564);
}
}
$output->writeListEnd();
@@ -16810,15 +16862,15 @@ class ThriftHiveMetastore_get_partitions
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size549 = 0;
- $_etype552 = 0;
- $xfer += $input->readListBegin($_etype552, $_size549);
- for ($_i553 = 0; $_i553 < $_size549; ++$_i553)
+ $_size565 = 0;
+ $_etype568 = 0;
+ $xfer += $input->readListBegin($_etype568, $_size565);
+ for ($_i569 = 0; $_i569 < $_size565; ++$_i569)
{
- $elem554 = null;
- $elem554 = new \metastore\Partition();
- $xfer += $elem554->read($input);
- $this->success []= $elem554;
+ $elem570 = null;
+ $elem570 = new \metastore\Partition();
+ $xfer += $elem570->read($input);
+ $this->success []= $elem570;
}
$xfer += $input->readListEnd();
} else {
@@ -16862,9 +16914,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter555)
+ foreach ($this->success as $iter571)
{
- $xfer += $iter555->write($output);
+ $xfer += $iter571->write($output);
}
}
$output->writeListEnd();
@@ -16993,14 +17045,14 @@ class ThriftHiveMetastore_get_partitions
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size556 = 0;
- $_etype559 = 0;
- $xfer += $input->readListBegin($_etype559, $_size556);
- for ($_i560 = 0; $_i560 < $_size556; ++$_i560)
+ $_size572 = 0;
+ $_etype575 = 0;
+ $xfer += $input->readListBegin($_etype575, $_size572);
+ for ($_i576 = 0; $_i576 < $_size572; ++$_i576)
{
- $elem561 = null;
- $xfer += $input->readString($elem561);
- $this->part_vals []= $elem561;
+ $elem577 = null;
+ $xfer += $input->readString($elem577);
+ $this->part_vals []= $elem577;
}
$xfer += $input->readListEnd();
} else {
@@ -17024,14 +17076,14 @@ class ThriftHiveMetastore_get_partitions
case 6:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size562 = 0;
- $_etype565 = 0;
- $xfer += $input->readListBegin($_etype565, $_size562);
- for ($_i566 = 0; $_i566 < $_size562; ++$_i566)
+ $_size578 = 0;
+ $_etype581 = 0;
+ $xfer += $input->readListBegin($_etype581, $_size578);
+ for ($_i582 = 0; $_i582 < $_size578; ++$_i582)
{
- $elem567 = null;
- $xfer += $input->readString($elem567);
- $this->group_names []= $elem567;
+ $elem583 = null;
+ $xfer += $input->readString($elem583);
+ $this->group_names []= $elem583;
}
$xfer += $input->readListEnd();
} else {
@@ -17069,9 +17121,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter568)
+ foreach ($this->part_vals as $iter584)
{
- $xfer += $output->writeString($iter568);
+ $xfer += $output->writeString($iter584);
}
}
$output->writeListEnd();
@@ -17096,9 +17148,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter569)
+ foreach ($this->group_names as $iter585)
{
- $xfer += $output->writeString($iter569);
+ $xfer += $output->writeString($iter585);
}
}
$output->writeListEnd();
@@ -17178,15 +17230,15 @@ class ThriftHiveMetastore_get_partitions
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size570 = 0;
- $_etype573 = 0;
- $xfer += $input->readListBegin($_etype573, $_size570);
- for ($_i574 = 0; $_i574 < $_size570; ++$_i574)
+ $_size586 = 0;
+ $_etype589 = 0;
+ $xfer += $input->readListBegin($_etype589, $_size586);
+ for ($_i590 = 0; $_i590 < $_size586; ++$_i590)
{
- $elem575 = null;
- $elem575 = new \metastore\Partition();
- $xfer += $elem575->read($input);
- $this->success []= $elem575;
+ $elem591 = null;
+ $elem591 = new \metastore\Partition();
+ $xfer += $elem591->read($input);
+ $this->success []= $elem591;
}
$xfer += $input->readListEnd();
} else {
@@ -17230,9 +17282,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter576)
+ foreach ($this->success as $iter592)
{
- $xfer += $iter576->write($output);
+ $xfer += $iter592->write($output);
}
}
$output->writeListEnd();
@@ -17341,14 +17393,14 @@ class ThriftHiveMetastore_get_partition_
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size577 = 0;
- $_etype580 = 0;
- $xfer += $input->readListBegin($_etype580, $_size577);
- for ($_i581 = 0; $_i581 < $_size577; ++$_i581)
+ $_size593 = 0;
+ $_etype596 = 0;
+ $xfer += $input->readListBegin($_etype596, $_size593);
+ for ($_i597 = 0; $_i597 < $_size593; ++$_i597)
{
- $elem582 = null;
- $xfer += $input->readString($elem582);
- $this->part_vals []= $elem582;
+ $elem598 = null;
+ $xfer += $input->readString($elem598);
+ $this->part_vals []= $elem598;
}
$xfer += $input->readListEnd();
} else {
@@ -17393,9 +17445,9 @@ class ThriftHiveMetastore_get_partition_
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter583)
+ foreach ($this->part_vals as $iter599)
{
- $xfer += $output->writeString($iter583);
+ $xfer += $output->writeString($iter599);
}
}
$output->writeListEnd();
@@ -17479,14 +17531,14 @@ class ThriftHiveMetastore_get_partition_
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size584 = 0;
- $_etype587 = 0;
- $xfer += $input->readListBegin($_etype587, $_size584);
- for ($_i588 = 0; $_i588 < $_size584; ++$_i588)
+ $_size600 = 0;
+ $_etype603 = 0;
+ $xfer += $input->readListBegin($_etype603, $_size600);
+ for ($_i604 = 0; $_i604 < $_size600; ++$_i604)
{
- $elem589 = null;
- $xfer += $input->readString($elem589);
- $this->success []= $elem589;
+ $elem605 = null;
+ $xfer += $input->readString($elem605);
+ $this->success []= $elem605;
}
$xfer += $input->readListEnd();
} else {
@@ -17530,9 +17582,9 @@ class ThriftHiveMetastore_get_partition_
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter590)
+ foreach ($this->success as $iter606)
{
- $xfer += $output->writeString($iter590);
+ $xfer += $output->writeString($iter606);
}
}
$output->writeListEnd();
@@ -17754,15 +17806,15 @@ class ThriftHiveMetastore_get_partitions
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size591 = 0;
- $_etype594 = 0;
- $xfer += $input->readListBegin($_etype594, $_size591);
- for ($_i595 = 0; $_i595 < $_size591; ++$_i595)
+ $_size607 = 0;
+ $_etype610 = 0;
+ $xfer += $input->readListBegin($_etype610, $_size607);
+ for ($_i611 = 0; $_i611 < $_size607; ++$_i611)
{
- $elem596 = null;
- $elem596 = new \metastore\Partition();
- $xfer += $elem596->read($input);
- $this->success []= $elem596;
+ $elem612 = null;
+ $elem612 = new \metastore\Partition();
+ $xfer += $elem612->read($input);
+ $this->success []= $elem612;
}
$xfer += $input->readListEnd();
} else {
@@ -17806,9 +17858,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter597)
+ foreach ($this->success as $iter613)
{
- $xfer += $iter597->write($output);
+ $xfer += $iter613->write($output);
}
}
$output->writeListEnd();
@@ -18107,14 +18159,14 @@ class ThriftHiveMetastore_get_partitions
case 3:
if ($ftype == TType::LST) {
$this->names = array();
- $_size598 = 0;
- $_etype601 = 0;
- $xfer += $input->readListBegin($_etype601, $_size598);
- for ($_i602 = 0; $_i602 < $_size598; ++$_i602)
+ $_size614 = 0;
+ $_etype617 = 0;
+ $xfer += $input->readListBegin($_etype617, $_size614);
+ for ($_i618 = 0; $_i618 < $_size614; ++$_i618)
{
- $elem603 = null;
- $xfer += $input->readString($elem603);
- $this->names []= $elem603;
+ $elem619 = null;
+ $xfer += $input->readString($elem619);
+ $this->names []= $elem619;
}
$xfer += $input->readListEnd();
} else {
@@ -18152,9 +18204,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRING, count($this->names));
{
- foreach ($this->names as $iter604)
+ foreach ($this->names as $iter620)
{
- $xfer += $output->writeString($iter604);
+ $xfer += $output->writeString($iter620);
}
}
$output->writeListEnd();
@@ -18234,15 +18286,15 @@ class ThriftHiveMetastore_get_partitions
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size605 = 0;
- $_etype608 = 0;
- $xfer += $input->readListBegin($_etype608, $_size605);
- for ($_i609 = 0; $_i609 < $_size605; ++$_i609)
+ $_size621 = 0;
+ $_etype624 = 0;
+ $xfer += $input->readListBegin($_etype624, $_size621);
+ for ($_i625 = 0; $_i625 < $_size621; ++$_i625)
{
- $elem610 = null;
- $elem610 = new \metastore\Partition();
- $xfer += $elem610->read($input);
- $this->success []= $elem610;
+ $elem626 = null;
+ $elem626 = new \metastore\Partition();
+ $xfer += $elem626->read($input);
+ $this->success []= $elem626;
}
$xfer += $input->readListEnd();
} else {
@@ -18286,9 +18338,9 @@ class ThriftHiveMetastore_get_partitions
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter611)
+ foreach ($this->success as $iter627)
{
- $xfer += $iter611->write($output);
+ $xfer += $iter627->write($output);
}
}
$output->writeListEnd();
@@ -18603,15 +18655,15 @@ class ThriftHiveMetastore_alter_partitio
case 3:
if ($ftype == TType::LST) {
$this->new_parts = array();
- $_size612 = 0;
- $_etype615 = 0;
- $xfer += $input->readListBegin($_etype615, $_size612);
- for ($_i616 = 0; $_i616 < $_size612; ++$_i616)
+ $_size628 = 0;
+ $_etype631 = 0;
+ $xfer += $input->readListBegin($_etype631, $_size628);
+ for ($_i632 = 0; $_i632 < $_size628; ++$_i632)
{
- $elem617 = null;
- $elem617 = new \metastore\Partition();
- $xfer += $elem617->read($input);
- $this->new_parts []= $elem617;
+ $elem633 = null;
+ $elem633 = new \metastore\Partition();
+ $xfer += $elem633->read($input);
+ $this->new_parts []= $elem633;
}
$xfer += $input->readListEnd();
} else {
@@ -18649,9 +18701,9 @@ class ThriftHiveMetastore_alter_partitio
{
$output->writeListBegin(TType::STRUCT, count($this->new_parts));
{
- foreach ($this->new_parts as $iter618)
+ foreach ($this->new_parts as $iter634)
{
- $xfer += $iter618->write($output);
+ $xfer += $iter634->write($output);
}
}
$output->writeListEnd();
@@ -19085,14 +19137,14 @@ class ThriftHiveMetastore_rename_partiti
case 3:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size619 = 0;
- $_etype622 = 0;
- $xfer += $input->readListBegin($_etype622, $_size619);
- for ($_i623 = 0; $_i623 < $_size619; ++$_i623)
+ $_size635 = 0;
+ $_etype638 = 0;
+ $xfer += $input->readListBegin($_etype638, $_size635);
+ for ($_i639 = 0; $_i639 < $_size635; ++$_i639)
{
- $elem624 = null;
- $xfer += $input->readString($elem624);
- $this->part_vals []= $elem624;
+ $elem640 = null;
+ $xfer += $input->readString($elem640);
+ $this->part_vals []= $elem640;
}
$xfer += $input->readListEnd();
} else {
@@ -19138,9 +19190,9 @@ class ThriftHiveMetastore_rename_partiti
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter625)
+ foreach ($this->part_vals as $iter641)
{
- $xfer += $output->writeString($iter625);
+ $xfer += $output->writeString($iter641);
}
}
$output->writeListEnd();
@@ -19313,14 +19365,14 @@ class ThriftHiveMetastore_partition_name
case 1:
if ($ftype == TType::LST) {
$this->part_vals = array();
- $_size626 = 0;
- $_etype629 = 0;
- $xfer += $input->readListBegin($_etype629, $_size626);
- for ($_i630 = 0; $_i630 < $_size626; ++$_i630)
+ $_size642 = 0;
+ $_etype645 = 0;
+ $xfer += $input->readListBegin($_etype645, $_size642);
+ for ($_i646 = 0; $_i646 < $_size642; ++$_i646)
{
- $elem631 = null;
- $xfer += $input->readString($elem631);
- $this->part_vals []= $elem631;
+ $elem647 = null;
+ $xfer += $input->readString($elem647);
+ $this->part_vals []= $elem647;
}
$xfer += $input->readListEnd();
} else {
@@ -19355,9 +19407,9 @@ class ThriftHiveMetastore_partition_name
{
$output->writeListBegin(TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $iter632)
+ foreach ($this->part_vals as $iter648)
{
- $xfer += $output->writeString($iter632);
+ $xfer += $output->writeString($iter648);
}
}
$output->writeListEnd();
@@ -19784,14 +19836,14 @@ class ThriftHiveMetastore_partition_name
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size633 = 0;
- $_etype636 = 0;
- $xfer += $input->readListBegin($_etype636, $_size633);
- for ($_i637 = 0; $_i637 < $_size633; ++$_i637)
+ $_size649 = 0;
+ $_etype652 = 0;
+ $xfer += $input->readListBegin($_etype652, $_size649);
+ for ($_i653 = 0; $_i653 < $_size649; ++$_i653)
{
- $elem638 = null;
- $xfer += $input->readString($elem638);
- $this->success []= $elem638;
+ $elem654 = null;
+ $xfer += $input->readString($elem654);
+ $this->success []= $elem654;
}
$xfer += $input->readListEnd();
} else {
@@ -19827,9 +19879,9 @@ class ThriftHiveMetastore_partition_name
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter639)
+ foreach ($this->success as $iter655)
{
- $xfer += $output->writeString($iter639);
+ $xfer += $output->writeString($iter655);
}
}
$output->writeListEnd();
@@ -19980,17 +20032,17 @@ class ThriftHiveMetastore_partition_name
case 0:
if ($ftype == TType::MAP) {
$this->success = array();
- $_size640 = 0;
- $_ktype641 = 0;
- $_vtype642 = 0;
- $xfer += $input->readMapBegin($_ktype641, $_vtype642, $_size640);
- for ($_i644 = 0; $_i644 < $_size640; ++$_i644)
+ $_size656 = 0;
+ $_ktype657 = 0;
+ $_vtype658 = 0;
+ $xfer += $input->readMapBegin($_ktype657, $_vtype658, $_size656);
+ for ($_i660 = 0; $_i660 < $_size656; ++$_i660)
{
- $key645 = '';
- $val646 = '';
- $xfer += $input->readString($key645);
- $xfer += $input->readString($val646);
- $this->success[$key645] = $val646;
+ $key661 = '';
+ $val662 = '';
+ $xfer += $input->readString($key661);
+ $xfer += $input->readString($val662);
+ $this->success[$key661] = $val662;
}
$xfer += $input->readMapEnd();
} else {
@@ -20026,10 +20078,10 @@ class ThriftHiveMetastore_partition_name
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->success));
{
- foreach ($this->success as $kiter647 => $viter648)
+ foreach ($this->success as $kiter663 => $viter664)
{
- $xfer += $output->writeString($kiter647);
- $xfer += $output->writeString($viter648);
+ $xfer += $output->writeString($kiter663);
+ $xfer += $output->writeString($viter664);
}
}
$output->writeMapEnd();
@@ -20137,17 +20189,17 @@ class ThriftHiveMetastore_markPartitionF
case 3:
if ($ftype == TType::MAP) {
$this->part_vals = array();
- $_size649 = 0;
- $_ktype650 = 0;
- $_vtype651 = 0;
- $xfer += $input->readMapBegin($_ktype650, $_vtype651, $_size649);
- for ($_i653 = 0; $_i653 < $_size649; ++$_i653)
+ $_size665 = 0;
+ $_ktype666 = 0;
+ $_vtype667 = 0;
+ $xfer += $input->readMapBegin($_ktype666, $_vtype667, $_size665);
+ for ($_i669 = 0; $_i669 < $_size665; ++$_i669)
{
- $key654 = '';
- $val655 = '';
- $xfer += $input->readString($key654);
- $xfer += $input->readString($val655);
- $this->part_vals[$key654] = $val655;
+ $key670 = '';
+ $val671 = '';
+ $xfer += $input->readString($key670);
+ $xfer += $input->readString($val671);
+ $this->part_vals[$key670] = $val671;
}
$xfer += $input->readMapEnd();
} else {
@@ -20192,10 +20244,10 @@ class ThriftHiveMetastore_markPartitionF
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $kiter656 => $viter657)
+ foreach ($this->part_vals as $kiter672 => $viter673)
{
- $xfer += $output->writeString($kiter656);
- $xfer += $output->writeString($viter657);
+ $xfer += $output->writeString($kiter672);
+ $xfer += $output->writeString($viter673);
}
}
$output->writeMapEnd();
@@ -20487,17 +20539,17 @@ class ThriftHiveMetastore_isPartitionMar
case 3:
if ($ftype == TType::MAP) {
$this->part_vals = array();
- $_size658 = 0;
- $_ktype659 = 0;
- $_vtype660 = 0;
- $xfer += $input->readMapBegin($_ktype659, $_vtype660, $_size658);
- for ($_i662 = 0; $_i662 < $_size658; ++$_i662)
+ $_size674 = 0;
+ $_ktype675 = 0;
+ $_vtype676 = 0;
+ $xfer += $input->readMapBegin($_ktype675, $_vtype676, $_size674);
+ for ($_i678 = 0; $_i678 < $_size674; ++$_i678)
{
- $key663 = '';
- $val664 = '';
- $xfer += $input->readString($key663);
- $xfer += $input->readString($val664);
- $this->part_vals[$key663] = $val664;
+ $key679 = '';
+ $val680 = '';
+ $xfer += $input->readString($key679);
+ $xfer += $input->readString($val680);
+ $this->part_vals[$key679] = $val680;
}
$xfer += $input->readMapEnd();
} else {
@@ -20542,10 +20594,10 @@ class ThriftHiveMetastore_isPartitionMar
{
$output->writeMapBegin(TType::STRING, TType::STRING, count($this->part_vals));
{
- foreach ($this->part_vals as $kiter665 => $viter666)
+ foreach ($this->part_vals as $kiter681 => $viter682)
{
- $xfer += $output->writeString($kiter665);
- $xfer += $output->writeString($viter666);
+ $xfer += $output->writeString($kiter681);
+ $xfer += $output->writeString($viter682);
}
}
$output->writeMapEnd();
@@ -21905,15 +21957,15 @@ class ThriftHiveMetastore_get_indexes_re
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size667 = 0;
- $_etype670 = 0;
- $xfer += $input->readListBegin($_etype670, $_size667);
- for ($_i671 = 0; $_i671 < $_size667; ++$_i671)
+ $_size683 = 0;
+ $_etype686 = 0;
+ $xfer += $input->readListBegin($_etype686, $_size683);
+ for ($_i687 = 0; $_i687 < $_size683; ++$_i687)
{
- $elem672 = null;
- $elem672 = new \metastore\Index();
- $xfer += $elem672->read($input);
- $this->success []= $elem672;
+ $elem688 = null;
+ $elem688 = new \metastore\Index();
+ $xfer += $elem688->read($input);
+ $this->success []= $elem688;
}
$xfer += $input->readListEnd();
} else {
@@ -21957,9 +22009,9 @@ class ThriftHiveMetastore_get_indexes_re
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter673)
+ foreach ($this->success as $iter689)
{
- $xfer += $iter673->write($output);
+ $xfer += $iter689->write($output);
}
}
$output->writeListEnd();
@@ -22151,14 +22203,14 @@ class ThriftHiveMetastore_get_index_name
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size674 = 0;
- $_etype677 = 0;
- $xfer += $input->readListBegin($_etype677, $_size674);
- for ($_i678 = 0; $_i678 < $_size674; ++$_i678)
+ $_size690 = 0;
+ $_etype693 = 0;
+ $xfer += $input->readListBegin($_etype693, $_size690);
+ for ($_i694 = 0; $_i694 < $_size690; ++$_i694)
{
- $elem679 = null;
- $xfer += $input->readString($elem679);
- $this->success []= $elem679;
+ $elem695 = null;
+ $xfer += $input->readString($elem695);
+ $this->success []= $elem695;
}
$xfer += $input->readListEnd();
} else {
@@ -22194,9 +22246,9 @@ class ThriftHiveMetastore_get_index_name
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter680)
+ foreach ($this->success as $iter696)
{
- $xfer += $output->writeString($iter680);
+ $xfer += $output->writeString($iter696);
}
}
$output->writeListEnd();
@@ -24989,14 +25041,14 @@ class ThriftHiveMetastore_get_functions_
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size681 = 0;
- $_etype684 = 0;
- $xfer += $input->readListBegin($_etype684, $_size681);
- for ($_i685 = 0; $_i685 < $_size681; ++$_i685)
+ $_size697 = 0;
+ $_etype700 = 0;
+ $xfer += $input->readListBegin($_etype700, $_size697);
+ for ($_i701 = 0; $_i701 < $_size697; ++$_i701)
{
- $elem686 = null;
- $xfer += $input->readString($elem686);
- $this->success []= $elem686;
+ $elem702 = null;
+ $xfer += $input->readString($elem702);
+ $this->success []= $elem702;
}
$xfer += $input->readListEnd();
} else {
@@ -25032,9 +25084,9 @@ class ThriftHiveMetastore_get_functions_
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter687)
+ foreach ($this->success as $iter703)
{
- $xfer += $output->writeString($iter687);
+ $xfer += $output->writeString($iter703);
}
}
$output->writeListEnd();
@@ -25709,14 +25761,14 @@ class ThriftHiveMetastore_get_role_names
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size688 = 0;
- $_etype691 = 0;
- $xfer += $input->readListBegin($_etype691, $_size688);
- for ($_i692 = 0; $_i692 < $_size688; ++$_i692)
+ $_size704 = 0;
+ $_etype707 = 0;
+ $xfer += $input->readListBegin($_etype707, $_size704);
+ for ($_i708 = 0; $_i708 < $_size704; ++$_i708)
{
- $elem693 = null;
- $xfer += $input->readString($elem693);
- $this->success []= $elem693;
+ $elem709 = null;
+ $xfer += $input->readString($elem709);
+ $this->success []= $elem709;
}
$xfer += $input->readListEnd();
} else {
@@ -25752,9 +25804,9 @@ class ThriftHiveMetastore_get_role_names
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter694)
+ foreach ($this->success as $iter710)
{
- $xfer += $output->writeString($iter694);
+ $xfer += $output->writeString($iter710);
}
}
$output->writeListEnd();
@@ -26394,15 +26446,15 @@ class ThriftHiveMetastore_list_roles_res
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size695 = 0;
- $_etype698 = 0;
- $xfer += $input->readListBegin($_etype698, $_size695);
- for ($_i699 = 0; $_i699 < $_size695; ++$_i699)
+ $_size711 = 0;
+ $_etype714 = 0;
+ $xfer += $input->readListBegin($_etype714, $_size711);
+ for ($_i715 = 0; $_i715 < $_size711; ++$_i715)
{
- $elem700 = null;
- $elem700 = new \metastore\Role();
- $xfer += $elem700->read($input);
- $this->success []= $elem700;
+ $elem716 = null;
+ $elem716 = new \metastore\Role();
+ $xfer += $elem716->read($input);
+ $this->success []= $elem716;
}
$xfer += $input->readListEnd();
} else {
@@ -26438,9 +26490,9 @@ class ThriftHiveMetastore_list_roles_res
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter701)
+ foreach ($this->success as $iter717)
{
- $xfer += $iter701->write($output);
+ $xfer += $iter717->write($output);
}
}
$output->writeListEnd();
@@ -26890,14 +26942,14 @@ class ThriftHiveMetastore_get_privilege_
case 3:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size702 = 0;
- $_etype705 = 0;
- $xfer += $input->readListBegin($_etype705, $_size702);
- for ($_i706 = 0; $_i706 < $_size702; ++$_i706)
+ $_size718 = 0;
+ $_etype721 = 0;
+ $xfer += $input->readListBegin($_etype721, $_size718);
+ for ($_i722 = 0; $_i722 < $_size718; ++$_i722)
{
- $elem707 = null;
- $xfer += $input->readString($elem707);
- $this->group_names []= $elem707;
+ $elem723 = null;
+ $xfer += $input->readString($elem723);
+ $this->group_names []= $elem723;
}
$xfer += $input->readListEnd();
} else {
@@ -26938,9 +26990,9 @@ class ThriftHiveMetastore_get_privilege_
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter708)
+ foreach ($this->group_names as $iter724)
{
- $xfer += $output->writeString($iter708);
+ $xfer += $output->writeString($iter724);
}
}
$output->writeListEnd();
@@ -27227,15 +27279,15 @@ class ThriftHiveMetastore_list_privilege
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size709 = 0;
- $_etype712 = 0;
- $xfer += $input->readListBegin($_etype712, $_size709);
- for ($_i713 = 0; $_i713 < $_size709; ++$_i713)
+ $_size725 = 0;
+ $_etype728 = 0;
+ $xfer += $input->readListBegin($_etype728, $_size725);
+ for ($_i729 = 0; $_i729 < $_size725; ++$_i729)
{
- $elem714 = null;
- $elem714 = new \metastore\HiveObjectPrivilege();
- $xfer += $elem714->read($input);
- $this->success []= $elem714;
+ $elem730 = null;
+ $elem730 = new \metastore\HiveObjectPrivilege();
+ $xfer += $elem730->read($input);
+ $this->success []= $elem730;
}
$xfer += $input->readListEnd();
} else {
@@ -27271,9 +27323,9 @@ class ThriftHiveMetastore_list_privilege
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter715)
+ foreach ($this->success as $iter731)
{
- $xfer += $iter715->write($output);
+ $xfer += $iter731->write($output);
}
}
$output->writeListEnd();
@@ -27696,14 +27748,14 @@ class ThriftHiveMetastore_set_ugi_args {
case 2:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size716 = 0;
- $_etype719 = 0;
- $xfer += $input->readListBegin($_etype719, $_size716);
- for ($_i720 = 0; $_i720 < $_size716; ++$_i720)
+ $_size732 = 0;
+ $_etype735 = 0;
+ $xfer += $input->readListBegin($_etype735, $_size732);
+ for ($_i736 = 0; $_i736 < $_size732; ++$_i736)
{
- $elem721 = null;
- $xfer += $input->readString($elem721);
- $this->group_names []= $elem721;
+ $elem737 = null;
+ $xfer += $input->readString($elem737);
+ $this->group_names []= $elem737;
}
$xfer += $input->readListEnd();
} else {
@@ -27736,9 +27788,9 @@ class ThriftHiveMetastore_set_ugi_args {
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter722)
+ foreach ($this->group_names as $iter738)
{
- $xfer += $output->writeString($iter722);
+ $xfer += $output->writeString($iter738);
}
}
$output->writeListEnd();
@@ -27808,14 +27860,14 @@ class ThriftHiveMetastore_set_ugi_result
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size723 = 0;
- $_etype726 = 0;
- $xfer += $input->readListBegin($_etype726, $_size723);
- for ($_i727 = 0; $_i727 < $_size723; ++$_i727)
+ $_size739 = 0;
+ $_etype742 = 0;
+ $xfer += $input->readListBegin($_etype742, $_size739);
+ for ($_i743 = 0; $_i743 < $_size739; ++$_i743)
{
- $elem728 = null;
- $xfer += $input->readString($elem728);
- $this->success []= $elem728;
+ $elem744 = null;
+ $xfer += $input->readString($elem744);
+ $this->success []= $elem744;
}
$xfer += $input->readListEnd();
} else {
@@ -27851,9 +27903,9 @@ class ThriftHiveMetastore_set_ugi_result
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter729)
+ foreach ($this->success as $iter745)
{
- $xfer += $output->writeString($iter729);
+ $xfer += $output->writeString($iter745);
}
}
$output->writeListEnd();
@@ -30042,6 +30094,160 @@ class ThriftHiveMetastore_heartbeat_resu
}
+class ThriftHiveMetastore_heartbeat_txn_range_args {
+ static $_TSPEC;
+
+ public $txns = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'txns',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\HeartbeatTxnRangeRequest',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['txns'])) {
+ $this->txns = $vals['txns'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_heartbeat_txn_range_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->txns = new \metastore\HeartbeatTxnRangeRequest();
+ $xfer += $this->txns->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_heartbeat_txn_range_args');
+ if ($this->txns !== null) {
+ if (!is_object($this->txns)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('txns', TType::STRUCT, 1);
+ $xfer += $this->txns->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_heartbeat_txn_range_result {
+ static $_TSPEC;
+
+ public $success = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\HeartbeatTxnRangeResponse',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_heartbeat_txn_range_result';
+ }
+
+ 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 0:
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \metastore\HeartbeatTxnRangeResponse();
+ $xfer += $this->success->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_heartbeat_txn_range_result');
+ if ($this->success !== null) {
+ if (!is_object($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class ThriftHiveMetastore_compact_args {
static $_TSPEC;
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=1583185&r1=1583184&r2=1583185&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 Sun Mar 30 18:39:33 2014
@@ -9604,6 +9604,258 @@ class HeartbeatRequest {
}
+class HeartbeatTxnRangeRequest {
+ static $_TSPEC;
+
+ public $min = null;
+ public $max = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'min',
+ 'type' => TType::I64,
+ ),
+ 2 => array(
+ 'var' => 'max',
+ 'type' => TType::I64,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['min'])) {
+ $this->min = $vals['min'];
+ }
+ if (isset($vals['max'])) {
+ $this->max = $vals['max'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'HeartbeatTxnRangeRequest';
+ }
+
+ 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->min);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->max);
+ } 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('HeartbeatTxnRangeRequest');
+ if ($this->min !== null) {
+ $xfer += $output->writeFieldBegin('min', TType::I64, 1);
+ $xfer += $output->writeI64($this->min);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->max !== null) {
+ $xfer += $output->writeFieldBegin('max', TType::I64, 2);
+ $xfer += $output->writeI64($this->max);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class HeartbeatTxnRangeResponse {
+ static $_TSPEC;
+
+ public $aborted = null;
+ public $nosuch = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'aborted',
+ 'type' => TType::SET,
+ 'etype' => TType::I64,
+ 'elem' => array(
+ 'type' => TType::I64,
+ ),
+ ),
+ 2 => array(
+ 'var' => 'nosuch',
+ 'type' => TType::SET,
+ 'etype' => TType::I64,
+ 'elem' => array(
+ 'type' => TType::I64,
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['aborted'])) {
+ $this->aborted = $vals['aborted'];
+ }
+ if (isset($vals['nosuch'])) {
+ $this->nosuch = $vals['nosuch'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'HeartbeatTxnRangeResponse';
+ }
+
+ 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::SET) {
+ $this->aborted = array();
+ $_size370 = 0;
+ $_etype373 = 0;
+ $xfer += $input->readSetBegin($_etype373, $_size370);
+ for ($_i374 = 0; $_i374 < $_size370; ++$_i374)
+ {
+ $elem375 = null;
+ $xfer += $input->readI64($elem375);
+ if (is_scalar($elem375)) {
+ $this->aborted[$elem375] = true;
+ } else {
+ $this->aborted []= $elem375;
+ }
+ }
+ $xfer += $input->readSetEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::SET) {
+ $this->nosuch = array();
+ $_size376 = 0;
+ $_etype379 = 0;
+ $xfer += $input->readSetBegin($_etype379, $_size376);
+ for ($_i380 = 0; $_i380 < $_size376; ++$_i380)
+ {
+ $elem381 = null;
+ $xfer += $input->readI64($elem381);
+ if (is_scalar($elem381)) {
+ $this->nosuch[$elem381] = true;
+ } else {
+ $this->nosuch []= $elem381;
+ }
+ }
+ $xfer += $input->readSetEnd();
+ } 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('HeartbeatTxnRangeResponse');
+ if ($this->aborted !== null) {
+ if (!is_array($this->aborted)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('aborted', TType::SET, 1);
+ {
+ $output->writeSetBegin(TType::I64, count($this->aborted));
+ {
+ foreach ($this->aborted as $iter382 => $iter383)
+ {
+ if (is_scalar($iter383)) {
+ $xfer += $output->writeI64($iter382);
+ } else {
+ $xfer += $output->writeI64($iter383);
+ }
+ }
+ }
+ $output->writeSetEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->nosuch !== null) {
+ if (!is_array($this->nosuch)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('nosuch', TType::SET, 2);
+ {
+ $output->writeSetBegin(TType::I64, count($this->nosuch));
+ {
+ foreach ($this->nosuch as $iter384 => $iter385)
+ {
+ if (is_scalar($iter385)) {
+ $xfer += $output->writeI64($iter384);
+ } else {
+ $xfer += $output->writeI64($iter385);
+ }
+ }
+ }
+ $output->writeSetEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class CompactionRequest {
static $_TSPEC;
@@ -10066,15 +10318,15 @@ class ShowCompactResponse {
case 1:
if ($ftype == TType::LST) {
$this->compacts = array();
- $_size370 = 0;
- $_etype373 = 0;
- $xfer += $input->readListBegin($_etype373, $_size370);
- for ($_i374 = 0; $_i374 < $_size370; ++$_i374)
+ $_size386 = 0;
+ $_etype389 = 0;
+ $xfer += $input->readListBegin($_etype389, $_size386);
+ for ($_i390 = 0; $_i390 < $_size386; ++$_i390)
{
- $elem375 = null;
- $elem375 = new \metastore\ShowCompactResponseElement();
- $xfer += $elem375->read($input);
- $this->compacts []= $elem375;
+ $elem391 = null;
+ $elem391 = new \metastore\ShowCompactResponseElement();
+ $xfer += $elem391->read($input);
+ $this->compacts []= $elem391;
}
$xfer += $input->readListEnd();
} else {
@@ -10102,9 +10354,9 @@ class ShowCompactResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->compacts));
{
- foreach ($this->compacts as $iter376)
+ foreach ($this->compacts as $iter392)
{
- $xfer += $iter376->write($output);
+ $xfer += $iter392->write($output);
}
}
$output->writeListEnd();
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=1583185&r1=1583184&r2=1583185&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 Sun Mar 30 18:39:33 2014
@@ -127,6 +127,7 @@ if len(sys.argv) <= 1 or sys.argv[1] ==
print ' void unlock(UnlockRequest rqst)'
print ' ShowLocksResponse show_locks(ShowLocksRequest rqst)'
print ' void heartbeat(HeartbeatRequest ids)'
+ print ' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)'
print ' void compact(CompactionRequest rqst)'
print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)'
print ''
@@ -804,6 +805,12 @@ elif cmd == 'heartbeat':
sys.exit(1)
pp.pprint(client.heartbeat(eval(args[0]),))
+elif cmd == 'heartbeat_txn_range':
+ if len(args) != 1:
+ print 'heartbeat_txn_range requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.heartbeat_txn_range(eval(args[0]),))
+
elif cmd == 'compact':
if len(args) != 1:
print 'compact requires 1 args'