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 ----------------------------------------------------------------------