org.apache.hadoop.hive.service

Class ThriftHive.Client

java.lang.Object

org.apache.thrift.TServiceClient

com.facebook.fb303.FacebookService.Client

org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore.Client

org.apache.hadoop.hive.service.ThriftHive.Client

All Implemented Interfaces:

com.facebook.fb303.FacebookService.Iface, ThriftHiveMetastore.Iface, ThriftHive.Iface

Enclosing class:

ThriftHive

public static class ThriftHive.Client
extends ThriftHiveMetastore.Client
implements ThriftHive.Iface

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThriftHive.Client.Factory

Field Summary

Fields inherited from class org.apache.thrift.TServiceClient

iprot_, oprot_, seqid_

Constructor Summary

Constructors

Constructor and Description
ThriftHive.Client(org.apache.thrift.protocol.TProtocol prot)
ThriftHive.Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot)

Method Summary

Methods

Modifier and Type	Method and Description
void	clean()
void	execute(String query)
List<String>	fetchAll()
List<String>	fetchN(int numRows)
String	fetchOne()
HiveClusterStatus	getClusterStatus()
QueryPlan	getQueryPlan()
Schema	getSchema()
Schema	getThriftSchema()
void	recv_clean()
void	recv_execute()
List<String>	recv_fetchAll()
List<String>	recv_fetchN()
String	recv_fetchOne()
HiveClusterStatus	recv_getClusterStatus()
QueryPlan	recv_getQueryPlan()
Schema	recv_getSchema()
Schema	recv_getThriftSchema()
void	send_clean()
void	send_execute(String query)
void	send_fetchAll()
void	send_fetchN(int numRows)
void	send_fetchOne()
void	send_getClusterStatus()
void	send_getQueryPlan()
void	send_getSchema()
void	send_getThriftSchema()

Methods inherited from class org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore.Client

