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

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

active_client_resources_impala::SimpleSchedulerprivate
active_reservations_impala::SimpleSchedulerprivate
active_resources_lock_impala::SimpleSchedulerprivate
ActiveClientResourcesMap typedefimpala::SimpleSchedulerprivate
ActiveReservationsMap typedefimpala::SimpleSchedulerprivate
AddToActiveResourceMaps(const TResourceBrokerReservationResponse &reservation, Coordinator *coord)impala::SimpleSchedulerprivate
admission_controller_impala::SimpleSchedulerprivate
backend_descriptor_impala::SimpleSchedulerprivate
backend_id_impala::SimpleSchedulerprivate
backend_ip_map_impala::SimpleSchedulerprivate
backend_map_impala::SimpleSchedulerprivate
backend_map_lock_impala::SimpleSchedulerprivate
BackendIdMap typedefimpala::SimpleSchedulerprivate
BackendIpAddressMap typedefimpala::SimpleSchedulerprivate
BackendList typedefimpala::Scheduler
BackendMap typedefimpala::SimpleSchedulerprivate
BackendsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document)impala::SimpleSchedulerprivate
ComputeFragmentExecParams(const TQueryExecRequest &exec_request, QuerySchedule *schedule)impala::SimpleSchedulerprivate
ComputeFragmentHosts(const TQueryExecRequest &exec_request, QuerySchedule *schedule)impala::SimpleSchedulerprivate
ComputeScanRangeAssignment(const TQueryExecRequest &exec_request, QuerySchedule *schedule)impala::SimpleSchedulerprivate
ComputeScanRangeAssignment(PlanNodeId node_id, const std::vector< TScanRangeLocations > &locations, const std::vector< TNetworkAddress > &host_list, bool exec_at_coord, const TQueryOptions &query_options, FragmentScanRangeAssignment *assignment)impala::SimpleSchedulerprivate
ContainsNode(const TPlan &plan, TPlanNodeType::type type)impala::SimpleSchedulerprivate
current_membership_impala::SimpleSchedulerprivate
FindLeftmostInputFragment(int fragment_idx, const TQueryExecRequest &exec_request)impala::SimpleSchedulerprivate
FindLeftmostNode(const TPlan &plan, const std::vector< TPlanNodeType::type > &types)impala::SimpleSchedulerprivate
FindNodes(const TPlan &plan, const std::vector< TPlanNodeType::type > &types, std::vector< TPlanNodeId > *results)impala::SimpleSchedulerprivate
FindSenderFragment(TPlanNodeId exch_id, int fragment_idx, const TQueryExecRequest &exec_request)impala::SimpleSchedulerprivate
GetAllKnownBackends(BackendList *backends)impala::SimpleSchedulervirtual
GetBackend(const TNetworkAddress &data_location, TBackendDescriptor *backend)impala::SimpleSchedulervirtual
GetBackends(const std::vector< TNetworkAddress > &data_locations, BackendList *backends)impala::SimpleSchedulervirtual
GetRequestPool(const std::string &user, const TQueryOptions &query_options, std::string *pool) const impala::SimpleSchedulerprivate
GetScanHosts(TPlanNodeId scan_id, const TQueryExecRequest &exec_request, const FragmentExecParams &params, std::vector< TNetworkAddress > *scan_hosts)impala::SimpleSchedulerprivate
HandleLostResource(const TUniqueId &client_resource_id)impala::SimpleSchedulervirtual
HandlePreemptedReservation(const TUniqueId &reservation_id)impala::SimpleSchedulervirtual
HandlePreemptedResource(const TUniqueId &client_resource_id)impala::SimpleSchedulervirtual
HasLocalBackend(const TNetworkAddress &data_location)impala::SimpleSchedulerinlinevirtual
IMPALA_MEMBERSHIP_TOPICimpala::SimpleSchedulerstatic
Init()impala::SimpleSchedulervirtual
initialised_impala::SimpleSchedulerprivate
metrics_impala::SimpleSchedulerprivate
next_nonlocal_backend_entry_impala::SimpleSchedulerprivate
num_backends_metric_impala::SimpleSchedulerprivate
Release(QuerySchedule *schedule)impala::SimpleSchedulervirtual
RemoveFromActiveResourceMaps(const TResourceBrokerReservationResponse &reservation)impala::SimpleSchedulerprivate
request_pool_service_impala::SimpleSchedulerprivate
resource_broker_impala::SimpleSchedulerprivate
Schedule(Coordinator *coord, QuerySchedule *schedule)impala::SimpleSchedulervirtual
SimpleScheduler(StatestoreSubscriber *subscriber, const std::string &backend_id, const TNetworkAddress &backend_address, MetricGroup *metrics, Webserver *webserver, ResourceBroker *resource_broker, RequestPoolService *request_pool_service)impala::SimpleScheduler
SimpleScheduler(const std::vector< TNetworkAddress > &backends, MetricGroup *metrics, Webserver *webserver, ResourceBroker *resource_broker, RequestPoolService *request_pool_service)impala::SimpleScheduler
statestore_subscriber_impala::SimpleSchedulerprivate
thrift_serializer_impala::SimpleSchedulerprivate
total_assignments_impala::SimpleSchedulerprivate
total_local_assignments_impala::SimpleSchedulerprivate
update_count_impala::SimpleSchedulerprivate
UpdateMembership(const StatestoreSubscriber::TopicDeltaMap &incoming_topic_deltas, std::vector< TTopicDelta > *subscriber_topic_updates)impala::SimpleSchedulerprivate
webserver_impala::SimpleSchedulerprivate
~Scheduler()impala::Schedulerinlinevirtual