|
Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
This is the complete list of members for impala::ImpalaServer, including all inherited members.
| ArchiveQuery(const QueryExecState &query) | impala::ImpalaServer | private |
| ASCII_PRECISION | impala::ImpalaServer | privatestatic |
| audit_event_logger_ | impala::ImpalaServer | private |
| audit_event_logger_flush_thread_ | impala::ImpalaServer | private |
| AuditEventLoggerFlushThread() | impala::ImpalaServer | private |
| authorized_proxy_user_config_ | impala::ImpalaServer | private |
| AuthorizeProxyUser(const std::string &user, const std::string &do_as_user) | impala::ImpalaServer | private |
| BackendAddressMap typedef | impala::ImpalaServer | private |
| Cancel(impala::TStatus &status, const beeswax::QueryHandle &query_id) | impala::ImpalaServer | virtual |
| CancelDelegationToken(apache::hive::service::cli::thrift::TCancelDelegationTokenResp &return_val, const apache::hive::service::cli::thrift::TCancelDelegationTokenReq &req) | impala::ImpalaServer | virtual |
| CancelFromThreadPool(uint32_t thread_id, const CancellationWork &cancellation_work) | impala::ImpalaServer | private |
| CancelInternal(const TUniqueId &query_id, bool check_inflight, const Status *cause=NULL) | impala::ImpalaServer | private |
| cancellation_thread_pool_ | impala::ImpalaServer | private |
| CancelOperation(apache::hive::service::cli::thrift::TCancelOperationResp &return_val, const apache::hive::service::cli::thrift::TCancelOperationReq &request) | impala::ImpalaServer | virtual |
| CancelQueryUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| catalog_update_info_ | impala::ImpalaServer | private |
| catalog_version_lock_ | impala::ImpalaServer | private |
| catalog_version_update_cv_ | impala::ImpalaServer | private |
| CatalogObjectsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *output) | impala::ImpalaServer | private |
| CatalogUpdateCallback(const StatestoreSubscriber::TopicDeltaMap &topic_deltas, std::vector< TTopicDelta > *topic_updates) | impala::ImpalaServer | |
| CatalogUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *output) | impala::ImpalaServer | private |
| ChildQuery class | impala::ImpalaServer | friend |
| clean(const beeswax::LogContextId &log_context) | impala::ImpalaServer | virtual |
| close(const beeswax::QueryHandle &handle) | impala::ImpalaServer | virtual |
| CloseInsert(impala::TInsertResult &insert_result, const beeswax::QueryHandle &query_handle) | impala::ImpalaServer | virtual |
| CloseInsertInternal(const TUniqueId &query_id, TInsertResult *insert_result) | impala::ImpalaServer | private |
| CloseOperation(apache::hive::service::cli::thrift::TCloseOperationResp &return_val, const apache::hive::service::cli::thrift::TCloseOperationReq &request) | impala::ImpalaServer | virtual |
| CloseSession(apache::hive::service::cli::thrift::TCloseSessionResp &return_val, const apache::hive::service::cli::thrift::TCloseSessionReq &request) | impala::ImpalaServer | virtual |
| CloseSessionInternal(const TUniqueId &session_id, bool ignore_if_absent) | impala::ImpalaServer | private |
| connection_to_sessions_map_ | impala::ImpalaServer | private |
| connection_to_sessions_map_lock_ | impala::ImpalaServer | private |
| ConnectionEnd(const ThriftServer::ConnectionContext &session_context) | impala::ImpalaServer | virtual |
| ConnectionStart(const ThriftServer::ConnectionContext &session_context) | impala::ImpalaServer | virtual |
| ConnectionToSessionMap typedef | impala::ImpalaServer | private |
| CreateHS2ResultSet(apache::hive::service::cli::thrift::TProtocolVersion::type version, const TResultSetMetadata &metadata, apache::hive::service::cli::thrift::TRowSet *rowset=NULL) | impala::ImpalaServer | private |
| default_configs_ | impala::ImpalaServer | private |
| default_query_options_ | impala::ImpalaServer | private |
| DetectNmFailures() | impala::ImpalaServer | private |
| dump_config(std::string &config) | impala::ImpalaServer | virtual |
| echo(std::string &echo_string, const std::string &input_string) | impala::ImpalaServer | virtual |
| exec_env_ | impala::ImpalaServer | private |
| Execute(TQueryCtx *query_ctx, boost::shared_ptr< SessionState > session_state, boost::shared_ptr< QueryExecState > *exec_state) | impala::ImpalaServer | private |
| executeAndWait(beeswax::QueryHandle &query_handle, const beeswax::Query &query, const beeswax::LogContextId &client_ctx) | impala::ImpalaServer | virtual |
| ExecuteInternal(const TQueryCtx &query_ctx, boost::shared_ptr< SessionState > session_state, bool *registered_exec_state, boost::shared_ptr< QueryExecState > *exec_state) | impala::ImpalaServer | private |
| 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::ImpalaServer | private |
| ExecuteStatement(apache::hive::service::cli::thrift::TExecuteStatementResp &return_val, const apache::hive::service::cli::thrift::TExecuteStatementReq &request) | impala::ImpalaServer | virtual |
| ExpirationEvent typedef | impala::ImpalaServer | private |
| ExpirationQueue typedef | impala::ImpalaServer | private |
| ExpireQueries() | impala::ImpalaServer | private |
| ExpireSessions() | impala::ImpalaServer | private |
| explain(beeswax::QueryExplanation &query_explanation, const beeswax::Query &query) | impala::ImpalaServer | virtual |
| fetch(beeswax::Results &query_results, const beeswax::QueryHandle &query_handle, const bool start_over, const int32_t fetch_size) | impala::ImpalaServer | virtual |
| FetchInternal(const TUniqueId &query_id, bool start_over, int32_t fetch_size, beeswax::Results *query_results) | impala::ImpalaServer | private |
| FetchInternal(const TUniqueId &query_id, int32_t fetch_size, bool fetch_first, apache::hive::service::cli::thrift::TFetchResultsResp *fetch_results) | impala::ImpalaServer | private |
| FetchResults(apache::hive::service::cli::thrift::TFetchResultsResp &return_val, const apache::hive::service::cli::thrift::TFetchResultsReq &request) | impala::ImpalaServer | virtual |
| get_default_configuration(std::vector< beeswax::ConfigVariable > &configurations, const bool include_hadoop) | impala::ImpalaServer | virtual |
| get_log(std::string &log, const beeswax::LogContextId &context) | impala::ImpalaServer | virtual |
| get_results_metadata(beeswax::ResultsMetadata &results_metadata, const beeswax::QueryHandle &handle) | impala::ImpalaServer | virtual |
| get_state(const beeswax::QueryHandle &handle) | impala::ImpalaServer | virtual |
| GetCatalogs(apache::hive::service::cli::thrift::TGetCatalogsResp &return_val, const apache::hive::service::cli::thrift::TGetCatalogsReq &request) | impala::ImpalaServer | virtual |
| GetColumns(apache::hive::service::cli::thrift::TGetColumnsResp &return_val, const apache::hive::service::cli::thrift::TGetColumnsReq &request) | impala::ImpalaServer | virtual |
| GetDelegationToken(apache::hive::service::cli::thrift::TGetDelegationTokenResp &return_val, const apache::hive::service::cli::thrift::TGetDelegationTokenReq &req) | impala::ImpalaServer | virtual |
| GetExecSummary(impala::TExecSummary &result, const beeswax::QueryHandle &query_id) | impala::ImpalaServer | virtual |
| GetExecSummary(TGetExecSummaryResp &return_val, const TGetExecSummaryReq &request) | impala::ImpalaServer | virtual |
| GetExecSummary(const TUniqueId &query_id, TExecSummary *result) | impala::ImpalaServer | private |
| GetFunctions(apache::hive::service::cli::thrift::TGetFunctionsResp &return_val, const apache::hive::service::cli::thrift::TGetFunctionsReq &request) | impala::ImpalaServer | virtual |
| GetInfo(apache::hive::service::cli::thrift::TGetInfoResp &return_val, const apache::hive::service::cli::thrift::TGetInfoReq &request) | impala::ImpalaServer | virtual |
| GetLog(apache::hive::service::cli::thrift::TGetLogResp &return_val, const apache::hive::service::cli::thrift::TGetLogReq &request) | impala::ImpalaServer | virtual |
| GetOperationStatus(apache::hive::service::cli::thrift::TGetOperationStatusResp &return_val, const apache::hive::service::cli::thrift::TGetOperationStatusReq &request) | impala::ImpalaServer | virtual |
| GetQueryExecState(const TUniqueId &query_id, bool lock) | impala::ImpalaServer | private |
| GetResultSetMetadata(apache::hive::service::cli::thrift::TGetResultSetMetadataResp &return_val, const apache::hive::service::cli::thrift::TGetResultSetMetadataReq &request) | impala::ImpalaServer | virtual |
| GetRuntimeProfile(std::string &profile_output, const beeswax::QueryHandle &query_id) | impala::ImpalaServer | virtual |
| GetRuntimeProfile(TGetRuntimeProfileResp &return_val, const TGetRuntimeProfileReq &request) | impala::ImpalaServer | virtual |
| GetRuntimeProfileStr(const TUniqueId &query_id, bool base64_encoded, std::stringstream *output) | impala::ImpalaServer | private |
| GetSchemas(apache::hive::service::cli::thrift::TGetSchemasResp &return_val, const apache::hive::service::cli::thrift::TGetSchemasReq &request) | impala::ImpalaServer | virtual |
| GetSessionIdForQuery(const TUniqueId &query_id, TUniqueId *session_id) | impala::ImpalaServer | private |
| GetSessionState(const TUniqueId &session_id, boost::shared_ptr< SessionState > *session_state, bool mark_active=false) | impala::ImpalaServer | private |
| GetTables(apache::hive::service::cli::thrift::TGetTablesResp &return_val, const apache::hive::service::cli::thrift::TGetTablesReq &request) | impala::ImpalaServer | virtual |
| GetTableTypes(apache::hive::service::cli::thrift::TGetTableTypesResp &return_val, const apache::hive::service::cli::thrift::TGetTableTypesReq &request) | impala::ImpalaServer | virtual |
| GetTypeInfo(apache::hive::service::cli::thrift::TGetTypeInfoResp &return_val, const apache::hive::service::cli::thrift::TGetTypeInfoReq &request) | impala::ImpalaServer | virtual |
| HadoopVarzUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| ImpalaServer(ExecEnv *exec_env) | impala::ImpalaServer | |
| InflightQueryIdsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| InitAuditEventLogging() | impala::ImpalaServer | private |
| InitializeConfigVariables() | impala::ImpalaServer | private |
| InitLineageLogging() | impala::ImpalaServer | private |
| InitLoggingDir(const std::string &log_dir) | impala::ImpalaServer | privatestatic |
| InitProfileLogging() | impala::ImpalaServer | private |
| is_offline_ | impala::ImpalaServer | private |
| is_offline_lock_ | impala::ImpalaServer | private |
| IsAuditEventLoggingEnabled() | impala::ImpalaServer | private |
| IsLineageLoggingEnabled() | impala::ImpalaServer | |
| IsOffline() | impala::ImpalaServer | inline |
| known_backends_ | impala::ImpalaServer | private |
| lineage_logger_ | impala::ImpalaServer | private |
| lineage_logger_flush_thread_ | impala::ImpalaServer | private |
| LineageLoggerFlushThread() | impala::ImpalaServer | private |
| LogAuditRecord(const QueryExecState &exec_state, const TExecRequest &request) | impala::ImpalaServer | private |
| LogFileFlushThread() | impala::ImpalaServer | private |
| LogLineageRecord(const TExecRequest &request) | impala::ImpalaServer | private |
| LogQueryEvents(const QueryExecState &exec_state) | impala::ImpalaServer | private |
| MarkSessionInactive(boost::shared_ptr< SessionState > session) | impala::ImpalaServer | inlineprivate |
| MembershipCallback(const StatestoreSubscriber::TopicDeltaMap &incoming_topic_deltas, std::vector< TTopicDelta > *subscriber_topic_updates) | impala::ImpalaServer | |
| min_subscriber_catalog_topic_version_ | impala::ImpalaServer | private |
| nm_failure_detection_thread_ | impala::ImpalaServer | private |
| OpenSession(apache::hive::service::cli::thrift::TOpenSessionResp &return_val, const apache::hive::service::cli::thrift::TOpenSessionReq &request) | impala::ImpalaServer | virtual |
| PingImpalaService(TPingImpalaServiceResp &return_val) | impala::ImpalaServer | virtual |
| PrepareQueryContext(TQueryCtx *query_ctx) | impala::ImpalaServer | static |
| ProcessCatalogUpdateResult(const TCatalogUpdateResult &catalog_update_result, bool wait_for_all_subscribers) | impala::ImpalaServer | private |
| profile_log_file_flush_thread_ | impala::ImpalaServer | private |
| profile_logger_ | impala::ImpalaServer | private |
| ProxyUserMap typedef | impala::ImpalaServer | private |
| queries_by_timestamp_ | impala::ImpalaServer | private |
| query(beeswax::QueryHandle &query_handle, const beeswax::Query &query) | impala::ImpalaServer | virtual |
| query_exec_state_map_ | impala::ImpalaServer | private |
| query_exec_state_map_lock_ | impala::ImpalaServer | private |
| query_expiration_lock_ | impala::ImpalaServer | private |
| query_expiration_thread_ | impala::ImpalaServer | private |
| query_locations_ | impala::ImpalaServer | private |
| query_locations_lock_ | impala::ImpalaServer | private |
| query_log_ | impala::ImpalaServer | private |
| query_log_index_ | impala::ImpalaServer | private |
| query_log_lock_ | impala::ImpalaServer | private |
| QueryExecStateMap typedef | impala::ImpalaServer | private |
| QueryHandleToTUniqueId(const beeswax::QueryHandle &handle, TUniqueId *query_id) | impala::ImpalaServer | inlineprivate |
| QueryLocations typedef | impala::ImpalaServer | private |
| QueryLog typedef | impala::ImpalaServer | private |
| QueryLogIndex typedef | impala::ImpalaServer | private |
| QueryProfileEncodedUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| QueryProfileUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| QueryStateToJson(const ImpalaServer::QueryStateRecord &record, rapidjson::Value *value, rapidjson::Document *document) | impala::ImpalaServer | private |
| QueryStateUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| QuerySummaryCallback(bool include_plan_json, bool include_summary, const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| QueryToTQueryContext(const beeswax::Query &query, TQueryCtx *query_ctx) | impala::ImpalaServer | private |
| RaiseBeeswaxException(const std::string &msg, const char *sql_state) | impala::ImpalaServer | private |
| RegisterQuery(boost::shared_ptr< SessionState > session_state, const boost::shared_ptr< QueryExecState > &exec_state) | impala::ImpalaServer | private |
| RegisterWebserverCallbacks(Webserver *webserver) | impala::ImpalaServer | private |
| RenewDelegationToken(apache::hive::service::cli::thrift::TRenewDelegationTokenResp &return_val, const apache::hive::service::cli::thrift::TRenewDelegationTokenReq &req) | impala::ImpalaServer | virtual |
| ReportExecStatus(TReportExecStatusResult &return_val, const TReportExecStatusParams ¶ms) | impala::ImpalaServer | |
| ResetCatalog(impala::TStatus &status) | impala::ImpalaServer | virtual |
| ResetTable(impala::TStatus &status, const TResetTableReq &request) | impala::ImpalaServer | virtual |
| ScopedSessionState class | impala::ImpalaServer | friend |
| session_state_map_ | impala::ImpalaServer | private |
| session_state_map_lock_ | impala::ImpalaServer | private |
| session_timeout_thread_ | impala::ImpalaServer | private |
| SessionStateMap typedef | impala::ImpalaServer | private |
| SessionsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::ImpalaServer | private |
| SetOffline(bool offline) | impala::ImpalaServer | private |
| SetQueryInflight(boost::shared_ptr< SessionState > session_state, const boost::shared_ptr< QueryExecState > &exec_state) | impala::ImpalaServer | private |
| SQLSTATE_GENERAL_ERROR | impala::ImpalaServer | privatestatic |
| SQLSTATE_OPTIONAL_FEATURE_NOT_IMPLEMENTED | impala::ImpalaServer | privatestatic |
| SQLSTATE_SYNTAX_ERROR_OR_ACCESS_VIOLATION | impala::ImpalaServer | privatestatic |
| TExecuteStatementReqToTQueryContext(const apache::hive::service::cli::thrift::TExecuteStatementReq execute_request, TQueryCtx *query_ctx) | impala::ImpalaServer | private |
| THandleIdentifierToTUniqueId(const apache::hive::service::cli::thrift::THandleIdentifier &handle, TUniqueId *unique_id, TUniqueId *secret) | impala::ImpalaServer | inlineprivatestatic |
| TransmitData(TTransmitDataResult &return_val, const TTransmitDataParams ¶ms) | impala::ImpalaServer | |
| TUniqueIdToQueryHandle(const TUniqueId &query_id, beeswax::QueryHandle *handle) | impala::ImpalaServer | inlineprivate |
| TUniqueIdToTHandleIdentifier(const TUniqueId &unique_id, const TUniqueId &secret, apache::hive::service::cli::thrift::THandleIdentifier *handle) | impala::ImpalaServer | inlineprivatestatic |
| UnregisterQuery(const TUniqueId &query_id, bool check_inflight, const Status *cause=NULL) | impala::ImpalaServer | private |
| UpdateCatalogMetrics() | impala::ImpalaServer | private |
| uuid_generator_ | impala::ImpalaServer | private |
| uuid_lock_ | impala::ImpalaServer | private |
| ~ImpalaServer() | impala::ImpalaServer |