Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
This is the complete list of members for impala::SimpleScheduler, including all inherited members.
active_client_resources_ | impala::SimpleScheduler | private |
active_reservations_ | impala::SimpleScheduler | private |
active_resources_lock_ | impala::SimpleScheduler | private |
ActiveClientResourcesMap typedef | impala::SimpleScheduler | private |
ActiveReservationsMap typedef | impala::SimpleScheduler | private |
AddToActiveResourceMaps(const TResourceBrokerReservationResponse &reservation, Coordinator *coord) | impala::SimpleScheduler | private |
admission_controller_ | impala::SimpleScheduler | private |
backend_descriptor_ | impala::SimpleScheduler | private |
backend_id_ | impala::SimpleScheduler | private |
backend_ip_map_ | impala::SimpleScheduler | private |
backend_map_ | impala::SimpleScheduler | private |
backend_map_lock_ | impala::SimpleScheduler | private |
BackendIdMap typedef | impala::SimpleScheduler | private |
BackendIpAddressMap typedef | impala::SimpleScheduler | private |
BackendList typedef | impala::Scheduler | |
BackendMap typedef | impala::SimpleScheduler | private |
BackendsUrlCallback(const Webserver::ArgumentMap &args, rapidjson::Document *document) | impala::SimpleScheduler | private |
ComputeFragmentExecParams(const TQueryExecRequest &exec_request, QuerySchedule *schedule) | impala::SimpleScheduler | private |
ComputeFragmentHosts(const TQueryExecRequest &exec_request, QuerySchedule *schedule) | impala::SimpleScheduler | private |
ComputeScanRangeAssignment(const TQueryExecRequest &exec_request, QuerySchedule *schedule) | impala::SimpleScheduler | private |
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::SimpleScheduler | private |
ContainsNode(const TPlan &plan, TPlanNodeType::type type) | impala::SimpleScheduler | private |
current_membership_ | impala::SimpleScheduler | private |
FindLeftmostInputFragment(int fragment_idx, const TQueryExecRequest &exec_request) | impala::SimpleScheduler | private |
FindLeftmostNode(const TPlan &plan, const std::vector< TPlanNodeType::type > &types) | impala::SimpleScheduler | private |
FindNodes(const TPlan &plan, const std::vector< TPlanNodeType::type > &types, std::vector< TPlanNodeId > *results) | impala::SimpleScheduler | private |
FindSenderFragment(TPlanNodeId exch_id, int fragment_idx, const TQueryExecRequest &exec_request) | impala::SimpleScheduler | private |
GetAllKnownBackends(BackendList *backends) | impala::SimpleScheduler | virtual |
GetBackend(const TNetworkAddress &data_location, TBackendDescriptor *backend) | impala::SimpleScheduler | virtual |
GetBackends(const std::vector< TNetworkAddress > &data_locations, BackendList *backends) | impala::SimpleScheduler | virtual |
GetRequestPool(const std::string &user, const TQueryOptions &query_options, std::string *pool) const | impala::SimpleScheduler | private |
GetScanHosts(TPlanNodeId scan_id, const TQueryExecRequest &exec_request, const FragmentExecParams ¶ms, std::vector< TNetworkAddress > *scan_hosts) | impala::SimpleScheduler | private |
HandleLostResource(const TUniqueId &client_resource_id) | impala::SimpleScheduler | virtual |
HandlePreemptedReservation(const TUniqueId &reservation_id) | impala::SimpleScheduler | virtual |
HandlePreemptedResource(const TUniqueId &client_resource_id) | impala::SimpleScheduler | virtual |
HasLocalBackend(const TNetworkAddress &data_location) | impala::SimpleScheduler | inlinevirtual |
IMPALA_MEMBERSHIP_TOPIC | impala::SimpleScheduler | static |
Init() | impala::SimpleScheduler | virtual |
initialised_ | impala::SimpleScheduler | private |
metrics_ | impala::SimpleScheduler | private |
next_nonlocal_backend_entry_ | impala::SimpleScheduler | private |
num_backends_metric_ | impala::SimpleScheduler | private |
Release(QuerySchedule *schedule) | impala::SimpleScheduler | virtual |
RemoveFromActiveResourceMaps(const TResourceBrokerReservationResponse &reservation) | impala::SimpleScheduler | private |
request_pool_service_ | impala::SimpleScheduler | private |
resource_broker_ | impala::SimpleScheduler | private |
Schedule(Coordinator *coord, QuerySchedule *schedule) | impala::SimpleScheduler | virtual |
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::SimpleScheduler | private |
thrift_serializer_ | impala::SimpleScheduler | private |
total_assignments_ | impala::SimpleScheduler | private |
total_local_assignments_ | impala::SimpleScheduler | private |
update_count_ | impala::SimpleScheduler | private |
UpdateMembership(const StatestoreSubscriber::TopicDeltaMap &incoming_topic_deltas, std::vector< TTopicDelta > *subscriber_topic_updates) | impala::SimpleScheduler | private |
webserver_ | impala::SimpleScheduler | private |
~Scheduler() | impala::Scheduler | inlinevirtual |