You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2018/06/15 20:10:36 UTC
[04/13] hive git commit: HIVE-19532: 03 patch
http://git-wip-us.apache.org/repos/asf/hive/blob/be303958/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
index a29ebb7..4a2bdc7 100644
--- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -203,6 +203,17 @@ final class SchemaVersionState {
);
}
+final class IsolationLevelCompliance {
+ const YES = 1;
+ const NO = 2;
+ const UNKNOWN = 3;
+ static public $__names = array(
+ 1 => 'YES',
+ 2 => 'NO',
+ 3 => 'UNKNOWN',
+ );
+}
+
final class FunctionType {
const JAVA = 1;
static public $__names = array(
@@ -6517,6 +6528,18 @@ class Table {
* @var int
*/
public $ownerType = 1;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -6609,6 +6632,18 @@ class Table {
'var' => 'ownerType',
'type' => TType::I32,
),
+ 19 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 20 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
+ 21 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -6666,6 +6701,15 @@ class Table {
if (isset($vals['ownerType'])) {
$this->ownerType = $vals['ownerType'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -6841,6 +6885,27 @@ class Table {
$xfer += $input->skip($ftype);
}
break;
+ case 19:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 20:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 21:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -6978,6 +7043,21 @@ class Table {
$xfer += $output->writeI32($this->ownerType);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 19);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 20);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 21);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -7024,6 +7104,18 @@ class Partition {
* @var string
*/
public $catName = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -7078,6 +7170,18 @@ class Partition {
'var' => 'catName',
'type' => TType::STRING,
),
+ 10 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 11 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
+ 12 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -7108,6 +7212,15 @@ class Partition {
if (isset($vals['catName'])) {
$this->catName = $vals['catName'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -7218,6 +7331,27 @@ class Partition {
$xfer += $input->skip($ftype);
}
break;
+ case 10:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 11:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 12:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -7307,6 +7441,21 @@ class Partition {
$xfer += $output->writeString($this->catName);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 10);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 11);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 12);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -7830,6 +7979,18 @@ class PartitionSpec {
* @var string
*/
public $catName = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -7860,6 +8021,18 @@ class PartitionSpec {
'var' => 'catName',
'type' => TType::STRING,
),
+ 7 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 8 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
+ 9 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -7881,6 +8054,15 @@ class PartitionSpec {
if (isset($vals['catName'])) {
$this->catName = $vals['catName'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -7947,6 +8129,27 @@ class PartitionSpec {
$xfer += $input->skip($ftype);
}
break;
+ case 7:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 9:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -7996,6 +8199,21 @@ class PartitionSpec {
$xfer += $output->writeString($this->catName);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 7);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 8);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 9);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -9894,6 +10112,18 @@ class ColumnStatistics {
* @var \metastore\ColumnStatisticsObj[]
*/
public $statsObj = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -9912,6 +10142,18 @@ class ColumnStatistics {
'class' => '\metastore\ColumnStatisticsObj',
),
),
+ 3 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 4 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -9921,6 +10163,15 @@ class ColumnStatistics {
if (isset($vals['statsObj'])) {
$this->statsObj = $vals['statsObj'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -9969,6 +10220,27 @@ class ColumnStatistics {
$xfer += $input->skip($ftype);
}
break;
+ case 3:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -10007,6 +10279,21 @@ class ColumnStatistics {
}
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 3);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 4);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 5);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -10025,6 +10312,10 @@ class AggrStats {
* @var int
*/
public $partsFound = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -10042,6 +10333,10 @@ class AggrStats {
'var' => 'partsFound',
'type' => TType::I64,
),
+ 3 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
@@ -10051,6 +10346,9 @@ class AggrStats {
if (isset($vals['partsFound'])) {
$this->partsFound = $vals['partsFound'];
}
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -10098,6 +10396,13 @@ class AggrStats {
$xfer += $input->skip($ftype);
}
break;
+ case 3:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -10133,6 +10438,11 @@ class AggrStats {
$xfer += $output->writeI64($this->partsFound);
$xfer += $output->writeFieldEnd();
}
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 3);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -10151,6 +10461,14 @@ class SetPartitionsStatsRequest {
* @var bool
*/
public $needMerge = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -10168,6 +10486,14 @@ class SetPartitionsStatsRequest {
'var' => 'needMerge',
'type' => TType::BOOL,
),
+ 3 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 4 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -10177,6 +10503,12 @@ class SetPartitionsStatsRequest {
if (isset($vals['needMerge'])) {
$this->needMerge = $vals['needMerge'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
}
}
@@ -10224,6 +10556,20 @@ class SetPartitionsStatsRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 3:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -10259,6 +10605,16 @@ class SetPartitionsStatsRequest {
$xfer += $output->writeBool($this->needMerge);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 3);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 4);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13010,6 +13366,10 @@ class TableStatsResult {
* @var \metastore\ColumnStatisticsObj[]
*/
public $tableStats = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13023,12 +13383,19 @@ class TableStatsResult {
'class' => '\metastore\ColumnStatisticsObj',
),
),
+ 2 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['tableStats'])) {
$this->tableStats = $vals['tableStats'];
}
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -13069,6 +13436,13 @@ class TableStatsResult {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -13099,6 +13473,11 @@ class TableStatsResult {
}
$xfer += $output->writeFieldEnd();
}
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 2);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13113,6 +13492,10 @@ class PartitionsStatsResult {
* @var array
*/
public $partStats = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13134,12 +13517,19 @@ class PartitionsStatsResult {
),
),
),
+ 2 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['partStats'])) {
$this->partStats = $vals['partStats'];
}
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -13193,6 +13583,13 @@ class PartitionsStatsResult {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -13233,6 +13630,11 @@ class PartitionsStatsResult {
}
$xfer += $output->writeFieldEnd();
}
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 2);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13259,6 +13661,14 @@ class TableStatsRequest {
* @var string
*/
public $catName = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13283,6 +13693,14 @@ class TableStatsRequest {
'var' => 'catName',
'type' => TType::STRING,
),
+ 5 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 6 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -13298,6 +13716,12 @@ class TableStatsRequest {
if (isset($vals['catName'])) {
$this->catName = $vals['catName'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
}
}
@@ -13358,6 +13782,20 @@ class TableStatsRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 5:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -13403,6 +13841,16 @@ class TableStatsRequest {
$xfer += $output->writeString($this->catName);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 5);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 6);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13433,6 +13881,14 @@ class PartitionsStatsRequest {
* @var string
*/
public $catName = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13465,6 +13921,14 @@ class PartitionsStatsRequest {
'var' => 'catName',
'type' => TType::STRING,
),
+ 6 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 7 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -13483,6 +13947,12 @@ class PartitionsStatsRequest {
if (isset($vals['catName'])) {
$this->catName = $vals['catName'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
}
}
@@ -13560,6 +14030,20 @@ class PartitionsStatsRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 6:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -13622,6 +14106,16 @@ class PartitionsStatsRequest {
$xfer += $output->writeString($this->catName);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 6);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 7);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13636,6 +14130,10 @@ class AddPartitionsResult {
* @var \metastore\Partition[]
*/
public $partitions = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13649,12 +14147,19 @@ class AddPartitionsResult {
'class' => '\metastore\Partition',
),
),
+ 2 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['partitions'])) {
$this->partitions = $vals['partitions'];
}
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -13695,6 +14200,13 @@ class AddPartitionsResult {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -13725,6 +14237,11 @@ class AddPartitionsResult {
}
$xfer += $output->writeFieldEnd();
}
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 2);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -13759,6 +14276,14 @@ class AddPartitionsRequest {
* @var string
*/
public $catName = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -13792,6 +14317,14 @@ class AddPartitionsRequest {
'var' => 'catName',
'type' => TType::STRING,
),
+ 7 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 8 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -13813,6 +14346,12 @@ class AddPartitionsRequest {
if (isset($vals['catName'])) {
$this->catName = $vals['catName'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
}
}
@@ -13888,6 +14427,20 @@ class AddPartitionsRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 7:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 8:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -13943,6 +14496,16 @@ class AddPartitionsRequest {
$xfer += $output->writeString($this->catName);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 7);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 8);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -23596,6 +24159,14 @@ class GetTableRequest {
* @var string
*/
public $catName = null;
+ /**
+ * @var int
+ */
+ public $txnId = -1;
+ /**
+ * @var string
+ */
+ public $validWriteIdList = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -23617,6 +24188,14 @@ class GetTableRequest {
'var' => 'catName',
'type' => TType::STRING,
),
+ 5 => array(
+ 'var' => 'txnId',
+ 'type' => TType::I64,
+ ),
+ 6 => array(
+ 'var' => 'validWriteIdList',
+ 'type' => TType::STRING,
+ ),
);
}
if (is_array($vals)) {
@@ -23632,6 +24211,12 @@ class GetTableRequest {
if (isset($vals['catName'])) {
$this->catName = $vals['catName'];
}
+ if (isset($vals['txnId'])) {
+ $this->txnId = $vals['txnId'];
+ }
+ if (isset($vals['validWriteIdList'])) {
+ $this->validWriteIdList = $vals['validWriteIdList'];
+ }
}
}
@@ -23683,6 +24268,20 @@ class GetTableRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 5:
+ if ($ftype == TType::I64) {
+ $xfer += $input->readI64($this->txnId);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->validWriteIdList);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -23719,6 +24318,16 @@ class GetTableRequest {
$xfer += $output->writeString($this->catName);
$xfer += $output->writeFieldEnd();
}
+ if ($this->txnId !== null) {
+ $xfer += $output->writeFieldBegin('txnId', TType::I64, 5);
+ $xfer += $output->writeI64($this->txnId);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->validWriteIdList !== null) {
+ $xfer += $output->writeFieldBegin('validWriteIdList', TType::STRING, 6);
+ $xfer += $output->writeString($this->validWriteIdList);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -23733,6 +24342,10 @@ class GetTableResult {
* @var \metastore\Table
*/
public $table = null;
+ /**
+ * @var int
+ */
+ public $isStatsCompliant = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -23742,12 +24355,19 @@ class GetTableResult {
'type' => TType::STRUCT,
'class' => '\metastore\Table',
),
+ 2 => array(
+ 'var' => 'isStatsCompliant',
+ 'type' => TType::I32,
+ ),
);
}
if (is_array($vals)) {
if (isset($vals['table'])) {
$this->table = $vals['table'];
}
+ if (isset($vals['isStatsCompliant'])) {
+ $this->isStatsCompliant = $vals['isStatsCompliant'];
+ }
}
}
@@ -23778,6 +24398,13 @@ class GetTableResult {
$xfer += $input->skip($ftype);
}
break;
+ case 2:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->isStatsCompliant);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -23799,6 +24426,11 @@ class GetTableResult {
$xfer += $this->table->write($output);
$xfer += $output->writeFieldEnd();
}
+ if ($this->isStatsCompliant !== null) {
+ $xfer += $output->writeFieldBegin('isStatsCompliant', TType::I32, 2);
+ $xfer += $output->writeI32($this->isStatsCompliant);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
http://git-wip-us.apache.org/repos/asf/hive/blob/be303958/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index 5402372..7a438db 100755
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@ -107,7 +107,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' get_partitions_by_names(string db_name, string tbl_name, names)')
print(' void alter_partition(string db_name, string tbl_name, Partition new_part)')
print(' void alter_partitions(string db_name, string tbl_name, new_parts)')
- print(' void alter_partitions_with_environment_context(string db_name, string tbl_name, new_parts, EnvironmentContext environment_context)')
+ print(' void alter_partitions_with_environment_context(string db_name, string tbl_name, new_parts, EnvironmentContext environment_context, i64 txnId, string writeIdList)')
print(' void alter_partition_with_environment_context(string db_name, string tbl_name, Partition new_part, EnvironmentContext environment_context)')
print(' void rename_partition(string db_name, string tbl_name, part_vals, Partition new_part)')
print(' bool partition_name_has_valid_characters( part_vals, bool throw_exception)')
@@ -799,10 +799,10 @@ elif cmd == 'alter_partitions':
pp.pprint(client.alter_partitions(args[0],args[1],eval(args[2]),))
elif cmd == 'alter_partitions_with_environment_context':
- if len(args) != 4:
- print('alter_partitions_with_environment_context requires 4 args')
+ if len(args) != 6:
+ print('alter_partitions_with_environment_context requires 6 args')
sys.exit(1)
- pp.pprint(client.alter_partitions_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),))
+ pp.pprint(client.alter_partitions_with_environment_context(args[0],args[1],eval(args[2]),eval(args[3]),eval(args[4]),args[5],))
elif cmd == 'alter_partition_with_environment_context':
if len(args) != 4:
http://git-wip-us.apache.org/repos/asf/hive/blob/be303958/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 5a3f2c1..665d401 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@ -717,13 +717,15 @@ class Iface(fb303.FacebookService.Iface):
"""
pass
- def alter_partitions_with_environment_context(self, db_name, tbl_name, new_parts, environment_context):
+ def alter_partitions_with_environment_context(self, db_name, tbl_name, new_parts, environment_context, txnId, writeIdList):
"""
Parameters:
- db_name
- tbl_name
- new_parts
- environment_context
+ - txnId
+ - writeIdList
"""
pass
@@ -4734,24 +4736,28 @@ class Client(fb303.FacebookService.Client, Iface):
raise result.o2
return
- def alter_partitions_with_environment_context(self, db_name, tbl_name, new_parts, environment_context):
+ def alter_partitions_with_environment_context(self, db_name, tbl_name, new_parts, environment_context, txnId, writeIdList):
"""
Parameters:
- db_name
- tbl_name
- new_parts
- environment_context
+ - txnId
+ - writeIdList
"""
- self.send_alter_partitions_with_environment_context(db_name, tbl_name, new_parts, environment_context)
+ self.send_alter_partitions_with_environment_context(db_name, tbl_name, new_parts, environment_context, txnId, writeIdList)
self.recv_alter_partitions_with_environment_context()
- def send_alter_partitions_with_environment_context(self, db_name, tbl_name, new_parts, environment_context):
+ def send_alter_partitions_with_environment_context(self, db_name, tbl_name, new_parts, environment_context, txnId, writeIdList):
self._oprot.writeMessageBegin('alter_partitions_with_environment_context', TMessageType.CALL, self._seqid)
args = alter_partitions_with_environment_context_args()
args.db_name = db_name
args.tbl_name = tbl_name
args.new_parts = new_parts
args.environment_context = environment_context
+ args.txnId = txnId
+ args.writeIdList = writeIdList
args.write(self._oprot)
self._oprot.writeMessageEnd()
self._oprot.trans.flush()
@@ -11366,7 +11372,7 @@ class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
iprot.readMessageEnd()
result = alter_partitions_with_environment_context_result()
try:
- self._handler.alter_partitions_with_environment_context(args.db_name, args.tbl_name, args.new_parts, args.environment_context)
+ self._handler.alter_partitions_with_environment_context(args.db_name, args.tbl_name, args.new_parts, args.environment_context, args.txnId, args.writeIdList)
msg_type = TMessageType.REPLY
except (TTransport.TTransportException, KeyboardInterrupt, SystemExit):
raise
@@ -29394,6 +29400,8 @@ class alter_partitions_with_environment_context_args:
- tbl_name
- new_parts
- environment_context
+ - txnId
+ - writeIdList
"""
thrift_spec = (
@@ -29402,13 +29410,17 @@ class alter_partitions_with_environment_context_args:
(2, TType.STRING, 'tbl_name', None, None, ), # 2
(3, TType.LIST, 'new_parts', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 3
(4, TType.STRUCT, 'environment_context', (EnvironmentContext, EnvironmentContext.thrift_spec), None, ), # 4
+ (5, TType.I64, 'txnId', None, None, ), # 5
+ (6, TType.STRING, 'writeIdList', None, None, ), # 6
)
- def __init__(self, db_name=None, tbl_name=None, new_parts=None, environment_context=None,):
+ def __init__(self, db_name=None, tbl_name=None, new_parts=None, environment_context=None, txnId=None, writeIdList=None,):
self.db_name = db_name
self.tbl_name = tbl_name
self.new_parts = new_parts
self.environment_context = environment_context
+ self.txnId = txnId
+ self.writeIdList = writeIdList
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -29446,6 +29458,16 @@ class alter_partitions_with_environment_context_args:
self.environment_context.read(iprot)
else:
iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.writeIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -29475,6 +29497,14 @@ class alter_partitions_with_environment_context_args:
oprot.writeFieldBegin('environment_context', TType.STRUCT, 4)
self.environment_context.write(oprot)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 5)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.writeIdList is not None:
+ oprot.writeFieldBegin('writeIdList', TType.STRING, 6)
+ oprot.writeString(self.writeIdList)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -29488,6 +29518,8 @@ class alter_partitions_with_environment_context_args:
value = (value * 31) ^ hash(self.tbl_name)
value = (value * 31) ^ hash(self.new_parts)
value = (value * 31) ^ hash(self.environment_context)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.writeIdList)
return value
def __repr__(self):
http://git-wip-us.apache.org/repos/asf/hive/blob/be303958/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
index 11affe3..899b744 100644
--- a/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
+++ b/standalone-metastore/src/gen/thrift/gen-py/hive_metastore/ttypes.py
@@ -305,6 +305,23 @@ class SchemaVersionState:
"DELETED": 8,
}
+class IsolationLevelCompliance:
+ YES = 1
+ NO = 2
+ UNKNOWN = 3
+
+ _VALUES_TO_NAMES = {
+ 1: "YES",
+ 2: "NO",
+ 3: "UNKNOWN",
+ }
+
+ _NAMES_TO_VALUES = {
+ "YES": 1,
+ "NO": 2,
+ "UNKNOWN": 3,
+ }
+
class FunctionType:
JAVA = 1
@@ -4550,6 +4567,9 @@ class Table:
- creationMetadata
- catName
- ownerType
+ - txnId
+ - validWriteIdList
+ - isStatsCompliant
"""
thrift_spec = (
@@ -4572,9 +4592,12 @@ class Table:
(16, TType.STRUCT, 'creationMetadata', (CreationMetadata, CreationMetadata.thrift_spec), None, ), # 16
(17, TType.STRING, 'catName', None, None, ), # 17
(18, TType.I32, 'ownerType', None, 1, ), # 18
+ (19, TType.I64, 'txnId', None, -1, ), # 19
+ (20, TType.STRING, 'validWriteIdList', None, None, ), # 20
+ (21, TType.I32, 'isStatsCompliant', None, None, ), # 21
)
- def __init__(self, tableName=None, dbName=None, owner=None, createTime=None, lastAccessTime=None, retention=None, sd=None, partitionKeys=None, parameters=None, viewOriginalText=None, viewExpandedText=None, tableType=None, privileges=None, temporary=thrift_spec[14][4], rewriteEnabled=None, creationMetadata=None, catName=None, ownerType=thrift_spec[18][4],):
+ def __init__(self, tableName=None, dbName=None, owner=None, createTime=None, lastAccessTime=None, retention=None, sd=None, partitionKeys=None, parameters=None, viewOriginalText=None, viewExpandedText=None, tableType=None, privileges=None, temporary=thrift_spec[14][4], rewriteEnabled=None, creationMetadata=None, catName=None, ownerType=thrift_spec[18][4], txnId=thrift_spec[19][4], validWriteIdList=None, isStatsCompliant=None,):
self.tableName = tableName
self.dbName = dbName
self.owner = owner
@@ -4593,6 +4616,9 @@ class Table:
self.creationMetadata = creationMetadata
self.catName = catName
self.ownerType = ownerType
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -4708,6 +4734,21 @@ class Table:
self.ownerType = iprot.readI32()
else:
iprot.skip(ftype)
+ elif fid == 19:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 20:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 21:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -4797,6 +4838,18 @@ class Table:
oprot.writeFieldBegin('ownerType', TType.I32, 18)
oprot.writeI32(self.ownerType)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 19)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 20)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 21)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -4824,6 +4877,9 @@ class Table:
value = (value * 31) ^ hash(self.creationMetadata)
value = (value * 31) ^ hash(self.catName)
value = (value * 31) ^ hash(self.ownerType)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -4849,6 +4905,9 @@ class Partition:
- parameters
- privileges
- catName
+ - txnId
+ - validWriteIdList
+ - isStatsCompliant
"""
thrift_spec = (
@@ -4862,9 +4921,12 @@ class Partition:
(7, TType.MAP, 'parameters', (TType.STRING,None,TType.STRING,None), None, ), # 7
(8, TType.STRUCT, 'privileges', (PrincipalPrivilegeSet, PrincipalPrivilegeSet.thrift_spec), None, ), # 8
(9, TType.STRING, 'catName', None, None, ), # 9
+ (10, TType.I64, 'txnId', None, -1, ), # 10
+ (11, TType.STRING, 'validWriteIdList', None, None, ), # 11
+ (12, TType.I32, 'isStatsCompliant', None, None, ), # 12
)
- def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None, privileges=None, catName=None,):
+ def __init__(self, values=None, dbName=None, tableName=None, createTime=None, lastAccessTime=None, sd=None, parameters=None, privileges=None, catName=None, txnId=thrift_spec[10][4], validWriteIdList=None, isStatsCompliant=None,):
self.values = values
self.dbName = dbName
self.tableName = tableName
@@ -4874,6 +4936,9 @@ class Partition:
self.parameters = parameters
self.privileges = privileges
self.catName = catName
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -4942,6 +5007,21 @@ class Partition:
self.catName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 10:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 11:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 12:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -4995,6 +5075,18 @@ class Partition:
oprot.writeFieldBegin('catName', TType.STRING, 9)
oprot.writeString(self.catName)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 10)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 11)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 12)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -5013,6 +5105,9 @@ class Partition:
value = (value * 31) ^ hash(self.parameters)
value = (value * 31) ^ hash(self.privileges)
value = (value * 31) ^ hash(self.catName)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -5346,6 +5441,9 @@ class PartitionSpec:
- sharedSDPartitionSpec
- partitionList
- catName
+ - txnId
+ - validWriteIdList
+ - isStatsCompliant
"""
thrift_spec = (
@@ -5356,15 +5454,21 @@ class PartitionSpec:
(4, TType.STRUCT, 'sharedSDPartitionSpec', (PartitionSpecWithSharedSD, PartitionSpecWithSharedSD.thrift_spec), None, ), # 4
(5, TType.STRUCT, 'partitionList', (PartitionListComposingSpec, PartitionListComposingSpec.thrift_spec), None, ), # 5
(6, TType.STRING, 'catName', None, None, ), # 6
+ (7, TType.I64, 'txnId', None, -1, ), # 7
+ (8, TType.STRING, 'validWriteIdList', None, None, ), # 8
+ (9, TType.I32, 'isStatsCompliant', None, None, ), # 9
)
- def __init__(self, dbName=None, tableName=None, rootPath=None, sharedSDPartitionSpec=None, partitionList=None, catName=None,):
+ def __init__(self, dbName=None, tableName=None, rootPath=None, sharedSDPartitionSpec=None, partitionList=None, catName=None, txnId=thrift_spec[7][4], validWriteIdList=None, isStatsCompliant=None,):
self.dbName = dbName
self.tableName = tableName
self.rootPath = rootPath
self.sharedSDPartitionSpec = sharedSDPartitionSpec
self.partitionList = partitionList
self.catName = catName
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -5407,6 +5511,21 @@ class PartitionSpec:
self.catName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 9:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -5441,6 +5560,18 @@ class PartitionSpec:
oprot.writeFieldBegin('catName', TType.STRING, 6)
oprot.writeString(self.catName)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 7)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 8)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 9)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -5456,6 +5587,9 @@ class PartitionSpec:
value = (value * 31) ^ hash(self.sharedSDPartitionSpec)
value = (value * 31) ^ hash(self.partitionList)
value = (value * 31) ^ hash(self.catName)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -6841,17 +6975,26 @@ class ColumnStatistics:
Attributes:
- statsDesc
- statsObj
+ - txnId
+ - validWriteIdList
+ - isStatsCompliant
"""
thrift_spec = (
None, # 0
(1, TType.STRUCT, 'statsDesc', (ColumnStatisticsDesc, ColumnStatisticsDesc.thrift_spec), None, ), # 1
(2, TType.LIST, 'statsObj', (TType.STRUCT,(ColumnStatisticsObj, ColumnStatisticsObj.thrift_spec)), None, ), # 2
+ (3, TType.I64, 'txnId', None, -1, ), # 3
+ (4, TType.STRING, 'validWriteIdList', None, None, ), # 4
+ (5, TType.I32, 'isStatsCompliant', None, None, ), # 5
)
- def __init__(self, statsDesc=None, statsObj=None,):
+ def __init__(self, statsDesc=None, statsObj=None, txnId=thrift_spec[3][4], validWriteIdList=None, isStatsCompliant=None,):
self.statsDesc = statsDesc
self.statsObj = statsObj
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -6879,6 +7022,21 @@ class ColumnStatistics:
iprot.readListEnd()
else:
iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -6900,6 +7058,18 @@ class ColumnStatistics:
iter243.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 3)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 4)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 5)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -6915,6 +7085,9 @@ class ColumnStatistics:
value = 17
value = (value * 31) ^ hash(self.statsDesc)
value = (value * 31) ^ hash(self.statsObj)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -6933,17 +7106,20 @@ class AggrStats:
Attributes:
- colStats
- partsFound
+ - isStatsCompliant
"""
thrift_spec = (
None, # 0
(1, TType.LIST, 'colStats', (TType.STRUCT,(ColumnStatisticsObj, ColumnStatisticsObj.thrift_spec)), None, ), # 1
(2, TType.I64, 'partsFound', None, None, ), # 2
+ (3, TType.I32, 'isStatsCompliant', None, None, ), # 3
)
- def __init__(self, colStats=None, partsFound=None,):
+ def __init__(self, colStats=None, partsFound=None, isStatsCompliant=None,):
self.colStats = colStats
self.partsFound = partsFound
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -6970,6 +7146,11 @@ class AggrStats:
self.partsFound = iprot.readI64()
else:
iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -6991,6 +7172,10 @@ class AggrStats:
oprot.writeFieldBegin('partsFound', TType.I64, 2)
oprot.writeI64(self.partsFound)
oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 3)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -7006,6 +7191,7 @@ class AggrStats:
value = 17
value = (value * 31) ^ hash(self.colStats)
value = (value * 31) ^ hash(self.partsFound)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -7024,17 +7210,23 @@ class SetPartitionsStatsRequest:
Attributes:
- colStats
- needMerge
+ - txnId
+ - validWriteIdList
"""
thrift_spec = (
None, # 0
(1, TType.LIST, 'colStats', (TType.STRUCT,(ColumnStatistics, ColumnStatistics.thrift_spec)), None, ), # 1
(2, TType.BOOL, 'needMerge', None, None, ), # 2
+ (3, TType.I64, 'txnId', None, -1, ), # 3
+ (4, TType.STRING, 'validWriteIdList', None, None, ), # 4
)
- def __init__(self, colStats=None, needMerge=None,):
+ def __init__(self, colStats=None, needMerge=None, txnId=thrift_spec[3][4], validWriteIdList=None,):
self.colStats = colStats
self.needMerge = needMerge
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -7061,6 +7253,16 @@ class SetPartitionsStatsRequest:
self.needMerge = iprot.readBool()
else:
iprot.skip(ftype)
+ elif fid == 3:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 4:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -7082,6 +7284,14 @@ class SetPartitionsStatsRequest:
oprot.writeFieldBegin('needMerge', TType.BOOL, 2)
oprot.writeBool(self.needMerge)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 3)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 4)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -7095,6 +7305,8 @@ class SetPartitionsStatsRequest:
value = 17
value = (value * 31) ^ hash(self.colStats)
value = (value * 31) ^ hash(self.needMerge)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
return value
def __repr__(self):
@@ -9133,15 +9345,18 @@ class TableStatsResult:
"""
Attributes:
- tableStats
+ - isStatsCompliant
"""
thrift_spec = (
None, # 0
(1, TType.LIST, 'tableStats', (TType.STRUCT,(ColumnStatisticsObj, ColumnStatisticsObj.thrift_spec)), None, ), # 1
+ (2, TType.I32, 'isStatsCompliant', None, None, ), # 2
)
- def __init__(self, tableStats=None,):
+ def __init__(self, tableStats=None, isStatsCompliant=None,):
self.tableStats = tableStats
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -9163,6 +9378,11 @@ class TableStatsResult:
iprot.readListEnd()
else:
iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9180,6 +9400,10 @@ class TableStatsResult:
iter380.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 2)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9192,6 +9416,7 @@ class TableStatsResult:
def __hash__(self):
value = 17
value = (value * 31) ^ hash(self.tableStats)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -9209,15 +9434,18 @@ class PartitionsStatsResult:
"""
Attributes:
- partStats
+ - isStatsCompliant
"""
thrift_spec = (
None, # 0
(1, TType.MAP, 'partStats', (TType.STRING,None,TType.LIST,(TType.STRUCT,(ColumnStatisticsObj, ColumnStatisticsObj.thrift_spec))), None, ), # 1
+ (2, TType.I32, 'isStatsCompliant', None, None, ), # 2
)
- def __init__(self, partStats=None,):
+ def __init__(self, partStats=None, isStatsCompliant=None,):
self.partStats = partStats
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -9245,6 +9473,11 @@ class PartitionsStatsResult:
iprot.readMapEnd()
else:
iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9266,6 +9499,10 @@ class PartitionsStatsResult:
oprot.writeListEnd()
oprot.writeMapEnd()
oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 2)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9278,6 +9515,7 @@ class PartitionsStatsResult:
def __hash__(self):
value = 17
value = (value * 31) ^ hash(self.partStats)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -9298,6 +9536,8 @@ class TableStatsRequest:
- tblName
- colNames
- catName
+ - txnId
+ - validWriteIdList
"""
thrift_spec = (
@@ -9306,13 +9546,17 @@ class TableStatsRequest:
(2, TType.STRING, 'tblName', None, None, ), # 2
(3, TType.LIST, 'colNames', (TType.STRING,None), None, ), # 3
(4, TType.STRING, 'catName', None, None, ), # 4
+ (5, TType.I64, 'txnId', None, -1, ), # 5
+ (6, TType.STRING, 'validWriteIdList', None, None, ), # 6
)
- def __init__(self, dbName=None, tblName=None, colNames=None, catName=None,):
+ def __init__(self, dbName=None, tblName=None, colNames=None, catName=None, txnId=thrift_spec[5][4], validWriteIdList=None,):
self.dbName = dbName
self.tblName = tblName
self.colNames = colNames
self.catName = catName
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -9348,6 +9592,16 @@ class TableStatsRequest:
self.catName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9377,6 +9631,14 @@ class TableStatsRequest:
oprot.writeFieldBegin('catName', TType.STRING, 4)
oprot.writeString(self.catName)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 5)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 6)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9396,6 +9658,8 @@ class TableStatsRequest:
value = (value * 31) ^ hash(self.tblName)
value = (value * 31) ^ hash(self.colNames)
value = (value * 31) ^ hash(self.catName)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
return value
def __repr__(self):
@@ -9417,6 +9681,8 @@ class PartitionsStatsRequest:
- colNames
- partNames
- catName
+ - txnId
+ - validWriteIdList
"""
thrift_spec = (
@@ -9426,14 +9692,18 @@ class PartitionsStatsRequest:
(3, TType.LIST, 'colNames', (TType.STRING,None), None, ), # 3
(4, TType.LIST, 'partNames', (TType.STRING,None), None, ), # 4
(5, TType.STRING, 'catName', None, None, ), # 5
+ (6, TType.I64, 'txnId', None, -1, ), # 6
+ (7, TType.STRING, 'validWriteIdList', None, None, ), # 7
)
- def __init__(self, dbName=None, tblName=None, colNames=None, partNames=None, catName=None,):
+ def __init__(self, dbName=None, tblName=None, colNames=None, partNames=None, catName=None, txnId=thrift_spec[6][4], validWriteIdList=None,):
self.dbName = dbName
self.tblName = tblName
self.colNames = colNames
self.partNames = partNames
self.catName = catName
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -9479,6 +9749,16 @@ class PartitionsStatsRequest:
self.catName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9515,6 +9795,14 @@ class PartitionsStatsRequest:
oprot.writeFieldBegin('catName', TType.STRING, 5)
oprot.writeString(self.catName)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 6)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 7)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9537,6 +9825,8 @@ class PartitionsStatsRequest:
value = (value * 31) ^ hash(self.colNames)
value = (value * 31) ^ hash(self.partNames)
value = (value * 31) ^ hash(self.catName)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
return value
def __repr__(self):
@@ -9554,15 +9844,18 @@ class AddPartitionsResult:
"""
Attributes:
- partitions
+ - isStatsCompliant
"""
thrift_spec = (
None, # 0
(1, TType.LIST, 'partitions', (TType.STRUCT,(Partition, Partition.thrift_spec)), None, ), # 1
+ (2, TType.I32, 'isStatsCompliant', None, None, ), # 2
)
- def __init__(self, partitions=None,):
+ def __init__(self, partitions=None, isStatsCompliant=None,):
self.partitions = partitions
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -9584,6 +9877,11 @@ class AddPartitionsResult:
iprot.readListEnd()
else:
iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9601,6 +9899,10 @@ class AddPartitionsResult:
iter424.write(oprot)
oprot.writeListEnd()
oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 2)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9611,6 +9913,7 @@ class AddPartitionsResult:
def __hash__(self):
value = 17
value = (value * 31) ^ hash(self.partitions)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):
@@ -9633,6 +9936,8 @@ class AddPartitionsRequest:
- ifNotExists
- needResult
- catName
+ - txnId
+ - validWriteIdList
"""
thrift_spec = (
@@ -9643,15 +9948,19 @@ class AddPartitionsRequest:
(4, TType.BOOL, 'ifNotExists', None, None, ), # 4
(5, TType.BOOL, 'needResult', None, True, ), # 5
(6, TType.STRING, 'catName', None, None, ), # 6
+ (7, TType.I64, 'txnId', None, -1, ), # 7
+ (8, TType.STRING, 'validWriteIdList', None, None, ), # 8
)
- def __init__(self, dbName=None, tblName=None, parts=None, ifNotExists=None, needResult=thrift_spec[5][4], catName=None,):
+ def __init__(self, dbName=None, tblName=None, parts=None, ifNotExists=None, needResult=thrift_spec[5][4], catName=None, txnId=thrift_spec[7][4], validWriteIdList=None,):
self.dbName = dbName
self.tblName = tblName
self.parts = parts
self.ifNotExists = ifNotExists
self.needResult = needResult
self.catName = catName
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -9698,6 +10007,16 @@ class AddPartitionsRequest:
self.catName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 7:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 8:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -9735,6 +10054,14 @@ class AddPartitionsRequest:
oprot.writeFieldBegin('catName', TType.STRING, 6)
oprot.writeString(self.catName)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 7)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 8)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -9758,6 +10085,8 @@ class AddPartitionsRequest:
value = (value * 31) ^ hash(self.ifNotExists)
value = (value * 31) ^ hash(self.needResult)
value = (value * 31) ^ hash(self.catName)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
return value
def __repr__(self):
@@ -16609,6 +16938,8 @@ class GetTableRequest:
- tblName
- capabilities
- catName
+ - txnId
+ - validWriteIdList
"""
thrift_spec = (
@@ -16617,13 +16948,17 @@ class GetTableRequest:
(2, TType.STRING, 'tblName', None, None, ), # 2
(3, TType.STRUCT, 'capabilities', (ClientCapabilities, ClientCapabilities.thrift_spec), None, ), # 3
(4, TType.STRING, 'catName', None, None, ), # 4
+ (5, TType.I64, 'txnId', None, -1, ), # 5
+ (6, TType.STRING, 'validWriteIdList', None, None, ), # 6
)
- def __init__(self, dbName=None, tblName=None, capabilities=None, catName=None,):
+ def __init__(self, dbName=None, tblName=None, capabilities=None, catName=None, txnId=thrift_spec[5][4], validWriteIdList=None,):
self.dbName = dbName
self.tblName = tblName
self.capabilities = capabilities
self.catName = catName
+ self.txnId = txnId
+ self.validWriteIdList = validWriteIdList
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -16655,6 +16990,16 @@ class GetTableRequest:
self.catName = iprot.readString()
else:
iprot.skip(ftype)
+ elif fid == 5:
+ if ftype == TType.I64:
+ self.txnId = iprot.readI64()
+ else:
+ iprot.skip(ftype)
+ elif fid == 6:
+ if ftype == TType.STRING:
+ self.validWriteIdList = iprot.readString()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -16681,6 +17026,14 @@ class GetTableRequest:
oprot.writeFieldBegin('catName', TType.STRING, 4)
oprot.writeString(self.catName)
oprot.writeFieldEnd()
+ if self.txnId is not None:
+ oprot.writeFieldBegin('txnId', TType.I64, 5)
+ oprot.writeI64(self.txnId)
+ oprot.writeFieldEnd()
+ if self.validWriteIdList is not None:
+ oprot.writeFieldBegin('validWriteIdList', TType.STRING, 6)
+ oprot.writeString(self.validWriteIdList)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -16698,6 +17051,8 @@ class GetTableRequest:
value = (value * 31) ^ hash(self.tblName)
value = (value * 31) ^ hash(self.capabilities)
value = (value * 31) ^ hash(self.catName)
+ value = (value * 31) ^ hash(self.txnId)
+ value = (value * 31) ^ hash(self.validWriteIdList)
return value
def __repr__(self):
@@ -16715,15 +17070,18 @@ class GetTableResult:
"""
Attributes:
- table
+ - isStatsCompliant
"""
thrift_spec = (
None, # 0
(1, TType.STRUCT, 'table', (Table, Table.thrift_spec), None, ), # 1
+ (2, TType.I32, 'isStatsCompliant', None, None, ), # 2
)
- def __init__(self, table=None,):
+ def __init__(self, table=None, isStatsCompliant=None,):
self.table = table
+ self.isStatsCompliant = isStatsCompliant
def read(self, iprot):
if iprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and isinstance(iprot.trans, TTransport.CReadableTransport) and self.thrift_spec is not None and fastbinary is not None:
@@ -16740,6 +17098,11 @@ class GetTableResult:
self.table.read(iprot)
else:
iprot.skip(ftype)
+ elif fid == 2:
+ if ftype == TType.I32:
+ self.isStatsCompliant = iprot.readI32()
+ else:
+ iprot.skip(ftype)
else:
iprot.skip(ftype)
iprot.readFieldEnd()
@@ -16754,6 +17117,10 @@ class GetTableResult:
oprot.writeFieldBegin('table', TType.STRUCT, 1)
self.table.write(oprot)
oprot.writeFieldEnd()
+ if self.isStatsCompliant is not None:
+ oprot.writeFieldBegin('isStatsCompliant', TType.I32, 2)
+ oprot.writeI32(self.isStatsCompliant)
+ oprot.writeFieldEnd()
oprot.writeFieldStop()
oprot.writeStructEnd()
@@ -16766,6 +17133,7 @@ class GetTableResult:
def __hash__(self):
value = 17
value = (value * 31) ^ hash(self.table)
+ value = (value * 31) ^ hash(self.isStatsCompliant)
return value
def __repr__(self):