#include "statestore/simple-scheduler.h"
#include <vector>
#include <boost/algorithm/string.hpp>
#include <boost/algorithm/string/join.hpp>
#include <boost/bind.hpp>
#include <boost/mem_fn.hpp>
#include <boost/foreach.hpp>
#include <gutil/strings/substitute.h>
#include "common/logging.h"
#include "util/metrics.h"
#include "runtime/exec-env.h"
#include "runtime/coordinator.h"
#include "service/impala-server.h"
#include "statestore/statestore-subscriber.h"
#include "gen-cpp/Types_types.h"
#include "gen-cpp/ImpalaInternalService_constants.h"
#include "util/network-util.h"
#include "util/uid-util.h"
#include "util/container-util.h"
#include "util/debug-util.h"
#include "util/error-util.h"
#include "util/llama-util.h"
#include "util/mem-info.h"
#include "util/parse-util.h"
#include "gen-cpp/ResourceBrokerService_types.h"
#include "common/names.h"

Include dependency graph for simple-scheduler.cc:

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

Functions
	DECLARE_int32 (be_port)

	DECLARE_string (hostname)

	DECLARE_bool (enable_rm)

	DECLARE_int32 (rm_default_cpu_vcores)

	DECLARE_string (rm_default_memory)

	DEFINE_bool (disable_admission_control, true,"Disables admission control.")

	DEFINE_bool (require_username, false,"Requires that a user be provided in order to ""schedule requests. If enabled and a user is not provided, requests will be ""rejected, otherwise requests without a username will be submitted with the ""username 'default'.")

static const string	impala::LOCAL_ASSIGNMENTS_KEY ("simple-scheduler.local-assignments.total")

static const string	impala::ASSIGNMENTS_KEY ("simple-scheduler.assignments.total")

static const string	impala::SCHEDULER_INIT_KEY ("simple-scheduler.initialized")

static const string	impala::NUM_BACKENDS_KEY ("simple-scheduler.num-backends")

static const string	impala::DEFAULT_USER ("default")

static const string	impala::ERROR_USER_TO_POOL_MAPPING_NOT_FOUND ("No mapping found for request from user '$0' with requested pool '$1'")

static const string	impala::ERROR_USER_NOT_ALLOWED_IN_POOL ("Request from user '$0' with ""requested pool '$1' denied access to assigned pool '$2'")

static const string	impala::ERROR_USER_NOT_SPECIFIED ("User must be specified because ""-require_username=true.")

bool	impala::TBackendDescriptorComparator (const TBackendDescriptor &a, const TBackendDescriptor &b)

Variables
static const string	impala::BACKENDS_WEB_PAGE = "/backends"

static const string	impala::BACKENDS_TEMPLATE = "backends.tmpl"

Function Documentation

DECLARE_bool ( enable_rm )

DECLARE_int32 ( be_port )

DECLARE_int32 ( rm_default_cpu_vcores )

DECLARE_string ( hostname )

DECLARE_string ( rm_default_memory )

DEFINE_bool	(	disable_admission_control	,
		true	,
		"Disables admission control."
	)

DEFINE_bool	(	require_username	,
		false	,
		"Requires that a user be provided in order to ""schedule requests. If enabled and a user is not	provided,
		requests will be""	rejected,
		otherwise requests without a username will be submitted with the""username 'default'."
	)

Namespaces

Functions

Variables

Function Documentation