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

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

active_llama_addr_idx_impala::ResourceBrokerprivate
active_llama_handle_metric_impala::ResourceBrokerprivate
active_llama_metric_impala::ResourceBrokerprivate
allocated_memory_metric_impala::ResourceBrokerprivate
allocated_requests_impala::ResourceBrokerprivate
allocated_requests_lock_impala::ResourceBrokerprivate
allocated_vcpus_metric_impala::ResourceBrokerprivate
AllocatedRequestMap typedefimpala::ResourceBrokerprivate
AMNotification(const llama::TLlamaAMNotificationRequest &request, llama::TLlamaAMNotificationResponse &response)impala::ResourceBroker
ClearRequests(const TUniqueId &reservation_id, bool include_reservation)impala::ResourceBroker
Close()impala::ResourceBroker
CreateLlamaReleaseRequest(const TResourceBrokerReleaseRequest &src, llama::TLlamaAMReleaseRequest &dest)impala::ResourceBrokerprivate
CreateLlamaReservationRequest(const TResourceBrokerReservationRequest &src, llama::TLlamaAMReservationRequest &dest)impala::ResourceBrokerprivate
Expand(const TResourceBrokerExpansionRequest &request, TResourceBrokerExpansionResponse *response)impala::ResourceBroker
expansion_requests_failed_metric_impala::ResourceBrokerprivate
expansion_requests_fulfilled_metric_impala::ResourceBrokerprivate
expansion_requests_rejected_metric_impala::ResourceBrokerprivate
expansion_requests_timedout_metric_impala::ResourceBrokerprivate
expansion_requests_total_metric_impala::ResourceBrokerprivate
expansion_response_time_metric_impala::ResourceBrokerprivate
expansion_rpc_time_metric_impala::ResourceBrokerprivate
GetQueryResourceMgr(const TUniqueId &query_id, const TUniqueId &reservation_id, const TNetworkAddress &local_resource_address, QueryResourceMgr **res_mgr)impala::ResourceBroker
has_standby_llama()impala::ResourceBrokerinlineprivate
Init()impala::ResourceBroker
llama_addresses_impala::ResourceBrokerprivate
llama_callback_address_impala::ResourceBrokerprivate
llama_callback_server_impala::ResourceBrokerprivate
llama_callback_thrift_iface_impala::ResourceBrokerprivate
llama_client_cache_impala::ResourceBrokerprivate
llama_client_id_impala::ResourceBrokerprivate
llama_handle_impala::ResourceBrokerprivate
llama_nodes()impala::ResourceBrokerinline
llama_nodes_impala::ResourceBrokerprivate
llama_registration_lock_impala::ResourceBrokerprivate
LlamaHasRestarted(const llama::TStatus &status) const impala::ResourceBrokerprivate
LlamaRpc(LlamaReqType *request, LlamaRespType *response, StatsMetric< double > *rpc_time_metric)impala::ResourceBrokerprivate
metrics_impala::ResourceBrokerprivate
NMNotification(const llama::TLlamaNMNotificationRequest &request, llama::TLlamaNMNotificationResponse &response)impala::ResourceBroker
pending_requests_impala::ResourceBrokerprivate
pending_requests_lock_impala::ResourceBrokerprivate
PendingRequestMap typedefimpala::ResourceBrokerprivate
query_resource_mgrs_impala::ResourceBrokerprivate
query_resource_mgrs_lock_impala::ResourceBrokerprivate
QueryResourceMgrsMap typedefimpala::ResourceBrokerprivate
RefreshLlamaNodes()impala::ResourceBroker
RegisterWithLlama()impala::ResourceBrokerprivate
Release(const TResourceBrokerReleaseRequest &request, TResourceBrokerReleaseResponse *response)impala::ResourceBroker
requests_released_metric_impala::ResourceBrokerprivate
ReRegisterWithLlama(const LlamaReqType &request, LlamaRespType *response)impala::ResourceBrokerprivate
ReRegisterWithLlama(const llama::TLlamaAMGetNodesRequest &request, llama::TLlamaAMGetNodesResponse *response)impala::ResourceBroker
reservation_requests_failed_metric_impala::ResourceBrokerprivate
reservation_requests_fulfilled_metric_impala::ResourceBrokerprivate
reservation_requests_rejected_metric_impala::ResourceBrokerprivate
reservation_requests_timedout_metric_impala::ResourceBrokerprivate
reservation_requests_total_metric_impala::ResourceBrokerprivate
reservation_response_time_metric_impala::ResourceBrokerprivate
reservation_rpc_time_metric_impala::ResourceBrokerprivate
Reserve(const TResourceBrokerReservationRequest &request, TResourceBrokerReservationResponse *response)impala::ResourceBroker
ResourceBroker(const std::vector< TNetworkAddress > &llama_addresses, const TNetworkAddress &llama_callback_address, MetricGroup *metrics)impala::ResourceBroker
ResourceMap typedefimpala::ResourceBrokerprivate
scheduler_impala::ResourceBrokerprivate
SendLlamaRpc(ClientConnection< llama::LlamaAMServiceClient > *llama_client, const LlamaReqType &request, LlamaRespType *response)impala::ResourceBrokerprivate
SendLlamaRpc(ClientConnection< llama::LlamaAMServiceClient > *llama_client, const llama::TLlamaAMGetNodesRequest &request, llama::TLlamaAMGetNodesResponse *response)impala::ResourceBroker
SendLlamaRpc(ClientConnection< llama::LlamaAMServiceClient > *llama_client, const llama::TLlamaAMReservationRequest &request, llama::TLlamaAMReservationResponse *response)impala::ResourceBroker
SendLlamaRpc(ClientConnection< llama::LlamaAMServiceClient > *llama_client, const llama::TLlamaAMReservationExpansionRequest &request, llama::TLlamaAMReservationExpansionResponse *response)impala::ResourceBroker
SendLlamaRpc(ClientConnection< llama::LlamaAMServiceClient > *llama_client, const llama::TLlamaAMReleaseRequest &request, llama::TLlamaAMReleaseResponse *response)impala::ResourceBroker
set_scheduler(Scheduler *scheduler)impala::ResourceBrokerinline
UnregisterQueryResourceMgr(const TUniqueId &query_id)impala::ResourceBroker
WaitForNotification(int64_t timeout, ResourceMap *resources, bool *timed_out, PendingRequest *reservation)impala::ResourceBrokerprivate