test_hive.rar_ThriftHive.php_hive_hive php_php hive_php hive Thr

<?php /** * Autogenerated by Thrift Compiler (0.7.0) * * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING */ include_once $GLOBALS['THRIFT_ROOT'].'/Thrift.php'; include_once $GLOBALS['THRIFT_ROOT'].'/packages/hive_metastore/hive_metastore_types.php'; include_once $GLOBALS['THRIFT_ROOT'].'/packages/fb303/FacebookService.php'; interface ThriftHiveMetastoreIf extends FacebookServiceIf { public function create_database($database); public function get_database($name); public function drop_database($name, $deleteData, $cascade); public function get_databases($pattern); public function get_all_databases(); public function alter_database($dbname, $db); public function get_type($name); public function create_type($type); public function drop_type($type); public function get_type_all($name); public function get_fields($db_name, $table_name); public function get_schema($db_name, $table_name); public function create_table($tbl); public function drop_table($dbname, $name, $deleteData); public function get_tables($db_name, $pattern); public function get_all_tables($db_name); public function get_table($dbname, $tbl_name); public function get_table_objects_by_name($dbname, $tbl_names); public function get_table_names_by_filter($dbname, $filter, $max_tables); public function alter_table($dbname, $tbl_name, $new_tbl); public function add_partition($new_part); public function add_partitions($new_parts); public function append_partition($db_name, $tbl_name, $part_vals); public function append_partition_by_name($db_name, $tbl_name, $part_name); public function drop_partition($db_name, $tbl_name, $part_vals, $deleteData); public function drop_partition_by_name($db_name, $tbl_name, $part_name, $deleteData); public function get_partition($db_name, $tbl_name, $part_vals); public function get_partition_with_auth($db_name, $tbl_name, $part_vals, $user_name, $group_names); public function get_partition_by_name($db_name, $tbl_name, $part_name); 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); 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); public function get_partitions_by_filter($db_name, $tbl_name, $filter, $max_parts); public function get_partitions_by_names($db_name, $tbl_name, $names); public function alter_partition($db_name, $tbl_name, $new_part); public function rename_partition($db_name, $tbl_name, $part_vals, $new_part); public function get_config_value($name, $defaultValue); public function partition_name_to_vals($part_name); 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); public function add_index($new_index, $index_table); public function alter_index($dbname, $base_tbl_name, $idx_name, $new_idx); public function drop_index_by_name($db_name, $tbl_name, $index_name, $deleteData); public function get_index_by_name($db_name, $tbl_name, $index_name); public function get_indexes($db_name, $tbl_name, $max_indexes); public function get_index_names($db_name, $tbl_name, $max_indexes); public function create_role($role); public function drop_role($role_name); public function get_role_names(); public function grant_role($role_name, $principal_name, $principal_type, $grantor, $grantorType, $grant_option); public function revoke_role($role_name, $principal_name, $principal_type); public function list_roles($principal_name, $principal_type); public function get_privilege_set($hiveObject, $user_name, $group_names); public function list_privileges($principal_name, $principal_type, $hiveObject); public function grant_privileges($privileges); public function revoke_privileges($privileges); public function set_ugi($user_name, $group_names); public function get_delegation_token($token_owner, $renewer_kerberos_principal_name); public function renew_delegation_token($token_str_form); public function cancel_delegation_token($token_str_form); } class ThriftHiveMetastoreClient extends FacebookServiceClient implements ThriftHiveMetastoreIf { public function __construct($input, $output=null) { parent::__construct($input, $output); } public function create_database($database) { $this->send_create_database($database); $this->recv_create_database(); } public function send_create_database($database) { $args = new ThriftHiveMetastore_create_database_args(); $args->database = $database; $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'create_database', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { $this->output_->writeMessageBegin('create_database', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } public function recv_create_database() { $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, 'ThriftHiveMetastore_create_database_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 ThriftHiveMetastore_create_database_result(); $result->read($this->input_); $this->input_->readMessageEnd(); } if ($result->o1 !== null) { throw $result->o1; } if ($result->o2 !== null) { throw $result->o2; } if ($result->o3 !== null) { throw $result->o3; } return; } public function get_database($name) { $this->send_get_database($name); return $this->recv_get_database(); } public function send_get_database($name) { $args = new ThriftHiveMetastore_get_database_args(); $args->name = $name; $bin_accel = ($this->output_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_write_binary'); if ($bin_accel) { thrift_protocol_write_binary($this->output_, 'get_database', TMessageType::CALL, $args, $this->seqid_, $this->output_->isStrictWrite()); } else { $this->output_->writeMessageBegin('get_database', TMessageType::CALL, $this->seqid_); $args->write($this->output_); $this->output_->writeMessageEnd(); $this->output_->getTransport()->flush(); } } public function recv_get_database() { $bin_accel = ($this->input_ instanceof TProtocol::$TBINARYPROTOCOLACCELERATED) && function_exists('thrift_protocol_read_binary'); if ($bin_accel) $result = thrift_protocol_read_binary($this->input_, 'ThriftHiveMetastore_get_database_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();