| <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> |
| <html xmlns="http://www.w3.org/1999/xhtml"> |
| <head> |
| <meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/> |
| <meta http-equiv="X-UA-Compatible" content="IE=9"/> |
| <meta name="generator" content="Doxygen 1.8.6"/> |
| <title>Impala: impala::SimpleScheduler Class Reference</title> |
| <link href="tabs.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="jquery.js"></script> |
| <script type="text/javascript" src="dynsections.js"></script> |
| <link href="navtree.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="resize.js"></script> |
| <script type="text/javascript" src="navtree.js"></script> |
| <script type="text/javascript"> |
| $(document).ready(initResizable); |
| $(window).load(resizeHeight); |
| </script> |
| <link href="search/search.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="search/search.js"></script> |
| <script type="text/javascript"> |
| $(document).ready(function() { searchBox.OnSelectItem(0); }); |
| </script> |
| <link href="doxygen.css" rel="stylesheet" type="text/css" /> |
| </head> |
| <body> |
| <div id="top"><!-- do not remove this div, it is closed by doxygen! --> |
| <div id="titlearea"> |
| <table cellspacing="0" cellpadding="0"> |
| <tbody> |
| <tr style="height: 56px;"> |
| <td style="padding-left: 0.5em;"> |
| <div id="projectname">Impala |
| </div> |
| <div id="projectbrief">Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| <!-- end header part --> |
| <!-- Generated by Doxygen 1.8.6 --> |
| <script type="text/javascript"> |
| var searchBox = new SearchBox("searchBox", "search",false,'Search'); |
| </script> |
| <div id="navrow1" class="tabs"> |
| <ul class="tablist"> |
| <li><a href="index.html"><span>Main Page</span></a></li> |
| <li><a href="namespaces.html"><span>Namespaces</span></a></li> |
| <li class="current"><a href="annotated.html"><span>Classes</span></a></li> |
| <li><a href="files.html"><span>Files</span></a></li> |
| <li> |
| <div id="MSearchBox" class="MSearchBoxInactive"> |
| <span class="left"> |
| <img id="MSearchSelect" src="search/mag_sel.png" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| alt=""/> |
| <input type="text" id="MSearchField" value="Search" accesskey="S" |
| onfocus="searchBox.OnSearchFieldFocus(true)" |
| onblur="searchBox.OnSearchFieldFocus(false)" |
| onkeyup="searchBox.OnSearchFieldChange(event)"/> |
| </span><span class="right"> |
| <a id="MSearchClose" href="javascript:searchBox.CloseResultsWindow()"><img id="MSearchCloseImg" border="0" src="search/close.png" alt=""/></a> |
| </span> |
| </div> |
| </li> |
| </ul> |
| </div> |
| <div id="navrow2" class="tabs2"> |
| <ul class="tablist"> |
| <li><a href="annotated.html"><span>Class List</span></a></li> |
| <li><a href="classes.html"><span>Class Index</span></a></li> |
| <li><a href="inherits.html"><span>Class Hierarchy</span></a></li> |
| <li><a href="functions.html"><span>Class Members</span></a></li> |
| </ul> |
| </div> |
| </div><!-- top --> |
| <div id="side-nav" class="ui-resizable side-nav-resizable"> |
| <div id="nav-tree"> |
| <div id="nav-tree-contents"> |
| <div id="nav-sync" class="sync"></div> |
| </div> |
| </div> |
| <div id="splitbar" style="-moz-user-select:none;" |
| class="ui-resizable-handle"> |
| </div> |
| </div> |
| <script type="text/javascript"> |
| $(document).ready(function(){initNavTree('classimpala_1_1SimpleScheduler.html','');}); |
| </script> |
| <div id="doc-content"> |
| <!-- window showing the filter options --> |
| <div id="MSearchSelectWindow" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| onkeydown="return searchBox.OnSearchSelectKey(event)"> |
| <a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(0)"><span class="SelectionMark"> </span>All</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(1)"><span class="SelectionMark"> </span>Classes</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(2)"><span class="SelectionMark"> </span>Namespaces</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(3)"><span class="SelectionMark"> </span>Files</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(4)"><span class="SelectionMark"> </span>Functions</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(5)"><span class="SelectionMark"> </span>Variables</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(6)"><span class="SelectionMark"> </span>Typedefs</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(7)"><span class="SelectionMark"> </span>Enumerations</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(8)"><span class="SelectionMark"> </span>Enumerator</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(9)"><span class="SelectionMark"> </span>Friends</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(10)"><span class="SelectionMark"> </span>Macros</a></div> |
| |
| <!-- iframe showing the search results (closed by default) --> |
| <div id="MSearchResultsWindow"> |
| <iframe src="javascript:void(0)" frameborder="0" |
| name="MSearchResults" id="MSearchResults"> |
| </iframe> |
| </div> |
| |
| <div class="header"> |
| <div class="summary"> |
| <a href="#pub-types">Public Types</a> | |
| <a href="#pub-methods">Public Member Functions</a> | |
| <a href="#pub-static-attribs">Static Public Attributes</a> | |
| <a href="#pri-types">Private Types</a> | |
| <a href="#pri-methods">Private Member Functions</a> | |
| <a href="#pri-attribs">Private Attributes</a> | |
| <a href="classimpala_1_1SimpleScheduler-members.html">List of all members</a> </div> |
| <div class="headertitle"> |
| <div class="title">impala::SimpleScheduler Class Reference</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| |
| <p><code>#include <<a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>></code></p> |
| <div class="dynheader"> |
| Inheritance diagram for impala::SimpleScheduler:</div> |
| <div class="dyncontent"> |
| <div class="center"><div class="zoom"><iframe scrolling="no" frameborder="0" src="classimpala_1_1SimpleScheduler__inherit__graph.svg" width="100%" height="600"><p><b>This browser is not able to show SVG: try Firefox, Chrome, Safari, or Opera instead.</b></p></iframe></div></div> |
| </div> |
| <div class="dynheader"> |
| Collaboration diagram for impala::SimpleScheduler:</div> |
| <div class="dyncontent"> |
| <div class="center"><div class="zoom"><iframe scrolling="no" frameborder="0" src="classimpala_1_1SimpleScheduler__coll__graph.svg" width="100%" height="600"><p><b>This browser is not able to show SVG: try Firefox, Chrome, Safari, or Opera instead.</b></p></iframe></div></div> |
| </div> |
| <table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-types"></a> |
| Public Types</h2></td></tr> |
| <tr class="memitem:af188a31a06554682f7f200dd690286a9"><td class="memItemLeft" align="right" valign="top">typedef std::vector<br class="typebreak"/> |
| < TBackendDescriptor > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1Scheduler.html#af188a31a06554682f7f200dd690286a9">BackendList</a></td></tr> |
| <tr class="memdesc:af188a31a06554682f7f200dd690286a9"><td class="mdescLeft"> </td><td class="mdescRight">List of server descriptors. <a href="#af188a31a06554682f7f200dd690286a9">More...</a><br/></td></tr> |
| <tr class="separator:af188a31a06554682f7f200dd690286a9"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-methods"></a> |
| Public Member Functions</h2></td></tr> |
| <tr class="memitem:add689ee214d3916983359970d10e458c"><td class="memItemLeft" align="right" valign="top"> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#add689ee214d3916983359970d10e458c">SimpleScheduler</a> (<a class="el" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a> *subscriber, const std::string &backend_id, const TNetworkAddress &backend_address, <a class="el" href="classimpala_1_1MetricGroup.html">MetricGroup</a> *metrics, <a class="el" href="classimpala_1_1Webserver.html">Webserver</a> *webserver, <a class="el" href="classimpala_1_1ResourceBroker.html">ResourceBroker</a> *resource_broker, <a class="el" href="classimpala_1_1RequestPoolService.html">RequestPoolService</a> *request_pool_service)</td></tr> |
| <tr class="separator:add689ee214d3916983359970d10e458c"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae97b1713444b66320b1adb8d810099b9"><td class="memItemLeft" align="right" valign="top"> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ae97b1713444b66320b1adb8d810099b9">SimpleScheduler</a> (const std::vector< TNetworkAddress > &<a class="el" href="name-resolution-benchmark_8cc.html#a67f146e42fdee811645594cfd7a0882f">backends</a>, <a class="el" href="classimpala_1_1MetricGroup.html">MetricGroup</a> *metrics, <a class="el" href="classimpala_1_1Webserver.html">Webserver</a> *webserver, <a class="el" href="classimpala_1_1ResourceBroker.html">ResourceBroker</a> *resource_broker, <a class="el" href="classimpala_1_1RequestPoolService.html">RequestPoolService</a> *request_pool_service)</td></tr> |
| <tr class="separator:ae97b1713444b66320b1adb8d810099b9"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa2d3bf1ee9968d9393fb43acc424b78a"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aa2d3bf1ee9968d9393fb43acc424b78a">GetBackends</a> (const std::vector< TNetworkAddress > &data_locations, <a class="el" href="classimpala_1_1Scheduler.html#af188a31a06554682f7f200dd690286a9">BackendList</a> *<a class="el" href="name-resolution-benchmark_8cc.html#a67f146e42fdee811645594cfd7a0882f">backends</a>)</td></tr> |
| <tr class="separator:aa2d3bf1ee9968d9393fb43acc424b78a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a53cd14fef292f7e5cbf8667c346ff3a1"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">impala::Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a53cd14fef292f7e5cbf8667c346ff3a1">GetBackend</a> (const TNetworkAddress &data_location, TBackendDescriptor *backend)</td></tr> |
| <tr class="separator:a53cd14fef292f7e5cbf8667c346ff3a1"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a4f8b0499b4fc2dfeb38ba7d24e9dc31c"><td class="memItemLeft" align="right" valign="top">virtual void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a4f8b0499b4fc2dfeb38ba7d24e9dc31c">GetAllKnownBackends</a> (<a class="el" href="classimpala_1_1Scheduler.html#af188a31a06554682f7f200dd690286a9">BackendList</a> *<a class="el" href="name-resolution-benchmark_8cc.html#a67f146e42fdee811645594cfd7a0882f">backends</a>)</td></tr> |
| <tr class="memdesc:a4f8b0499b4fc2dfeb38ba7d24e9dc31c"><td class="mdescLeft"> </td><td class="mdescRight">Return a list of all backends known to the scheduler. <a href="#a4f8b0499b4fc2dfeb38ba7d24e9dc31c">More...</a><br/></td></tr> |
| <tr class="separator:a4f8b0499b4fc2dfeb38ba7d24e9dc31c"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aecd9fa6688740dbb1c64274cb4a08da8"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classbool.html">bool</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aecd9fa6688740dbb1c64274cb4a08da8">HasLocalBackend</a> (const TNetworkAddress &data_location)</td></tr> |
| <tr class="memdesc:aecd9fa6688740dbb1c64274cb4a08da8"><td class="mdescLeft"> </td><td class="mdescRight">Return true if there is a backend located on the given data_location. <a href="#aecd9fa6688740dbb1c64274cb4a08da8">More...</a><br/></td></tr> |
| <tr class="separator:aecd9fa6688740dbb1c64274cb4a08da8"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a0c607cfb2bad2be3c2c981e1e1ab605b"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">impala::Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a0c607cfb2bad2be3c2c981e1e1ab605b">Init</a> ()</td></tr> |
| <tr class="memdesc:a0c607cfb2bad2be3c2c981e1e1ab605b"><td class="mdescLeft"> </td><td class="mdescRight">Registers with the subscription manager if required. <a href="#a0c607cfb2bad2be3c2c981e1e1ab605b">More...</a><br/></td></tr> |
| <tr class="separator:a0c607cfb2bad2be3c2c981e1e1ab605b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ab1bd929a9f3e8e9240676f83c9b67f41"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ab1bd929a9f3e8e9240676f83c9b67f41">Schedule</a> (Coordinator *coord, <a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> *schedule)</td></tr> |
| <tr class="separator:ab1bd929a9f3e8e9240676f83c9b67f41"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a6f404a00140d7b7d8e98e8fccffa4f24"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a6f404a00140d7b7d8e98e8fccffa4f24">Release</a> (<a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> *schedule)</td></tr> |
| <tr class="memdesc:a6f404a00140d7b7d8e98e8fccffa4f24"><td class="mdescLeft"> </td><td class="mdescRight">Releases the reserved resources (if any) from the given schedule. <a href="#a6f404a00140d7b7d8e98e8fccffa4f24">More...</a><br/></td></tr> |
| <tr class="separator:a6f404a00140d7b7d8e98e8fccffa4f24"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a4b32b715b806350d406a382762b84d93"><td class="memItemLeft" align="right" valign="top">virtual void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a4b32b715b806350d406a382762b84d93">HandlePreemptedReservation</a> (const TUniqueId &reservation_id)</td></tr> |
| <tr class="separator:a4b32b715b806350d406a382762b84d93"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac16a1d19a4be2f2c219a0061ea351be4"><td class="memItemLeft" align="right" valign="top">virtual void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ac16a1d19a4be2f2c219a0061ea351be4">HandlePreemptedResource</a> (const TUniqueId &client_resource_id)</td></tr> |
| <tr class="separator:ac16a1d19a4be2f2c219a0061ea351be4"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae1239ce6fe1935b4d43ece10d0bc479e"><td class="memItemLeft" align="right" valign="top">virtual void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ae1239ce6fe1935b4d43ece10d0bc479e">HandleLostResource</a> (const TUniqueId &client_resource_id)</td></tr> |
| <tr class="separator:ae1239ce6fe1935b4d43ece10d0bc479e"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-static-attribs"></a> |
| Static Public Attributes</h2></td></tr> |
| <tr class="memitem:a67cb9cfbd5fd7a18eb7533f1a226081a"><td class="memItemLeft" align="right" valign="top">static const std::string </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a67cb9cfbd5fd7a18eb7533f1a226081a">IMPALA_MEMBERSHIP_TOPIC</a></td></tr> |
| <tr class="separator:a67cb9cfbd5fd7a18eb7533f1a226081a"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-types"></a> |
| Private Types</h2></td></tr> |
| <tr class="memitem:a5bf9963f01cec937d810092870ad9030"><td class="memItemLeft" align="right" valign="top">typedef boost::unordered_map<br class="typebreak"/> |
| < std::string, std::list<br class="typebreak"/> |
| < TBackendDescriptor > > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a5bf9963f01cec937d810092870ad9030">BackendMap</a></td></tr> |
| <tr class="memdesc:a5bf9963f01cec937d810092870ad9030"><td class="mdescLeft"> </td><td class="mdescRight">Map from a datanode's IP address to a list of backend addresses running on that node. <a href="#a5bf9963f01cec937d810092870ad9030">More...</a><br/></td></tr> |
| <tr class="separator:a5bf9963f01cec937d810092870ad9030"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a82aa8a159c66b22b98213999ed730905"><td class="memItemLeft" align="right" valign="top">typedef boost::unordered_map<br class="typebreak"/> |
| < std::string, std::string > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a82aa8a159c66b22b98213999ed730905">BackendIpAddressMap</a></td></tr> |
| <tr class="separator:a82aa8a159c66b22b98213999ed730905"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac7fcdd112ce741185e28aa76dd7b467d"><td class="memItemLeft" align="right" valign="top">typedef boost::unordered_map<br class="typebreak"/> |
| < std::string, <br class="typebreak"/> |
| TBackendDescriptor > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ac7fcdd112ce741185e28aa76dd7b467d">BackendIdMap</a></td></tr> |
| <tr class="separator:ac7fcdd112ce741185e28aa76dd7b467d"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a1f69c4ee9b8c81b09f553b46de796cc2"><td class="memItemLeft" align="right" valign="top">typedef boost::unordered_map<br class="typebreak"/> |
| < TUniqueId, Coordinator * > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a1f69c4ee9b8c81b09f553b46de796cc2">ActiveReservationsMap</a></td></tr> |
| <tr class="separator:a1f69c4ee9b8c81b09f553b46de796cc2"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a150aabee5c6931de14a52127224deb0f"><td class="memItemLeft" align="right" valign="top">typedef boost::unordered_map<br class="typebreak"/> |
| < TUniqueId, Coordinator * > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a150aabee5c6931de14a52127224deb0f">ActiveClientResourcesMap</a></td></tr> |
| <tr class="separator:a150aabee5c6931de14a52127224deb0f"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-methods"></a> |
| Private Member Functions</h2></td></tr> |
| <tr class="memitem:aba7e31e7f6562e6cdd6300abb230ce37"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aba7e31e7f6562e6cdd6300abb230ce37">AddToActiveResourceMaps</a> (const TResourceBrokerReservationResponse &reservation, Coordinator *coord)</td></tr> |
| <tr class="separator:aba7e31e7f6562e6cdd6300abb230ce37"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a8b115ad3b1d6fcac2ba328bc78a28212"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a8b115ad3b1d6fcac2ba328bc78a28212">RemoveFromActiveResourceMaps</a> (const TResourceBrokerReservationResponse &reservation)</td></tr> |
| <tr class="separator:a8b115ad3b1d6fcac2ba328bc78a28212"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a3a4ea1a733529d653add9028e77d5733"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a3a4ea1a733529d653add9028e77d5733">UpdateMembership</a> (const <a class="el" href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2">StatestoreSubscriber::TopicDeltaMap</a> &incoming_topic_deltas, std::vector< TTopicDelta > *subscriber_topic_updates)</td></tr> |
| <tr class="memdesc:a3a4ea1a733529d653add9028e77d5733"><td class="mdescLeft"> </td><td class="mdescRight">Called asynchronously when an update is received from the subscription manager. <a href="#a3a4ea1a733529d653add9028e77d5733">More...</a><br/></td></tr> |
| <tr class="separator:a3a4ea1a733529d653add9028e77d5733"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a1c48622eddbb673522662afc19d635ec"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a1c48622eddbb673522662afc19d635ec">BackendsUrlCallback</a> (const <a class="el" href="classimpala_1_1Webserver.html#ac9f7aacffabb53e5c203ea7a3652802b">Webserver::ArgumentMap</a> &args, rapidjson::Document *document)</td></tr> |
| <tr class="separator:a1c48622eddbb673522662afc19d635ec"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a15f1f4850a8895694d0cc9bca4c2f202"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a15f1f4850a8895694d0cc9bca4c2f202">GetRequestPool</a> (const std::string &user, const TQueryOptions &query_options, std::string *<a class="el" href="expr-benchmark_8cc.html#a3a5de7bd423fbc0afc4cf935c166ca6b">pool</a>) const </td></tr> |
| <tr class="memdesc:a15f1f4850a8895694d0cc9bca4c2f202"><td class="mdescLeft"> </td><td class="mdescRight">Determines the pool for a user and query options via request_pool_service_. <a href="#a15f1f4850a8895694d0cc9bca4c2f202">More...</a><br/></td></tr> |
| <tr class="separator:a15f1f4850a8895694d0cc9bca4c2f202"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa4ed69aa39c5671d59c84256045a7890"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aa4ed69aa39c5671d59c84256045a7890">ComputeScanRangeAssignment</a> (const TQueryExecRequest &exec_request, <a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> *schedule)</td></tr> |
| <tr class="separator:aa4ed69aa39c5671d59c84256045a7890"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ace422ff71e55f5a61a6badb57ebbb3c5"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ace422ff71e55f5a61a6badb57ebbb3c5">ComputeScanRangeAssignment</a> (<a class="el" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> node_id, const std::vector< TScanRangeLocations > &locations, const std::vector< TNetworkAddress > &host_list, <a class="el" href="classbool.html">bool</a> exec_at_coord, const TQueryOptions &query_options, <a class="el" href="namespaceimpala.html#a2edfe42681c50f6818d204b8ee2428a5">FragmentScanRangeAssignment</a> *assignment)</td></tr> |
| <tr class="separator:ace422ff71e55f5a61a6badb57ebbb3c5"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ab7c970ef2b534381cabf83d08f8b4d04"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ab7c970ef2b534381cabf83d08f8b4d04">ComputeFragmentExecParams</a> (const TQueryExecRequest &exec_request, <a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> *schedule)</td></tr> |
| <tr class="memdesc:ab7c970ef2b534381cabf83d08f8b4d04"><td class="mdescLeft"> </td><td class="mdescRight">Populates fragment_exec_params_ in schedule. <a href="#ab7c970ef2b534381cabf83d08f8b4d04">More...</a><br/></td></tr> |
| <tr class="separator:ab7c970ef2b534381cabf83d08f8b4d04"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a1513f352f0f1ca2d9c2b3e91b231256e"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a1513f352f0f1ca2d9c2b3e91b231256e">ComputeFragmentHosts</a> (const TQueryExecRequest &exec_request, <a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> *schedule)</td></tr> |
| <tr class="separator:a1513f352f0f1ca2d9c2b3e91b231256e"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a81b69c78a516da26106121b3f1cadd35"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a81b69c78a516da26106121b3f1cadd35">FindLeftmostNode</a> (const TPlan &plan, const std::vector< TPlanNodeType::type > &types)</td></tr> |
| <tr class="separator:a81b69c78a516da26106121b3f1cadd35"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a89a148969321e6d5f7f4095bc4eb5cc1"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a89a148969321e6d5f7f4095bc4eb5cc1">FindLeftmostInputFragment</a> (int fragment_idx, const TQueryExecRequest &exec_request)</td></tr> |
| <tr class="separator:a89a148969321e6d5f7f4095bc4eb5cc1"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aad7d8e866e3512eec1f39cd6f9a132ee"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aad7d8e866e3512eec1f39cd6f9a132ee">GetScanHosts</a> (TPlanNodeId scan_id, const TQueryExecRequest &exec_request, const <a class="el" href="structimpala_1_1FragmentExecParams.html">FragmentExecParams</a> &params, std::vector< TNetworkAddress > *scan_hosts)</td></tr> |
| <tr class="memdesc:aad7d8e866e3512eec1f39cd6f9a132ee"><td class="mdescLeft"> </td><td class="mdescRight">Adds all hosts the given scan is executed on to scan_hosts. <a href="#aad7d8e866e3512eec1f39cd6f9a132ee">More...</a><br/></td></tr> |
| <tr class="separator:aad7d8e866e3512eec1f39cd6f9a132ee"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:adec79920ed8c4a9234a1ec60f0722f5d"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classbool.html">bool</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#adec79920ed8c4a9234a1ec60f0722f5d">ContainsNode</a> (const TPlan &plan, TPlanNodeType::type type)</td></tr> |
| <tr class="memdesc:adec79920ed8c4a9234a1ec60f0722f5d"><td class="mdescLeft"> </td><td class="mdescRight">Returns true if 'plan' contains a node of the given type. <a href="#adec79920ed8c4a9234a1ec60f0722f5d">More...</a><br/></td></tr> |
| <tr class="separator:adec79920ed8c4a9234a1ec60f0722f5d"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:af241e5cc9130e555a2584665110c12e5"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#af241e5cc9130e555a2584665110c12e5">FindNodes</a> (const TPlan &plan, const std::vector< TPlanNodeType::type > &types, std::vector< TPlanNodeId > *results)</td></tr> |
| <tr class="memdesc:af241e5cc9130e555a2584665110c12e5"><td class="mdescLeft"> </td><td class="mdescRight">Returns all ids of nodes in 'plan' of any of the given types. <a href="#af241e5cc9130e555a2584665110c12e5">More...</a><br/></td></tr> |
| <tr class="separator:af241e5cc9130e555a2584665110c12e5"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad825e61bcfb0be1fc5699b8fe3ac123f"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ad825e61bcfb0be1fc5699b8fe3ac123f">FindSenderFragment</a> (TPlanNodeId exch_id, int fragment_idx, const TQueryExecRequest &exec_request)</td></tr> |
| <tr class="separator:ad825e61bcfb0be1fc5699b8fe3ac123f"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-attribs"></a> |
| Private Attributes</h2></td></tr> |
| <tr class="memitem:a801842ac98378f3161712e0290849128"><td class="memItemLeft" align="right" valign="top">boost::mutex </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a801842ac98378f3161712e0290849128">backend_map_lock_</a></td></tr> |
| <tr class="separator:a801842ac98378f3161712e0290849128"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a650bafcf64bc986a066993ca2fb67522"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1SimpleScheduler.html#a5bf9963f01cec937d810092870ad9030">BackendMap</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a650bafcf64bc986a066993ca2fb67522">backend_map_</a></td></tr> |
| <tr class="separator:a650bafcf64bc986a066993ca2fb67522"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a1359b7be3a8373ec5c8db7a447adfb00"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1SimpleScheduler.html#a82aa8a159c66b22b98213999ed730905">BackendIpAddressMap</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a1359b7be3a8373ec5c8db7a447adfb00">backend_ip_map_</a></td></tr> |
| <tr class="separator:a1359b7be3a8373ec5c8db7a447adfb00"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a4628dae65113ff56ff8b4189fb2bd284"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1SimpleScheduler.html#ac7fcdd112ce741185e28aa76dd7b467d">BackendIdMap</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a4628dae65113ff56ff8b4189fb2bd284">current_membership_</a></td></tr> |
| <tr class="separator:a4628dae65113ff56ff8b4189fb2bd284"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:af78d5d6416d93dfe4e80f897d4afecf4"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1MetricGroup.html">MetricGroup</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#af78d5d6416d93dfe4e80f897d4afecf4">metrics_</a></td></tr> |
| <tr class="memdesc:af78d5d6416d93dfe4e80f897d4afecf4"><td class="mdescLeft"> </td><td class="mdescRight"><a class="el" href="classimpala_1_1MetricGroup.html" title="MetricGroups may be organised hierarchically as a tree. ">MetricGroup</a> subsystem access. <a href="#af78d5d6416d93dfe4e80f897d4afecf4">More...</a><br/></td></tr> |
| <tr class="separator:af78d5d6416d93dfe4e80f897d4afecf4"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aed76ff7e1e483696a2068eda5be408cc"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1Webserver.html">Webserver</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aed76ff7e1e483696a2068eda5be408cc">webserver_</a></td></tr> |
| <tr class="memdesc:aed76ff7e1e483696a2068eda5be408cc"><td class="mdescLeft"> </td><td class="mdescRight"><a class="el" href="classimpala_1_1Webserver.html">Webserver</a> for /backends. Not owned by us. <a href="#aed76ff7e1e483696a2068eda5be408cc">More...</a><br/></td></tr> |
| <tr class="separator:aed76ff7e1e483696a2068eda5be408cc"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:adc4454343791f01da344dd9cd487d847"><td class="memItemLeft" align="right" valign="top">BackendMap::iterator </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#adc4454343791f01da344dd9cd487d847">next_nonlocal_backend_entry_</a></td></tr> |
| <tr class="memdesc:adc4454343791f01da344dd9cd487d847"><td class="mdescLeft"> </td><td class="mdescRight">round robin entry in BackendMap for non-local host assignment <a href="#adc4454343791f01da344dd9cd487d847">More...</a><br/></td></tr> |
| <tr class="separator:adc4454343791f01da344dd9cd487d847"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a47a86314b6205d3269c751a7c13658e0"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a47a86314b6205d3269c751a7c13658e0">statestore_subscriber_</a></td></tr> |
| <tr class="separator:a47a86314b6205d3269c751a7c13658e0"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aae42bf07c03c45003b6a525a3bce76b9"><td class="memItemLeft" align="right" valign="top">const std::string </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aae42bf07c03c45003b6a525a3bce76b9">backend_id_</a></td></tr> |
| <tr class="memdesc:aae42bf07c03c45003b6a525a3bce76b9"><td class="mdescLeft"> </td><td class="mdescRight">Unique - across the cluster - identifier for this impala backend. <a href="#aae42bf07c03c45003b6a525a3bce76b9">More...</a><br/></td></tr> |
| <tr class="separator:aae42bf07c03c45003b6a525a3bce76b9"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad05b6f9a673ae1f9cc9f268b207d79ff"><td class="memItemLeft" align="right" valign="top">TBackendDescriptor </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ad05b6f9a673ae1f9cc9f268b207d79ff">backend_descriptor_</a></td></tr> |
| <tr class="memdesc:ad05b6f9a673ae1f9cc9f268b207d79ff"><td class="mdescLeft"> </td><td class="mdescRight">Describes this backend, including the Impalad service address. <a href="#ad05b6f9a673ae1f9cc9f268b207d79ff">More...</a><br/></td></tr> |
| <tr class="separator:ad05b6f9a673ae1f9cc9f268b207d79ff"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aae723291f36a21bfcefff0eb824ceef1"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1ThriftSerializer.html">ThriftSerializer</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aae723291f36a21bfcefff0eb824ceef1">thrift_serializer_</a></td></tr> |
| <tr class="separator:aae723291f36a21bfcefff0eb824ceef1"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:af39936aa927dd2c3f2e35670d31d870e"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespaceimpala.html#ae72a16e1b3afb603ff4b5b4d78f0f0d0">IntCounter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#af39936aa927dd2c3f2e35670d31d870e">total_assignments_</a></td></tr> |
| <tr class="memdesc:af39936aa927dd2c3f2e35670d31d870e"><td class="mdescLeft"> </td><td class="mdescRight">Locality metrics. <a href="#af39936aa927dd2c3f2e35670d31d870e">More...</a><br/></td></tr> |
| <tr class="separator:af39936aa927dd2c3f2e35670d31d870e"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a7c8ab1e4924539437edb477b84bc02f4"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespaceimpala.html#ae72a16e1b3afb603ff4b5b4d78f0f0d0">IntCounter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a7c8ab1e4924539437edb477b84bc02f4">total_local_assignments_</a></td></tr> |
| <tr class="separator:a7c8ab1e4924539437edb477b84bc02f4"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad61ede5a43e08ff1cbb71fc573e44c33"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespaceimpala.html#a67659fb7ecbc7faa1705c0fde687076f">BooleanProperty</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ad61ede5a43e08ff1cbb71fc573e44c33">initialised_</a></td></tr> |
| <tr class="memdesc:ad61ede5a43e08ff1cbb71fc573e44c33"><td class="mdescLeft"> </td><td class="mdescRight">Initialisation metric. <a href="#ad61ede5a43e08ff1cbb71fc573e44c33">More...</a><br/></td></tr> |
| <tr class="separator:ad61ede5a43e08ff1cbb71fc573e44c33"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae1a8521a12f3caf38906b64efca56266"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespaceimpala.html#aa5fe574b057692843a420853cf325bbe">IntGauge</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ae1a8521a12f3caf38906b64efca56266">num_backends_metric_</a></td></tr> |
| <tr class="memdesc:ae1a8521a12f3caf38906b64efca56266"><td class="mdescLeft"> </td><td class="mdescRight">Current number of backends. <a href="#ae1a8521a12f3caf38906b64efca56266">More...</a><br/></td></tr> |
| <tr class="separator:ae1a8521a12f3caf38906b64efca56266"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae52845768c0bd89de0a869507b579763"><td class="memItemLeft" align="right" valign="top">uint32_t </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ae52845768c0bd89de0a869507b579763">update_count_</a></td></tr> |
| <tr class="memdesc:ae52845768c0bd89de0a869507b579763"><td class="mdescLeft"> </td><td class="mdescRight">Counts the number of UpdateMembership invocations, to help throttle the logging. <a href="#ae52845768c0bd89de0a869507b579763">More...</a><br/></td></tr> |
| <tr class="separator:ae52845768c0bd89de0a869507b579763"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad65cd8cb75978202f76fd06b0ad8b168"><td class="memItemLeft" align="right" valign="top">boost::mutex </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ad65cd8cb75978202f76fd06b0ad8b168">active_resources_lock_</a></td></tr> |
| <tr class="memdesc:ad65cd8cb75978202f76fd06b0ad8b168"><td class="mdescLeft"> </td><td class="mdescRight">Protects active_reservations_ and active_client_resources_. <a href="#ad65cd8cb75978202f76fd06b0ad8b168">More...</a><br/></td></tr> |
| <tr class="separator:ad65cd8cb75978202f76fd06b0ad8b168"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa82b81b73e7c72583bdff6ba9790ab61"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1SimpleScheduler.html#a1f69c4ee9b8c81b09f553b46de796cc2">ActiveReservationsMap</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aa82b81b73e7c72583bdff6ba9790ab61">active_reservations_</a></td></tr> |
| <tr class="separator:aa82b81b73e7c72583bdff6ba9790ab61"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa2311e64d7a6f9d247511d6e2a3faf02"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1SimpleScheduler.html#a150aabee5c6931de14a52127224deb0f">ActiveClientResourcesMap</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#aa2311e64d7a6f9d247511d6e2a3faf02">active_client_resources_</a></td></tr> |
| <tr class="separator:aa2311e64d7a6f9d247511d6e2a3faf02"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac3aa2991338bf59634df5fd1c45db7f7"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1ResourceBroker.html">ResourceBroker</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#ac3aa2991338bf59634df5fd1c45db7f7">resource_broker_</a></td></tr> |
| <tr class="separator:ac3aa2991338bf59634df5fd1c45db7f7"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a0eced35ab0140f2021bac4e2c8a4ac69"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RequestPoolService.html">RequestPoolService</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a0eced35ab0140f2021bac4e2c8a4ac69">request_pool_service_</a></td></tr> |
| <tr class="separator:a0eced35ab0140f2021bac4e2c8a4ac69"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a4646458932199c87fc290639469e54bb"><td class="memItemLeft" align="right" valign="top">boost::scoped_ptr<br class="typebreak"/> |
| < <a class="el" href="classimpala_1_1AdmissionController.html">AdmissionController</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1SimpleScheduler.html#a4646458932199c87fc290639469e54bb">admission_controller_</a></td></tr> |
| <tr class="memdesc:a4646458932199c87fc290639469e54bb"><td class="mdescLeft"> </td><td class="mdescRight">Used to make admission decisions in '<a class="el" href="classimpala_1_1SimpleScheduler.html#ab1bd929a9f3e8e9240676f83c9b67f41">Schedule()</a>'. <a href="#a4646458932199c87fc290639469e54bb">More...</a><br/></td></tr> |
| <tr class="separator:a4646458932199c87fc290639469e54bb"><td class="memSeparator" colspan="2"> </td></tr> |
| </table> |
| <a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2> |
| <div class="textblock"><p>Performs simple scheduling by matching between a list of backends configured either from the statestore, or from a static list of addresses, and a list of target data locations. TODO: Notice when there are duplicate statestore registrations (IMPALA-23) TODO: Handle deltas from the statestore </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00046">46</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| </div><h2 class="groupheader">Member Typedef Documentation</h2> |
| <a class="anchor" id="a150aabee5c6931de14a52127224deb0f"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">typedef boost::unordered_map<TUniqueId, Coordinator*> <a class="el" href="classimpala_1_1SimpleScheduler.html#a150aabee5c6931de14a52127224deb0f">impala::SimpleScheduler::ActiveClientResourcesMap</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Maps from client resource id to the coordinator of the query using that resource. The map is used to cancel queries whose resource(s) have been preempted. Entries are added in <a class="el" href="classimpala_1_1SimpleScheduler.html#ab1bd929a9f3e8e9240676f83c9b67f41">Schedule()</a> calls that result in granted resource allocations. Entries are removed in <a class="el" href="classimpala_1_1SimpleScheduler.html#a6f404a00140d7b7d8e98e8fccffa4f24" title="Releases the reserved resources (if any) from the given schedule. ">Release()</a>. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00167">167</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a1f69c4ee9b8c81b09f553b46de796cc2"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">typedef boost::unordered_map<TUniqueId, Coordinator*> <a class="el" href="classimpala_1_1SimpleScheduler.html#a1f69c4ee9b8c81b09f553b46de796cc2">impala::SimpleScheduler::ActiveReservationsMap</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Maps from a Llama reservation id to the coordinator of the query using that reservation. The map is used to cancel queries whose reservation has been preempted. Entries are added in <a class="el" href="classimpala_1_1SimpleScheduler.html#ab1bd929a9f3e8e9240676f83c9b67f41">Schedule()</a> calls that result in granted resource allocations. Entries are removed in <a class="el" href="classimpala_1_1SimpleScheduler.html#a6f404a00140d7b7d8e98e8fccffa4f24" title="Releases the reserved resources (if any) from the given schedule. ">Release()</a>. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00160">160</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ac7fcdd112ce741185e28aa76dd7b467d"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">typedef boost::unordered_map<std::string, TBackendDescriptor> <a class="el" href="classimpala_1_1SimpleScheduler.html#ac7fcdd112ce741185e28aa76dd7b467d">impala::SimpleScheduler::BackendIdMap</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Map from unique backend id to TBackendDescriptor. Used to track the known backends from the statestore. It's important to track both the backend ID as well as the TBackendDescriptor so we know what is being removed in a given update. Locking of this map is not needed since it should only be read/modified from within the <a class="el" href="classimpala_1_1SimpleScheduler.html#a3a4ea1a733529d653add9028e77d5733" title="Called asynchronously when an update is received from the subscription manager. ">UpdateMembership()</a> function. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00116">116</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a82aa8a159c66b22b98213999ed730905"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">typedef boost::unordered_map<std::string, std::string> <a class="el" href="classimpala_1_1SimpleScheduler.html#a82aa8a159c66b22b98213999ed730905">impala::SimpleScheduler::BackendIpAddressMap</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Map from a datanode's hostname to its IP address to support both hostname based lookup. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00108">108</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="af188a31a06554682f7f200dd690286a9"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">typedef std::vector<TBackendDescriptor> <a class="el" href="classimpala_1_1Scheduler.html#af188a31a06554682f7f200dd690286a9">impala::Scheduler::BackendList</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">inherited</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>List of server descriptors. </p> |
| |
| <p>Definition at line <a class="el" href="scheduler_8h_source.html#l00045">45</a> of file <a class="el" href="scheduler_8h_source.html">scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a5bf9963f01cec937d810092870ad9030"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">typedef boost::unordered_map<std::string, std::list<TBackendDescriptor> > <a class="el" href="classimpala_1_1SimpleScheduler.html#a5bf9963f01cec937d810092870ad9030">impala::SimpleScheduler::BackendMap</a></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Map from a datanode's IP address to a list of backend addresses running on that node. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00103">103</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Constructor & Destructor Documentation</h2> |
| <a class="anchor" id="add689ee214d3916983359970d10e458c"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">impala::SimpleScheduler::SimpleScheduler </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a> * </td> |
| <td class="paramname"><em>subscriber</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>backend_id</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TNetworkAddress & </td> |
| <td class="paramname"><em>backend_address</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1MetricGroup.html">MetricGroup</a> * </td> |
| <td class="paramname"><em>metrics</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1Webserver.html">Webserver</a> * </td> |
| <td class="paramname"><em>webserver</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1ResourceBroker.html">ResourceBroker</a> * </td> |
| <td class="paramname"><em>resource_broker</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RequestPoolService.html">RequestPoolService</a> * </td> |
| <td class="paramname"><em>request_pool_service</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Initialize with a subscription manager that we can register with for updates to the set of available backends.</p> |
| <ul> |
| <li>backend_id - unique identifier for this Impala backend (usually a host:port)</li> |
| <li>backend_address - the address that this backend listens on </li> |
| </ul> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ae97b1713444b66320b1adb8d810099b9"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">impala::SimpleScheduler::SimpleScheduler </td> |
| <td>(</td> |
| <td class="paramtype">const std::vector< TNetworkAddress > & </td> |
| <td class="paramname"><em>backends</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1MetricGroup.html">MetricGroup</a> * </td> |
| <td class="paramname"><em>metrics</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1Webserver.html">Webserver</a> * </td> |
| <td class="paramname"><em>webserver</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1ResourceBroker.html">ResourceBroker</a> * </td> |
| <td class="paramname"><em>resource_broker</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RequestPoolService.html">RequestPoolService</a> * </td> |
| <td class="paramname"><em>request_pool_service</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Initialize with a list of <host:port> pairs in 'static' mode - i.e. the set of backends is fixed and will not be updated. </p> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Member Function Documentation</h2> |
| <a class="anchor" id="aba7e31e7f6562e6cdd6300abb230ce37"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::AddToActiveResourceMaps </td> |
| <td>(</td> |
| <td class="paramtype">const TResourceBrokerReservationResponse & </td> |
| <td class="paramname"><em>reservation</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">Coordinator * </td> |
| <td class="paramname"><em>coord</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Adds the granted reservation and resources to the active_reservations_ and active_client_resources_ maps, respectively. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00916">916</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a1c48622eddbb673522662afc19d635ec"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::BackendsUrlCallback </td> |
| <td>(</td> |
| <td class="paramtype">const <a class="el" href="classimpala_1_1Webserver.html#ac9f7aacffabb53e5c203ea7a3652802b">Webserver::ArgumentMap</a> & </td> |
| <td class="paramname"><em>args</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">rapidjson::Document * </td> |
| <td class="paramname"><em>document</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p><a class="el" href="classimpala_1_1Webserver.html">Webserver</a> callback that produces a list of known backends. Example output: "backends": [ "henry-metrics-pkg-cdh5.ent.cloudera.com:22000" ], </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00252">252</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="name-resolution-benchmark_8cc_source.html#l00042">backends</a>, and <a class="el" href="network-util_8cc_source.html#l00126">impala::TNetworkAddressToString()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ab7c970ef2b534381cabf83d08f8b4d04"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::ComputeFragmentExecParams </td> |
| <td>(</td> |
| <td class="paramtype">const TQueryExecRequest & </td> |
| <td class="paramname"><em>exec_request</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> * </td> |
| <td class="paramname"><em>schedule</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Populates fragment_exec_params_ in schedule. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00599">599</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="query-schedule_8h_source.html#l00050">impala::FragmentExecParams::destinations</a>, <a class="el" href="query-schedule_8h_source.html#l00110">impala::QuerySchedule::exec_params()</a>, <a class="el" href="query-schedule_8h_source.html#l00048">impala::FragmentExecParams::hosts</a>, <a class="el" href="query-schedule_8h_source.html#l00049">impala::FragmentExecParams::instance_ids</a>, <a class="el" href="query-schedule_8h_source.html#l00077">impala::QuerySchedule::query_id()</a>, <a class="el" href="query-schedule_8h_source.html#l00057">impala::FragmentExecParams::sender_id_base</a>, <a class="el" href="query-schedule_8h_source.html#l00101">impala::QuerySchedule::set_num_backends()</a>, and <a class="el" href="logging_8h_source.html#l00056">VLOG_RPC</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a1513f352f0f1ca2d9c2b3e91b231256e"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::ComputeFragmentHosts </td> |
| <td>(</td> |
| <td class="paramtype">const TQueryExecRequest & </td> |
| <td class="paramname"><em>exec_request</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> * </td> |
| <td class="paramname"><em>schedule</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>For each fragment in exec_request, computes hosts on which to run the instances and stores result in fragment_exec_params_.hosts. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00658">658</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="query-schedule_8h_source.html#l00110">impala::QuerySchedule::exec_params()</a>, <a class="el" href="query-schedule_8h_source.html#l00048">impala::FragmentExecParams::hosts</a>, <a class="el" href="network-util_8cc_source.html#l00096">impala::MakeNetworkAddress()</a>, and <a class="el" href="query-schedule_8cc_source.html#l00159">impala::QuerySchedule::SetUniqueHosts()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aa4ed69aa39c5671d59c84256045a7890"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::ComputeScanRangeAssignment </td> |
| <td>(</td> |
| <td class="paramtype">const TQueryExecRequest & </td> |
| <td class="paramname"><em>exec_request</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> * </td> |
| <td class="paramname"><em>schedule</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Computes the assignment of scan ranges to hosts for each scan node in schedule. Unpartitioned fragments are assigned to the coord. Populates the schedule's fragment_exec_params_ with the resulting scan range assignment. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00438">438</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="query-schedule_8h_source.html#l00100">impala::QuerySchedule::AddScanRanges()</a>, <a class="el" href="query-schedule_8h_source.html#l00110">impala::QuerySchedule::exec_params()</a>, <a class="el" href="query-schedule_8h_source.html#l00109">impala::QuerySchedule::GetFragmentIdx()</a>, <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>, <a class="el" href="query-schedule_8h_source.html#l00079">impala::QuerySchedule::query_options()</a>, and <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ace422ff71e55f5a61a6badb57ebbb3c5"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::ComputeScanRangeAssignment </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> </td> |
| <td class="paramname"><em>node_id</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::vector< TScanRangeLocations > & </td> |
| <td class="paramname"><em>locations</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::vector< TNetworkAddress > & </td> |
| <td class="paramname"><em>host_list</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classbool.html">bool</a> </td> |
| <td class="paramname"><em>exec_at_coord</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TQueryOptions & </td> |
| <td class="paramname"><em>query_options</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="namespaceimpala.html#a2edfe42681c50f6818d204b8ee2428a5">FragmentScanRangeAssignment</a> * </td> |
| <td class="paramname"><em>assignment</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Does a scan range assignment (returned in 'assignment') based on a list of scan range locations for a particular scan node. If exec_at_coord is true, all scan ranges will be assigned to the coord node. </p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="adec79920ed8c4a9234a1ec60f0722f5d"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classbool.html">bool</a> impala::SimpleScheduler::ContainsNode </td> |
| <td>(</td> |
| <td class="paramtype">const TPlan & </td> |
| <td class="paramname"><em>plan</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">TPlanNodeType::type </td> |
| <td class="paramname"><em>type</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Returns true if 'plan' contains a node of the given type. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00758">758</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a89a148969321e6d5f7f4095bc4eb5cc1"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">int impala::SimpleScheduler::FindLeftmostInputFragment </td> |
| <td>(</td> |
| <td class="paramtype">int </td> |
| <td class="paramname"><em>fragment_idx</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TQueryExecRequest & </td> |
| <td class="paramname"><em>exec_request</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Returns the index (w/in exec_request.fragments) of fragment that sends its output to exec_request.fragment[fragment_idx]'s leftmost <a class="el" href="classimpala_1_1ExchangeNode.html">ExchangeNode</a>. Returns INVALID_PLAN_NODE_ID if the leftmost node is not an exchange node. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00798">798</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a81b69c78a516da26106121b3f1cadd35"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> impala::SimpleScheduler::FindLeftmostNode </td> |
| <td>(</td> |
| <td class="paramtype">const TPlan & </td> |
| <td class="paramname"><em>plan</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::vector< TPlanNodeType::type > & </td> |
| <td class="paramname"><em>types</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Returns the id of the leftmost node of any of the given types in 'plan', or INVALID_PLAN_NODE_ID if no such node present. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00740">740</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="af241e5cc9130e555a2584665110c12e5"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::FindNodes </td> |
| <td>(</td> |
| <td class="paramtype">const TPlan & </td> |
| <td class="paramname"><em>plan</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::vector< TPlanNodeType::type > & </td> |
| <td class="paramname"><em>types</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">std::vector< TPlanNodeId > * </td> |
| <td class="paramname"><em>results</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Returns all ids of nodes in 'plan' of any of the given types. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00765">765</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ad825e61bcfb0be1fc5699b8fe3ac123f"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">int impala::SimpleScheduler::FindSenderFragment </td> |
| <td>(</td> |
| <td class="paramtype">TPlanNodeId </td> |
| <td class="paramname"><em>exch_id</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">int </td> |
| <td class="paramname"><em>fragment_idx</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TQueryExecRequest & </td> |
| <td class="paramname"><em>exec_request</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Returns the index (w/in exec_request.fragments) of fragment that sends its output to the given exchange in the given fragment index. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00812">812</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a4f8b0499b4fc2dfeb38ba7d24e9dc31c"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::GetAllKnownBackends </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1Scheduler.html#af188a31a06554682f7f200dd690286a9">BackendList</a> * </td> |
| <td class="paramname"><em>backends</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Return a list of all backends known to the scheduler. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#ab0e4737db96c239e1ca809b1c560f456">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00429">429</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a53cd14fef292f7e5cbf8667c346ff3a1"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::GetBackend </td> |
| <td>(</td> |
| <td class="paramtype">const TNetworkAddress & </td> |
| <td class="paramname"><em>data_location</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">TBackendDescriptor * </td> |
| <td class="paramname"><em>backend</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Return a backend such that the impalad at backend.address should be used to read data from the given data_loation </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a201e8832773a12be2c9bf40c41482b78">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00376">376</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>, <a class="el" href="logging_8h_source.html#l00058">VLOG_FILE</a>, and <a class="el" href="logging_8h_source.html#l00065">VLOG_FILE_IS_ON</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aa2d3bf1ee9968d9393fb43acc424b78a"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::GetBackends </td> |
| <td>(</td> |
| <td class="paramtype">const std::vector< TNetworkAddress > & </td> |
| <td class="paramname"><em>data_locations</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1Scheduler.html#af188a31a06554682f7f200dd690286a9">BackendList</a> * </td> |
| <td class="paramname"><em>backends</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Returns a list of backends such that the impalad at backends[i] should be used to read data from data_locations[i]. For each data_location, we choose a backend whose host matches the data_location in a round robin fashion and insert it into backends. If no match is found for a data location, assign the data location in round-robin order to any of the backends. If the set of available backends is updated between calls, round-robin state is reset. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a2fa8dc5bc1bffbd2a47c3618928a5fa0">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00364">364</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a15f1f4850a8895694d0cc9bca4c2f202"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::GetRequestPool </td> |
| <td>(</td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>user</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TQueryOptions & </td> |
| <td class="paramname"><em>query_options</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">std::string * </td> |
| <td class="paramname"><em>pool</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td> const</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Determines the pool for a user and query options via request_pool_service_. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00826">826</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="namespaceimpala.html#a7d80d03fe190b3f4ff06c3b2d78286bc">impala::ERROR_USER_NOT_ALLOWED_IN_POOL()</a>, <a class="el" href="namespaceimpala.html#a1abfca2efe10c78cb9650f330d4d04d5">impala::ERROR_USER_TO_POOL_MAPPING_NOT_FOUND()</a>, <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>, and <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aad7d8e866e3512eec1f39cd6f9a132ee"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::GetScanHosts </td> |
| <td>(</td> |
| <td class="paramtype">TPlanNodeId </td> |
| <td class="paramname"><em>scan_id</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TQueryExecRequest & </td> |
| <td class="paramname"><em>exec_request</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="structimpala_1_1FragmentExecParams.html">FragmentExecParams</a> & </td> |
| <td class="paramname"><em>params</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">std::vector< TNetworkAddress > * </td> |
| <td class="paramname"><em>scan_hosts</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Adds all hosts the given scan is executed on to scan_hosts. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00777">777</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="network-util_8cc_source.html#l00096">impala::MakeNetworkAddress()</a>, and <a class="el" href="query-schedule_8h_source.html#l00052">impala::FragmentExecParams::scan_range_assignment</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ae1239ce6fe1935b4d43ece10d0bc479e"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::HandleLostResource </td> |
| <td>(</td> |
| <td class="paramtype">const TUniqueId & </td> |
| <td class="paramname"><em>client_resource_id</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Notifies this scheduler that a single resource with the given client resource id has been lost by the central scheduler (Yarn via Llama). All affected queries are cancelled via their coordinator. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a14883df19362db12bd8b4238e5ca7b92">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00981">981</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a4b32b715b806350d406a382762b84d93"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::HandlePreemptedReservation </td> |
| <td>(</td> |
| <td class="paramtype">const TUniqueId & </td> |
| <td class="paramname"><em>reservation_id</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Notifies this scheduler that a resource reservation has been preempted by the central scheduler (Yarn via Llama). All affected queries are cancelled via their coordinator. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#aefd4dc897813e36fafe31dbcd8e1cd00">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00944">944</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ac16a1d19a4be2f2c219a0061ea351be4"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::HandlePreemptedResource </td> |
| <td>(</td> |
| <td class="paramtype">const TUniqueId & </td> |
| <td class="paramname"><em>client_resource_id</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Notifies this scheduler that a single resource with the given client resource id has been preempted by the central scheduler (Yarn via Llama). All affected queries are cancelled via their coordinator. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a1806571a367d4bac0c302aeb12d98e64">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00962">962</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aecd9fa6688740dbb1c64274cb4a08da8"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">virtual <a class="el" href="classbool.html">bool</a> impala::SimpleScheduler::HasLocalBackend </td> |
| <td>(</td> |
| <td class="paramtype">const TNetworkAddress & </td> |
| <td class="paramname"><em>data_location</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">inline</span><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Return true if there is a backend located on the given data_location. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a63e9e16cd4045e4a06e7d36537f937f0">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00081">81</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| <p>References <a class="el" href="simple-scheduler_8h_source.html#l00104">backend_map_</a>, and <a class="el" href="simple-scheduler_8h_source.html#l00100">backend_map_lock_</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a0c607cfb2bad2be3c2c981e1e1ab605b"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::Init </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Registers with the subscription manager if required. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a4cfc2b8bc689d862027a3813ce23b520">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00181">181</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="status_8cc_source.html#l00166">impala::Status::AddDetail()</a>, <a class="el" href="namespaceimpala.html#a35926e1c40cc378432306362a77d7e27">impala::ASSIGNMENTS_KEY()</a>, <a class="el" href="simple-scheduler_8cc_source.html#l00075">impala::BACKENDS_TEMPLATE</a>, <a class="el" href="simple-scheduler_8cc_source.html#l00074">impala::BACKENDS_WEB_PAGE</a>, <a class="el" href="network-util_8cc_source.html#l00085">impala::FindFirstNonLocalhost()</a>, <a class="el" href="status_8cc_source.html#l00184">impala::Status::GetDetail()</a>, <a class="el" href="network-util_8cc_source.html#l00053">impala::HostnameToIpAddrs()</a>, <a class="el" href="network-util_8cc_source.html#l00122">impala::IsWildcardAddress()</a>, <a class="el" href="namespaceimpala.html#ace1fe270397d988634136ee9ebbb022f">impala::LOCAL_ASSIGNMENTS_KEY()</a>, <a class="el" href="network-util_8cc_source.html#l00096">impala::MakeNetworkAddress()</a>, <a class="el" href="namespaceimpala.html#ad183f8d55e86753040688ee3144de8ec">impala::NUM_BACKENDS_KEY()</a>, <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>, <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>, <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>, and <a class="el" href="namespaceimpala.html#ae2b4c34a6aaadc1c266d0c58e6d87db8">impala::SCHEDULER_INIT_KEY()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a6f404a00140d7b7d8e98e8fccffa4f24"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::Release </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> * </td> |
| <td class="paramname"><em>schedule</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Releases the reserved resources (if any) from the given schedule. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a4822a4f36fc867e0fe94a550135e9eb5">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00896">896</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="query-schedule_8h_source.html#l00087">impala::QuerySchedule::NeedsRelease()</a>, <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>, <a class="el" href="query-schedule_8h_source.html#l00114">impala::QuerySchedule::reservation()</a>, and <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a8b115ad3b1d6fcac2ba328bc78a28212"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::RemoveFromActiveResourceMaps </td> |
| <td>(</td> |
| <td class="paramtype">const TResourceBrokerReservationResponse & </td> |
| <td class="paramname"><em>reservation</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Removes the given reservation and resources from the active_reservations_ and active_client_resources_ maps, respectively. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00930">930</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ab1bd929a9f3e8e9240676f83c9b67f41"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::SimpleScheduler::Schedule </td> |
| <td>(</td> |
| <td class="paramtype">Coordinator * </td> |
| <td class="paramname"><em>coord</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1QuerySchedule.html">QuerySchedule</a> * </td> |
| <td class="paramname"><em>schedule</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Populates given query schedule whose execution is to be coordinated by coord. Assigns fragments to hosts based on scan ranges in the query exec request. If resource management is enabled, also reserves resources from the central resource manager (Yarn via Llama) to run the query in. This function blocks until the reservation request has been granted or denied. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1Scheduler.html#a6a97868f104701ef3a652c522b1d39bc">impala::Scheduler</a>.</p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00847">847</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="status_8cc_source.html#l00166">impala::Status::AddDetail()</a>, <a class="el" href="namespaceimpala.html#a45831d3c44db75fc59e4a50eafc61683">impala::DEFAULT_USER()</a>, <a class="el" href="query-schedule_8h_source.html#l00080">impala::QuerySchedule::effective_user()</a>, <a class="el" href="namespaceimpala.html#a32c38de863348fd506941a299fe407be">impala::ERROR_USER_NOT_SPECIFIED()</a>, <a class="el" href="error-util_8cc_source.html#l00040">impala::GetTablesMissingStatsWarning()</a>, <a class="el" href="webserver_8cc_source.html#l00115">impala::OK</a>, <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>, <a class="el" href="expr-benchmark_8cc_source.html#l00089">pool</a>, <a class="el" href="query-schedule_8cc_source.html#l00164">impala::QuerySchedule::PrepareReservationRequest()</a>, <a class="el" href="query-schedule_8h_source.html#l00079">impala::QuerySchedule::query_options()</a>, <a class="el" href="query-schedule_8h_source.html#l00078">impala::QuerySchedule::request()</a>, <a class="el" href="query-schedule_8h_source.html#l00114">impala::QuerySchedule::reservation()</a>, <a class="el" href="query-schedule_8h_source.html#l00115">impala::QuerySchedule::reservation_request()</a>, <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>, <a class="el" href="query-schedule_8h_source.html#l00102">impala::QuerySchedule::set_num_hosts()</a>, <a class="el" href="query-schedule_8h_source.html#l00082">impala::QuerySchedule::set_request_pool()</a>, and <a class="el" href="query-schedule_8cc_source.html#l00214">impala::QuerySchedule::ValidateReservation()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a3a4ea1a733529d653add9028e77d5733"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::SimpleScheduler::UpdateMembership </td> |
| <td>(</td> |
| <td class="paramtype">const <a class="el" href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2">StatestoreSubscriber::TopicDeltaMap</a> & </td> |
| <td class="paramname"><em>incoming_topic_deltas</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">std::vector< TTopicDelta > * </td> |
| <td class="paramname"><em>subscriber_topic_updates</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Called asynchronously when an update is received from the subscription manager. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8cc_source.html#l00265">265</a> of file <a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a>.</p> |
| |
| <p>References <a class="el" href="parquet-reader_8cc_source.html#l00066">DeserializeThriftMsg()</a>, <a class="el" href="status_8cc_source.html#l00184">impala::Status::GetDetail()</a>, and <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>.</p> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Member Data Documentation</h2> |
| <a class="anchor" id="aa2311e64d7a6f9d247511d6e2a3faf02"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1SimpleScheduler.html#a150aabee5c6931de14a52127224deb0f">ActiveClientResourcesMap</a> impala::SimpleScheduler::active_client_resources_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00168">168</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aa82b81b73e7c72583bdff6ba9790ab61"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1SimpleScheduler.html#a1f69c4ee9b8c81b09f553b46de796cc2">ActiveReservationsMap</a> impala::SimpleScheduler::active_reservations_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00161">161</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ad65cd8cb75978202f76fd06b0ad8b168"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">boost::mutex impala::SimpleScheduler::active_resources_lock_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Protects active_reservations_ and active_client_resources_. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00154">154</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a4646458932199c87fc290639469e54bb"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">boost::scoped_ptr<<a class="el" href="classimpala_1_1AdmissionController.html">AdmissionController</a>> impala::SimpleScheduler::admission_controller_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Used to make admission decisions in '<a class="el" href="classimpala_1_1SimpleScheduler.html#ab1bd929a9f3e8e9240676f83c9b67f41">Schedule()</a>'. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00179">179</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ad05b6f9a673ae1f9cc9f268b207d79ff"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">TBackendDescriptor impala::SimpleScheduler::backend_descriptor_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Describes this backend, including the Impalad service address. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00137">137</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aae42bf07c03c45003b6a525a3bce76b9"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">const std::string impala::SimpleScheduler::backend_id_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Unique - across the cluster - identifier for this impala backend. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00134">134</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a1359b7be3a8373ec5c8db7a447adfb00"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1SimpleScheduler.html#a82aa8a159c66b22b98213999ed730905">BackendIpAddressMap</a> impala::SimpleScheduler::backend_ip_map_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00109">109</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a650bafcf64bc986a066993ca2fb67522"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1SimpleScheduler.html#a5bf9963f01cec937d810092870ad9030">BackendMap</a> impala::SimpleScheduler::backend_map_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00104">104</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="simple-scheduler_8h_source.html#l00081">HasLocalBackend()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a801842ac98378f3161712e0290849128"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">boost::mutex impala::SimpleScheduler::backend_map_lock_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Protects access to backend_map_ and backend_ip_map_, which might otherwise be updated asynchronously with respect to reads. Also protects the locality counters, which are updated in GetBackends. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00100">100</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="simple-scheduler_8h_source.html#l00081">HasLocalBackend()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a4628dae65113ff56ff8b4189fb2bd284"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1SimpleScheduler.html#ac7fcdd112ce741185e28aa76dd7b467d">BackendIdMap</a> impala::SimpleScheduler::current_membership_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00117">117</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a67cb9cfbd5fd7a18eb7533f1a226081a"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">const string impala::SimpleScheduler::IMPALA_MEMBERSHIP_TOPIC</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">static</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00048">48</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="impala-server_8cc_source.html#l00226">impala::ImpalaServer::ImpalaServer()</a>, and <a class="el" href="impala-server_8cc_source.html#l01317">impala::ImpalaServer::MembershipCallback()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ad61ede5a43e08ff1cbb71fc573e44c33"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespaceimpala.html#a67659fb7ecbc7faa1705c0fde687076f">BooleanProperty</a>* impala::SimpleScheduler::initialised_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Initialisation metric. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00146">146</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="af78d5d6416d93dfe4e80f897d4afecf4"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1MetricGroup.html">MetricGroup</a>* impala::SimpleScheduler::metrics_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p><a class="el" href="classimpala_1_1MetricGroup.html" title="MetricGroups may be organised hierarchically as a tree. ">MetricGroup</a> subsystem access. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00120">120</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="adc4454343791f01da344dd9cd487d847"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">BackendMap::iterator impala::SimpleScheduler::next_nonlocal_backend_entry_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>round robin entry in BackendMap for non-local host assignment </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00126">126</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ae1a8521a12f3caf38906b64efca56266"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespaceimpala.html#aa5fe574b057692843a420853cf325bbe">IntGauge</a>* impala::SimpleScheduler::num_backends_metric_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Current number of backends. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00148">148</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a0eced35ab0140f2021bac4e2c8a4ac69"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RequestPoolService.html">RequestPoolService</a>* impala::SimpleScheduler::request_pool_service_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Used for user-to-pool resolution and looking up pool configurations. Not owned by us. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00176">176</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ac3aa2991338bf59634df5fd1c45db7f7"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1ResourceBroker.html">ResourceBroker</a>* impala::SimpleScheduler::resource_broker_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Resource broker that mediates resource requests between Impala and the Llama. Set to NULL if resource management is disabled. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00172">172</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a47a86314b6205d3269c751a7c13658e0"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a>* impala::SimpleScheduler::statestore_subscriber_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Pointer to a subscription manager (which we do not own) which is used to register for dynamic updates to the set of available backends. May be NULL if the set of backends is fixed. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00131">131</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aae723291f36a21bfcefff0eb824ceef1"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1ThriftSerializer.html">ThriftSerializer</a> impala::SimpleScheduler::thrift_serializer_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00139">139</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="af39936aa927dd2c3f2e35670d31d870e"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespaceimpala.html#ae72a16e1b3afb603ff4b5b4d78f0f0d0">IntCounter</a>* impala::SimpleScheduler::total_assignments_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Locality metrics. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00142">142</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a7c8ab1e4924539437edb477b84bc02f4"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespaceimpala.html#ae72a16e1b3afb603ff4b5b4d78f0f0d0">IntCounter</a>* impala::SimpleScheduler::total_local_assignments_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00143">143</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ae52845768c0bd89de0a869507b579763"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">uint32_t impala::SimpleScheduler::update_count_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Counts the number of UpdateMembership invocations, to help throttle the logging. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00151">151</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aed76ff7e1e483696a2068eda5be408cc"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Webserver.html">Webserver</a>* impala::SimpleScheduler::webserver_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p><a class="el" href="classimpala_1_1Webserver.html">Webserver</a> for /backends. Not owned by us. </p> |
| |
| <p>Definition at line <a class="el" href="simple-scheduler_8h_source.html#l00123">123</a> of file <a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a>.</p> |
| |
| </div> |
| </div> |
| <hr/>The documentation for this class was generated from the following files:<ul> |
| <li>be/src/statestore/<a class="el" href="simple-scheduler_8h_source.html">simple-scheduler.h</a></li> |
| <li>be/src/statestore/<a class="el" href="simple-scheduler_8cc_source.html">simple-scheduler.cc</a></li> |
| </ul> |
| </div><!-- contents --> |
| </div><!-- doc-content --> |
| <!-- start footer part --> |
| <div id="nav-path" class="navpath"><!-- id is needed for treeview function! --> |
| <ul> |
| <li class="navelem"><a class="el" href="namespaceimpala.html">impala</a></li><li class="navelem"><a class="el" href="classimpala_1_1SimpleScheduler.html">SimpleScheduler</a></li> |
| <li class="footer">Generated on Thu May 7 2015 16:10:50 for Impala by |
| <a href="http://www.doxygen.org/index.html"> |
| <img class="footer" src="doxygen.png" alt="doxygen"/></a> 1.8.6 </li> |
| </ul> |
| </div> |
| </body> |
| </html> |
