hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From w...@apache.org
Subject [17/51] [partial] hive git commit: HIVE-14671 : merge master into hive-14535 (Wei Zheng)
Date Fri, 05 May 2017 17:32:04 GMT
http://git-wip-us.apache.org/repos/asf/hive/blob/187eb760/metastore/src/gen/thrift/gen-php/metastore/Types.php
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-php/metastore/Types.php b/metastore/src/gen/thrift/gen-php/metastore/Types.php
index 4dcfc76..a3201cc 100644
--- a/metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -12130,6 +12130,10 @@ class GetOpenTxnsResponse {
    * @var int
    */
   public $min_open_txn = null;
+  /**
+   * @var string
+   */
+  public $abortedBits = null;
 
   public function __construct($vals=null) {
     if (!isset(self::$_TSPEC)) {
@@ -12140,7 +12144,7 @@ class GetOpenTxnsResponse {
           ),
         2 => array(
           'var' => 'open_txns',
-          'type' => TType::SET,
+          'type' => TType::LST,
           'etype' => TType::I64,
           'elem' => array(
             'type' => TType::I64,
@@ -12150,6 +12154,10 @@ class GetOpenTxnsResponse {
           'var' => 'min_open_txn',
           'type' => TType::I64,
           ),
+        4 => array(
+          'var' => 'abortedBits',
+          'type' => TType::STRING,
+          ),
         );
     }
     if (is_array($vals)) {
@@ -12162,6 +12170,9 @@ class GetOpenTxnsResponse {
       if (isset($vals['min_open_txn'])) {
         $this->min_open_txn = $vals['min_open_txn'];
       }
+      if (isset($vals['abortedBits'])) {
+        $this->abortedBits = $vals['abortedBits'];
+      }
     }
   }
 
@@ -12192,22 +12203,18 @@ class GetOpenTxnsResponse {
           }
           break;
         case 2:
-          if ($ftype == TType::SET) {
+          if ($ftype == TType::LST) {
             $this->open_txns = array();
             $_size413 = 0;
             $_etype416 = 0;
-            $xfer += $input->readSetBegin($_etype416, $_size413);
+            $xfer += $input->readListBegin($_etype416, $_size413);
             for ($_i417 = 0; $_i417 < $_size413; ++$_i417)
             {
               $elem418 = null;
               $xfer += $input->readI64($elem418);
-              if (is_scalar($elem418)) {
-                $this->open_txns[$elem418] = true;
-              } else {
-                $this->open_txns []= $elem418;
-              }
+              $this->open_txns []= $elem418;
             }
-            $xfer += $input->readSetEnd();
+            $xfer += $input->readListEnd();
           } else {
             $xfer += $input->skip($ftype);
           }
@@ -12219,6 +12226,13 @@ class GetOpenTxnsResponse {
             $xfer += $input->skip($ftype);
           }
           break;
+        case 4:
+          if ($ftype == TType::STRING) {
+            $xfer += $input->readString($this->abortedBits);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
         default:
           $xfer += $input->skip($ftype);
           break;
@@ -12241,20 +12255,16 @@ class GetOpenTxnsResponse {
       if (!is_array($this->open_txns)) {
         throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
       }
-      $xfer += $output->writeFieldBegin('open_txns', TType::SET, 2);
+      $xfer += $output->writeFieldBegin('open_txns', TType::LST, 2);
       {
-        $output->writeSetBegin(TType::I64, count($this->open_txns));
+        $output->writeListBegin(TType::I64, count($this->open_txns));
         {
-          foreach ($this->open_txns as $iter419 => $iter420)
+          foreach ($this->open_txns as $iter419)
           {
-            if (is_scalar($iter420)) {
             $xfer += $output->writeI64($iter419);
-            } else {
-            $xfer += $output->writeI64($iter420);
-            }
           }
         }
-        $output->writeSetEnd();
+        $output->writeListEnd();
       }
       $xfer += $output->writeFieldEnd();
     }
@@ -12263,6 +12273,11 @@ class GetOpenTxnsResponse {
       $xfer += $output->writeI64($this->min_open_txn);
       $xfer += $output->writeFieldEnd();
     }
+    if ($this->abortedBits !== null) {
+      $xfer += $output->writeFieldBegin('abortedBits', TType::STRING, 4);
+      $xfer += $output->writeString($this->abortedBits);
+      $xfer += $output->writeFieldEnd();
+    }
     $xfer += $output->writeFieldStop();
     $xfer += $output->writeStructEnd();
     return $xfer;
@@ -12464,14 +12479,14 @@ class OpenTxnsResponse {
         case 1:
           if ($ftype == TType::LST) {
             $this->txn_ids = array();
-            $_size421 = 0;
-            $_etype424 = 0;
-            $xfer += $input->readListBegin($_etype424, $_size421);
-            for ($_i425 = 0; $_i425 < $_size421; ++$_i425)
+            $_size420 = 0;
+            $_etype423 = 0;
+            $xfer += $input->readListBegin($_etype423, $_size420);
+            for ($_i424 = 0; $_i424 < $_size420; ++$_i424)
             {
-              $elem426 = null;
-              $xfer += $input->readI64($elem426);
-              $this->txn_ids []= $elem426;
+              $elem425 = null;
+              $xfer += $input->readI64($elem425);
+              $this->txn_ids []= $elem425;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -12499,9 +12514,9 @@ class OpenTxnsResponse {
       {
         $output->writeListBegin(TType::I64, count($this->txn_ids));
         {
-          foreach ($this->txn_ids as $iter427)
+          foreach ($this->txn_ids as $iter426)
           {
-            $xfer += $output->writeI64($iter427);
+            $xfer += $output->writeI64($iter426);
           }
         }
         $output->writeListEnd();
@@ -12640,14 +12655,14 @@ class AbortTxnsRequest {
         case 1:
           if ($ftype == TType::LST) {
             $this->txn_ids = array();
-            $_size428 = 0;
-            $_etype431 = 0;
-            $xfer += $input->readListBegin($_etype431, $_size428);
-            for ($_i432 = 0; $_i432 < $_size428; ++$_i432)
+            $_size427 = 0;
+            $_etype430 = 0;
+            $xfer += $input->readListBegin($_etype430, $_size427);
+            for ($_i431 = 0; $_i431 < $_size427; ++$_i431)
             {
-              $elem433 = null;
-              $xfer += $input->readI64($elem433);
-              $this->txn_ids []= $elem433;
+              $elem432 = null;
+              $xfer += $input->readI64($elem432);
+              $this->txn_ids []= $elem432;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -12675,9 +12690,9 @@ class AbortTxnsRequest {
       {
         $output->writeListBegin(TType::I64, count($this->txn_ids));
         {
-          foreach ($this->txn_ids as $iter434)
+          foreach ($this->txn_ids as $iter433)
           {
-            $xfer += $output->writeI64($iter434);
+            $xfer += $output->writeI64($iter433);
           }
         }
         $output->writeListEnd();
@@ -13097,15 +13112,15 @@ class LockRequest {
         case 1:
           if ($ftype == TType::LST) {
             $this->component = array();
-            $_size435 = 0;
-            $_etype438 = 0;
-            $xfer += $input->readListBegin($_etype438, $_size435);
-            for ($_i439 = 0; $_i439 < $_size435; ++$_i439)
+            $_size434 = 0;
+            $_etype437 = 0;
+            $xfer += $input->readListBegin($_etype437, $_size434);
+            for ($_i438 = 0; $_i438 < $_size434; ++$_i438)
             {
-              $elem440 = null;
-              $elem440 = new \metastore\LockComponent();
-              $xfer += $elem440->read($input);
-              $this->component []= $elem440;
+              $elem439 = null;
+              $elem439 = new \metastore\LockComponent();
+              $xfer += $elem439->read($input);
+              $this->component []= $elem439;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -13161,9 +13176,9 @@ class LockRequest {
       {
         $output->writeListBegin(TType::STRUCT, count($this->component));
         {
-          foreach ($this->component as $iter441)
+          foreach ($this->component as $iter440)
           {
-            $xfer += $iter441->write($output);
+            $xfer += $iter440->write($output);
           }
         }
         $output->writeListEnd();
@@ -14106,15 +14121,15 @@ class ShowLocksResponse {
         case 1:
           if ($ftype == TType::LST) {
             $this->locks = array();
-            $_size442 = 0;
-            $_etype445 = 0;
-            $xfer += $input->readListBegin($_etype445, $_size442);
-            for ($_i446 = 0; $_i446 < $_size442; ++$_i446)
+            $_size441 = 0;
+            $_etype444 = 0;
+            $xfer += $input->readListBegin($_etype444, $_size441);
+            for ($_i445 = 0; $_i445 < $_size441; ++$_i445)
             {
-              $elem447 = null;
-              $elem447 = new \metastore\ShowLocksResponseElement();
-              $xfer += $elem447->read($input);
-              $this->locks []= $elem447;
+              $elem446 = null;
+              $elem446 = new \metastore\ShowLocksResponseElement();
+              $xfer += $elem446->read($input);
+              $this->locks []= $elem446;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -14142,9 +14157,9 @@ class ShowLocksResponse {
       {
         $output->writeListBegin(TType::STRUCT, count($this->locks));
         {
-          foreach ($this->locks as $iter448)
+          foreach ($this->locks as $iter447)
           {
-            $xfer += $iter448->write($output);
+            $xfer += $iter447->write($output);
           }
         }
         $output->writeListEnd();
@@ -14419,17 +14434,17 @@ class HeartbeatTxnRangeResponse {
         case 1:
           if ($ftype == TType::SET) {
             $this->aborted = array();
-            $_size449 = 0;
-            $_etype452 = 0;
-            $xfer += $input->readSetBegin($_etype452, $_size449);
-            for ($_i453 = 0; $_i453 < $_size449; ++$_i453)
+            $_size448 = 0;
+            $_etype451 = 0;
+            $xfer += $input->readSetBegin($_etype451, $_size448);
+            for ($_i452 = 0; $_i452 < $_size448; ++$_i452)
             {
-              $elem454 = null;
-              $xfer += $input->readI64($elem454);
-              if (is_scalar($elem454)) {
-                $this->aborted[$elem454] = true;
+              $elem453 = null;
+              $xfer += $input->readI64($elem453);
+              if (is_scalar($elem453)) {
+                $this->aborted[$elem453] = true;
               } else {
-                $this->aborted []= $elem454;
+                $this->aborted []= $elem453;
               }
             }
             $xfer += $input->readSetEnd();
@@ -14440,17 +14455,17 @@ class HeartbeatTxnRangeResponse {
         case 2:
           if ($ftype == TType::SET) {
             $this->nosuch = array();
-            $_size455 = 0;
-            $_etype458 = 0;
-            $xfer += $input->readSetBegin($_etype458, $_size455);
-            for ($_i459 = 0; $_i459 < $_size455; ++$_i459)
+            $_size454 = 0;
+            $_etype457 = 0;
+            $xfer += $input->readSetBegin($_etype457, $_size454);
+            for ($_i458 = 0; $_i458 < $_size454; ++$_i458)
             {
-              $elem460 = null;
-              $xfer += $input->readI64($elem460);
-              if (is_scalar($elem460)) {
-                $this->nosuch[$elem460] = true;
+              $elem459 = null;
+              $xfer += $input->readI64($elem459);
+              if (is_scalar($elem459)) {
+                $this->nosuch[$elem459] = true;
               } else {
-                $this->nosuch []= $elem460;
+                $this->nosuch []= $elem459;
               }
             }
             $xfer += $input->readSetEnd();
@@ -14479,12 +14494,12 @@ class HeartbeatTxnRangeResponse {
       {
         $output->writeSetBegin(TType::I64, count($this->aborted));
         {
-          foreach ($this->aborted as $iter461 => $iter462)
+          foreach ($this->aborted as $iter460 => $iter461)
           {
-            if (is_scalar($iter462)) {
-            $xfer += $output->writeI64($iter461);
+            if (is_scalar($iter461)) {
+            $xfer += $output->writeI64($iter460);
             } else {
-            $xfer += $output->writeI64($iter462);
+            $xfer += $output->writeI64($iter461);
             }
           }
         }
@@ -14500,12 +14515,12 @@ class HeartbeatTxnRangeResponse {
       {
         $output->writeSetBegin(TType::I64, count($this->nosuch));
         {
-          foreach ($this->nosuch as $iter463 => $iter464)
+          foreach ($this->nosuch as $iter462 => $iter463)
           {
-            if (is_scalar($iter464)) {
-            $xfer += $output->writeI64($iter463);
+            if (is_scalar($iter463)) {
+            $xfer += $output->writeI64($iter462);
             } else {
-            $xfer += $output->writeI64($iter464);
+            $xfer += $output->writeI64($iter463);
             }
           }
         }
@@ -14664,17 +14679,17 @@ class CompactionRequest {
         case 6:
           if ($ftype == TType::MAP) {
             $this->properties = array();
-            $_size465 = 0;
-            $_ktype466 = 0;
-            $_vtype467 = 0;
-            $xfer += $input->readMapBegin($_ktype466, $_vtype467, $_size465);
-            for ($_i469 = 0; $_i469 < $_size465; ++$_i469)
+            $_size464 = 0;
+            $_ktype465 = 0;
+            $_vtype466 = 0;
+            $xfer += $input->readMapBegin($_ktype465, $_vtype466, $_size464);
+            for ($_i468 = 0; $_i468 < $_size464; ++$_i468)
             {
-              $key470 = '';
-              $val471 = '';
-              $xfer += $input->readString($key470);
-              $xfer += $input->readString($val471);
-              $this->properties[$key470] = $val471;
+              $key469 = '';
+              $val470 = '';
+              $xfer += $input->readString($key469);
+              $xfer += $input->readString($val470);
+              $this->properties[$key469] = $val470;
             }
             $xfer += $input->readMapEnd();
           } else {
@@ -14727,10 +14742,10 @@ class CompactionRequest {
       {
         $output->writeMapBegin(TType::STRING, TType::STRING, count($this->properties));
         {
-          foreach ($this->properties as $kiter472 => $viter473)
+          foreach ($this->properties as $kiter471 => $viter472)
           {
-            $xfer += $output->writeString($kiter472);
-            $xfer += $output->writeString($viter473);
+            $xfer += $output->writeString($kiter471);
+            $xfer += $output->writeString($viter472);
           }
         }
         $output->writeMapEnd();
@@ -15317,15 +15332,15 @@ class ShowCompactResponse {
         case 1:
           if ($ftype == TType::LST) {
             $this->compacts = array();
-            $_size474 = 0;
-            $_etype477 = 0;
-            $xfer += $input->readListBegin($_etype477, $_size474);
-            for ($_i478 = 0; $_i478 < $_size474; ++$_i478)
+            $_size473 = 0;
+            $_etype476 = 0;
+            $xfer += $input->readListBegin($_etype476, $_size473);
+            for ($_i477 = 0; $_i477 < $_size473; ++$_i477)
             {
-              $elem479 = null;
-              $elem479 = new \metastore\ShowCompactResponseElement();
-              $xfer += $elem479->read($input);
-              $this->compacts []= $elem479;
+              $elem478 = null;
+              $elem478 = new \metastore\ShowCompactResponseElement();
+              $xfer += $elem478->read($input);
+              $this->compacts []= $elem478;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -15353,9 +15368,9 @@ class ShowCompactResponse {
       {
         $output->writeListBegin(TType::STRUCT, count($this->compacts));
         {
-          foreach ($this->compacts as $iter480)
+          foreach ($this->compacts as $iter479)
           {
-            $xfer += $iter480->write($output);
+            $xfer += $iter479->write($output);
           }
         }
         $output->writeListEnd();
@@ -15484,14 +15499,14 @@ class AddDynamicPartitions {
         case 4:
           if ($ftype == TType::LST) {
             $this->partitionnames = array();
-            $_size481 = 0;
-            $_etype484 = 0;
-            $xfer += $input->readListBegin($_etype484, $_size481);
-            for ($_i485 = 0; $_i485 < $_size481; ++$_i485)
+            $_size480 = 0;
+            $_etype483 = 0;
+            $xfer += $input->readListBegin($_etype483, $_size480);
+            for ($_i484 = 0; $_i484 < $_size480; ++$_i484)
             {
-              $elem486 = null;
-              $xfer += $input->readString($elem486);
-              $this->partitionnames []= $elem486;
+              $elem485 = null;
+              $xfer += $input->readString($elem485);
+              $this->partitionnames []= $elem485;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -15541,9 +15556,9 @@ class AddDynamicPartitions {
       {
         $output->writeListBegin(TType::STRING, count($this->partitionnames));
         {
-          foreach ($this->partitionnames as $iter487)
+          foreach ($this->partitionnames as $iter486)
           {
-            $xfer += $output->writeString($iter487);
+            $xfer += $output->writeString($iter486);
           }
         }
         $output->writeListEnd();
@@ -15924,15 +15939,15 @@ class NotificationEventResponse {
         case 1:
           if ($ftype == TType::LST) {
             $this->events = array();
-            $_size488 = 0;
-            $_etype491 = 0;
-            $xfer += $input->readListBegin($_etype491, $_size488);
-            for ($_i492 = 0; $_i492 < $_size488; ++$_i492)
+            $_size487 = 0;
+            $_etype490 = 0;
+            $xfer += $input->readListBegin($_etype490, $_size487);
+            for ($_i491 = 0; $_i491 < $_size487; ++$_i491)
             {
-              $elem493 = null;
-              $elem493 = new \metastore\NotificationEvent();
-              $xfer += $elem493->read($input);
-              $this->events []= $elem493;
+              $elem492 = null;
+              $elem492 = new \metastore\NotificationEvent();
+              $xfer += $elem492->read($input);
+              $this->events []= $elem492;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -15960,9 +15975,9 @@ class NotificationEventResponse {
       {
         $output->writeListBegin(TType::STRUCT, count($this->events));
         {
-          foreach ($this->events as $iter494)
+          foreach ($this->events as $iter493)
           {
-            $xfer += $iter494->write($output);
+            $xfer += $iter493->write($output);
           }
         }
         $output->writeListEnd();
@@ -16055,6 +16070,10 @@ class InsertEventRequestData {
   static $_TSPEC;
 
   /**
+   * @var bool
+   */
+  public $replace = null;
+  /**
    * @var string[]
    */
   public $filesAdded = null;
@@ -16067,6 +16086,10 @@ class InsertEventRequestData {
     if (!isset(self::$_TSPEC)) {
       self::$_TSPEC = array(
         1 => array(
+          'var' => 'replace',
+          'type' => TType::BOOL,
+          ),
+        2 => array(
           'var' => 'filesAdded',
           'type' => TType::LST,
           'etype' => TType::STRING,
@@ -16074,7 +16097,7 @@ class InsertEventRequestData {
             'type' => TType::STRING,
             ),
           ),
-        2 => array(
+        3 => array(
           'var' => 'filesAddedChecksum',
           'type' => TType::LST,
           'etype' => TType::STRING,
@@ -16085,6 +16108,9 @@ class InsertEventRequestData {
         );
     }
     if (is_array($vals)) {
+      if (isset($vals['replace'])) {
+        $this->replace = $vals['replace'];
+      }
       if (isset($vals['filesAdded'])) {
         $this->filesAdded = $vals['filesAdded'];
       }
@@ -16114,33 +16140,40 @@ class InsertEventRequestData {
       switch ($fid)
       {
         case 1:
+          if ($ftype == TType::BOOL) {
+            $xfer += $input->readBool($this->replace);
+          } else {
+            $xfer += $input->skip($ftype);
+          }
+          break;
+        case 2:
           if ($ftype == TType::LST) {
             $this->filesAdded = array();
-            $_size495 = 0;
-            $_etype498 = 0;
-            $xfer += $input->readListBegin($_etype498, $_size495);
-            for ($_i499 = 0; $_i499 < $_size495; ++$_i499)
+            $_size494 = 0;
+            $_etype497 = 0;
+            $xfer += $input->readListBegin($_etype497, $_size494);
+            for ($_i498 = 0; $_i498 < $_size494; ++$_i498)
             {
-              $elem500 = null;
-              $xfer += $input->readString($elem500);
-              $this->filesAdded []= $elem500;
+              $elem499 = null;
+              $xfer += $input->readString($elem499);
+              $this->filesAdded []= $elem499;
             }
             $xfer += $input->readListEnd();
           } else {
             $xfer += $input->skip($ftype);
           }
           break;
-        case 2:
+        case 3:
           if ($ftype == TType::LST) {
             $this->filesAddedChecksum = array();
-            $_size501 = 0;
-            $_etype504 = 0;
-            $xfer += $input->readListBegin($_etype504, $_size501);
-            for ($_i505 = 0; $_i505 < $_size501; ++$_i505)
+            $_size500 = 0;
+            $_etype503 = 0;
+            $xfer += $input->readListBegin($_etype503, $_size500);
+            for ($_i504 = 0; $_i504 < $_size500; ++$_i504)
             {
-              $elem506 = null;
-              $xfer += $input->readString($elem506);
-              $this->filesAddedChecksum []= $elem506;
+              $elem505 = null;
+              $xfer += $input->readString($elem505);
+              $this->filesAddedChecksum []= $elem505;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -16160,17 +16193,22 @@ class InsertEventRequestData {
   public function write($output) {
     $xfer = 0;
     $xfer += $output->writeStructBegin('InsertEventRequestData');
+    if ($this->replace !== null) {
+      $xfer += $output->writeFieldBegin('replace', TType::BOOL, 1);
+      $xfer += $output->writeBool($this->replace);
+      $xfer += $output->writeFieldEnd();
+    }
     if ($this->filesAdded !== null) {
       if (!is_array($this->filesAdded)) {
         throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
       }
-      $xfer += $output->writeFieldBegin('filesAdded', TType::LST, 1);
+      $xfer += $output->writeFieldBegin('filesAdded', TType::LST, 2);
       {
         $output->writeListBegin(TType::STRING, count($this->filesAdded));
         {
-          foreach ($this->filesAdded as $iter507)
+          foreach ($this->filesAdded as $iter506)
           {
-            $xfer += $output->writeString($iter507);
+            $xfer += $output->writeString($iter506);
           }
         }
         $output->writeListEnd();
@@ -16181,13 +16219,13 @@ class InsertEventRequestData {
       if (!is_array($this->filesAddedChecksum)) {
         throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
       }
-      $xfer += $output->writeFieldBegin('filesAddedChecksum', TType::LST, 2);
+      $xfer += $output->writeFieldBegin('filesAddedChecksum', TType::LST, 3);
       {
         $output->writeListBegin(TType::STRING, count($this->filesAddedChecksum));
         {
-          foreach ($this->filesAddedChecksum as $iter508)
+          foreach ($this->filesAddedChecksum as $iter507)
           {
-            $xfer += $output->writeString($iter508);
+            $xfer += $output->writeString($iter507);
           }
         }
         $output->writeListEnd();
@@ -16405,14 +16443,14 @@ class FireEventRequest {
         case 5:
           if ($ftype == TType::LST) {
             $this->partitionVals = array();
-            $_size509 = 0;
-            $_etype512 = 0;
-            $xfer += $input->readListBegin($_etype512, $_size509);
-            for ($_i513 = 0; $_i513 < $_size509; ++$_i513)
+            $_size508 = 0;
+            $_etype511 = 0;
+            $xfer += $input->readListBegin($_etype511, $_size508);
+            for ($_i512 = 0; $_i512 < $_size508; ++$_i512)
             {
-              $elem514 = null;
-              $xfer += $input->readString($elem514);
-              $this->partitionVals []= $elem514;
+              $elem513 = null;
+              $xfer += $input->readString($elem513);
+              $this->partitionVals []= $elem513;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -16463,9 +16501,9 @@ class FireEventRequest {
       {
         $output->writeListBegin(TType::STRING, count($this->partitionVals));
         {
-          foreach ($this->partitionVals as $iter515)
+          foreach ($this->partitionVals as $iter514)
           {
-            $xfer += $output->writeString($iter515);
+            $xfer += $output->writeString($iter514);
           }
         }
         $output->writeListEnd();
@@ -16693,18 +16731,18 @@ class GetFileMetadataByExprResult {
         case 1:
           if ($ftype == TType::MAP) {
             $this->metadata = array();
-            $_size516 = 0;
-            $_ktype517 = 0;
-            $_vtype518 = 0;
-            $xfer += $input->readMapBegin($_ktype517, $_vtype518, $_size516);
-            for ($_i520 = 0; $_i520 < $_size516; ++$_i520)
+            $_size515 = 0;
+            $_ktype516 = 0;
+            $_vtype517 = 0;
+            $xfer += $input->readMapBegin($_ktype516, $_vtype517, $_size515);
+            for ($_i519 = 0; $_i519 < $_size515; ++$_i519)
             {
-              $key521 = 0;
-              $val522 = new \metastore\MetadataPpdResult();
-              $xfer += $input->readI64($key521);
-              $val522 = new \metastore\MetadataPpdResult();
-              $xfer += $val522->read($input);
-              $this->metadata[$key521] = $val522;
+              $key520 = 0;
+              $val521 = new \metastore\MetadataPpdResult();
+              $xfer += $input->readI64($key520);
+              $val521 = new \metastore\MetadataPpdResult();
+              $xfer += $val521->read($input);
+              $this->metadata[$key520] = $val521;
             }
             $xfer += $input->readMapEnd();
           } else {
@@ -16739,10 +16777,10 @@ class GetFileMetadataByExprResult {
       {
         $output->writeMapBegin(TType::I64, TType::STRUCT, count($this->metadata));
         {
-          foreach ($this->metadata as $kiter523 => $viter524)
+          foreach ($this->metadata as $kiter522 => $viter523)
           {
-            $xfer += $output->writeI64($kiter523);
-            $xfer += $viter524->write($output);
+            $xfer += $output->writeI64($kiter522);
+            $xfer += $viter523->write($output);
           }
         }
         $output->writeMapEnd();
@@ -16844,14 +16882,14 @@ class GetFileMetadataByExprRequest {
         case 1:
           if ($ftype == TType::LST) {
             $this->fileIds = array();
-            $_size525 = 0;
-            $_etype528 = 0;
-            $xfer += $input->readListBegin($_etype528, $_size525);
-            for ($_i529 = 0; $_i529 < $_size525; ++$_i529)
+            $_size524 = 0;
+            $_etype527 = 0;
+            $xfer += $input->readListBegin($_etype527, $_size524);
+            for ($_i528 = 0; $_i528 < $_size524; ++$_i528)
             {
-              $elem530 = null;
-              $xfer += $input->readI64($elem530);
-              $this->fileIds []= $elem530;
+              $elem529 = null;
+              $xfer += $input->readI64($elem529);
+              $this->fileIds []= $elem529;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -16900,9 +16938,9 @@ class GetFileMetadataByExprRequest {
       {
         $output->writeListBegin(TType::I64, count($this->fileIds));
         {
-          foreach ($this->fileIds as $iter531)
+          foreach ($this->fileIds as $iter530)
           {
-            $xfer += $output->writeI64($iter531);
+            $xfer += $output->writeI64($iter530);
           }
         }
         $output->writeListEnd();
@@ -16996,17 +17034,17 @@ class GetFileMetadataResult {
         case 1:
           if ($ftype == TType::MAP) {
             $this->metadata = array();
-            $_size532 = 0;
-            $_ktype533 = 0;
-            $_vtype534 = 0;
-            $xfer += $input->readMapBegin($_ktype533, $_vtype534, $_size532);
-            for ($_i536 = 0; $_i536 < $_size532; ++$_i536)
+            $_size531 = 0;
+            $_ktype532 = 0;
+            $_vtype533 = 0;
+            $xfer += $input->readMapBegin($_ktype532, $_vtype533, $_size531);
+            for ($_i535 = 0; $_i535 < $_size531; ++$_i535)
             {
-              $key537 = 0;
-              $val538 = '';
-              $xfer += $input->readI64($key537);
-              $xfer += $input->readString($val538);
-              $this->metadata[$key537] = $val538;
+              $key536 = 0;
+              $val537 = '';
+              $xfer += $input->readI64($key536);
+              $xfer += $input->readString($val537);
+              $this->metadata[$key536] = $val537;
             }
             $xfer += $input->readMapEnd();
           } else {
@@ -17041,10 +17079,10 @@ class GetFileMetadataResult {
       {
         $output->writeMapBegin(TType::I64, TType::STRING, count($this->metadata));
         {
-          foreach ($this->metadata as $kiter539 => $viter540)
+          foreach ($this->metadata as $kiter538 => $viter539)
           {
-            $xfer += $output->writeI64($kiter539);
-            $xfer += $output->writeString($viter540);
+            $xfer += $output->writeI64($kiter538);
+            $xfer += $output->writeString($viter539);
           }
         }
         $output->writeMapEnd();
@@ -17113,14 +17151,14 @@ class GetFileMetadataRequest {
         case 1:
           if ($ftype == TType::LST) {
             $this->fileIds = array();
-            $_size541 = 0;
-            $_etype544 = 0;
-            $xfer += $input->readListBegin($_etype544, $_size541);
-            for ($_i545 = 0; $_i545 < $_size541; ++$_i545)
+            $_size540 = 0;
+            $_etype543 = 0;
+            $xfer += $input->readListBegin($_etype543, $_size540);
+            for ($_i544 = 0; $_i544 < $_size540; ++$_i544)
             {
-              $elem546 = null;
-              $xfer += $input->readI64($elem546);
-              $this->fileIds []= $elem546;
+              $elem545 = null;
+              $xfer += $input->readI64($elem545);
+              $this->fileIds []= $elem545;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -17148,9 +17186,9 @@ class GetFileMetadataRequest {
       {
         $output->writeListBegin(TType::I64, count($this->fileIds));
         {
-          foreach ($this->fileIds as $iter547)
+          foreach ($this->fileIds as $iter546)
           {
-            $xfer += $output->writeI64($iter547);
+            $xfer += $output->writeI64($iter546);
           }
         }
         $output->writeListEnd();
@@ -17290,14 +17328,14 @@ class PutFileMetadataRequest {
         case 1:
           if ($ftype == TType::LST) {
             $this->fileIds = array();
-            $_size548 = 0;
-            $_etype551 = 0;
-            $xfer += $input->readListBegin($_etype551, $_size548);
-            for ($_i552 = 0; $_i552 < $_size548; ++$_i552)
+            $_size547 = 0;
+            $_etype550 = 0;
+            $xfer += $input->readListBegin($_etype550, $_size547);
+            for ($_i551 = 0; $_i551 < $_size547; ++$_i551)
             {
-              $elem553 = null;
-              $xfer += $input->readI64($elem553);
-              $this->fileIds []= $elem553;
+              $elem552 = null;
+              $xfer += $input->readI64($elem552);
+              $this->fileIds []= $elem552;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -17307,14 +17345,14 @@ class PutFileMetadataRequest {
         case 2:
           if ($ftype == TType::LST) {
             $this->metadata = array();
-            $_size554 = 0;
-            $_etype557 = 0;
-            $xfer += $input->readListBegin($_etype557, $_size554);
-            for ($_i558 = 0; $_i558 < $_size554; ++$_i558)
+            $_size553 = 0;
+            $_etype556 = 0;
+            $xfer += $input->readListBegin($_etype556, $_size553);
+            for ($_i557 = 0; $_i557 < $_size553; ++$_i557)
             {
-              $elem559 = null;
-              $xfer += $input->readString($elem559);
-              $this->metadata []= $elem559;
+              $elem558 = null;
+              $xfer += $input->readString($elem558);
+              $this->metadata []= $elem558;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -17349,9 +17387,9 @@ class PutFileMetadataRequest {
       {
         $output->writeListBegin(TType::I64, count($this->fileIds));
         {
-          foreach ($this->fileIds as $iter560)
+          foreach ($this->fileIds as $iter559)
           {
-            $xfer += $output->writeI64($iter560);
+            $xfer += $output->writeI64($iter559);
           }
         }
         $output->writeListEnd();
@@ -17366,9 +17404,9 @@ class PutFileMetadataRequest {
       {
         $output->writeListBegin(TType::STRING, count($this->metadata));
         {
-          foreach ($this->metadata as $iter561)
+          foreach ($this->metadata as $iter560)
           {
-            $xfer += $output->writeString($iter561);
+            $xfer += $output->writeString($iter560);
           }
         }
         $output->writeListEnd();
@@ -17487,14 +17525,14 @@ class ClearFileMetadataRequest {
         case 1:
           if ($ftype == TType::LST) {
             $this->fileIds = array();
-            $_size562 = 0;
-            $_etype565 = 0;
-            $xfer += $input->readListBegin($_etype565, $_size562);
-            for ($_i566 = 0; $_i566 < $_size562; ++$_i566)
+            $_size561 = 0;
+            $_etype564 = 0;
+            $xfer += $input->readListBegin($_etype564, $_size561);
+            for ($_i565 = 0; $_i565 < $_size561; ++$_i565)
             {
-              $elem567 = null;
-              $xfer += $input->readI64($elem567);
-              $this->fileIds []= $elem567;
+              $elem566 = null;
+              $xfer += $input->readI64($elem566);
+              $this->fileIds []= $elem566;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -17522,9 +17560,9 @@ class ClearFileMetadataRequest {
       {
         $output->writeListBegin(TType::I64, count($this->fileIds));
         {
-          foreach ($this->fileIds as $iter568)
+          foreach ($this->fileIds as $iter567)
           {
-            $xfer += $output->writeI64($iter568);
+            $xfer += $output->writeI64($iter567);
           }
         }
         $output->writeListEnd();
@@ -18497,14 +18535,14 @@ class GetValidWriteIdsResult {
         case 4:
           if ($ftype == TType::LST) {
             $this->ids = array();
-            $_size569 = 0;
-            $_etype572 = 0;
-            $xfer += $input->readListBegin($_etype572, $_size569);
-            for ($_i573 = 0; $_i573 < $_size569; ++$_i573)
+            $_size568 = 0;
+            $_etype571 = 0;
+            $xfer += $input->readListBegin($_etype571, $_size568);
+            for ($_i572 = 0; $_i572 < $_size568; ++$_i572)
             {
-              $elem574 = null;
-              $xfer += $input->readI64($elem574);
-              $this->ids []= $elem574;
+              $elem573 = null;
+              $xfer += $input->readI64($elem573);
+              $this->ids []= $elem573;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -18547,9 +18585,9 @@ class GetValidWriteIdsResult {
       {
         $output->writeListBegin(TType::I64, count($this->ids));
         {
-          foreach ($this->ids as $iter575)
+          foreach ($this->ids as $iter574)
           {
-            $xfer += $output->writeI64($iter575);
+            $xfer += $output->writeI64($iter574);
           }
         }
         $output->writeListEnd();
@@ -18614,15 +18652,15 @@ class GetAllFunctionsResponse {
         case 1:
           if ($ftype == TType::LST) {
             $this->functions = array();
-            $_size576 = 0;
-            $_etype579 = 0;
-            $xfer += $input->readListBegin($_etype579, $_size576);
-            for ($_i580 = 0; $_i580 < $_size576; ++$_i580)
+            $_size575 = 0;
+            $_etype578 = 0;
+            $xfer += $input->readListBegin($_etype578, $_size575);
+            for ($_i579 = 0; $_i579 < $_size575; ++$_i579)
             {
-              $elem581 = null;
-              $elem581 = new \metastore\Function();
-              $xfer += $elem581->read($input);
-              $this->functions []= $elem581;
+              $elem580 = null;
+              $elem580 = new \metastore\Function();
+              $xfer += $elem580->read($input);
+              $this->functions []= $elem580;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -18650,9 +18688,9 @@ class GetAllFunctionsResponse {
       {
         $output->writeListBegin(TType::STRUCT, count($this->functions));
         {
-          foreach ($this->functions as $iter582)
+          foreach ($this->functions as $iter581)
           {
-            $xfer += $iter582->write($output);
+            $xfer += $iter581->write($output);
           }
         }
         $output->writeListEnd();
@@ -18716,14 +18754,14 @@ class ClientCapabilities {
         case 1:
           if ($ftype == TType::LST) {
             $this->values = array();
-            $_size583 = 0;
-            $_etype586 = 0;
-            $xfer += $input->readListBegin($_etype586, $_size583);
-            for ($_i587 = 0; $_i587 < $_size583; ++$_i587)
+            $_size582 = 0;
+            $_etype585 = 0;
+            $xfer += $input->readListBegin($_etype585, $_size582);
+            for ($_i586 = 0; $_i586 < $_size582; ++$_i586)
             {
-              $elem588 = null;
-              $xfer += $input->readI32($elem588);
-              $this->values []= $elem588;
+              $elem587 = null;
+              $xfer += $input->readI32($elem587);
+              $this->values []= $elem587;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -18751,9 +18789,9 @@ class ClientCapabilities {
       {
         $output->writeListBegin(TType::I32, count($this->values));
         {
-          foreach ($this->values as $iter589)
+          foreach ($this->values as $iter588)
           {
-            $xfer += $output->writeI32($iter589);
+            $xfer += $output->writeI32($iter588);
           }
         }
         $output->writeListEnd();
@@ -19053,14 +19091,14 @@ class GetTablesRequest {
         case 2:
           if ($ftype == TType::LST) {
             $this->tblNames = array();
-            $_size590 = 0;
-            $_etype593 = 0;
-            $xfer += $input->readListBegin($_etype593, $_size590);
-            for ($_i594 = 0; $_i594 < $_size590; ++$_i594)
+            $_size589 = 0;
+            $_etype592 = 0;
+            $xfer += $input->readListBegin($_etype592, $_size589);
+            for ($_i593 = 0; $_i593 < $_size589; ++$_i593)
             {
-              $elem595 = null;
-              $xfer += $input->readString($elem595);
-              $this->tblNames []= $elem595;
+              $elem594 = null;
+              $xfer += $input->readString($elem594);
+              $this->tblNames []= $elem594;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -19101,9 +19139,9 @@ class GetTablesRequest {
       {
         $output->writeListBegin(TType::STRING, count($this->tblNames));
         {
-          foreach ($this->tblNames as $iter596)
+          foreach ($this->tblNames as $iter595)
           {
-            $xfer += $output->writeString($iter596);
+            $xfer += $output->writeString($iter595);
           }
         }
         $output->writeListEnd();
@@ -19176,15 +19214,15 @@ class GetTablesResult {
         case 1:
           if ($ftype == TType::LST) {
             $this->tables = array();
-            $_size597 = 0;
-            $_etype600 = 0;
-            $xfer += $input->readListBegin($_etype600, $_size597);
-            for ($_i601 = 0; $_i601 < $_size597; ++$_i601)
+            $_size596 = 0;
+            $_etype599 = 0;
+            $xfer += $input->readListBegin($_etype599, $_size596);
+            for ($_i600 = 0; $_i600 < $_size596; ++$_i600)
             {
-              $elem602 = null;
-              $elem602 = new \metastore\Table();
-              $xfer += $elem602->read($input);
-              $this->tables []= $elem602;
+              $elem601 = null;
+              $elem601 = new \metastore\Table();
+              $xfer += $elem601->read($input);
+              $this->tables []= $elem601;
             }
             $xfer += $input->readListEnd();
           } else {
@@ -19212,9 +19250,9 @@ class GetTablesResult {
       {
         $output->writeListBegin(TType::STRUCT, count($this->tables));
         {
-          foreach ($this->tables as $iter603)
+          foreach ($this->tables as $iter602)
           {
-            $xfer += $iter603->write($output);
+            $xfer += $iter602->write($output);
           }
         }
         $output->writeListEnd();

http://git-wip-us.apache.org/repos/asf/hive/blob/187eb760/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --git a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index 3db3bad..c1c3393 100755
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -48,6 +48,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
   print('  void add_foreign_key(AddForeignKeyRequest req)')
   print('  void drop_table(string dbname, string name, bool deleteData)')
   print('  void drop_table_with_environment_context(string dbname, string name, bool deleteData,
EnvironmentContext environment_context)')
+  print('  void truncate_table(string dbName, string tableName,  partNames)')
   print('   get_tables(string db_name, string pattern)')
   print('   get_tables_by_type(string db_name, string pattern, string tableType)')
   print('   get_table_meta(string db_patterns, string tbl_patterns,  tbl_types)')
@@ -394,6 +395,12 @@ elif cmd == 'drop_table_with_environment_context':
     sys.exit(1)
   pp.pprint(client.drop_table_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
 
+elif cmd == 'truncate_table':
+  if len(args) != 3:
+    print('truncate_table requires 3 args')
+    sys.exit(1)
+  pp.pprint(client.truncate_table(args[0],args[1],eval(args[2]),))
+
 elif cmd == 'get_tables':
   if len(args) != 2:
     print('get_tables requires 2 args')


Mime
View raw message