abort_txn, add_dynamic_partitions, add_index, add_partition_with_environment_context, add_partition, add_partitions_pspec, add_partitions_req, add_partitions, alter_database, alter_function, alter_index, alter_partition_with_environment_context, alter_partition, alter_partitions, alter_table_with_cascade, alter_table_with_environment_context, alter_table, append_partition_by_name_with_environment_context, append_partition_by_name, append_partition_with_environment_context, append_partition, cancel_delegation_token, check_lock, commit_txn, compact, create_database, create_function, create_role, create_table_with_environment_context, create_table, create_type, delete_partition_column_statistics, delete_table_column_statistics, drop_database, drop_function, drop_index_by_name, drop_partition_by_name_with_environment_context, drop_partition_by_name, drop_partition_with_environment_context, drop_partition, drop_partitions_req, drop_role, drop_table_with_environment_context, drop_table, drop_type, exchange_partition, fire_listener_event, get_aggr_stats_for, get_all_databases, get_all_tables, get_config_value, get_current_notificationEventId, get_database, get_databases, get_delegation_token, get_fields_with_environment_context, get_fields, get_function, get_functions, get_index_by_name, get_index_names, get_indexes, get_next_notification, get_open_txns_info, get_open_txns, get_part_specs_by_filter, get_partition_by_name, get_partition_column_statistics, get_partition_names_ps, get_partition_names, get_partition_with_auth, get_partition, get_partitions_by_expr, get_partitions_by_filter, get_partitions_by_names, get_partitions_ps_with_auth, get_partitions_ps, get_partitions_pspec, get_partitions_statistics_req, get_partitions_with_auth, get_partitions, get_principals_in_role, get_privilege_set, get_role_grants_for_principal, get_role_names, get_schema_with_environment_context, get_schema, get_table_column_statistics, get_table_names_by_filter, get_table_objects_by_name, get_table_statistics_req, get_table, get_tables, get_type_all, get_type, getMetaConf, grant_privileges, grant_revoke_privileges, grant_revoke_role, grant_role, heartbeat_txn_range, heartbeat, isPartitionMarkedForEvent, list_privileges, list_roles, lock, markPartitionForEvent, open_txns, partition_name_has_valid_characters, partition_name_to_spec, partition_name_to_vals, recv_abort_txn, recv_add_dynamic_partitions, recv_add_index, recv_add_partition_with_environment_context, recv_add_partition, recv_add_partitions_pspec, recv_add_partitions_req, recv_add_partitions, recv_alter_database, recv_alter_function, recv_alter_index, recv_alter_partition_with_environment_context, recv_alter_partition, recv_alter_partitions, recv_alter_table_with_cascade, recv_alter_table_with_environment_context, recv_alter_table, recv_append_partition_by_name_with_environment_context, recv_append_partition_by_name, recv_append_partition_with_environment_context, recv_append_partition, recv_cancel_delegation_token, recv_check_lock, recv_commit_txn, recv_compact, recv_create_database, recv_create_function, recv_create_role, recv_create_table_with_environment_context, recv_create_table, recv_create_type, recv_delete_partition_column_statistics, recv_delete_table_column_statistics, recv_drop_database, recv_drop_function, recv_drop_index_by_name, recv_drop_partition_by_name_with_environment_context, recv_drop_partition_by_name, recv_drop_partition_with_environment_context, recv_drop_partition, recv_drop_partitions_req, recv_drop_role, recv_drop_table_with_environment_context, recv_drop_table, recv_drop_type, recv_exchange_partition, recv_fire_listener_event, recv_get_aggr_stats_for, recv_get_all_databases, recv_get_all_tables, recv_get_config_value, recv_get_current_notificationEventId, recv_get_database, recv_get_databases, recv_get_delegation_token, recv_get_fields_with_environment_context, recv_get_fields, recv_get_function, recv_get_functions, recv_get_index_by_name, recv_get_index_names, recv_get_indexes, recv_get_next_notification, recv_get_open_txns_info, recv_get_open_txns, recv_get_part_specs_by_filter, recv_get_partition_by_name, recv_get_partition_column_statistics, recv_get_partition_names_ps, recv_get_partition_names, recv_get_partition_with_auth, recv_get_partition, recv_get_partitions_by_expr, recv_get_partitions_by_filter, recv_get_partitions_by_names, recv_get_partitions_ps_with_auth, recv_get_partitions_ps, recv_get_partitions_pspec, recv_get_partitions_statistics_req, recv_get_partitions_with_auth, recv_get_partitions, recv_get_principals_in_role, recv_get_privilege_set, recv_get_role_grants_for_principal, recv_get_role_names, recv_get_schema_with_environment_context, recv_get_schema, recv_get_table_column_statistics, recv_get_table_names_by_filter, recv_get_table_objects_by_name, recv_get_table_statistics_req, recv_get_table, recv_get_tables, recv_get_type_all, recv_get_type, recv_getMetaConf, recv_grant_privileges, recv_grant_revoke_privileges, recv_grant_revoke_role, recv_grant_role, recv_heartbeat_txn_range, recv_heartbeat, recv_isPartitionMarkedForEvent, recv_list_privileges, recv_list_roles, recv_lock, recv_markPartitionForEvent, recv_open_txns, recv_partition_name_has_valid_characters, recv_partition_name_to_spec, recv_partition_name_to_vals, recv_rename_partition, recv_renew_delegation_token, recv_revoke_privileges, recv_revoke_role, recv_set_aggr_stats_for, recv_set_ugi, recv_setMetaConf, recv_show_compact, recv_show_locks, recv_unlock, recv_update_partition_column_statistics, recv_update_table_column_statistics, rename_partition, renew_delegation_token, revoke_privileges, revoke_role, send_abort_txn, send_add_dynamic_partitions, send_add_index, send_add_partition_with_environment_context, send_add_partition, send_add_partitions_pspec, send_add_partitions_req, send_add_partitions, send_alter_database, send_alter_function, send_alter_index, send_alter_partition_with_environment_context, send_alter_partition, send_alter_partitions, send_alter_table_with_cascade, send_alter_table_with_environment_context, send_alter_table, send_append_partition_by_name_with_environment_context, send_append_partition_by_name, send_append_partition_with_environment_context, send_append_partition, send_cancel_delegation_token, send_check_lock, send_commit_txn, send_compact, send_create_database, send_create_function, send_create_role, send_create_table_with_environment_context, send_create_table, send_create_type, send_delete_partition_column_statistics, send_delete_table_column_statistics, send_drop_database, send_drop_function, send_drop_index_by_name, send_drop_partition_by_name_with_environment_context, send_drop_partition_by_name, send_drop_partition_with_environment_context, send_drop_partition, send_drop_partitions_req, send_drop_role, send_drop_table_with_environment_context, send_drop_table, send_drop_type, send_exchange_partition, send_fire_listener_event, send_get_aggr_stats_for, send_get_all_databases, send_get_all_tables, send_get_config_value, send_get_current_notificationEventId, send_get_database, send_get_databases, send_get_delegation_token, send_get_fields_with_environment_context, send_get_fields, send_get_function, send_get_functions, send_get_index_by_name, send_get_index_names, send_get_indexes, send_get_next_notification, send_get_open_txns_info, send_get_open_txns, send_get_part_specs_by_filter, send_get_partition_by_name, send_get_partition_column_statistics, send_get_partition_names_ps, send_get_partition_names, send_get_partition_with_auth, send_get_partition, send_get_partitions_by_expr, send_get_partitions_by_filter, send_get_partitions_by_names, send_get_partitions_ps_with_auth, send_get_partitions_ps, send_get_partitions_pspec, send_get_partitions_statistics_req, send_get_partitions_with_auth, send_get_partitions, send_get_principals_in_role, send_get_privilege_set, send_get_role_grants_for_principal, send_get_role_names, send_get_schema_with_environment_context, send_get_schema, send_get_table_column_statistics, send_get_table_names_by_filter, send_get_table_objects_by_name, send_get_table_statistics_req, send_get_table, send_get_tables, send_get_type_all, send_get_type, send_getMetaConf, send_grant_privileges, send_grant_revoke_privileges, send_grant_revoke_role, send_grant_role, send_heartbeat_txn_range, send_heartbeat, send_isPartitionMarkedForEvent, send_list_privileges, send_list_roles, send_lock, send_markPartitionForEvent, send_open_txns, send_partition_name_has_valid_characters, send_partition_name_to_spec, send_partition_name_to_vals, send_rename_partition, send_renew_delegation_token, send_revoke_privileges, send_revoke_role, send_set_aggr_stats_for, send_set_ugi, send_setMetaConf, send_show_compact, send_show_locks, send_unlock, send_update_partition_column_statistics, send_update_table_column_statistics, set_aggr_stats_for, set_ugi, setMetaConf, show_compact, show_locks, unlock, update_partition_column_statistics, update_table_column_statistics

