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 |