AddPoolUpdates(std::vector< TTopicDelta > *subscriber_topic_updates) | impala::AdmissionController | private |
admission_ctrl_lock_ | impala::AdmissionController | private |
AdmissionController(RequestPoolService *request_pool_service, MetricGroup *metrics, const std::string &backend_id) | impala::AdmissionController | |
AdmitQuery(QuerySchedule *schedule) | impala::AdmissionController | |
backend_id_ | impala::AdmissionController | private |
CanAdmitRequest(const std::string &pool, const int64_t max_requests, const int64_t mem_limit, const QuerySchedule &schedule, bool admit_from_queue) | impala::AdmissionController | private |
cluster_pool_stats_ | impala::AdmissionController | private |
dequeue_cv_ | impala::AdmissionController | private |
dequeue_thread_ | impala::AdmissionController | private |
DequeueLoop() | impala::AdmissionController | private |
done_ | impala::AdmissionController | private |
GetPoolMetrics(const std::string &pool_name) | impala::AdmissionController | private |
HandleTopicDeletions(const std::vector< std::string > &topic_deletions) | impala::AdmissionController | private |
HandleTopicUpdates(const std::vector< TTopicItem > &topic_updates) | impala::AdmissionController | private |
IMPALA_REQUEST_QUEUE_TOPIC | impala::AdmissionController | privatestatic |
Init(StatestoreSubscriber *subscriber) | impala::AdmissionController | |
local_pool_stats_ | impala::AdmissionController | private |
metrics_ | impala::AdmissionController | private |
per_backend_pool_stats_map_ | impala::AdmissionController | private |
PerBackendPoolStatsMap typedef | impala::AdmissionController | private |
pool_config_cache_ | impala::AdmissionController | private |
pool_metrics_map_ | impala::AdmissionController | private |
PoolConfigMap typedef | impala::AdmissionController | private |
PoolMetricsMap typedef | impala::AdmissionController | private |
pools_for_updates_ | impala::AdmissionController | private |
PoolSet typedef | impala::AdmissionController | private |
PoolStatsMap typedef | impala::AdmissionController | private |
RejectRequest(const std::string &pool, const int64_t max_requests, const int64_t mem_limit, const int64_t max_queued, const QuerySchedule &schedule) | impala::AdmissionController | private |
ReleaseQuery(QuerySchedule *schedule) | impala::AdmissionController | |
request_pool_service_ | impala::AdmissionController | private |
request_queue_map_ | impala::AdmissionController | private |
RequestQueue typedef | impala::AdmissionController | private |
RequestQueueMap typedef | impala::AdmissionController | private |
thrift_serializer_ | impala::AdmissionController | private |
UpdateClusterAggregates(const std::string &pool_name) | impala::AdmissionController | private |
UpdateLocalMemUsage(const std::string &pool_name) | impala::AdmissionController | private |
UpdatePoolStats(const StatestoreSubscriber::TopicDeltaMap &incoming_topic_deltas, std::vector< TTopicDelta > *subscriber_topic_updates) | impala::AdmissionController | private |
~AdmissionController() | impala::AdmissionController | |