Methods inherited from class com.facebook.fb303.FacebookService.Client

aliveSince, getCounter, getCounters, getCpuProfile, getName, getOption, getOptions, getStatus, getStatusDetails, getVersion, recv_aliveSince, recv_getCounter, recv_getCounters, recv_getCpuProfile, recv_getName, recv_getOption, recv_getOptions, recv_getStatus, recv_getStatusDetails, recv_getVersion, recv_setOption, reinitialize, send_aliveSince, send_getCounter, send_getCounters, send_getCpuProfile, send_getName, send_getOption, send_getOptions, send_getStatus, send_getStatusDetails, send_getVersion, send_reinitialize, send_setOption, send_shutdown, setOption, shutdown

Methods inherited from class org.apache.thrift.TServiceClient

getInputProtocol, getOutputProtocol, receiveBase, sendBase

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore.Iface

abort_txn, add_dynamic_partitions, add_index, add_partition_with_environment_context, add_partition, add_partitions_pspec, add_partitions_req, add_partitions, alter_database, alter_function, alter_index, alter_partition_with_environment_context, alter_partition, alter_partitions, alter_table_with_cascade, alter_table_with_environment_context, alter_table, append_partition_by_name_with_environment_context, append_partition_by_name, append_partition_with_environment_context, append_partition, cancel_delegation_token, check_lock, commit_txn, compact, create_database, create_function, create_role, create_table_with_environment_context, create_table, create_type, delete_partition_column_statistics, delete_table_column_statistics, drop_database, drop_function, drop_index_by_name, drop_partition_by_name_with_environment_context, drop_partition_by_name, drop_partition_with_environment_context, drop_partition, drop_partitions_req, drop_role, drop_table_with_environment_context, drop_table, drop_type, exchange_partition, fire_listener_event, get_aggr_stats_for, get_all_databases, get_all_tables, get_config_value, get_current_notificationEventId, get_database, get_databases, get_delegation_token, get_fields_with_environment_context, get_fields, get_function, get_functions, get_index_by_name, get_index_names, get_indexes, get_next_notification, get_open_txns_info, get_open_txns, get_part_specs_by_filter, get_partition_by_name, get_partition_column_statistics, get_partition_names_ps, get_partition_names, get_partition_with_auth, get_partition, get_partitions_by_expr, get_partitions_by_filter, get_partitions_by_names, get_partitions_ps_with_auth, get_partitions_ps, get_partitions_pspec, get_partitions_statistics_req, get_partitions_with_auth, get_partitions, get_principals_in_role, get_privilege_set, get_role_grants_for_principal, get_role_names, get_schema_with_environment_context, get_schema, get_table_column_statistics, get_table_names_by_filter, get_table_objects_by_name, get_table_statistics_req, get_table, get_tables, get_type_all, get_type, getMetaConf, grant_privileges, grant_revoke_privileges, grant_revoke_role, grant_role, heartbeat_txn_range, heartbeat, isPartitionMarkedForEvent, list_privileges, list_roles, lock, markPartitionForEvent, open_txns, partition_name_has_valid_characters, partition_name_to_spec, partition_name_to_vals, rename_partition, renew_delegation_token, revoke_privileges, revoke_role, set_aggr_stats_for, set_ugi, setMetaConf, show_compact, show_locks, unlock, update_partition_column_statistics, update_table_column_statistics

