#include "scheduling/admission-controller.h"
#include <boost/algorithm/string.hpp>
#include <boost/bind.hpp>
#include <boost/foreach.hpp>
#include <boost/mem_fn.hpp>
#include <gutil/strings/substitute.h>
#include "common/logging.h"
#include "statestore/simple-scheduler.h"
#include "runtime/exec-env.h"
#include "runtime/mem-tracker.h"
#include "util/debug-util.h"
#include "util/time.h"
#include "util/runtime-profile.h"
#include "common/names.h"

Include dependency graph for admission-controller.cc:

Namespaces
	impala
	This file contains type definitions that are used throughout the code base.

Functions
	DEFINE_int64 (queue_wait_timeout_ms, 60 *1000,"Maximum amount of time (in ""milliseconds) that a request will wait to be admitted before timing out.")

static bool	impala::ParsePoolTopicKey (const string &topic_key, string pool_name, string backend_id)

static string	impala::MakePoolTopicKey (const string &pool_name, const string &backend_id)

static string	impala::DebugPoolStats (const string &pool_name, const TPoolStats total_stats, const TPoolStats local_stats)

Variables
const char	impala::TOPIC_KEY_DELIMITER = '!'

const string	impala::LOCAL_ADMITTED_METRIC_KEY_FORMAT

const string	impala::LOCAL_QUEUED_METRIC_KEY_FORMAT

const string	impala::LOCAL_DEQUEUED_METRIC_KEY_FORMAT

const string	impala::LOCAL_REJECTED_METRIC_KEY_FORMAT

const string	impala::LOCAL_TIMED_OUT_METRIC_KEY_FORMAT

const string	impala::LOCAL_COMPLETED_METRIC_KEY_FORMAT

const string	impala::LOCAL_TIME_IN_QUEUE_METRIC_KEY_FORMAT

const string	impala::CLUSTER_NUM_RUNNING_METRIC_KEY_FORMAT

const string	impala::CLUSTER_IN_QUEUE_METRIC_KEY_FORMAT

const string	impala::CLUSTER_MEM_USAGE_METRIC_KEY_FORMAT

const string	impala::CLUSTER_MEM_ESTIMATE_METRIC_KEY_FORMAT

const string	impala::LOCAL_NUM_RUNNING_METRIC_KEY_FORMAT

const string	impala::LOCAL_IN_QUEUE_METRIC_KEY_FORMAT

const string	impala::LOCAL_MEM_USAGE_METRIC_KEY_FORMAT

const string	impala::LOCAL_MEM_ESTIMATE_METRIC_KEY_FORMAT

const string	impala::QUERY_EVENT_SUBMIT_FOR_ADMISSION = "Submit for admission"

const string	impala::QUERY_EVENT_COMPLETED_ADMISSION = "Completed admission"

const string	impala::PROFILE_INFO_KEY_ADMISSION_RESULT = "Admission result"

const string	impala::PROFILE_INFO_VAL_ADMIT_IMMEDIATELY = "Admitted immediately"

const string	impala::PROFILE_INFO_VAL_ADMIT_QUEUED = "Admitted (queued)"

const string	impala::PROFILE_INFO_VAL_REJECTED = "Rejected"

const string	impala::PROFILE_INFO_VAL_TIME_OUT = "Timed out (queued)"

const string	impala::STATUS_REJECTED = "Rejected query from pool $0 : $1"

const string	impala::REASON_DISABLED_MEM_LIMIT = "disabled by mem limit set to 0"

const string	impala::REASON_DISABLED_REQUESTS_LIMIT = "disabled by requests limit set to 0"

const string	impala::REASON_QUEUE_FULL = "queue full, limit=$0, num_queued=$1"

const string	impala::REASON_REQ_OVER_MEM_LIMIT

const string	impala::QUEUED_NUM_RUNNING = "number of running queries $0 is over limit $1"

const string	impala::QUEUED_MEM_LIMIT

const string	impala::QUEUED_QUEUE_NOT_EMPTY

const string	impala::STATUS_TIME_OUT

Function Documentation

DEFINE_int64	(	queue_wait_timeout_ms	,
		60 *	1000,
		"Maximum amount of time (in ""milliseconds) that a request will wait to be admitted before timing out."
	)

Namespaces

Functions

Variables

Function Documentation