You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2014/02/20 00:50:34 UTC
svn commit: r1569985 [6/8] - in /hive/trunk:
itests/hive-unit/src/test/java/org/apache/hadoop/hive/metastore/
itests/util/src/main/java/org/apache/hadoop/hive/ql/ metastore/if/
metastore/src/gen/thrift/gen-cpp/
metastore/src/gen/thrift/gen-javabean/org...
Modified: hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java?rev=1569985&r1=1569984&r2=1569985&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java Wed Feb 19 23:50:32 2014
@@ -618,7 +618,7 @@ public class Type implements org.apache.
struct.fields = new ArrayList<FieldSchema>(_list0.size);
for (int _i1 = 0; _i1 < _list0.size; ++_i1)
{
- FieldSchema _elem2; // required
+ FieldSchema _elem2; // optional
_elem2 = new FieldSchema();
_elem2.read(iprot);
struct.fields.add(_elem2);
@@ -749,7 +749,7 @@ public class Type implements org.apache.
struct.fields = new ArrayList<FieldSchema>(_list5.size);
for (int _i6 = 0; _i6 < _list5.size; ++_i6)
{
- FieldSchema _elem7; // required
+ FieldSchema _elem7; // optional
_elem7 = new FieldSchema();
_elem7.read(iprot);
struct.fields.add(_elem7);
Modified: hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php?rev=1569985&r1=1569984&r2=1569985&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php Wed Feb 19 23:50:32 2014
@@ -89,6 +89,11 @@ interface ThriftHiveMetastoreIf extends
public function get_partitions_statistics_req(\metastore\PartitionsStatsRequest $request);
public function delete_partition_column_statistics($db_name, $tbl_name, $part_name, $col_name);
public function delete_table_column_statistics($db_name, $tbl_name, $col_name);
+ public function create_function(\metastore\Function $func);
+ public function drop_function($dbName, $funcName);
+ public function alter_function($dbName, $funcName, \metastore\Function $newFunc);
+ public function get_functions($dbName, $pattern);
+ public function get_function($dbName, $funcName);
public function create_role(\metastore\Role $role);
public function drop_role($role_name);
public function get_role_names();
@@ -4441,6 +4446,290 @@ class ThriftHiveMetastoreClient extends
throw new \Exception("delete_table_column_statistics failed: unknown result");
}
+ public function create_function(\metastore\Function $func)
+ {
+ $this->send_create_function($func);
+ $this->recv_create_function();
+ }
+
+ public function send_create_function(\metastore\Function $func)
+ {
+ $args = new \metastore\ThriftHiveMetastore_create_function_args();
+ $args->func = $func;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'create_function', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('create_function', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_create_function()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_create_function_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_create_function_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o2 !== null) {
+ throw $result->o2;
+ }
+ if ($result->o3 !== null) {
+ throw $result->o3;
+ }
+ if ($result->o4 !== null) {
+ throw $result->o4;
+ }
+ return;
+ }
+
+ public function drop_function($dbName, $funcName)
+ {
+ $this->send_drop_function($dbName, $funcName);
+ $this->recv_drop_function();
+ }
+
+ public function send_drop_function($dbName, $funcName)
+ {
+ $args = new \metastore\ThriftHiveMetastore_drop_function_args();
+ $args->dbName = $dbName;
+ $args->funcName = $funcName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'drop_function', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('drop_function', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_drop_function()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_drop_function_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_drop_function_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o3 !== null) {
+ throw $result->o3;
+ }
+ return;
+ }
+
+ public function alter_function($dbName, $funcName, \metastore\Function $newFunc)
+ {
+ $this->send_alter_function($dbName, $funcName, $newFunc);
+ $this->recv_alter_function();
+ }
+
+ public function send_alter_function($dbName, $funcName, \metastore\Function $newFunc)
+ {
+ $args = new \metastore\ThriftHiveMetastore_alter_function_args();
+ $args->dbName = $dbName;
+ $args->funcName = $funcName;
+ $args->newFunc = $newFunc;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'alter_function', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('alter_function', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_alter_function()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_alter_function_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_alter_function_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o2 !== null) {
+ throw $result->o2;
+ }
+ return;
+ }
+
+ public function get_functions($dbName, $pattern)
+ {
+ $this->send_get_functions($dbName, $pattern);
+ return $this->recv_get_functions();
+ }
+
+ public function send_get_functions($dbName, $pattern)
+ {
+ $args = new \metastore\ThriftHiveMetastore_get_functions_args();
+ $args->dbName = $dbName;
+ $args->pattern = $pattern;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'get_functions', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('get_functions', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_get_functions()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_get_functions_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_get_functions_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ throw new \Exception("get_functions failed: unknown result");
+ }
+
+ public function get_function($dbName, $funcName)
+ {
+ $this->send_get_function($dbName, $funcName);
+ return $this->recv_get_function();
+ }
+
+ public function send_get_function($dbName, $funcName)
+ {
+ $args = new \metastore\ThriftHiveMetastore_get_function_args();
+ $args->dbName = $dbName;
+ $args->funcName = $funcName;
+ $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'get_function', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('get_function', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_get_function()
+ {
+ $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_get_function_result', $this->input_->isStrictRead());
+ else
+ {
+ $rseqid = 0;
+ $fname = null;
+ $mtype = 0;
+
+ $this->input_->readMessageBegin($fname, $mtype, $rseqid);
+ if ($mtype == TMessageType::EXCEPTION) {
+ $x = new TApplicationException();
+ $x->read($this->input_);
+ $this->input_->readMessageEnd();
+ throw $x;
+ }
+ $result = new \metastore\ThriftHiveMetastore_get_function_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ if ($result->success !== null) {
+ return $result->success;
+ }
+ if ($result->o1 !== null) {
+ throw $result->o1;
+ }
+ if ($result->o2 !== null) {
+ throw $result->o2;
+ }
+ throw new \Exception("get_function failed: unknown result");
+ }
+
public function create_role(\metastore\Role $role)
{
$this->send_create_role($role);
@@ -23178,30 +23467,30 @@ class ThriftHiveMetastore_delete_table_c
}
-class ThriftHiveMetastore_create_role_args {
+class ThriftHiveMetastore_create_function_args {
static $_TSPEC;
- public $role = null;
+ public $func = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
1 => array(
- 'var' => 'role',
+ 'var' => 'func',
'type' => TType::STRUCT,
- 'class' => '\metastore\Role',
+ 'class' => '\metastore\Function',
),
);
}
if (is_array($vals)) {
- if (isset($vals['role'])) {
- $this->role = $vals['role'];
+ if (isset($vals['func'])) {
+ $this->func = $vals['func'];
}
}
}
public function getName() {
- return 'ThriftHiveMetastore_create_role_args';
+ return 'ThriftHiveMetastore_create_function_args';
}
public function read($input)
@@ -23221,8 +23510,8 @@ class ThriftHiveMetastore_create_role_ar
{
case 1:
if ($ftype == TType::STRUCT) {
- $this->role = new \metastore\Role();
- $xfer += $this->role->read($input);
+ $this->func = new \metastore\Function();
+ $xfer += $this->func->read($input);
} else {
$xfer += $input->skip($ftype);
}
@@ -23239,13 +23528,13 @@ class ThriftHiveMetastore_create_role_ar
public function write($output) {
$xfer = 0;
- $xfer += $output->writeStructBegin('ThriftHiveMetastore_create_role_args');
- if ($this->role !== null) {
- if (!is_object($this->role)) {
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_create_function_args');
+ if ($this->func !== null) {
+ if (!is_object($this->func)) {
throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
}
- $xfer += $output->writeFieldBegin('role', TType::STRUCT, 1);
- $xfer += $this->role->write($output);
+ $xfer += $output->writeFieldBegin('func', TType::STRUCT, 1);
+ $xfer += $this->func->write($output);
$xfer += $output->writeFieldEnd();
}
$xfer += $output->writeFieldStop();
@@ -23255,19 +23544,1062 @@ class ThriftHiveMetastore_create_role_ar
}
-class ThriftHiveMetastore_create_role_result {
+class ThriftHiveMetastore_create_function_result {
static $_TSPEC;
- public $success = null;
public $o1 = null;
+ public $o2 = null;
+ public $o3 = null;
+ public $o4 = null;
public function __construct($vals=null) {
if (!isset(self::$_TSPEC)) {
self::$_TSPEC = array(
- 0 => array(
- 'var' => 'success',
- 'type' => TType::BOOL,
- ),
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\AlreadyExistsException',
+ ),
+ 2 => array(
+ 'var' => 'o2',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\InvalidObjectException',
+ ),
+ 3 => array(
+ 'var' => 'o3',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ 4 => array(
+ 'var' => 'o4',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\NoSuchObjectException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ if (isset($vals['o2'])) {
+ $this->o2 = $vals['o2'];
+ }
+ if (isset($vals['o3'])) {
+ $this->o3 = $vals['o3'];
+ }
+ if (isset($vals['o4'])) {
+ $this->o4 = $vals['o4'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_create_function_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\AlreadyExistsException();
+ $xfer += $this->o1->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->o2 = new \metastore\InvalidObjectException();
+ $xfer += $this->o2->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->o3 = new \metastore\MetaException();
+ $xfer += $this->o3->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRUCT) {
+ $this->o4 = new \metastore\NoSuchObjectException();
+ $xfer += $this->o4->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_create_function_result');
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o2 !== null) {
+ $xfer += $output->writeFieldBegin('o2', TType::STRUCT, 2);
+ $xfer += $this->o2->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o3 !== null) {
+ $xfer += $output->writeFieldBegin('o3', TType::STRUCT, 3);
+ $xfer += $this->o3->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o4 !== null) {
+ $xfer += $output->writeFieldBegin('o4', TType::STRUCT, 4);
+ $xfer += $this->o4->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_drop_function_args {
+ static $_TSPEC;
+
+ public $dbName = null;
+ public $funcName = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'funcName',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['funcName'])) {
+ $this->funcName = $vals['funcName'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_drop_function_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->funcName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_drop_function_args');
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 1);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->funcName !== null) {
+ $xfer += $output->writeFieldBegin('funcName', TType::STRING, 2);
+ $xfer += $output->writeString($this->funcName);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_drop_function_result {
+ static $_TSPEC;
+
+ public $o1 = null;
+ public $o3 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\NoSuchObjectException',
+ ),
+ 2 => array(
+ 'var' => 'o3',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ if (isset($vals['o3'])) {
+ $this->o3 = $vals['o3'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_drop_function_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\NoSuchObjectException();
+ $xfer += $this->o1->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->o3 = new \metastore\MetaException();
+ $xfer += $this->o3->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_drop_function_result');
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o3 !== null) {
+ $xfer += $output->writeFieldBegin('o3', TType::STRUCT, 2);
+ $xfer += $this->o3->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_alter_function_args {
+ static $_TSPEC;
+
+ public $dbName = null;
+ public $funcName = null;
+ public $newFunc = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'funcName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'newFunc',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Function',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['funcName'])) {
+ $this->funcName = $vals['funcName'];
+ }
+ if (isset($vals['newFunc'])) {
+ $this->newFunc = $vals['newFunc'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_alter_function_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->funcName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRUCT) {
+ $this->newFunc = new \metastore\Function();
+ $xfer += $this->newFunc->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_function_args');
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 1);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->funcName !== null) {
+ $xfer += $output->writeFieldBegin('funcName', TType::STRING, 2);
+ $xfer += $output->writeString($this->funcName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->newFunc !== null) {
+ if (!is_object($this->newFunc)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('newFunc', TType::STRUCT, 3);
+ $xfer += $this->newFunc->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_alter_function_result {
+ static $_TSPEC;
+
+ public $o1 = null;
+ public $o2 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\InvalidOperationException',
+ ),
+ 2 => array(
+ 'var' => 'o2',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ if (isset($vals['o2'])) {
+ $this->o2 = $vals['o2'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_alter_function_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\InvalidOperationException();
+ $xfer += $this->o1->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->o2 = new \metastore\MetaException();
+ $xfer += $this->o2->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_alter_function_result');
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o2 !== null) {
+ $xfer += $output->writeFieldBegin('o2', TType::STRUCT, 2);
+ $xfer += $this->o2->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_get_functions_args {
+ static $_TSPEC;
+
+ public $dbName = null;
+ public $pattern = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'pattern',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['pattern'])) {
+ $this->pattern = $vals['pattern'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_get_functions_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->pattern);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_functions_args');
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 1);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->pattern !== null) {
+ $xfer += $output->writeFieldBegin('pattern', TType::STRING, 2);
+ $xfer += $output->writeString($this->pattern);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_get_functions_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $o1 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::LST,
+ 'etype' => TType::STRING,
+ 'elem' => array(
+ 'type' => TType::STRING,
+ ),
+ ),
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_get_functions_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::LST) {
+ $this->success = array();
+ $_size617 = 0;
+ $_etype620 = 0;
+ $xfer += $input->readListBegin($_etype620, $_size617);
+ for ($_i621 = 0; $_i621 < $_size617; ++$_i621)
+ {
+ $elem622 = null;
+ $xfer += $input->readString($elem622);
+ $this->success []= $elem622;
+ }
+ $xfer += $input->readListEnd();
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\MetaException();
+ $xfer += $this->o1->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_functions_result');
+ if ($this->success !== null) {
+ if (!is_array($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::LST, 0);
+ {
+ $output->writeListBegin(TType::STRING, count($this->success));
+ {
+ foreach ($this->success as $iter623)
+ {
+ $xfer += $output->writeString($iter623);
+ }
+ }
+ $output->writeListEnd();
+ }
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_get_function_args {
+ static $_TSPEC;
+
+ public $dbName = null;
+ public $funcName = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'funcName',
+ 'type' => TType::STRING,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['funcName'])) {
+ $this->funcName = $vals['funcName'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_get_function_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->funcName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_function_args');
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 1);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->funcName !== null) {
+ $xfer += $output->writeFieldBegin('funcName', TType::STRING, 2);
+ $xfer += $output->writeString($this->funcName);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_get_function_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $o1 = null;
+ public $o2 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Function',
+ ),
+ 1 => array(
+ 'var' => 'o1',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\MetaException',
+ ),
+ 2 => array(
+ 'var' => 'o2',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\NoSuchObjectException',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['success'])) {
+ $this->success = $vals['success'];
+ }
+ if (isset($vals['o1'])) {
+ $this->o1 = $vals['o1'];
+ }
+ if (isset($vals['o2'])) {
+ $this->o2 = $vals['o2'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_get_function_result';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 0:
+ if ($ftype == TType::STRUCT) {
+ $this->success = new \metastore\Function();
+ $xfer += $this->success->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->o1 = new \metastore\MetaException();
+ $xfer += $this->o1->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRUCT) {
+ $this->o2 = new \metastore\NoSuchObjectException();
+ $xfer += $this->o2->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_get_function_result');
+ if ($this->success !== null) {
+ if (!is_object($this->success)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('success', TType::STRUCT, 0);
+ $xfer += $this->success->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o1 !== null) {
+ $xfer += $output->writeFieldBegin('o1', TType::STRUCT, 1);
+ $xfer += $this->o1->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->o2 !== null) {
+ $xfer += $output->writeFieldBegin('o2', TType::STRUCT, 2);
+ $xfer += $this->o2->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_create_role_args {
+ static $_TSPEC;
+
+ public $role = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'role',
+ 'type' => TType::STRUCT,
+ 'class' => '\metastore\Role',
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['role'])) {
+ $this->role = $vals['role'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'ThriftHiveMetastore_create_role_args';
+ }
+
+ public function read($input)
+ {
+ $xfer = 0;
+ $fname = null;
+ $ftype = 0;
+ $fid = 0;
+ $xfer += $input->readStructBegin($fname);
+ while (true)
+ {
+ $xfer += $input->readFieldBegin($fname, $ftype, $fid);
+ if ($ftype == TType::STOP) {
+ break;
+ }
+ switch ($fid)
+ {
+ case 1:
+ if ($ftype == TType::STRUCT) {
+ $this->role = new \metastore\Role();
+ $xfer += $this->role->read($input);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ default:
+ $xfer += $input->skip($ftype);
+ break;
+ }
+ $xfer += $input->readFieldEnd();
+ }
+ $xfer += $input->readStructEnd();
+ return $xfer;
+ }
+
+ public function write($output) {
+ $xfer = 0;
+ $xfer += $output->writeStructBegin('ThriftHiveMetastore_create_role_args');
+ if ($this->role !== null) {
+ if (!is_object($this->role)) {
+ throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA);
+ }
+ $xfer += $output->writeFieldBegin('role', TType::STRUCT, 1);
+ $xfer += $this->role->write($output);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
+class ThriftHiveMetastore_create_role_result {
+ static $_TSPEC;
+
+ public $success = null;
+ public $o1 = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 0 => array(
+ 'var' => 'success',
+ 'type' => TType::BOOL,
+ ),
1 => array(
'var' => 'o1',
'type' => TType::STRUCT,
@@ -23621,14 +24953,14 @@ class ThriftHiveMetastore_get_role_names
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size617 = 0;
- $_etype620 = 0;
- $xfer += $input->readListBegin($_etype620, $_size617);
- for ($_i621 = 0; $_i621 < $_size617; ++$_i621)
+ $_size624 = 0;
+ $_etype627 = 0;
+ $xfer += $input->readListBegin($_etype627, $_size624);
+ for ($_i628 = 0; $_i628 < $_size624; ++$_i628)
{
- $elem622 = null;
- $xfer += $input->readString($elem622);
- $this->success []= $elem622;
+ $elem629 = null;
+ $xfer += $input->readString($elem629);
+ $this->success []= $elem629;
}
$xfer += $input->readListEnd();
} else {
@@ -23664,9 +24996,9 @@ class ThriftHiveMetastore_get_role_names
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter623)
+ foreach ($this->success as $iter630)
{
- $xfer += $output->writeString($iter623);
+ $xfer += $output->writeString($iter630);
}
}
$output->writeListEnd();
@@ -24306,15 +25638,15 @@ class ThriftHiveMetastore_list_roles_res
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size624 = 0;
- $_etype627 = 0;
- $xfer += $input->readListBegin($_etype627, $_size624);
- for ($_i628 = 0; $_i628 < $_size624; ++$_i628)
+ $_size631 = 0;
+ $_etype634 = 0;
+ $xfer += $input->readListBegin($_etype634, $_size631);
+ for ($_i635 = 0; $_i635 < $_size631; ++$_i635)
{
- $elem629 = null;
- $elem629 = new \metastore\Role();
- $xfer += $elem629->read($input);
- $this->success []= $elem629;
+ $elem636 = null;
+ $elem636 = new \metastore\Role();
+ $xfer += $elem636->read($input);
+ $this->success []= $elem636;
}
$xfer += $input->readListEnd();
} else {
@@ -24350,9 +25682,9 @@ class ThriftHiveMetastore_list_roles_res
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter630)
+ foreach ($this->success as $iter637)
{
- $xfer += $iter630->write($output);
+ $xfer += $iter637->write($output);
}
}
$output->writeListEnd();
@@ -24450,14 +25782,14 @@ class ThriftHiveMetastore_get_privilege_
case 3:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size631 = 0;
- $_etype634 = 0;
- $xfer += $input->readListBegin($_etype634, $_size631);
- for ($_i635 = 0; $_i635 < $_size631; ++$_i635)
+ $_size638 = 0;
+ $_etype641 = 0;
+ $xfer += $input->readListBegin($_etype641, $_size638);
+ for ($_i642 = 0; $_i642 < $_size638; ++$_i642)
{
- $elem636 = null;
- $xfer += $input->readString($elem636);
- $this->group_names []= $elem636;
+ $elem643 = null;
+ $xfer += $input->readString($elem643);
+ $this->group_names []= $elem643;
}
$xfer += $input->readListEnd();
} else {
@@ -24498,9 +25830,9 @@ class ThriftHiveMetastore_get_privilege_
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter637)
+ foreach ($this->group_names as $iter644)
{
- $xfer += $output->writeString($iter637);
+ $xfer += $output->writeString($iter644);
}
}
$output->writeListEnd();
@@ -24787,15 +26119,15 @@ class ThriftHiveMetastore_list_privilege
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size638 = 0;
- $_etype641 = 0;
- $xfer += $input->readListBegin($_etype641, $_size638);
- for ($_i642 = 0; $_i642 < $_size638; ++$_i642)
+ $_size645 = 0;
+ $_etype648 = 0;
+ $xfer += $input->readListBegin($_etype648, $_size645);
+ for ($_i649 = 0; $_i649 < $_size645; ++$_i649)
{
- $elem643 = null;
- $elem643 = new \metastore\HiveObjectPrivilege();
- $xfer += $elem643->read($input);
- $this->success []= $elem643;
+ $elem650 = null;
+ $elem650 = new \metastore\HiveObjectPrivilege();
+ $xfer += $elem650->read($input);
+ $this->success []= $elem650;
}
$xfer += $input->readListEnd();
} else {
@@ -24831,9 +26163,9 @@ class ThriftHiveMetastore_list_privilege
{
$output->writeListBegin(TType::STRUCT, count($this->success));
{
- foreach ($this->success as $iter644)
+ foreach ($this->success as $iter651)
{
- $xfer += $iter644->write($output);
+ $xfer += $iter651->write($output);
}
}
$output->writeListEnd();
@@ -25256,14 +26588,14 @@ class ThriftHiveMetastore_set_ugi_args {
case 2:
if ($ftype == TType::LST) {
$this->group_names = array();
- $_size645 = 0;
- $_etype648 = 0;
- $xfer += $input->readListBegin($_etype648, $_size645);
- for ($_i649 = 0; $_i649 < $_size645; ++$_i649)
+ $_size652 = 0;
+ $_etype655 = 0;
+ $xfer += $input->readListBegin($_etype655, $_size652);
+ for ($_i656 = 0; $_i656 < $_size652; ++$_i656)
{
- $elem650 = null;
- $xfer += $input->readString($elem650);
- $this->group_names []= $elem650;
+ $elem657 = null;
+ $xfer += $input->readString($elem657);
+ $this->group_names []= $elem657;
}
$xfer += $input->readListEnd();
} else {
@@ -25296,9 +26628,9 @@ class ThriftHiveMetastore_set_ugi_args {
{
$output->writeListBegin(TType::STRING, count($this->group_names));
{
- foreach ($this->group_names as $iter651)
+ foreach ($this->group_names as $iter658)
{
- $xfer += $output->writeString($iter651);
+ $xfer += $output->writeString($iter658);
}
}
$output->writeListEnd();
@@ -25368,14 +26700,14 @@ class ThriftHiveMetastore_set_ugi_result
case 0:
if ($ftype == TType::LST) {
$this->success = array();
- $_size652 = 0;
- $_etype655 = 0;
- $xfer += $input->readListBegin($_etype655, $_size652);
- for ($_i656 = 0; $_i656 < $_size652; ++$_i656)
+ $_size659 = 0;
+ $_etype662 = 0;
+ $xfer += $input->readListBegin($_etype662, $_size659);
+ for ($_i663 = 0; $_i663 < $_size659; ++$_i663)
{
- $elem657 = null;
- $xfer += $input->readString($elem657);
- $this->success []= $elem657;
+ $elem664 = null;
+ $xfer += $input->readString($elem664);
+ $this->success []= $elem664;
}
$xfer += $input->readListEnd();
} else {
@@ -25411,9 +26743,9 @@ class ThriftHiveMetastore_set_ugi_result
{
$output->writeListBegin(TType::STRING, count($this->success));
{
- foreach ($this->success as $iter658)
+ foreach ($this->success as $iter665)
{
- $xfer += $output->writeString($iter658);
+ $xfer += $output->writeString($iter665);
}
}
$output->writeListEnd();
Modified: hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1569985&r1=1569984&r2=1569985&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-php/metastore/Types.php Wed Feb 19 23:50:32 2014
@@ -49,6 +49,13 @@ final class PartitionEventType {
);
}
+final class FunctionType {
+ const JAVA = 1;
+ static public $__names = array(
+ 1 => 'JAVA',
+ );
+}
+
class Version {
static $_TSPEC;
@@ -6690,6 +6697,198 @@ class DropPartitionsRequest {
}
+class Function {
+ static $_TSPEC;
+
+ public $functionName = null;
+ public $dbName = null;
+ public $className = null;
+ public $ownerName = null;
+ public $ownerType = null;
+ public $createTime = null;
+ public $functionType = null;
+
+ public function __construct($vals=null) {
+ if (!isset(self::$_TSPEC)) {
+ self::$_TSPEC = array(
+ 1 => array(
+ 'var' => 'functionName',
+ 'type' => TType::STRING,
+ ),
+ 2 => array(
+ 'var' => 'dbName',
+ 'type' => TType::STRING,
+ ),
+ 3 => array(
+ 'var' => 'className',
+ 'type' => TType::STRING,
+ ),
+ 4 => array(
+ 'var' => 'ownerName',
+ 'type' => TType::STRING,
+ ),
+ 5 => array(
+ 'var' => 'ownerType',
+ 'type' => TType::I32,
+ ),
+ 6 => array(
+ 'var' => 'createTime',
+ 'type' => TType::I32,
+ ),
+ 7 => array(
+ 'var' => 'functionType',
+ 'type' => TType::I32,
+ ),
+ );
+ }
+ if (is_array($vals)) {
+ if (isset($vals['functionName'])) {
+ $this->functionName = $vals['functionName'];
+ }
+ if (isset($vals['dbName'])) {
+ $this->dbName = $vals['dbName'];
+ }
+ if (isset($vals['className'])) {
+ $this->className = $vals['className'];
+ }
+ if (isset($vals['ownerName'])) {
+ $this->ownerName = $vals['ownerName'];
+ }
+ if (isset($vals['ownerType'])) {
+ $this->ownerType = $vals['ownerType'];
+ }
+ if (isset($vals['createTime'])) {
+ $this->createTime = $vals['createTime'];
+ }
+ if (isset($vals['functionType'])) {
+ $this->functionType = $vals['functionType'];
+ }
+ }
+ }
+
+ public function getName() {
+ return 'Function';
+ }
+
+ 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->functionName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 2:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->dbName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 3:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->className);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 4:
+ if ($ftype == TType::STRING) {
+ $xfer += $input->readString($this->ownerName);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 5:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->ownerType);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 6:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->createTime);
+ } else {
+ $xfer += $input->skip($ftype);
+ }
+ break;
+ case 7:
+ if ($ftype == TType::I32) {
+ $xfer += $input->readI32($this->functionType);
+ } 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('Function');
+ if ($this->functionName !== null) {
+ $xfer += $output->writeFieldBegin('functionName', TType::STRING, 1);
+ $xfer += $output->writeString($this->functionName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->dbName !== null) {
+ $xfer += $output->writeFieldBegin('dbName', TType::STRING, 2);
+ $xfer += $output->writeString($this->dbName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->className !== null) {
+ $xfer += $output->writeFieldBegin('className', TType::STRING, 3);
+ $xfer += $output->writeString($this->className);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ownerName !== null) {
+ $xfer += $output->writeFieldBegin('ownerName', TType::STRING, 4);
+ $xfer += $output->writeString($this->ownerName);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->ownerType !== null) {
+ $xfer += $output->writeFieldBegin('ownerType', TType::I32, 5);
+ $xfer += $output->writeI32($this->ownerType);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->createTime !== null) {
+ $xfer += $output->writeFieldBegin('createTime', TType::I32, 6);
+ $xfer += $output->writeI32($this->createTime);
+ $xfer += $output->writeFieldEnd();
+ }
+ if ($this->functionType !== null) {
+ $xfer += $output->writeFieldBegin('functionType', TType::I32, 7);
+ $xfer += $output->writeI32($this->functionType);
+ $xfer += $output->writeFieldEnd();
+ }
+ $xfer += $output->writeFieldStop();
+ $xfer += $output->writeStructEnd();
+ return $xfer;
+ }
+
+}
+
class MetaException extends TException {
static $_TSPEC;
Modified: hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
URL: http://svn.apache.org/viewvc/hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1569985&r1=1569984&r2=1569985&view=diff
==============================================================================
--- hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original)
+++ hive/trunk/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Wed Feb 19 23:50:32 2014
@@ -96,6 +96,11 @@ if len(sys.argv) <= 1 or sys.argv[1] ==
print ' PartitionsStatsResult get_partitions_statistics_req(PartitionsStatsRequest request)'
print ' bool delete_partition_column_statistics(string db_name, string tbl_name, string part_name, string col_name)'
print ' bool delete_table_column_statistics(string db_name, string tbl_name, string col_name)'
+ print ' void create_function(Function func)'
+ print ' void drop_function(string dbName, string funcName)'
+ print ' void alter_function(string dbName, string funcName, Function newFunc)'
+ print ' get_functions(string dbName, string pattern)'
+ print ' Function get_function(string dbName, string funcName)'
print ' bool create_role(Role role)'
print ' bool drop_role(string role_name)'
print ' get_role_names()'
@@ -599,6 +604,36 @@ elif cmd == 'delete_table_column_statist
sys.exit(1)
pp.pprint(client.delete_table_column_statistics(args[0],args[1],args[2],))
+elif cmd == 'create_function':
+ if len(args) != 1:
+ print 'create_function requires 1 args'
+ sys.exit(1)
+ pp.pprint(client.create_function(eval(args[0]),))
+
+elif cmd == 'drop_function':
+ if len(args) != 2:
+ print 'drop_function requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.drop_function(args[0],args[1],))
+
+elif cmd == 'alter_function':
+ if len(args) != 3:
+ print 'alter_function requires 3 args'
+ sys.exit(1)
+ pp.pprint(client.alter_function(args[0],args[1],eval(args[2]),))
+
+elif cmd == 'get_functions':
+ if len(args) != 2:
+ print 'get_functions requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.get_functions(args[0],args[1],))
+
+elif cmd == 'get_function':
+ if len(args) != 2:
+ print 'get_function requires 2 args'
+ sys.exit(1)
+ pp.pprint(client.get_function(args[0],args[1],))
+
elif cmd == 'create_role':
if len(args) != 1:
print 'create_role requires 1 args'