request-pool-service.cc File Reference

#include "scheduling/request-pool-service.h"
#include <list>
#include <string>
#include "common/logging.h"
#include "rpc/jni-thrift-util.h"
#include "util/mem-info.h"
#include "util/parse-util.h"
#include "util/time.h"
#include "common/names.h"

Include dependency graph for request-pool-service.cc:

Go to the source code of this file.

Functions
	DEFINE_string (fair_scheduler_allocation_path,"","Path to the fair scheduler ""allocation file (fair-scheduler.xml).")
	DEFINE_string (llama_site_path,"","Path to the Llama configuration file ""(llama-site.xml). If set, fair_scheduler_allocation_path must also be set.")
	DEFINE_int64 (default_pool_max_requests, 200,"Maximum number of concurrent outstanding ""requests allowed to run before queueing incoming requests. A negative value ""indicates no limit. 0 indicates no requests will be admitted. Ignored if ""fair_scheduler_config_path and llama_site_path are set.")
	DEFINE_string (default_pool_mem_limit,"","Maximum amount of memory that all ""outstanding requests in this pool may use before new requests to this pool"" are queued. Specified as a number of bytes ('<int>[bB]?'), megabytes ""('<float>[mM]'), gigabytes ('<float>[gG]'), or percentage of the physical memory ""('<int>%'). 0 or not setting indicates no limit. Defaults to bytes if no unit is ""given. Ignored if fair_scheduler_config_path and llama_site_path are set.")
	DEFINE_int64 (default_pool_max_queued, 200,"Maximum number of requests allowed to be ""queued before rejecting requests. A negative value or 0 indicates requests ""will always be rejected once the maximum number of concurrent requests are ""executing. Ignored if fair_scheduler_config_path and ""llama_site_path are set.")
	DEFINE_bool (disable_pool_mem_limits, false,"Disables all per-pool mem limits.")
	DEFINE_bool (disable_pool_max_requests, false,"Disables all per-pool limits on the ""maximum number of running requests.")
	DECLARE_bool (enable_rm)

Variables
const string	DEFAULT_POOL_NAME = "default-pool"
const string	RESOLVE_POOL_METRIC_NAME = "request-pool-service.resolve-pool-duration-ms"

Function Documentation

DECLARE_bool

(

enable_rm

)

DEFINE_bool	(	disable_pool_mem_limits	,
		false	,
		"Disables all per-pool mem limits."
	)

DEFINE_bool	(	disable_pool_max_requests	,
		false	,
		"Disables all per-pool limits on the ""maximum number of running requests."
	)

DEFINE_int64	(	default_pool_max_requests	,
		200	,
		"Maximum number of concurrent outstanding ""requests allowed to run before queueing incoming requests. A negative value ""indicates no limit. 0 indicates no requests will be admitted. Ignored if ""fair_scheduler_config_path and llama_site_path are set."
	)

DEFINE_int64	(	default_pool_max_queued	,
		200	,
		"Maximum number of requests allowed to be ""queued before rejecting requests. A negative value or 0 indicates requests ""will always be rejected once the maximum number of concurrent requests are ""executing. Ignored if fair_scheduler_config_path and ""llama_site_path are set."
	)

DEFINE_string	(	fair_scheduler_allocation_path	,
		""	,
		"Path to the fair scheduler ""allocation file (fair-scheduler.xml)."
	)

DEFINE_string	(	llama_site_path	,
		""	,
		"Path to the Llama configuration file ""(llama-site.xml). If	set,
		fair_scheduler_allocation_path must also be set."
	)

DEFINE_string	(	default_pool_mem_limit	,
		""	,
		"Maximum amount of memory that all ""outstanding requests in this pool may use before new requests to this pool"" are queued. Specified as a number of bytes	'<int>[bB]?',
		megabytes""	'< float >[mM]',
		gigabytes('< float >[gG]')	,
		or percentage of the physical memory""('< int >%').0 or not setting indicates no limit.Defaults to bytes if no unit is""given.Ignored if fair_scheduler_config_path and llama_site_path are set."
	)

Variable Documentation

const string DEFAULT_POOL_NAME = "default-pool"

Definition at line 63 of file request-pool-service.cc.

Referenced by impala::RequestPoolService::ResolveRequestPool().

const string RESOLVE_POOL_METRIC_NAME = "request-pool-service.resolve-pool-duration-ms"

Definition at line 65 of file request-pool-service.cc.

Referenced by impala::RequestPoolService::RequestPoolService().