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 2015/09/22 23:31:54 UTC
[13/52] [abbrv] hive git commit: HIVE-11568 : merge master into
branch (Sergey Shelukhin)
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
index ae39507,a877338..fe60838
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnAbortedException.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class TxnAbortedException extends TException implements org.apache.thrift.TBase<TxnAbortedException, TxnAbortedException._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class TxnAbortedException extends TException implements org.apache.thrift.TBase<TxnAbortedException, TxnAbortedException._Fields>, java.io.Serializable, Cloneable, Comparable<TxnAbortedException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnAbortedException");
private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
index 18cbe53,8b255b9..266fbe1
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnInfo.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class TxnInfo implements org.apache.thrift.TBase<TxnInfo, TxnInfo._Fields>, java.io.Serializable, Cloneable, Comparable<TxnInfo> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnInfo");
private static final org.apache.thrift.protocol.TField ID_FIELD_DESC = new org.apache.thrift.protocol.TField("id", org.apache.thrift.protocol.TType.I64, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
index 4f5d02d,05af505..18db1b8
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TxnOpenException.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class TxnOpenException extends TException implements org.apache.thrift.TBase<TxnOpenException, TxnOpenException._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class TxnOpenException extends TException implements org.apache.thrift.TBase<TxnOpenException, TxnOpenException._Fields>, java.io.Serializable, Cloneable, Comparable<TxnOpenException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TxnOpenException");
private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
index 1882b57,61e7ceb..b330ce2
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Type.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class Type implements org.apache.thrift.TBase<Type, Type._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class Type implements org.apache.thrift.TBase<Type, Type._Fields>, java.io.Serializable, Cloneable, Comparable<Type> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Type");
private static final org.apache.thrift.protocol.TField NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("name", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
index ab91419,e05e79d..b7623ca
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownDBException.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class UnknownDBException extends TException implements org.apache.thrift.TBase<UnknownDBException, UnknownDBException._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class UnknownDBException extends TException implements org.apache.thrift.TBase<UnknownDBException, UnknownDBException._Fields>, java.io.Serializable, Cloneable, Comparable<UnknownDBException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnknownDBException");
private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
index 7e28591,c626bf6..bdd674b
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownPartitionException.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class UnknownPartitionException extends TException implements org.apache.thrift.TBase<UnknownPartitionException, UnknownPartitionException._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class UnknownPartitionException extends TException implements org.apache.thrift.TBase<UnknownPartitionException, UnknownPartitionException._Fields>, java.io.Serializable, Cloneable, Comparable<UnknownPartitionException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnknownPartitionException");
private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
index 7aa8012,2856121..768eb65
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnknownTableException.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class UnknownTableException extends TException implements org.apache.thrift.TBase<UnknownTableException, UnknownTableException._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class UnknownTableException extends TException implements org.apache.thrift.TBase<UnknownTableException, UnknownTableException._Fields>, java.io.Serializable, Cloneable, Comparable<UnknownTableException> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnknownTableException");
private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
index 54b949d,cf248e0..395c15f
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/UnlockRequest.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class UnlockRequest implements org.apache.thrift.TBase<UnlockRequest, UnlockRequest._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class UnlockRequest implements org.apache.thrift.TBase<UnlockRequest, UnlockRequest._Fields>, java.io.Serializable, Cloneable, Comparable<UnlockRequest> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("UnlockRequest");
private static final org.apache.thrift.protocol.TField LOCKID_FIELD_DESC = new org.apache.thrift.protocol.TField("lockid", org.apache.thrift.protocol.TType.I64, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
index aa83fd7,cc8d5f5..f3cbb74
--- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
+++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Version.java
@@@ -31,7 -33,9 +33,9 @@@ import javax.annotation.Generated
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
- public class Version implements org.apache.thrift.TBase<Version, Version._Fields>, java.io.Serializable, Cloneable {
+ @SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
-@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-3")
++@Generated(value = "Autogenerated by Thrift Compiler (0.9.2)", date = "2015-8-14")
+ public class Version implements org.apache.thrift.TBase<Version, Version._Fields>, java.io.Serializable, Cloneable, Comparable<Version> {
private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Version");
private static final org.apache.thrift.protocol.TField VERSION_FIELD_DESC = new org.apache.thrift.protocol.TField("version", org.apache.thrift.protocol.TType.STRING, (short)1);
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
index 1684674,ae47cb5..9c73767
--- a/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
+++ b/metastore/src/gen/thrift/gen-php/metastore/ThriftHiveMetastore.php
@@@ -15,131 -16,997 +16,1000 @@@ use Thrift\Protocol\TBinaryProtocolAcce
use Thrift\Exception\TApplicationException;
+ /**
+ * This interface is live.
+ */
interface ThriftHiveMetastoreIf extends \FacebookServiceIf {
+ /**
+ * @param string $key
+ * @return string
+ * @throws \metastore\MetaException
+ */
public function getMetaConf($key);
+ /**
+ * @param string $key
+ * @param string $value
+ * @throws \metastore\MetaException
+ */
public function setMetaConf($key, $value);
+ /**
+ * @param \metastore\Database $database
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ */
public function create_database(\metastore\Database $database);
+ /**
+ * @param string $name
+ * @return \metastore\Database
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_database($name);
+ /**
+ * @param string $name
+ * @param bool $deleteData
+ * @param bool $cascade
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function drop_database($name, $deleteData, $cascade);
+ /**
+ * @param string $pattern
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_databases($pattern);
+ /**
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_all_databases();
+ /**
+ * @param string $dbname
+ * @param \metastore\Database $db
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function alter_database($dbname, \metastore\Database $db);
+ /**
+ * @param string $name
+ * @return \metastore\Type
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_type($name);
+ /**
+ * @param \metastore\Type $type
+ * @return bool
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ */
public function create_type(\metastore\Type $type);
+ /**
+ * @param string $type
+ * @return bool
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function drop_type($type);
+ /**
+ * @param string $name
+ * @return array
+ * @throws \metastore\MetaException
+ */
public function get_type_all($name);
+ /**
+ * @param string $db_name
+ * @param string $table_name
+ * @return \metastore\FieldSchema[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\UnknownTableException
+ * @throws \metastore\UnknownDBException
+ */
public function get_fields($db_name, $table_name);
+ /**
+ * @param string $db_name
+ * @param string $table_name
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return \metastore\FieldSchema[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\UnknownTableException
+ * @throws \metastore\UnknownDBException
+ */
public function get_fields_with_environment_context($db_name, $table_name, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $db_name
+ * @param string $table_name
+ * @return \metastore\FieldSchema[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\UnknownTableException
+ * @throws \metastore\UnknownDBException
+ */
public function get_schema($db_name, $table_name);
+ /**
+ * @param string $db_name
+ * @param string $table_name
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return \metastore\FieldSchema[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\UnknownTableException
+ * @throws \metastore\UnknownDBException
+ */
public function get_schema_with_environment_context($db_name, $table_name, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param \metastore\Table $tbl
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function create_table(\metastore\Table $tbl);
+ /**
+ * @param \metastore\Table $tbl
+ * @param \metastore\EnvironmentContext $environment_context
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function create_table_with_environment_context(\metastore\Table $tbl, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $dbname
+ * @param string $name
+ * @param bool $deleteData
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_table($dbname, $name, $deleteData);
+ /**
+ * @param string $dbname
+ * @param string $name
+ * @param bool $deleteData
+ * @param \metastore\EnvironmentContext $environment_context
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_table_with_environment_context($dbname, $name, $deleteData, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $db_name
+ * @param string $pattern
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_tables($db_name, $pattern);
+ /**
+ * @param string $db_name
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_all_tables($db_name);
+ /**
+ * @param string $dbname
+ * @param string $tbl_name
+ * @return \metastore\Table
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_table($dbname, $tbl_name);
- public function get_table_objects_by_name($dbname, $tbl_names);
+ /**
+ * @param string $dbname
+ * @param string[] $tbl_names
+ * @return \metastore\Table[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\UnknownDBException
+ */
+ public function get_table_objects_by_name($dbname, array $tbl_names);
+ /**
+ * @param string $dbname
+ * @param string $filter
+ * @param int $max_tables
+ * @return string[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\UnknownDBException
+ */
public function get_table_names_by_filter($dbname, $filter, $max_tables);
+ /**
+ * @param string $dbname
+ * @param string $tbl_name
+ * @param \metastore\Table $new_tbl
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_table($dbname, $tbl_name, \metastore\Table $new_tbl);
+ /**
+ * @param string $dbname
+ * @param string $tbl_name
+ * @param \metastore\Table $new_tbl
+ * @param \metastore\EnvironmentContext $environment_context
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_table_with_environment_context($dbname, $tbl_name, \metastore\Table $new_tbl, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $dbname
+ * @param string $tbl_name
+ * @param \metastore\Table $new_tbl
+ * @param bool $cascade
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_table_with_cascade($dbname, $tbl_name, \metastore\Table $new_tbl, $cascade);
+ /**
+ * @param \metastore\Partition $new_part
+ * @return \metastore\Partition
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
public function add_partition(\metastore\Partition $new_part);
+ /**
+ * @param \metastore\Partition $new_part
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return \metastore\Partition
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
public function add_partition_with_environment_context(\metastore\Partition $new_part, \metastore\EnvironmentContext $environment_context);
- public function add_partitions($new_parts);
- public function add_partitions_pspec($new_parts);
- public function append_partition($db_name, $tbl_name, $part_vals);
+ /**
+ * @param \metastore\Partition[] $new_parts
+ * @return int
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
+ public function add_partitions(array $new_parts);
+ /**
+ * @param \metastore\PartitionSpec[] $new_parts
+ * @return int
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
+ public function add_partitions_pspec(array $new_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @return \metastore\Partition
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
+ public function append_partition($db_name, $tbl_name, array $part_vals);
+ /**
+ * @param \metastore\AddPartitionsRequest $request
+ * @return \metastore\AddPartitionsResult
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
public function add_partitions_req(\metastore\AddPartitionsRequest $request);
- public function append_partition_with_environment_context($db_name, $tbl_name, $part_vals, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return \metastore\Partition
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
+ public function append_partition_with_environment_context($db_name, $tbl_name, array $part_vals, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @return \metastore\Partition
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
public function append_partition_by_name($db_name, $tbl_name, $part_name);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return \metastore\Partition
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
public function append_partition_by_name_with_environment_context($db_name, $tbl_name, $part_name, \metastore\EnvironmentContext $environment_context);
- public function drop_partition($db_name, $tbl_name, $part_vals, $deleteData);
- public function drop_partition_with_environment_context($db_name, $tbl_name, $part_vals, $deleteData, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param bool $deleteData
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
+ public function drop_partition($db_name, $tbl_name, array $part_vals, $deleteData);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param bool $deleteData
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
+ public function drop_partition_with_environment_context($db_name, $tbl_name, array $part_vals, $deleteData, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @param bool $deleteData
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_partition_by_name($db_name, $tbl_name, $part_name, $deleteData);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @param bool $deleteData
+ * @param \metastore\EnvironmentContext $environment_context
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_partition_by_name_with_environment_context($db_name, $tbl_name, $part_name, $deleteData, \metastore\EnvironmentContext $environment_context);
+ /**
+ * @param \metastore\DropPartitionsRequest $req
+ * @return \metastore\DropPartitionsResult
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_partitions_req(\metastore\DropPartitionsRequest $req);
- public function get_partition($db_name, $tbl_name, $part_vals);
- public function exchange_partition($partitionSpecs, $source_db, $source_table_name, $dest_db, $dest_table_name);
- public function get_partition_with_auth($db_name, $tbl_name, $part_vals, $user_name, $group_names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @return \metastore\Partition
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
+ public function get_partition($db_name, $tbl_name, array $part_vals);
+ /**
+ * @param array $partitionSpecs
+ * @param string $source_db
+ * @param string $source_table_name
+ * @param string $dest_db
+ * @param string $dest_table_name
+ * @return \metastore\Partition
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\InvalidInputException
+ */
+ public function exchange_partition(array $partitionSpecs, $source_db, $source_table_name, $dest_db, $dest_table_name);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param string $user_name
+ * @param string[] $group_names
+ * @return \metastore\Partition
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
+ public function get_partition_with_auth($db_name, $tbl_name, array $part_vals, $user_name, array $group_names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @return \metastore\Partition
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_partition_by_name($db_name, $tbl_name, $part_name);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param int $max_parts
+ * @return \metastore\Partition[]
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_partitions($db_name, $tbl_name, $max_parts);
- public function get_partitions_with_auth($db_name, $tbl_name, $max_parts, $user_name, $group_names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param int $max_parts
+ * @param string $user_name
+ * @param string[] $group_names
+ * @return \metastore\Partition[]
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
+ public function get_partitions_with_auth($db_name, $tbl_name, $max_parts, $user_name, array $group_names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param int $max_parts
+ * @return \metastore\PartitionSpec[]
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_partitions_pspec($db_name, $tbl_name, $max_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param int $max_parts
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_partition_names($db_name, $tbl_name, $max_parts);
- public function get_partitions_ps($db_name, $tbl_name, $part_vals, $max_parts);
- public function get_partitions_ps_with_auth($db_name, $tbl_name, $part_vals, $max_parts, $user_name, $group_names);
- public function get_partition_names_ps($db_name, $tbl_name, $part_vals, $max_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param int $max_parts
+ * @return \metastore\Partition[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
+ public function get_partitions_ps($db_name, $tbl_name, array $part_vals, $max_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param int $max_parts
+ * @param string $user_name
+ * @param string[] $group_names
+ * @return \metastore\Partition[]
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
+ public function get_partitions_ps_with_auth($db_name, $tbl_name, array $part_vals, $max_parts, $user_name, array $group_names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param int $max_parts
+ * @return string[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
+ public function get_partition_names_ps($db_name, $tbl_name, array $part_vals, $max_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $filter
+ * @param int $max_parts
+ * @return \metastore\Partition[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_partitions_by_filter($db_name, $tbl_name, $filter, $max_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $filter
+ * @param int $max_parts
+ * @return \metastore\PartitionSpec[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_part_specs_by_filter($db_name, $tbl_name, $filter, $max_parts);
+ /**
+ * @param \metastore\PartitionsByExprRequest $req
+ * @return \metastore\PartitionsByExprResult
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_partitions_by_expr(\metastore\PartitionsByExprRequest $req);
- public function get_partitions_by_names($db_name, $tbl_name, $names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $names
+ * @return \metastore\Partition[]
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
+ public function get_partitions_by_names($db_name, $tbl_name, array $names);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param \metastore\Partition $new_part
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_partition($db_name, $tbl_name, \metastore\Partition $new_part);
- public function alter_partitions($db_name, $tbl_name, $new_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param \metastore\Partition[] $new_parts
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
+ public function alter_partitions($db_name, $tbl_name, array $new_parts);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param \metastore\Partition $new_part
+ * @param \metastore\EnvironmentContext $environment_context
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_partition_with_environment_context($db_name, $tbl_name, \metastore\Partition $new_part, \metastore\EnvironmentContext $environment_context);
- public function rename_partition($db_name, $tbl_name, $part_vals, \metastore\Partition $new_part);
- public function partition_name_has_valid_characters($part_vals, $throw_exception);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string[] $part_vals
+ * @param \metastore\Partition $new_part
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
+ public function rename_partition($db_name, $tbl_name, array $part_vals, \metastore\Partition $new_part);
+ /**
+ * @param string[] $part_vals
+ * @param bool $throw_exception
+ * @return bool
+ * @throws \metastore\MetaException
+ */
+ public function partition_name_has_valid_characters(array $part_vals, $throw_exception);
+ /**
+ * @param string $name
+ * @param string $defaultValue
+ * @return string
+ * @throws \metastore\ConfigValSecurityException
+ */
public function get_config_value($name, $defaultValue);
+ /**
+ * @param string $part_name
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function partition_name_to_vals($part_name);
+ /**
+ * @param string $part_name
+ * @return array
+ * @throws \metastore\MetaException
+ */
public function partition_name_to_spec($part_name);
- public function markPartitionForEvent($db_name, $tbl_name, $part_vals, $eventType);
- public function isPartitionMarkedForEvent($db_name, $tbl_name, $part_vals, $eventType);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param array $part_vals
+ * @param int $eventType
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\UnknownDBException
+ * @throws \metastore\UnknownTableException
+ * @throws \metastore\UnknownPartitionException
+ * @throws \metastore\InvalidPartitionException
+ */
+ public function markPartitionForEvent($db_name, $tbl_name, array $part_vals, $eventType);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param array $part_vals
+ * @param int $eventType
+ * @return bool
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\UnknownDBException
+ * @throws \metastore\UnknownTableException
+ * @throws \metastore\UnknownPartitionException
+ * @throws \metastore\InvalidPartitionException
+ */
+ public function isPartitionMarkedForEvent($db_name, $tbl_name, array $part_vals, $eventType);
+ /**
+ * @param \metastore\Index $new_index
+ * @param \metastore\Table $index_table
+ * @return \metastore\Index
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\MetaException
+ */
public function add_index(\metastore\Index $new_index, \metastore\Table $index_table);
+ /**
+ * @param string $dbname
+ * @param string $base_tbl_name
+ * @param string $idx_name
+ * @param \metastore\Index $new_idx
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_index($dbname, $base_tbl_name, $idx_name, \metastore\Index $new_idx);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $index_name
+ * @param bool $deleteData
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_index_by_name($db_name, $tbl_name, $index_name, $deleteData);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $index_name
+ * @return \metastore\Index
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_index_by_name($db_name, $tbl_name, $index_name);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param int $max_indexes
+ * @return \metastore\Index[]
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_indexes($db_name, $tbl_name, $max_indexes);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param int $max_indexes
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_index_names($db_name, $tbl_name, $max_indexes);
+ /**
+ * @param \metastore\ColumnStatistics $stats_obj
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ */
public function update_table_column_statistics(\metastore\ColumnStatistics $stats_obj);
+ /**
+ * @param \metastore\ColumnStatistics $stats_obj
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ */
public function update_partition_column_statistics(\metastore\ColumnStatistics $stats_obj);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $col_name
+ * @return \metastore\ColumnStatistics
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ * @throws \metastore\InvalidObjectException
+ */
public function get_table_column_statistics($db_name, $tbl_name, $col_name);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @param string $col_name
+ * @return \metastore\ColumnStatistics
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ * @throws \metastore\InvalidObjectException
+ */
public function get_partition_column_statistics($db_name, $tbl_name, $part_name, $col_name);
+ /**
+ * @param \metastore\TableStatsRequest $request
+ * @return \metastore\TableStatsResult
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_table_statistics_req(\metastore\TableStatsRequest $request);
+ /**
+ * @param \metastore\PartitionsStatsRequest $request
+ * @return \metastore\PartitionsStatsResult
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_partitions_statistics_req(\metastore\PartitionsStatsRequest $request);
+ /**
+ * @param \metastore\PartitionsStatsRequest $request
+ * @return \metastore\AggrStats
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function get_aggr_stats_for(\metastore\PartitionsStatsRequest $request);
+ /**
+ * @param \metastore\SetPartitionsStatsRequest $request
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidInputException
+ */
public function set_aggr_stats_for(\metastore\SetPartitionsStatsRequest $request);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $part_name
+ * @param string $col_name
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\InvalidInputException
+ */
public function delete_partition_column_statistics($db_name, $tbl_name, $part_name, $col_name);
+ /**
+ * @param string $db_name
+ * @param string $tbl_name
+ * @param string $col_name
+ * @return bool
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\InvalidInputException
+ */
public function delete_table_column_statistics($db_name, $tbl_name, $col_name);
+ /**
+ * @param \metastore\Function $func
+ * @throws \metastore\AlreadyExistsException
+ * @throws \metastore\InvalidObjectException
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function create_function(\metastore\Function $func);
+ /**
+ * @param string $dbName
+ * @param string $funcName
+ * @throws \metastore\NoSuchObjectException
+ * @throws \metastore\MetaException
+ */
public function drop_function($dbName, $funcName);
+ /**
+ * @param string $dbName
+ * @param string $funcName
+ * @param \metastore\Function $newFunc
+ * @throws \metastore\InvalidOperationException
+ * @throws \metastore\MetaException
+ */
public function alter_function($dbName, $funcName, \metastore\Function $newFunc);
+ /**
+ * @param string $dbName
+ * @param string $pattern
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_functions($dbName, $pattern);
+ /**
+ * @param string $dbName
+ * @param string $funcName
+ * @return \metastore\Function
+ * @throws \metastore\MetaException
+ * @throws \metastore\NoSuchObjectException
+ */
public function get_function($dbName, $funcName);
+ /**
+ * @return \metastore\GetAllFunctionsResponse
+ * @throws \metastore\MetaException
+ */
+ public function get_all_functions();
+ /**
+ * @param \metastore\Role $role
+ * @return bool
+ * @throws \metastore\MetaException
+ */
public function create_role(\metastore\Role $role);
+ /**
+ * @param string $role_name
+ * @return bool
+ * @throws \metastore\MetaException
+ */
public function drop_role($role_name);
+ /**
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
public function get_role_names();
+ /**
+ * @param string $role_name
+ * @param string $principal_name
+ * @param int $principal_type
+ * @param string $grantor
+ * @param int $grantorType
+ * @param bool $grant_option
+ * @return bool
+ * @throws \metastore\MetaException
+ */
public function grant_role($role_name, $principal_name, $principal_type, $grantor, $grantorType, $grant_option);
+ /**
+ * @param string $role_name
+ * @param string $principal_name
+ * @param int $principal_type
+ * @return bool
+ * @throws \metastore\MetaException
+ */
public function revoke_role($role_name, $principal_name, $principal_type);
+ /**
+ * @param string $principal_name
+ * @param int $principal_type
+ * @return \metastore\Role[]
+ * @throws \metastore\MetaException
+ */
public function list_roles($principal_name, $principal_type);
+ /**
+ * @param \metastore\GrantRevokeRoleRequest $request
+ * @return \metastore\GrantRevokeRoleResponse
+ * @throws \metastore\MetaException
+ */
public function grant_revoke_role(\metastore\GrantRevokeRoleRequest $request);
+ /**
+ * @param \metastore\GetPrincipalsInRoleRequest $request
+ * @return \metastore\GetPrincipalsInRoleResponse
+ * @throws \metastore\MetaException
+ */
public function get_principals_in_role(\metastore\GetPrincipalsInRoleRequest $request);
+ /**
+ * @param \metastore\GetRoleGrantsForPrincipalRequest $request
+ * @return \metastore\GetRoleGrantsForPrincipalResponse
+ * @throws \metastore\MetaException
+ */
public function get_role_grants_for_principal(\metastore\GetRoleGrantsForPrincipalRequest $request);
- public function get_privilege_set(\metastore\HiveObjectRef $hiveObject, $user_name, $group_names);
+ /**
+ * @param \metastore\HiveObjectRef $hiveObject
+ * @param string $user_name
+ * @param string[] $group_names
+ * @return \metastore\PrincipalPrivilegeSet
+ * @throws \metastore\MetaException
+ */
+ public function get_privilege_set(\metastore\HiveObjectRef $hiveObject, $user_name, array $group_names);
+ /**
+ * @param string $principal_name
+ * @param int $principal_type
+ * @param \metastore\HiveObjectRef $hiveObject
+ * @return \metastore\HiveObjectPrivilege[]
+ * @throws \metastore\MetaException
+ */
public function list_privileges($principal_name, $principal_type, \metastore\HiveObjectRef $hiveObject);
+ /**
+ * @param \metastore\PrivilegeBag $privileges
+ * @return bool
+ * @throws \metastore\MetaException
+ */
public function grant_privileges(\metastore\PrivilegeBag $privileges);
+ /**
+ * @param \metastore\PrivilegeBag $privileges
+ * @return bool
+ * @throws \metastore\MetaException
+ */
public function revoke_privileges(\metastore\PrivilegeBag $privileges);
+ /**
+ * @param \metastore\GrantRevokePrivilegeRequest $request
+ * @return \metastore\GrantRevokePrivilegeResponse
+ * @throws \metastore\MetaException
+ */
public function grant_revoke_privileges(\metastore\GrantRevokePrivilegeRequest $request);
- public function set_ugi($user_name, $group_names);
+ /**
+ * @param string $user_name
+ * @param string[] $group_names
+ * @return string[]
+ * @throws \metastore\MetaException
+ */
+ public function set_ugi($user_name, array $group_names);
+ /**
+ * @param string $token_owner
+ * @param string $renewer_kerberos_principal_name
+ * @return string
+ * @throws \metastore\MetaException
+ */
public function get_delegation_token($token_owner, $renewer_kerberos_principal_name);
+ /**
+ * @param string $token_str_form
+ * @return int
+ * @throws \metastore\MetaException
+ */
public function renew_delegation_token($token_str_form);
+ /**
+ * @param string $token_str_form
+ * @throws \metastore\MetaException
+ */
public function cancel_delegation_token($token_str_form);
+ /**
+ * @return \metastore\GetOpenTxnsResponse
+ */
public function get_open_txns();
+ /**
+ * @return \metastore\GetOpenTxnsInfoResponse
+ */
public function get_open_txns_info();
+ /**
+ * @param \metastore\OpenTxnRequest $rqst
+ * @return \metastore\OpenTxnsResponse
+ */
public function open_txns(\metastore\OpenTxnRequest $rqst);
+ /**
+ * @param \metastore\AbortTxnRequest $rqst
+ * @throws \metastore\NoSuchTxnException
+ */
public function abort_txn(\metastore\AbortTxnRequest $rqst);
+ /**
+ * @param \metastore\CommitTxnRequest $rqst
+ * @throws \metastore\NoSuchTxnException
+ * @throws \metastore\TxnAbortedException
+ */
public function commit_txn(\metastore\CommitTxnRequest $rqst);
+ /**
+ * @param \metastore\LockRequest $rqst
+ * @return \metastore\LockResponse
+ * @throws \metastore\NoSuchTxnException
+ * @throws \metastore\TxnAbortedException
+ */
public function lock(\metastore\LockRequest $rqst);
+ /**
+ * @param \metastore\CheckLockRequest $rqst
+ * @return \metastore\LockResponse
+ * @throws \metastore\NoSuchTxnException
+ * @throws \metastore\TxnAbortedException
+ * @throws \metastore\NoSuchLockException
+ */
public function check_lock(\metastore\CheckLockRequest $rqst);
+ /**
+ * @param \metastore\UnlockRequest $rqst
+ * @throws \metastore\NoSuchLockException
+ * @throws \metastore\TxnOpenException
+ */
public function unlock(\metastore\UnlockRequest $rqst);
+ /**
+ * @param \metastore\ShowLocksRequest $rqst
+ * @return \metastore\ShowLocksResponse
+ */
public function show_locks(\metastore\ShowLocksRequest $rqst);
+ /**
+ * @param \metastore\HeartbeatRequest $ids
+ * @throws \metastore\NoSuchLockException
+ * @throws \metastore\NoSuchTxnException
+ * @throws \metastore\TxnAbortedException
+ */
public function heartbeat(\metastore\HeartbeatRequest $ids);
+ /**
+ * @param \metastore\HeartbeatTxnRangeRequest $txns
+ * @return \metastore\HeartbeatTxnRangeResponse
+ */
public function heartbeat_txn_range(\metastore\HeartbeatTxnRangeRequest $txns);
+ /**
+ * @param \metastore\CompactionRequest $rqst
+ */
public function compact(\metastore\CompactionRequest $rqst);
+ /**
+ * @param \metastore\ShowCompactRequest $rqst
+ * @return \metastore\ShowCompactResponse
+ */
public function show_compact(\metastore\ShowCompactRequest $rqst);
+ /**
+ * @param \metastore\AddDynamicPartitions $rqst
+ * @throws \metastore\NoSuchTxnException
+ * @throws \metastore\TxnAbortedException
+ */
public function add_dynamic_partitions(\metastore\AddDynamicPartitions $rqst);
+ /**
+ * @param \metastore\NotificationEventRequest $rqst
+ * @return \metastore\NotificationEventResponse
+ */
public function get_next_notification(\metastore\NotificationEventRequest $rqst);
+ /**
+ * @return \metastore\CurrentNotificationEventId
+ */
public function get_current_notificationEventId();
+ /**
+ * @param \metastore\FireEventRequest $rqst
+ * @return \metastore\FireEventResponse
+ */
public function fire_listener_event(\metastore\FireEventRequest $rqst);
++ /**
++ */
+ public function flushCache();
}
class ThriftHiveMetastoreClient extends \FacebookServiceClient implements \metastore\ThriftHiveMetastoreIf {
@@@ -7221,53 -8141,6 +8144,53 @@@
throw new \Exception("fire_listener_event failed: unknown result");
}
+ public function flushCache()
+ {
+ $this->send_flushCache();
+ $this->recv_flushCache();
+ }
+
+ public function send_flushCache()
+ {
+ $args = new \metastore\ThriftHiveMetastore_flushCache_args();
- $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary');
++ $bin_accel = ($this->output_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_write_binary');
+ if ($bin_accel)
+ {
+ thrift_protocol_write_binary($this->output_, 'flushCache', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite());
+ }
+ else
+ {
+ $this->output_->writeMessageBegin('flushCache', TMessageType::CALL, $this->seqid_);
+ $args->write($this->output_);
+ $this->output_->writeMessageEnd();
+ $this->output_->getTransport()->flush();
+ }
+ }
+
+ public function recv_flushCache()
+ {
- $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary');
++ $bin_accel = ($this->input_ instanceof TBinaryProtocolAccelerated) && function_exists('thrift_protocol_read_binary');
+ if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, '\metastore\ThriftHiveMetastore_flushCache_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_flushCache_result();
+ $result->read($this->input_);
+ $this->input_->readMessageEnd();
+ }
+ return;
+ }
+
}
// HELPER FUNCTIONS AND STRUCTURES
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
index 531a475,dc348ef..6bd2728
mode 100644,100755..100755
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore-remote
@@@ -15,139 -16,152 +16,153 @@@ from thrift.transport import TSSLSocke
from thrift.transport import THttpClient
from thrift.protocol import TBinaryProtocol
- import ThriftHiveMetastore
- from ttypes import *
+ from hive_metastore import ThriftHiveMetastore
+ from hive_metastore.ttypes import *
if len(sys.argv) <= 1 or sys.argv[1] == '--help':
- print ''
- print 'Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] function [arg1 [arg2...]]'
- print ''
- print 'Functions:'
- print ' string getMetaConf(string key)'
- print ' void setMetaConf(string key, string value)'
- print ' void create_database(Database database)'
- print ' Database get_database(string name)'
- print ' void drop_database(string name, bool deleteData, bool cascade)'
- print ' get_databases(string pattern)'
- print ' get_all_databases()'
- print ' void alter_database(string dbname, Database db)'
- print ' Type get_type(string name)'
- print ' bool create_type(Type type)'
- print ' bool drop_type(string type)'
- print ' get_type_all(string name)'
- print ' get_fields(string db_name, string table_name)'
- print ' get_fields_with_environment_context(string db_name, string table_name, EnvironmentContext environment_context)'
- print ' get_schema(string db_name, string table_name)'
- print ' get_schema_with_environment_context(string db_name, string table_name, EnvironmentContext environment_context)'
- print ' void create_table(Table tbl)'
- print ' void create_table_with_environment_context(Table tbl, EnvironmentContext environment_context)'
- print ' void drop_table(string dbname, string name, bool deleteData)'
- print ' void drop_table_with_environment_context(string dbname, string name, bool deleteData, EnvironmentContext environment_context)'
- print ' get_tables(string db_name, string pattern)'
- print ' get_all_tables(string db_name)'
- print ' Table get_table(string dbname, string tbl_name)'
- print ' get_table_objects_by_name(string dbname, tbl_names)'
- print ' get_table_names_by_filter(string dbname, string filter, i16 max_tables)'
- print ' void alter_table(string dbname, string tbl_name, Table new_tbl)'
- print ' void alter_table_with_environment_context(string dbname, string tbl_name, Table new_tbl, EnvironmentContext environment_context)'
- print ' void alter_table_with_cascade(string dbname, string tbl_name, Table new_tbl, bool cascade)'
- print ' Partition add_partition(Partition new_part)'
- print ' Partition add_partition_with_environment_context(Partition new_part, EnvironmentContext environment_context)'
- print ' i32 add_partitions( new_parts)'
- print ' i32 add_partitions_pspec( new_parts)'
- print ' Partition append_partition(string db_name, string tbl_name, part_vals)'
- print ' AddPartitionsResult add_partitions_req(AddPartitionsRequest request)'
- print ' Partition append_partition_with_environment_context(string db_name, string tbl_name, part_vals, EnvironmentContext environment_context)'
- print ' Partition append_partition_by_name(string db_name, string tbl_name, string part_name)'
- print ' Partition append_partition_by_name_with_environment_context(string db_name, string tbl_name, string part_name, EnvironmentContext environment_context)'
- print ' bool drop_partition(string db_name, string tbl_name, part_vals, bool deleteData)'
- print ' bool drop_partition_with_environment_context(string db_name, string tbl_name, part_vals, bool deleteData, EnvironmentContext environment_context)'
- print ' bool drop_partition_by_name(string db_name, string tbl_name, string part_name, bool deleteData)'
- print ' bool drop_partition_by_name_with_environment_context(string db_name, string tbl_name, string part_name, bool deleteData, EnvironmentContext environment_context)'
- print ' DropPartitionsResult drop_partitions_req(DropPartitionsRequest req)'
- print ' Partition get_partition(string db_name, string tbl_name, part_vals)'
- print ' Partition exchange_partition( partitionSpecs, string source_db, string source_table_name, string dest_db, string dest_table_name)'
- print ' Partition get_partition_with_auth(string db_name, string tbl_name, part_vals, string user_name, group_names)'
- print ' Partition get_partition_by_name(string db_name, string tbl_name, string part_name)'
- print ' get_partitions(string db_name, string tbl_name, i16 max_parts)'
- print ' get_partitions_with_auth(string db_name, string tbl_name, i16 max_parts, string user_name, group_names)'
- print ' get_partitions_pspec(string db_name, string tbl_name, i32 max_parts)'
- print ' get_partition_names(string db_name, string tbl_name, i16 max_parts)'
- print ' get_partitions_ps(string db_name, string tbl_name, part_vals, i16 max_parts)'
- print ' get_partitions_ps_with_auth(string db_name, string tbl_name, part_vals, i16 max_parts, string user_name, group_names)'
- print ' get_partition_names_ps(string db_name, string tbl_name, part_vals, i16 max_parts)'
- print ' get_partitions_by_filter(string db_name, string tbl_name, string filter, i16 max_parts)'
- print ' get_part_specs_by_filter(string db_name, string tbl_name, string filter, i32 max_parts)'
- print ' PartitionsByExprResult get_partitions_by_expr(PartitionsByExprRequest req)'
- 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_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)'
- print ' string get_config_value(string name, string defaultValue)'
- print ' partition_name_to_vals(string part_name)'
- print ' partition_name_to_spec(string part_name)'
- print ' void markPartitionForEvent(string db_name, string tbl_name, part_vals, PartitionEventType eventType)'
- print ' bool isPartitionMarkedForEvent(string db_name, string tbl_name, part_vals, PartitionEventType eventType)'
- print ' Index add_index(Index new_index, Table index_table)'
- print ' void alter_index(string dbname, string base_tbl_name, string idx_name, Index new_idx)'
- print ' bool drop_index_by_name(string db_name, string tbl_name, string index_name, bool deleteData)'
- print ' Index get_index_by_name(string db_name, string tbl_name, string index_name)'
- print ' get_indexes(string db_name, string tbl_name, i16 max_indexes)'
- print ' get_index_names(string db_name, string tbl_name, i16 max_indexes)'
- print ' bool update_table_column_statistics(ColumnStatistics stats_obj)'
- print ' bool update_partition_column_statistics(ColumnStatistics stats_obj)'
- print ' ColumnStatistics get_table_column_statistics(string db_name, string tbl_name, string col_name)'
- print ' ColumnStatistics get_partition_column_statistics(string db_name, string tbl_name, string part_name, string col_name)'
- print ' TableStatsResult get_table_statistics_req(TableStatsRequest request)'
- print ' PartitionsStatsResult get_partitions_statistics_req(PartitionsStatsRequest request)'
- print ' AggrStats get_aggr_stats_for(PartitionsStatsRequest request)'
- print ' bool set_aggr_stats_for(SetPartitionsStatsRequest 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()'
- print ' bool grant_role(string role_name, string principal_name, PrincipalType principal_type, string grantor, PrincipalType grantorType, bool grant_option)'
- print ' bool revoke_role(string role_name, string principal_name, PrincipalType principal_type)'
- print ' list_roles(string principal_name, PrincipalType principal_type)'
- print ' GrantRevokeRoleResponse grant_revoke_role(GrantRevokeRoleRequest request)'
- print ' GetPrincipalsInRoleResponse get_principals_in_role(GetPrincipalsInRoleRequest request)'
- print ' GetRoleGrantsForPrincipalResponse get_role_grants_for_principal(GetRoleGrantsForPrincipalRequest request)'
- print ' PrincipalPrivilegeSet get_privilege_set(HiveObjectRef hiveObject, string user_name, group_names)'
- print ' list_privileges(string principal_name, PrincipalType principal_type, HiveObjectRef hiveObject)'
- print ' bool grant_privileges(PrivilegeBag privileges)'
- print ' bool revoke_privileges(PrivilegeBag privileges)'
- print ' GrantRevokePrivilegeResponse grant_revoke_privileges(GrantRevokePrivilegeRequest request)'
- print ' set_ugi(string user_name, group_names)'
- print ' string get_delegation_token(string token_owner, string renewer_kerberos_principal_name)'
- print ' i64 renew_delegation_token(string token_str_form)'
- print ' void cancel_delegation_token(string token_str_form)'
- print ' GetOpenTxnsResponse get_open_txns()'
- print ' GetOpenTxnsInfoResponse get_open_txns_info()'
- print ' OpenTxnsResponse open_txns(OpenTxnRequest rqst)'
- print ' void abort_txn(AbortTxnRequest rqst)'
- print ' void commit_txn(CommitTxnRequest rqst)'
- print ' LockResponse lock(LockRequest rqst)'
- print ' LockResponse check_lock(CheckLockRequest rqst)'
- print ' void unlock(UnlockRequest rqst)'
- print ' ShowLocksResponse show_locks(ShowLocksRequest rqst)'
- print ' void heartbeat(HeartbeatRequest ids)'
- print ' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)'
- print ' void compact(CompactionRequest rqst)'
- print ' ShowCompactResponse show_compact(ShowCompactRequest rqst)'
- print ' void add_dynamic_partitions(AddDynamicPartitions rqst)'
- print ' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)'
- print ' CurrentNotificationEventId get_current_notificationEventId()'
- print ' FireEventResponse fire_listener_event(FireEventRequest rqst)'
- print ' void flushCache()'
- print ''
+ print('')
+ print('Usage: ' + sys.argv[0] + ' [-h host[:port]] [-u url] [-f[ramed]] [-s[sl]] function [arg1 [arg2...]]')
+ print('')
+ print('Functions:')
+ print(' string getMetaConf(string key)')
+ print(' void setMetaConf(string key, string value)')
+ print(' void create_database(Database database)')
+ print(' Database get_database(string name)')
+ print(' void drop_database(string name, bool deleteData, bool cascade)')
+ print(' get_databases(string pattern)')
+ print(' get_all_databases()')
+ print(' void alter_database(string dbname, Database db)')
+ print(' Type get_type(string name)')
+ print(' bool create_type(Type type)')
+ print(' bool drop_type(string type)')
+ print(' get_type_all(string name)')
+ print(' get_fields(string db_name, string table_name)')
+ print(' get_fields_with_environment_context(string db_name, string table_name, EnvironmentContext environment_context)')
+ print(' get_schema(string db_name, string table_name)')
+ print(' get_schema_with_environment_context(string db_name, string table_name, EnvironmentContext environment_context)')
+ print(' void create_table(Table tbl)')
+ print(' void create_table_with_environment_context(Table tbl, EnvironmentContext environment_context)')
+ print(' void drop_table(string dbname, string name, bool deleteData)')
+ print(' void drop_table_with_environment_context(string dbname, string name, bool deleteData, EnvironmentContext environment_context)')
+ print(' get_tables(string db_name, string pattern)')
+ print(' get_all_tables(string db_name)')
+ print(' Table get_table(string dbname, string tbl_name)')
+ print(' get_table_objects_by_name(string dbname, tbl_names)')
+ print(' get_table_names_by_filter(string dbname, string filter, i16 max_tables)')
+ print(' void alter_table(string dbname, string tbl_name, Table new_tbl)')
+ print(' void alter_table_with_environment_context(string dbname, string tbl_name, Table new_tbl, EnvironmentContext environment_context)')
+ print(' void alter_table_with_cascade(string dbname, string tbl_name, Table new_tbl, bool cascade)')
+ print(' Partition add_partition(Partition new_part)')
+ print(' Partition add_partition_with_environment_context(Partition new_part, EnvironmentContext environment_context)')
+ print(' i32 add_partitions( new_parts)')
+ print(' i32 add_partitions_pspec( new_parts)')
+ print(' Partition append_partition(string db_name, string tbl_name, part_vals)')
+ print(' AddPartitionsResult add_partitions_req(AddPartitionsRequest request)')
+ print(' Partition append_partition_with_environment_context(string db_name, string tbl_name, part_vals, EnvironmentContext environment_context)')
+ print(' Partition append_partition_by_name(string db_name, string tbl_name, string part_name)')
+ print(' Partition append_partition_by_name_with_environment_context(string db_name, string tbl_name, string part_name, EnvironmentContext environment_context)')
+ print(' bool drop_partition(string db_name, string tbl_name, part_vals, bool deleteData)')
+ print(' bool drop_partition_with_environment_context(string db_name, string tbl_name, part_vals, bool deleteData, EnvironmentContext environment_context)')
+ print(' bool drop_partition_by_name(string db_name, string tbl_name, string part_name, bool deleteData)')
+ print(' bool drop_partition_by_name_with_environment_context(string db_name, string tbl_name, string part_name, bool deleteData, EnvironmentContext environment_context)')
+ print(' DropPartitionsResult drop_partitions_req(DropPartitionsRequest req)')
+ print(' Partition get_partition(string db_name, string tbl_name, part_vals)')
+ print(' Partition exchange_partition( partitionSpecs, string source_db, string source_table_name, string dest_db, string dest_table_name)')
+ print(' Partition get_partition_with_auth(string db_name, string tbl_name, part_vals, string user_name, group_names)')
+ print(' Partition get_partition_by_name(string db_name, string tbl_name, string part_name)')
+ print(' get_partitions(string db_name, string tbl_name, i16 max_parts)')
+ print(' get_partitions_with_auth(string db_name, string tbl_name, i16 max_parts, string user_name, group_names)')
+ print(' get_partitions_pspec(string db_name, string tbl_name, i32 max_parts)')
+ print(' get_partition_names(string db_name, string tbl_name, i16 max_parts)')
+ print(' get_partitions_ps(string db_name, string tbl_name, part_vals, i16 max_parts)')
+ print(' get_partitions_ps_with_auth(string db_name, string tbl_name, part_vals, i16 max_parts, string user_name, group_names)')
+ print(' get_partition_names_ps(string db_name, string tbl_name, part_vals, i16 max_parts)')
+ print(' get_partitions_by_filter(string db_name, string tbl_name, string filter, i16 max_parts)')
+ print(' get_part_specs_by_filter(string db_name, string tbl_name, string filter, i32 max_parts)')
+ print(' PartitionsByExprResult get_partitions_by_expr(PartitionsByExprRequest req)')
+ 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_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)')
+ print(' string get_config_value(string name, string defaultValue)')
+ print(' partition_name_to_vals(string part_name)')
+ print(' partition_name_to_spec(string part_name)')
+ print(' void markPartitionForEvent(string db_name, string tbl_name, part_vals, PartitionEventType eventType)')
+ print(' bool isPartitionMarkedForEvent(string db_name, string tbl_name, part_vals, PartitionEventType eventType)')
+ print(' Index add_index(Index new_index, Table index_table)')
+ print(' void alter_index(string dbname, string base_tbl_name, string idx_name, Index new_idx)')
+ print(' bool drop_index_by_name(string db_name, string tbl_name, string index_name, bool deleteData)')
+ print(' Index get_index_by_name(string db_name, string tbl_name, string index_name)')
+ print(' get_indexes(string db_name, string tbl_name, i16 max_indexes)')
+ print(' get_index_names(string db_name, string tbl_name, i16 max_indexes)')
+ print(' bool update_table_column_statistics(ColumnStatistics stats_obj)')
+ print(' bool update_partition_column_statistics(ColumnStatistics stats_obj)')
+ print(' ColumnStatistics get_table_column_statistics(string db_name, string tbl_name, string col_name)')
+ print(' ColumnStatistics get_partition_column_statistics(string db_name, string tbl_name, string part_name, string col_name)')
+ print(' TableStatsResult get_table_statistics_req(TableStatsRequest request)')
+ print(' PartitionsStatsResult get_partitions_statistics_req(PartitionsStatsRequest request)')
+ print(' AggrStats get_aggr_stats_for(PartitionsStatsRequest request)')
+ print(' bool set_aggr_stats_for(SetPartitionsStatsRequest 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(' GetAllFunctionsResponse get_all_functions()')
+ print(' bool create_role(Role role)')
+ print(' bool drop_role(string role_name)')
+ print(' get_role_names()')
+ print(' bool grant_role(string role_name, string principal_name, PrincipalType principal_type, string grantor, PrincipalType grantorType, bool grant_option)')
+ print(' bool revoke_role(string role_name, string principal_name, PrincipalType principal_type)')
+ print(' list_roles(string principal_name, PrincipalType principal_type)')
+ print(' GrantRevokeRoleResponse grant_revoke_role(GrantRevokeRoleRequest request)')
+ print(' GetPrincipalsInRoleResponse get_principals_in_role(GetPrincipalsInRoleRequest request)')
+ print(' GetRoleGrantsForPrincipalResponse get_role_grants_for_principal(GetRoleGrantsForPrincipalRequest request)')
+ print(' PrincipalPrivilegeSet get_privilege_set(HiveObjectRef hiveObject, string user_name, group_names)')
+ print(' list_privileges(string principal_name, PrincipalType principal_type, HiveObjectRef hiveObject)')
+ print(' bool grant_privileges(PrivilegeBag privileges)')
+ print(' bool revoke_privileges(PrivilegeBag privileges)')
+ print(' GrantRevokePrivilegeResponse grant_revoke_privileges(GrantRevokePrivilegeRequest request)')
+ print(' set_ugi(string user_name, group_names)')
+ print(' string get_delegation_token(string token_owner, string renewer_kerberos_principal_name)')
+ print(' i64 renew_delegation_token(string token_str_form)')
+ print(' void cancel_delegation_token(string token_str_form)')
+ print(' GetOpenTxnsResponse get_open_txns()')
+ print(' GetOpenTxnsInfoResponse get_open_txns_info()')
+ print(' OpenTxnsResponse open_txns(OpenTxnRequest rqst)')
+ print(' void abort_txn(AbortTxnRequest rqst)')
+ print(' void commit_txn(CommitTxnRequest rqst)')
+ print(' LockResponse lock(LockRequest rqst)')
+ print(' LockResponse check_lock(CheckLockRequest rqst)')
+ print(' void unlock(UnlockRequest rqst)')
+ print(' ShowLocksResponse show_locks(ShowLocksRequest rqst)')
+ print(' void heartbeat(HeartbeatRequest ids)')
+ print(' HeartbeatTxnRangeResponse heartbeat_txn_range(HeartbeatTxnRangeRequest txns)')
+ print(' void compact(CompactionRequest rqst)')
+ print(' ShowCompactResponse show_compact(ShowCompactRequest rqst)')
+ print(' void add_dynamic_partitions(AddDynamicPartitions rqst)')
+ print(' NotificationEventResponse get_next_notification(NotificationEventRequest rqst)')
+ print(' CurrentNotificationEventId get_current_notificationEventId()')
+ print(' FireEventResponse fire_listener_event(FireEventRequest rqst)')
++ print(' void flushCache()')
+ print(' string getName()')
+ print(' string getVersion()')
+ print(' fb_status getStatus()')
+ print(' string getStatusDetails()')
+ print(' getCounters()')
+ print(' i64 getCounter(string key)')
+ print(' void setOption(string key, string value)')
+ print(' string getOption(string key)')
+ print(' getOptions()')
++ print(' string getCpuProfile(i32 profileDurationInSec)')
+ print(' i64 aliveSince()')
- print(' reflection_limited.Service getLimitedReflection()')
+ print(' void reinitialize()')
+ print(' void shutdown()')
+ print('')
sys.exit(0)
pp = pprint.PrettyPrinter(indent = 2)
@@@ -936,14 -961,86 +962,92 @@@ elif cmd == 'fire_listener_event'
sys.exit(1)
pp.pprint(client.fire_listener_event(eval(args[0]),))
+elif cmd == 'flushCache':
+ if len(args) != 0:
- print 'flushCache requires 0 args'
++ print('flushCache requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.flushCache())
+
+ elif cmd == 'getName':
+ if len(args) != 0:
+ print('getName requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getName())
+
+ elif cmd == 'getVersion':
+ if len(args) != 0:
+ print('getVersion requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getVersion())
+
+ elif cmd == 'getStatus':
+ if len(args) != 0:
+ print('getStatus requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getStatus())
+
+ elif cmd == 'getStatusDetails':
+ if len(args) != 0:
+ print('getStatusDetails requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getStatusDetails())
+
+ elif cmd == 'getCounters':
+ if len(args) != 0:
+ print('getCounters requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getCounters())
+
+ elif cmd == 'getCounter':
+ if len(args) != 1:
+ print('getCounter requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getCounter(args[0],))
+
+ elif cmd == 'setOption':
+ if len(args) != 2:
+ print('setOption requires 2 args')
+ sys.exit(1)
+ pp.pprint(client.setOption(args[0],args[1],))
+
+ elif cmd == 'getOption':
+ if len(args) != 1:
+ print('getOption requires 1 args')
+ sys.exit(1)
+ pp.pprint(client.getOption(args[0],))
+
+ elif cmd == 'getOptions':
+ if len(args) != 0:
+ print('getOptions requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.getOptions())
+
++elif cmd == 'getCpuProfile':
++ if len(args) != 1:
++ print('getCpuProfile requires 1 args')
++ sys.exit(1)
++ pp.pprint(client.getCpuProfile(eval(args[0]),))
++
+ elif cmd == 'aliveSince':
+ if len(args) != 0:
+ print('aliveSince requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.aliveSince())
+
-elif cmd == 'getLimitedReflection':
- if len(args) != 0:
- print('getLimitedReflection requires 0 args')
- sys.exit(1)
- pp.pprint(client.getLimitedReflection())
-
+ elif cmd == 'reinitialize':
+ if len(args) != 0:
+ print('reinitialize requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.reinitialize())
+
+ elif cmd == 'shutdown':
+ if len(args) != 0:
+ print('shutdown requires 0 args')
+ sys.exit(1)
+ pp.pprint(client.shutdown())
+
else:
- print 'Unrecognized method %s' % cmd
+ print('Unrecognized method %s' % cmd)
sys.exit(1)
transport.close()
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
----------------------------------------------------------------------
diff --cc metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
index 4aad3aa,9e460f0..dd75b01
--- a/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
+++ b/metastore/src/gen/thrift/gen-py/hive_metastore/ThriftHiveMetastore.py
@@@ -1018,9 -1021,6 +1021,9 @@@ class Iface(fb303.FacebookService.Iface
"""
pass
- def flushCache(self, ):
++ def flushCache(self):
+ pass
+
class Client(fb303.FacebookService.Client, Iface):
"""
@@@ -5438,29 -5589,6 +5592,30 @@@
return result.success
raise TApplicationException(TApplicationException.MISSING_RESULT, "fire_listener_event failed: unknown result");
- def flushCache(self, ):
++ def flushCache(self):
+ self.send_flushCache()
+ self.recv_flushCache()
+
- def send_flushCache(self, ):
++ def send_flushCache(self):
+ self._oprot.writeMessageBegin('flushCache', TMessageType.CALL, self._seqid)
+ args = flushCache_args()
+ args.write(self._oprot)
+ self._oprot.writeMessageEnd()
+ self._oprot.trans.flush()
+
- def recv_flushCache(self, ):
- (fname, mtype, rseqid) = self._iprot.readMessageBegin()
++ def recv_flushCache(self):
++ iprot = self._iprot
++ (fname, mtype, rseqid) = iprot.readMessageBegin()
+ if mtype == TMessageType.EXCEPTION:
+ x = TApplicationException()
- x.read(self._iprot)
- self._iprot.readMessageEnd()
++ x.read(iprot)
++ iprot.readMessageEnd()
+ raise x
+ result = flushCache_result()
- result.read(self._iprot)
- self._iprot.readMessageEnd()
++ result.read(iprot)
++ iprot.readMessageEnd()
+ return
+
class Processor(fb303.FacebookService.Processor, Iface, TProcessor):
def __init__(self, handler):
@@@ -27411,87 -29264,3 +29303,95 @@@ class fire_listener_event_result
def __ne__(self, other):
return not (self == other)
+
+class flushCache_args:
+
+ thrift_spec = (
+ )
+
+ 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:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('flushCache_args')
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
++ def __hash__(self):
++ value = 17
++ return value
++
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
+
+class flushCache_result:
+
+ thrift_spec = (
+ )
+
+ 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:
+ fastbinary.decode_binary(self, iprot.trans, (self.__class__, self.thrift_spec))
+ return
+ iprot.readStructBegin()
+ while True:
+ (fname, ftype, fid) = iprot.readFieldBegin()
+ if ftype == TType.STOP:
+ break
+ else:
+ iprot.skip(ftype)
+ iprot.readFieldEnd()
+ iprot.readStructEnd()
+
+ def write(self, oprot):
+ if oprot.__class__ == TBinaryProtocol.TBinaryProtocolAccelerated and self.thrift_spec is not None and fastbinary is not None:
+ oprot.trans.write(fastbinary.encode_binary(self, (self.__class__, self.thrift_spec)))
+ return
+ oprot.writeStructBegin('flushCache_result')
+ oprot.writeFieldStop()
+ oprot.writeStructEnd()
+
+ def validate(self):
+ return
+
+
++ def __hash__(self):
++ value = 17
++ return value
++
+ def __repr__(self):
+ L = ['%s=%r' % (key, value)
+ for key, value in self.__dict__.iteritems()]
+ return '%s(%s)' % (self.__class__.__name__, ', '.join(L))
+
+ def __eq__(self, other):
+ return isinstance(other, self.__class__) and self.__dict__ == other.__dict__
+
+ def __ne__(self, other):
+ return not (self == other)
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/gen/thrift/gen-rb/thrift_hive_metastore.rb
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStore.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/java/org/apache/hadoop/hive/metastore/HiveMetaStoreClient.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/java/org/apache/hadoop/hive/metastore/IMetaStoreClient.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/java/org/apache/hadoop/hive/metastore/ObjectStore.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/c528294b/metastore/src/java/org/apache/hadoop/hive/metastore/RawStore.java
----------------------------------------------------------------------