Methods inherited from interface com.facebook.fb303.FacebookService.Iface

aliveSince, getCounter, getCounters, getCpuProfile, getName, getOption, getOptions, getStatus, getStatusDetails, getVersion, reinitialize, setOption, shutdown

Constructor Detail

ThriftHive.Client

public ThriftHive.Client(org.apache.thrift.protocol.TProtocol prot)

ThriftHive.Client

public ThriftHive.Client(org.apache.thrift.protocol.TProtocol iprot,
                 org.apache.thrift.protocol.TProtocol oprot)

Method Detail

execute

public void execute(String query)
             throws HiveServerException,
                    org.apache.thrift.TException

Specified by:

execute in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_execute

public void send_execute(String query)
                  throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_execute

public void recv_execute()
                  throws HiveServerException,
                         org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

fetchOne

public String fetchOne()
                throws HiveServerException,
                       org.apache.thrift.TException

Specified by:

fetchOne in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_fetchOne

public void send_fetchOne()
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_fetchOne

public String recv_fetchOne()
                     throws HiveServerException,
                            org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

fetchN

public List<String> fetchN(int numRows)
                    throws HiveServerException,
                           org.apache.thrift.TException

Specified by:

fetchN in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_fetchN

public void send_fetchN(int numRows)
                 throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_fetchN

public List<String> recv_fetchN()
                         throws HiveServerException,
                                org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

fetchAll

public List<String> fetchAll()
                      throws HiveServerException,
                             org.apache.thrift.TException

Specified by:

fetchAll in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_fetchAll

public void send_fetchAll()
                   throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_fetchAll

public List<String> recv_fetchAll()
                           throws HiveServerException,
                                  org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

getSchema

public Schema getSchema()
                 throws HiveServerException,
                        org.apache.thrift.TException

Specified by:

getSchema in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_getSchema

public void send_getSchema()
                    throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getSchema

public Schema recv_getSchema()
                      throws HiveServerException,
                             org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

getThriftSchema

public Schema getThriftSchema()
                       throws HiveServerException,
                              org.apache.thrift.TException

Specified by:

getThriftSchema in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_getThriftSchema

public void send_getThriftSchema()
                          throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getThriftSchema

public Schema recv_getThriftSchema()
                            throws HiveServerException,
                                   org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

getClusterStatus

public HiveClusterStatus getClusterStatus()
                                   throws HiveServerException,
                                          org.apache.thrift.TException

Specified by:

getClusterStatus in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_getClusterStatus

public void send_getClusterStatus()
                           throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getClusterStatus

public HiveClusterStatus recv_getClusterStatus()
                                        throws HiveServerException,
                                               org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

getQueryPlan

public QueryPlan getQueryPlan()
                       throws HiveServerException,
                              org.apache.thrift.TException

Specified by:

getQueryPlan in interface ThriftHive.Iface

Throws:

HiveServerException

org.apache.thrift.TException

send_getQueryPlan

public void send_getQueryPlan()
                       throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_getQueryPlan

public QueryPlan recv_getQueryPlan()
                            throws HiveServerException,
                                   org.apache.thrift.TException

Throws:

HiveServerException

org.apache.thrift.TException

clean

public void clean()
           throws org.apache.thrift.TException

Specified by:

clean in interface ThriftHive.Iface

Throws:

org.apache.thrift.TException

send_clean

public void send_clean()
                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException

recv_clean

public void recv_clean()
                throws org.apache.thrift.TException

Throws:

org.apache.thrift.TException