Modified: hive/branches/tez/metastore/src/gen/thrift/gen-php/metastore/Types.php URL: http://svn.apache.org/viewvc/hive/branches/tez/metastore/src/gen/thrift/gen-php/metastore/Types.php?rev=1571600&r1=1571599&r2=1571600&view=diff ============================================================================== --- hive/branches/tez/metastore/src/gen/thrift/gen-php/metastore/Types.php (original) +++ hive/branches/tez/metastore/src/gen/thrift/gen-php/metastore/Types.php Tue Feb 25 07:58:52 2014 @@ -49,6 +49,24 @@ final class PartitionEventType { ); } +final class FunctionType { + const JAVA = 1; + static public $__names = array( + 1 => 'JAVA', + ); +} + +final class ResourceType { + const JAR = 1; + const FILE = 2; + const ARCHIVE = 3; + static public $__names = array( + 1 => 'JAR', + 2 => 'FILE', + 3 => 'ARCHIVE', + ); +} + class Version { static $_TSPEC; @@ -1494,6 +1512,8 @@ class Database { public $locationUri = null; public $parameters = null; public $privileges = null; + public $ownerName = null; + public $ownerType = null; public function __construct($vals=null) { if (!isset(self::$_TSPEC)) { @@ -1527,6 +1547,14 @@ class Database { 'type' => TType::STRUCT, 'class' => '\metastore\PrincipalPrivilegeSet', ), + 6 => array( + 'var' => 'ownerName', + 'type' => TType::STRING, + ), + 7 => array( + 'var' => 'ownerType', + 'type' => TType::I32, + ), ); } if (is_array($vals)) { @@ -1545,6 +1573,12 @@ class Database { if (isset($vals['privileges'])) { $this->privileges = $vals['privileges']; } + if (isset($vals['ownerName'])) { + $this->ownerName = $vals['ownerName']; + } + if (isset($vals['ownerType'])) { + $this->ownerType = $vals['ownerType']; + } } } @@ -1616,6 +1650,20 @@ class Database { $xfer += $input->skip($ftype); } break; + case 6: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->ownerName); + } else { + $xfer += $input->skip($ftype); + } + break; + case 7: + if ($ftype == TType::I32) { + $xfer += $input->readI32($this->ownerType); + } else { + $xfer += $input->skip($ftype); + } + break; default: $xfer += $input->skip($ftype); break; @@ -1670,6 +1718,16 @@ class Database { $xfer += $this->privileges->write($output); $xfer += $output->writeFieldEnd(); } + if ($this->ownerName !== null) { + $xfer += $output->writeFieldBegin('ownerName', TType::STRING, 6); + $xfer += $output->writeString($this->ownerName); + $xfer += $output->writeFieldEnd(); + } + if ($this->ownerType !== null) { + $xfer += $output->writeFieldBegin('ownerType', TType::I32, 7); + $xfer += $output->writeI32($this->ownerType); + $xfer += $output->writeFieldEnd(); + } $xfer += $output->writeFieldStop(); $xfer += $output->writeStructEnd(); return $xfer; @@ -6650,6 +6708,338 @@ class DropPartitionsRequest { } +class ResourceUri { + static $_TSPEC; + + public $resourceType = null; + public $uri = null; + + public function __construct($vals=null) { + if (!isset(self::$_TSPEC)) { + self::$_TSPEC = array( + 1 => array( + 'var' => 'resourceType', + 'type' => TType::I32, + ), + 2 => array( + 'var' => 'uri', + 'type' => TType::STRING, + ), + ); + } + if (is_array($vals)) { + if (isset($vals['resourceType'])) { + $this->resourceType = $vals['resourceType']; + } + if (isset($vals['uri'])) { + $this->uri = $vals['uri']; + } + } + } + + public function getName() { + return 'ResourceUri'; + } + + 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::I32) { + $xfer += $input->readI32($this->resourceType); + } else { + $xfer += $input->skip($ftype); + } + break; + case 2: + if ($ftype == TType::STRING) { + $xfer += $input->readString($this->uri); + } 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('ResourceUri'); + if ($this->resourceType !== null) { + $xfer += $output->writeFieldBegin('resourceType', TType::I32, 1); + $xfer += $output->writeI32($this->resourceType); + $xfer += $output->writeFieldEnd(); + } + if ($this->uri !== null) { + $xfer += $output->writeFieldBegin('uri', TType::STRING, 2); + $xfer += $output->writeString($this->uri); + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + +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 $resourceUris = 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, + ), + 8 => array( + 'var' => 'resourceUris', + 'type' => TType::LST, + 'etype' => TType::STRUCT, + 'elem' => array( + 'type' => TType::STRUCT, + 'class' => '\metastore\ResourceUri', + ), + ), + ); + } + 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']; + } + if (isset($vals['resourceUris'])) { + $this->resourceUris = $vals['resourceUris']; + } + } + } + + 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; + case 8: + if ($ftype == TType::LST) { + $this->resourceUris = array(); + $_size313 = 0; + $_etype316 = 0; + $xfer += $input->readListBegin($_etype316, $_size313); + for ($_i317 = 0; $_i317 < $_size313; ++$_i317) + { + $elem318 = null; + $elem318 = new \metastore\ResourceUri(); + $xfer += $elem318->read($input); + $this->resourceUris []= $elem318; + } + $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('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(); + } + if ($this->resourceUris !== null) { + if (!is_array($this->resourceUris)) { + throw new TProtocolException('Bad type in structure.', TProtocolException::INVALID_DATA); + } + $xfer += $output->writeFieldBegin('resourceUris', TType::LST, 8); + { + $output->writeListBegin(TType::STRUCT, count($this->resourceUris)); + { + foreach ($this->resourceUris as $iter319) + { + $xfer += $iter319->write($output); + } + } + $output->writeListEnd(); + } + $xfer += $output->writeFieldEnd(); + } + $xfer += $output->writeFieldStop(); + $xfer += $output->writeStructEnd(); + return $xfer; + } + +} + class MetaException extends TException { static $_TSPEC; @@ -7526,6 +7916,8 @@ $GLOBALS['hive_metastore_CONSTANTS']['IS $GLOBALS['hive_metastore_CONSTANTS']['ORIGINAL_LOCATION'] = "original_location"; +$GLOBALS['hive_metastore_CONSTANTS']['IS_IMMUTABLE'] = "immutable"; + $GLOBALS['hive_metastore_CONSTANTS']['META_TABLE_COLUMNS'] = "columns"; $GLOBALS['hive_metastore_CONSTANTS']['META_TABLE_COLUMN_TYPES'] = "columns.types";
Modified: hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote URL: http://svn.apache.org/viewvc/hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote?rev=1571600&r1=1571599&r2=1571600&view=diff ============================================================================== --- hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote (original) +++ hive/branches/tez/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote Tue Feb 25 07:58:52 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'
