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 2017/11/06 19:44:52 UTC
[03/10] hive git commit: HIVE-17907 : enable and apply resource plan
commands in HS2 (Sergey Shelukhin, reviewed by Prasanth Jayachandran)
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/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 55498bd..716638c 100644
--- a/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
+++ b/standalone-metastore/src/gen/thrift/gen-php/metastore/Types.php
@@ -20574,11 +20574,7 @@ class WMPool {
/**
* @var string
*/
- public $poolName = null;
- /**
- * @var string
- */
- public $parentPoolName = null;
+ public $poolPath = null;
/**
* @var double
*/
@@ -20600,22 +20596,18 @@ class WMPool {
'type' => TType::STRING,
),
2 => array(
- 'var' => 'poolName',
+ 'var' => 'poolPath',
'type' => TType::STRING,
),
3 => array(
- 'var' => 'parentPoolName',
- 'type' => TType::STRING,
- ),
- 4 => array(
'var' => 'allocFraction',
'type' => TType::DOUBLE,
),
- 5 => array(
+ 4 => array(
'var' => 'queryParallelism',
'type' => TType::I32,
),
- 6 => array(
+ 5 => array(
'var' => 'schedulingPolicy',
'type' => TType::STRING,
),
@@ -20625,11 +20617,8 @@ class WMPool {
if (isset($vals['resourcePlanName'])) {
$this->resourcePlanName = $vals['resourcePlanName'];
}
- if (isset($vals['poolName'])) {
- $this->poolName = $vals['poolName'];
- }
- if (isset($vals['parentPoolName'])) {
- $this->parentPoolName = $vals['parentPoolName'];
+ if (isset($vals['poolPath'])) {
+ $this->poolPath = $vals['poolPath'];
}
if (isset($vals['allocFraction'])) {
$this->allocFraction = $vals['allocFraction'];
@@ -20671,33 +20660,26 @@ class WMPool {
break;
case 2:
if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->poolName);
+ $xfer += $input->readString($this->poolPath);
} else {
$xfer += $input->skip($ftype);
}
break;
case 3:
- if ($ftype == TType::STRING) {
- $xfer += $input->readString($this->parentPoolName);
- } else {
- $xfer += $input->skip($ftype);
- }
- break;
- case 4:
if ($ftype == TType::DOUBLE) {
$xfer += $input->readDouble($this->allocFraction);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 5:
+ case 4:
if ($ftype == TType::I32) {
$xfer += $input->readI32($this->queryParallelism);
} else {
$xfer += $input->skip($ftype);
}
break;
- case 6:
+ case 5:
if ($ftype == TType::STRING) {
$xfer += $input->readString($this->schedulingPolicy);
} else {
@@ -20722,28 +20704,23 @@ class WMPool {
$xfer += $output->writeString($this->resourcePlanName);
$xfer += $output->writeFieldEnd();
}
- if ($this->poolName !== null) {
- $xfer += $output->writeFieldBegin('poolName', TType::STRING, 2);
- $xfer += $output->writeString($this->poolName);
- $xfer += $output->writeFieldEnd();
- }
- if ($this->parentPoolName !== null) {
- $xfer += $output->writeFieldBegin('parentPoolName', TType::STRING, 3);
- $xfer += $output->writeString($this->parentPoolName);
+ if ($this->poolPath !== null) {
+ $xfer += $output->writeFieldBegin('poolPath', TType::STRING, 2);
+ $xfer += $output->writeString($this->poolPath);
$xfer += $output->writeFieldEnd();
}
if ($this->allocFraction !== null) {
- $xfer += $output->writeFieldBegin('allocFraction', TType::DOUBLE, 4);
+ $xfer += $output->writeFieldBegin('allocFraction', TType::DOUBLE, 3);
$xfer += $output->writeDouble($this->allocFraction);
$xfer += $output->writeFieldEnd();
}
if ($this->queryParallelism !== null) {
- $xfer += $output->writeFieldBegin('queryParallelism', TType::I32, 5);
+ $xfer += $output->writeFieldBegin('queryParallelism', TType::I32, 4);
$xfer += $output->writeI32($this->queryParallelism);
$xfer += $output->writeFieldEnd();
}
if ($this->schedulingPolicy !== null) {
- $xfer += $output->writeFieldBegin('schedulingPolicy', TType::STRING, 6);
+ $xfer += $output->writeFieldBegin('schedulingPolicy', TType::STRING, 5);
$xfer += $output->writeString($this->schedulingPolicy);
$xfer += $output->writeFieldEnd();
}
@@ -21065,6 +21042,388 @@ class WMMapping {
}
+class WMPoolTrigger {
+ static $_TSPEC;
+
+ /**
+ * @var string
+ */
+ public $pool = null;
+ /**
+ * @var string
+ */
+ public $trigger = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'pool',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'trigger',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['pool'])) {
+ $this->pool = $vals['pool'];
+ }
+ if (isset($vals['trigger'])) {
+ $this->trigger = $vals['trigger'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WMPoolTrigger';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->pool);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->trigger);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WMPoolTrigger');
+ if ($this->pool !== null) {
+ $xfer += $output->writeFieldBegin('pool', TType::STRING, 1);
+ $xfer += $output->writeString($this->pool);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->trigger !== null) {
+ $xfer += $output->writeFieldBegin('trigger', TType::STRING, 2);
+ $xfer += $output->writeString($this->trigger);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class WMFullResourcePlan {
+ static $_TSPEC;
+
+ /**
+ * @var \metastore\WMResourcePlan
+ */
+ public $plan = null;
+ /**
+ * @var \metastore\WMPool[]
+ */
+ public $pools = null;
+ /**
+ * @var \metastore\WMMapping[]
+ */
+ public $mappings = null;
+ /**
+ * @var \metastore\WMTrigger[]
+ */
+ public $triggers = null;
+ /**
+ * @var \metastore\WMPoolTrigger[]
+ */
+ public $poolTriggers = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'plan',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMResourcePlan',
+ ),
+ 2 => array(
+ 'var' => 'pools',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMPool',
+ ),
+ ),
+ 3 => array(
+ 'var' => 'mappings',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMMapping',
+ ),
+ ),
+ 4 => array(
+ 'var' => 'triggers',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMTrigger',
+ ),
+ ),
+ 5 => array(
+ 'var' => 'poolTriggers',
+ 'type' => TType::LST,
+ 'etype' => TType::STRUCT,
+ 'elem' => array(
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMPoolTrigger',
+ ),
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['plan'])) {
+ $this->plan = $vals['plan'];
+ }
+ if (isset($vals['pools'])) {
+ $this->pools = $vals['pools'];
+ }
+ if (isset($vals['mappings'])) {
+ $this->mappings = $vals['mappings'];
+ }
+ if (isset($vals['triggers'])) {
+ $this->triggers = $vals['triggers'];
+ }
+ if (isset($vals['poolTriggers'])) {
+ $this->poolTriggers = $vals['poolTriggers'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WMFullResourcePlan';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->plan = new \metastore\WMResourcePlan();
+ $xfer += $this->plan->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::LST) {
+ $this->pools = array();
+ $_size652 = 0;
+ $_etype655 = 0;
+ $xfer += $input->readListBegin($_etype655, $_size652);
+ for ($_i656 = 0; $_i656 < $_size652; ++$_i656)
+ {
+ $elem657 = null;
+ $elem657 = new \metastore\WMPool();
+ $xfer += $elem657->read($input);
+ $this->pools []= $elem657;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::LST) {
+ $this->mappings = array();
+ $_size658 = 0;
+ $_etype661 = 0;
+ $xfer += $input->readListBegin($_etype661, $_size658);
+ for ($_i662 = 0; $_i662 < $_size658; ++$_i662)
+ {
+ $elem663 = null;
+ $elem663 = new \metastore\WMMapping();
+ $xfer += $elem663->read($input);
+ $this->mappings []= $elem663;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::LST) {
+ $this->triggers = array();
+ $_size664 = 0;
+ $_etype667 = 0;
+ $xfer += $input->readListBegin($_etype667, $_size664);
+ for ($_i668 = 0; $_i668 < $_size664; ++$_i668)
+ {
+ $elem669 = null;
+ $elem669 = new \metastore\WMTrigger();
+ $xfer += $elem669->read($input);
+ $this->triggers []= $elem669;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::LST) {
+ $this->poolTriggers = array();
+ $_size670 = 0;
+ $_etype673 = 0;
+ $xfer += $input->readListBegin($_etype673, $_size670);
+ for ($_i674 = 0; $_i674 < $_size670; ++$_i674)
+ {
+ $elem675 = null;
+ $elem675 = new \metastore\WMPoolTrigger();
+ $xfer += $elem675->read($input);
+ $this->poolTriggers []= $elem675;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WMFullResourcePlan');
+ if ($this->plan !== null) {
+ if (!is_object($this->plan)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('plan', TType::STRUCT, 1);
+ $xfer += $this->plan->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->pools !== null) {
+ if (!is_array($this->pools)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('pools', TType::LST, 2);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->pools));
+ {
+ foreach ($this->pools as $iter676)
+ {
+ $xfer += $iter676->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->mappings !== null) {
+ if (!is_array($this->mappings)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('mappings', TType::LST, 3);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->mappings));
+ {
+ foreach ($this->mappings as $iter677)
+ {
+ $xfer += $iter677->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->triggers !== null) {
+ if (!is_array($this->triggers)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('triggers', TType::LST, 4);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->triggers));
+ {
+ foreach ($this->triggers as $iter678)
+ {
+ $xfer += $iter678->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->poolTriggers !== null) {
+ if (!is_array($this->poolTriggers)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('poolTriggers', TType::LST, 5);
+ {
+ $output->writeListBegin(TType::STRUCT, count($this->poolTriggers));
+ {
+ foreach ($this->poolTriggers as $iter679)
+ {
+ $xfer += $iter679->write($output);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class WMCreateResourcePlanRequest {
static $_TSPEC;
@@ -21195,6 +21554,136 @@ class WMCreateResourcePlanResponse {
}
+class WMGetActiveResourcePlanRequest {
+ static $_TSPEC;
+
+
+ public function __construct() {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ );
+ }
+ }
+
+ public function getName() {
+ return 'WMGetActiveResourcePlanRequest';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WMGetActiveResourcePlanRequest');
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class WMGetActiveResourcePlanResponse {
+ static $_TSPEC;
+
+ /**
+ * @var \metastore\WMFullResourcePlan
+ */
+ public $resourcePlan = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'resourcePlan',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMFullResourcePlan',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['resourcePlan'])) {
+ $this->resourcePlan = $vals['resourcePlan'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'WMGetActiveResourcePlanResponse';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->resourcePlan = new \metastore\WMFullResourcePlan();
+ $xfer += $this->resourcePlan->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('WMGetActiveResourcePlanResponse');
+ if ($this->resourcePlan !== null) {
+ if (!is_object($this->resourcePlan)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('resourcePlan', TType::STRUCT, 1);
+ $xfer += $this->resourcePlan->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class WMGetResourcePlanRequest {
static $_TSPEC;
@@ -21451,15 +21940,15 @@ class WMGetAllResourcePlanResponse {
case 1:
if ($ftype == TType::LST) {
$this->resourcePlans = array();
- $_size652 = 0;
- $_etype655 = 0;
- $xfer += $input->readListBegin($_etype655, $_size652);
- for ($_i656 = 0; $_i656 < $_size652; ++$_i656)
+ $_size680 = 0;
+ $_etype683 = 0;
+ $xfer += $input->readListBegin($_etype683, $_size680);
+ for ($_i684 = 0; $_i684 < $_size680; ++$_i684)
{
- $elem657 = null;
- $elem657 = new \metastore\WMResourcePlan();
- $xfer += $elem657->read($input);
- $this->resourcePlans []= $elem657;
+ $elem685 = null;
+ $elem685 = new \metastore\WMResourcePlan();
+ $xfer += $elem685->read($input);
+ $this->resourcePlans []= $elem685;
}
$xfer += $input->readListEnd();
} else {
@@ -21487,9 +21976,9 @@ class WMGetAllResourcePlanResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->resourcePlans));
{
- foreach ($this->resourcePlans as $iter658)
+ foreach ($this->resourcePlans as $iter686)
{
- $xfer += $iter658->write($output);
+ $xfer += $iter686->write($output);
}
}
$output->writeListEnd();
@@ -21514,6 +22003,10 @@ class WMAlterResourcePlanRequest {
* @var \metastore\WMResourcePlan
*/
public $resourcePlan = null;
+ /**
+ * @var bool
+ */
+ public $isEnableAndActivate = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
@@ -21527,6 +22020,10 @@ class WMAlterResourcePlanRequest {
'type' => TType::STRUCT,
'class' => '\metastore\WMResourcePlan',
),
+ 3 => array(
+ 'var' => 'isEnableAndActivate',
+ 'type' => TType::BOOL,
+ ),
);
}
if (is_array($vals)) {
@@ -21536,6 +22033,9 @@ class WMAlterResourcePlanRequest {
if (isset($vals['resourcePlan'])) {
$this->resourcePlan = $vals['resourcePlan'];
}
+ if (isset($vals['isEnableAndActivate'])) {
+ $this->isEnableAndActivate = $vals['isEnableAndActivate'];
+ }
}
}
@@ -21573,6 +22073,13 @@ class WMAlterResourcePlanRequest {
$xfer += $input->skip($ftype);
}
break;
+ case 3:
+ if ($ftype == TType::BOOL) {
+ $xfer += $input->readBool($this->isEnableAndActivate);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -21599,6 +22106,11 @@ class WMAlterResourcePlanRequest {
$xfer += $this->resourcePlan->write($output);
$xfer += $output->writeFieldEnd();
}
+ if ($this->isEnableAndActivate !== null) {
+ $xfer += $output->writeFieldBegin('isEnableAndActivate', TType::BOOL, 3);
+ $xfer += $output->writeBool($this->isEnableAndActivate);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -21609,12 +22121,26 @@ class WMAlterResourcePlanRequest {
class WMAlterResourcePlanResponse {
static $_TSPEC;
+ /**
+ * @var \metastore\WMFullResourcePlan
+ */
+ public $fullResourcePlan = null;
- public function __construct() {
+ public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'fullResourcePlan',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\WMFullResourcePlan',
+ ),
);
}
+ if (is_array($vals)) {
+ if (isset($vals['fullResourcePlan'])) {
+ $this->fullResourcePlan = $vals['fullResourcePlan'];
+ }
+ }
}
public function getName() {
@@ -21636,6 +22162,14 @@ class WMAlterResourcePlanResponse {
}
switch ($fid)
{
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->fullResourcePlan = new \metastore\WMFullResourcePlan();
+ $xfer += $this->fullResourcePlan->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
default:
$xfer += $input->skip($ftype);
break;
@@ -21649,6 +22183,14 @@ class WMAlterResourcePlanResponse {
public function write($output) {
$xfer = 0;
$xfer += $output->writeStructBegin('WMAlterResourcePlanResponse');
+ if ($this->fullResourcePlan !== null) {
+ if (!is_object($this->fullResourcePlan)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('fullResourcePlan', TType::STRUCT, 1);
+ $xfer += $this->fullResourcePlan->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
$xfer += $output->writeFieldStop();
$xfer += $output->writeStructEnd();
return $xfer;
@@ -22465,15 +23007,15 @@ class WMGetTriggersForResourePlanResponse {
case 1:
if ($ftype == TType::LST) {
$this->triggers = array();
- $_size659 = 0;
- $_etype662 = 0;
- $xfer += $input->readListBegin($_etype662, $_size659);
- for ($_i663 = 0; $_i663 < $_size659; ++$_i663)
+ $_size687 = 0;
+ $_etype690 = 0;
+ $xfer += $input->readListBegin($_etype690, $_size687);
+ for ($_i691 = 0; $_i691 < $_size687; ++$_i691)
{
- $elem664 = null;
- $elem664 = new \metastore\WMTrigger();
- $xfer += $elem664->read($input);
- $this->triggers []= $elem664;
+ $elem692 = null;
+ $elem692 = new \metastore\WMTrigger();
+ $xfer += $elem692->read($input);
+ $this->triggers []= $elem692;
}
$xfer += $input->readListEnd();
} else {
@@ -22501,9 +23043,9 @@ class WMGetTriggersForResourePlanResponse {
{
$output->writeListBegin(TType::STRUCT, count($this->triggers));
{
- foreach ($this->triggers as $iter665)
+ foreach ($this->triggers as $iter693)
{
- $xfer += $iter665->write($output);
+ $xfer += $iter693->write($output);
}
}
$output->writeListEnd();
http://git-wip-us.apache.org/repos/asf/hive/blob/ddce801f/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 7dc34dd..9cc9d1c 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
@@ -188,6 +188,7 @@ if len(sys.argv) <= 1 or sys.argv[1] == '--help':
print(' string get_metastore_db_uuid()')
print(' WMCreateResourcePlanResponse create_resource_plan(WMCreateResourcePlanRequest request)')
print(' WMGetResourcePlanResponse get_resource_plan(WMGetResourcePlanRequest request)')
+ print(' WMGetActiveResourcePlanResponse get_active_resource_plan(WMGetActiveResourcePlanRequest request)')
print(' WMGetAllResourcePlanResponse get_all_resource_plans(WMGetAllResourcePlanRequest request)')
print(' WMAlterResourcePlanResponse alter_resource_plan(WMAlterResourcePlanRequest request)')
print(' WMValidateResourcePlanResponse validate_resource_plan(WMValidateResourcePlanRequest request)')
@@ -1249,6 +1250,12 @@ elif cmd == 'get_resource_plan':
sys.exit(1)
pp.pprint(client.get_resource_plan(eval(args[0]),))
+elif cmd == 'get_active_resource_plan':
+ if len(args) != 1:
+ print('get_active_resource_plan requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.get_active_resource_plan(eval(args[0]),))
+
elif cmd == 'get_all_resource_plans':
if len(args) != 1:
print('get_all_resource_plans requires 1 args')