Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::ImpalaServer Member List

This is the complete list of members for impala::ImpalaServer, including all inherited members.

ArchiveQuery(const QueryExecState &query)impala::ImpalaServerprivate
ASCII_PRECISIONimpala::ImpalaServerprivatestatic
audit_event_logger_impala::ImpalaServerprivate
audit_event_logger_flush_thread_impala::ImpalaServerprivate
AuditEventLoggerFlushThread()impala::ImpalaServerprivate
authorized_proxy_user_config_impala::ImpalaServerprivate
AuthorizeProxyUser(const std::string &user, const std::string &do_as_user)impala::ImpalaServerprivate
BackendAddressMap typedefimpala::ImpalaServerprivate
Cancel(impala::TStatus &status, const beeswax::QueryHandle &query_id)impala::ImpalaServervirtual
CancelDelegationToken(apache::hive::service::cli::thrift::TCancelDelegationTokenResp &return_val, const apache::hive::service::cli::thrift::TCancelDelegationTokenReq &req)impala::ImpalaServervirtual
CancelFromThreadPool(uint32_t thread_id, const CancellationWork &cancellation_work)impala::ImpalaServerprivate
CancelInternal(const TUniqueId &query_id, bool check_inflight, const Status *cause=NULL)impala::ImpalaServerprivate
cancellation_thread_pool_impala::ImpalaServerprivate
CancelOperation(apache::hive::service::cli::thrift::TCancelOperationResp &return_val, const apache::hive::service::cli::thrift::TCancelOperationReq &request)impala::ImpalaServervirtual
CancelQueryUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
catalog_update_info_impala::ImpalaServerprivate
catalog_version_lock_impala::ImpalaServerprivate
catalog_version_update_cv_impala::ImpalaServerprivate
CatalogObjectsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *output)impala::ImpalaServerprivate
CatalogUpdateCallback(const StatestoreSubscriber::TopicDeltaMap &topic_deltas, std::vector< TTopicDelta > *topic_updates)impala::ImpalaServer
CatalogUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *output)impala::ImpalaServerprivate
ChildQuery classimpala::ImpalaServerfriend
clean(const beeswax::LogContextId &log_context)impala::ImpalaServervirtual
close(const beeswax::QueryHandle &handle)impala::ImpalaServervirtual
CloseInsert(impala::TInsertResult &insert_result, const beeswax::QueryHandle &query_handle)impala::ImpalaServervirtual
CloseInsertInternal(const TUniqueId &query_id, TInsertResult *insert_result)impala::ImpalaServerprivate
CloseOperation(apache::hive::service::cli::thrift::TCloseOperationResp &return_val, const apache::hive::service::cli::thrift::TCloseOperationReq &request)impala::ImpalaServervirtual
CloseSession(apache::hive::service::cli::thrift::TCloseSessionResp &return_val, const apache::hive::service::cli::thrift::TCloseSessionReq &request)impala::ImpalaServervirtual
CloseSessionInternal(const TUniqueId &session_id, bool ignore_if_absent)impala::ImpalaServerprivate
connection_to_sessions_map_impala::ImpalaServerprivate
connection_to_sessions_map_lock_impala::ImpalaServerprivate
ConnectionEnd(const ThriftServer::ConnectionContext &session_context)impala::ImpalaServervirtual
ConnectionStart(const ThriftServer::ConnectionContext &session_context)impala::ImpalaServervirtual
ConnectionToSessionMap typedefimpala::ImpalaServerprivate
CreateHS2ResultSet(apache::hive::service::cli::thrift::TProtocolVersion::type version, const TResultSetMetadata &metadata, apache::hive::service::cli::thrift::TRowSet *rowset=NULL)impala::ImpalaServerprivate
default_configs_impala::ImpalaServerprivate
default_query_options_impala::ImpalaServerprivate
DetectNmFailures()impala::ImpalaServerprivate
dump_config(std::string &config)impala::ImpalaServervirtual
echo(std::string &echo_string, const std::string &input_string)impala::ImpalaServervirtual
exec_env_impala::ImpalaServerprivate
Execute(TQueryCtx *query_ctx, boost::shared_ptr< SessionState > session_state, boost::shared_ptr< QueryExecState > *exec_state)impala::ImpalaServerprivate
executeAndWait(beeswax::QueryHandle &query_handle, const beeswax::Query &query, const beeswax::LogContextId &client_ctx)impala::ImpalaServervirtual
ExecuteInternal(const TQueryCtx &query_ctx, boost::shared_ptr< SessionState > session_state, bool *registered_exec_state, boost::shared_ptr< QueryExecState > *exec_state)impala::ImpalaServerprivate
ExecuteMetadataOp(const apache::hive::service::cli::thrift::THandleIdentifier &session_handle, TMetadataOpRequest *request, apache::hive::service::cli::thrift::TOperationHandle *handle, apache::hive::service::cli::thrift::TStatus *status)impala::ImpalaServerprivate
ExecuteStatement(apache::hive::service::cli::thrift::TExecuteStatementResp &return_val, const apache::hive::service::cli::thrift::TExecuteStatementReq &request)impala::ImpalaServervirtual
ExpirationEvent typedefimpala::ImpalaServerprivate
ExpirationQueue typedefimpala::ImpalaServerprivate
ExpireQueries()impala::ImpalaServerprivate
ExpireSessions()impala::ImpalaServerprivate
explain(beeswax::QueryExplanation &query_explanation, const beeswax::Query &query)impala::ImpalaServervirtual
fetch(beeswax::Results &query_results, const beeswax::QueryHandle &query_handle, const bool start_over, const int32_t fetch_size)impala::ImpalaServervirtual
FetchInternal(const TUniqueId &query_id, bool start_over, int32_t fetch_size, beeswax::Results *query_results)impala::ImpalaServerprivate
FetchInternal(const TUniqueId &query_id, int32_t fetch_size, bool fetch_first, apache::hive::service::cli::thrift::TFetchResultsResp *fetch_results)impala::ImpalaServerprivate
FetchResults(apache::hive::service::cli::thrift::TFetchResultsResp &return_val, const apache::hive::service::cli::thrift::TFetchResultsReq &request)impala::ImpalaServervirtual
get_default_configuration(std::vector< beeswax::ConfigVariable > &configurations, const bool include_hadoop)impala::ImpalaServervirtual
get_log(std::string &log, const beeswax::LogContextId &context)impala::ImpalaServervirtual
get_results_metadata(beeswax::ResultsMetadata &results_metadata, const beeswax::QueryHandle &handle)impala::ImpalaServervirtual
get_state(const beeswax::QueryHandle &handle)impala::ImpalaServervirtual
GetCatalogs(apache::hive::service::cli::thrift::TGetCatalogsResp &return_val, const apache::hive::service::cli::thrift::TGetCatalogsReq &request)impala::ImpalaServervirtual
GetColumns(apache::hive::service::cli::thrift::TGetColumnsResp &return_val, const apache::hive::service::cli::thrift::TGetColumnsReq &request)impala::ImpalaServervirtual
GetDelegationToken(apache::hive::service::cli::thrift::TGetDelegationTokenResp &return_val, const apache::hive::service::cli::thrift::TGetDelegationTokenReq &req)impala::ImpalaServervirtual
GetExecSummary(impala::TExecSummary &result, const beeswax::QueryHandle &query_id)impala::ImpalaServervirtual
GetExecSummary(TGetExecSummaryResp &return_val, const TGetExecSummaryReq &request)impala::ImpalaServervirtual
GetExecSummary(const TUniqueId &query_id, TExecSummary *result)impala::ImpalaServerprivate
GetFunctions(apache::hive::service::cli::thrift::TGetFunctionsResp &return_val, const apache::hive::service::cli::thrift::TGetFunctionsReq &request)impala::ImpalaServervirtual
GetInfo(apache::hive::service::cli::thrift::TGetInfoResp &return_val, const apache::hive::service::cli::thrift::TGetInfoReq &request)impala::ImpalaServervirtual
GetLog(apache::hive::service::cli::thrift::TGetLogResp &return_val, const apache::hive::service::cli::thrift::TGetLogReq &request)impala::ImpalaServervirtual
GetOperationStatus(apache::hive::service::cli::thrift::TGetOperationStatusResp &return_val, const apache::hive::service::cli::thrift::TGetOperationStatusReq &request)impala::ImpalaServervirtual
GetQueryExecState(const TUniqueId &query_id, bool lock)impala::ImpalaServerprivate
GetResultSetMetadata(apache::hive::service::cli::thrift::TGetResultSetMetadataResp &return_val, const apache::hive::service::cli::thrift::TGetResultSetMetadataReq &request)impala::ImpalaServervirtual
GetRuntimeProfile(std::string &profile_output, const beeswax::QueryHandle &query_id)impala::ImpalaServervirtual
GetRuntimeProfile(TGetRuntimeProfileResp &return_val, const TGetRuntimeProfileReq &request)impala::ImpalaServervirtual
GetRuntimeProfileStr(const TUniqueId &query_id, bool base64_encoded, std::stringstream *output)impala::ImpalaServerprivate
GetSchemas(apache::hive::service::cli::thrift::TGetSchemasResp &return_val, const apache::hive::service::cli::thrift::TGetSchemasReq &request)impala::ImpalaServervirtual
GetSessionIdForQuery(const TUniqueId &query_id, TUniqueId *session_id)impala::ImpalaServerprivate
GetSessionState(const TUniqueId &session_id, boost::shared_ptr< SessionState > *session_state, bool mark_active=false)impala::ImpalaServerprivate
GetTables(apache::hive::service::cli::thrift::TGetTablesResp &return_val, const apache::hive::service::cli::thrift::TGetTablesReq &request)impala::ImpalaServervirtual
GetTableTypes(apache::hive::service::cli::thrift::TGetTableTypesResp &return_val, const apache::hive::service::cli::thrift::TGetTableTypesReq &request)impala::ImpalaServervirtual
GetTypeInfo(apache::hive::service::cli::thrift::TGetTypeInfoResp &return_val, const apache::hive::service::cli::thrift::TGetTypeInfoReq &request)impala::ImpalaServervirtual
HadoopVarzUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
ImpalaServer(ExecEnv *exec_env)impala::ImpalaServer
InflightQueryIdsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
InitAuditEventLogging()impala::ImpalaServerprivate
InitializeConfigVariables()impala::ImpalaServerprivate
InitLineageLogging()impala::ImpalaServerprivate
InitLoggingDir(const std::string &log_dir)impala::ImpalaServerprivatestatic
InitProfileLogging()impala::ImpalaServerprivate
is_offline_impala::ImpalaServerprivate
is_offline_lock_impala::ImpalaServerprivate
IsAuditEventLoggingEnabled()impala::ImpalaServerprivate
IsLineageLoggingEnabled()impala::ImpalaServer
IsOffline()impala::ImpalaServerinline
known_backends_impala::ImpalaServerprivate
lineage_logger_impala::ImpalaServerprivate
lineage_logger_flush_thread_impala::ImpalaServerprivate
LineageLoggerFlushThread()impala::ImpalaServerprivate
LogAuditRecord(const QueryExecState &exec_state, const TExecRequest &request)impala::ImpalaServerprivate
LogFileFlushThread()impala::ImpalaServerprivate
LogLineageRecord(const TExecRequest &request)impala::ImpalaServerprivate
LogQueryEvents(const QueryExecState &exec_state)impala::ImpalaServerprivate
MarkSessionInactive(boost::shared_ptr< SessionState > session)impala::ImpalaServerinlineprivate
MembershipCallback(const StatestoreSubscriber::TopicDeltaMap &incoming_topic_deltas, std::vector< TTopicDelta > *subscriber_topic_updates)impala::ImpalaServer
min_subscriber_catalog_topic_version_impala::ImpalaServerprivate
nm_failure_detection_thread_impala::ImpalaServerprivate
OpenSession(apache::hive::service::cli::thrift::TOpenSessionResp &return_val, const apache::hive::service::cli::thrift::TOpenSessionReq &request)impala::ImpalaServervirtual
PingImpalaService(TPingImpalaServiceResp &return_val)impala::ImpalaServervirtual
PrepareQueryContext(TQueryCtx *query_ctx)impala::ImpalaServerstatic
ProcessCatalogUpdateResult(const TCatalogUpdateResult &catalog_update_result, bool wait_for_all_subscribers)impala::ImpalaServerprivate
profile_log_file_flush_thread_impala::ImpalaServerprivate
profile_logger_impala::ImpalaServerprivate
ProxyUserMap typedefimpala::ImpalaServerprivate
queries_by_timestamp_impala::ImpalaServerprivate
query(beeswax::QueryHandle &query_handle, const beeswax::Query &query)impala::ImpalaServervirtual
query_exec_state_map_impala::ImpalaServerprivate
query_exec_state_map_lock_impala::ImpalaServerprivate
query_expiration_lock_impala::ImpalaServerprivate
query_expiration_thread_impala::ImpalaServerprivate
query_locations_impala::ImpalaServerprivate
query_locations_lock_impala::ImpalaServerprivate
query_log_impala::ImpalaServerprivate
query_log_index_impala::ImpalaServerprivate
query_log_lock_impala::ImpalaServerprivate
QueryExecStateMap typedefimpala::ImpalaServerprivate
QueryHandleToTUniqueId(const beeswax::QueryHandle &handle, TUniqueId *query_id)impala::ImpalaServerinlineprivate
QueryLocations typedefimpala::ImpalaServerprivate
QueryLog typedefimpala::ImpalaServerprivate
QueryLogIndex typedefimpala::ImpalaServerprivate
QueryProfileEncodedUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
QueryProfileUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
QueryStateToJson(const ImpalaServer::QueryStateRecord &record, rapidjson::Value *value, rapidjson::Document *document)impala::ImpalaServerprivate
QueryStateUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
QuerySummaryCallback(bool include_plan_json, bool include_summary, const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
QueryToTQueryContext(const beeswax::Query &query, TQueryCtx *query_ctx)impala::ImpalaServerprivate
RaiseBeeswaxException(const std::string &msg, const char *sql_state)impala::ImpalaServerprivate
RegisterQuery(boost::shared_ptr< SessionState > session_state, const boost::shared_ptr< QueryExecState > &exec_state)impala::ImpalaServerprivate
RegisterWebserverCallbacks(Webserver *webserver)impala::ImpalaServerprivate
RenewDelegationToken(apache::hive::service::cli::thrift::TRenewDelegationTokenResp &return_val, const apache::hive::service::cli::thrift::TRenewDelegationTokenReq &req)impala::ImpalaServervirtual
ReportExecStatus(TReportExecStatusResult &return_val, const TReportExecStatusParams &params)impala::ImpalaServer
ResetCatalog(impala::TStatus &status)impala::ImpalaServervirtual
ResetTable(impala::TStatus &status, const TResetTableReq &request)impala::ImpalaServervirtual
ScopedSessionState classimpala::ImpalaServerfriend
session_state_map_impala::ImpalaServerprivate
session_state_map_lock_impala::ImpalaServerprivate
session_timeout_thread_impala::ImpalaServerprivate
SessionStateMap typedefimpala::ImpalaServerprivate
SessionsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::ImpalaServerprivate
SetOffline(bool offline)impala::ImpalaServerprivate
SetQueryInflight(boost::shared_ptr< SessionState > session_state, const boost::shared_ptr< QueryExecState > &exec_state)impala::ImpalaServerprivate
SQLSTATE_GENERAL_ERRORimpala::ImpalaServerprivatestatic
SQLSTATE_OPTIONAL_FEATURE_NOT_IMPLEMENTEDimpala::ImpalaServerprivatestatic
SQLSTATE_SYNTAX_ERROR_OR_ACCESS_VIOLATIONimpala::ImpalaServerprivatestatic
TExecuteStatementReqToTQueryContext(const apache::hive::service::cli::thrift::TExecuteStatementReq execute_request, TQueryCtx *query_ctx)impala::ImpalaServerprivate
THandleIdentifierToTUniqueId(const apache::hive::service::cli::thrift::THandleIdentifier &handle, TUniqueId *unique_id, TUniqueId *secret)impala::ImpalaServerinlineprivatestatic
TransmitData(TTransmitDataResult &return_val, const TTransmitDataParams &params)impala::ImpalaServer
TUniqueIdToQueryHandle(const TUniqueId &query_id, beeswax::QueryHandle *handle)impala::ImpalaServerinlineprivate
TUniqueIdToTHandleIdentifier(const TUniqueId &unique_id, const TUniqueId &secret, apache::hive::service::cli::thrift::THandleIdentifier *handle)impala::ImpalaServerinlineprivatestatic
UnregisterQuery(const TUniqueId &query_id, bool check_inflight, const Status *cause=NULL)impala::ImpalaServerprivate
UpdateCatalogMetrics()impala::ImpalaServerprivate
uuid_generator_impala::ImpalaServerprivate
uuid_lock_impala::ImpalaServerprivate
~ImpalaServer()impala::ImpalaServer