| <!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: be/src/statestore/statestore-subscriber.h Source File</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><a href="annotated.html"><span>Classes</span></a></li> |
| <li class="current"><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="files.html"><span>File List</span></a></li> |
| <li><a href="globals.html"><span>File 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('statestore-subscriber_8h_source.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="headertitle"> |
| <div class="title">statestore-subscriber.h</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="statestore-subscriber_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">// Copyright 2012 Cloudera Inc.</span></div> |
| <div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// Licensed under the Apache License, Version 2.0 (the "License");</span></div> |
| <div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">// you may not use this file except in compliance with the License.</span></div> |
| <div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// You may obtain a copy of the License at</span></div> |
| <div class="line"><a name="l00006"></a><span class="lineno"> 6</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div> |
| <div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// Unless required by applicable law or agreed to in writing, software</span></div> |
| <div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">// distributed under the License is distributed on an "AS IS" BASIS,</span></div> |
| <div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span></div> |
| <div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// See the License for the specific language governing permissions and</span></div> |
| <div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// limitations under the License.</span></div> |
| <div class="line"><a name="l00014"></a><span class="lineno"> 14</span> </div> |
| <div class="line"><a name="l00015"></a><span class="lineno"> 15</span> </div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="preprocessor">#ifndef STATESTORE_STATESTORE_SUBSCRIBER_H</span></div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="preprocessor"></span><span class="preprocessor">#define STATESTORE_STATESTORE_SUBSCRIBER_H</span></div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor"></span></div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#include <string></span></div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include <boost/scoped_ptr.hpp></span></div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <boost/shared_ptr.hpp></span></div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> <span class="preprocessor">#include <boost/thread/mutex.hpp></span></div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include <boost/thread/thread.hpp></span></div> |
| <div class="line"><a name="l00025"></a><span class="lineno"> 25</span> </div> |
| <div class="line"><a name="l00026"></a><span class="lineno"> 26</span> <span class="preprocessor">#include "<a class="code" href="statestore_8h.html">statestore/statestore.h</a>"</span></div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include "<a class="code" href="stopwatch_8h.html">util/stopwatch.h</a>"</span></div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="preprocessor">#include "<a class="code" href="thrift-util_8h.html">rpc/thrift-util.h</a>"</span></div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "<a class="code" href="thrift-client_8h.html">rpc/thrift-client.h</a>"</span></div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="thread_8h.html">util/thread.h</a>"</span></div> |
| <div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include "<a class="code" href="metrics_8h.html">util/metrics.h</a>"</span></div> |
| <div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "gen-cpp/StatestoreService.h"</span></div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="preprocessor">#include "gen-cpp/StatestoreSubscriber.h"</span></div> |
| <div class="line"><a name="l00034"></a><span class="lineno"> 34</span> </div> |
| <div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00036"></a><span class="lineno"> 36</span> </div> |
| <div class="line"><a name="l00037"></a><span class="lineno"> 37</span> <span class="keyword">class </span>TimeoutFailureDetector;</div> |
| <div class="line"><a name="l00038"></a><span class="lineno"> 38</span> <span class="keyword">class </span>Status;</div> |
| <div class="line"><a name="l00039"></a><span class="lineno"> 39</span> <span class="keyword">class </span>TNetworkAddress;</div> |
| <div class="line"><a name="l00040"></a><span class="lineno"><a class="line" href="namespaceimpala.html#ac468011cd4f6868b9b7e1f2acb56c94e"> 40</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1ThriftServer.html">ThriftServer</a>;</div> |
| <div class="line"><a name="l00041"></a><span class="lineno"> 41</span> </div> |
| <div class="line"><a name="l00042"></a><span class="lineno"> 42</span> <span class="keyword">typedef</span> <a class="code" href="classimpala_1_1ClientCache.html">ClientCache<StatestoreServiceClient></a> <a class="code" href="namespaceimpala.html#ac468011cd4f6868b9b7e1f2acb56c94e">StatestoreClientCache</a>;</div> |
| <div class="line"><a name="l00043"></a><span class="lineno"> 43</span> </div> |
| <div class="line"><a name="l00050"></a><span class="lineno"> 50</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00055"></a><span class="lineno"> 55</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00059"></a><span class="lineno"> 59</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00064"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html"> 64</a></span> <span class="comment"></span><span class="keyword">class </span><a class="code" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a> {</div> |
| <div class="line"><a name="l00065"></a><span class="lineno"> 65</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00068"></a><span class="lineno"> 68</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00071"></a><span class="lineno"> 71</span> <span class="comment"></span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00073"></a><span class="lineno"> 73</span> <span class="comment"></span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae36a7a9bae5f9bb10a52ed6214ca1a5a">StatestoreSubscriber</a>(<span class="keyword">const</span> std::string& subscriber_id,</div> |
| <div class="line"><a name="l00074"></a><span class="lineno"> 74</span>  <span class="keyword">const</span> TNetworkAddress& heartbeat_address,</div> |
| <div class="line"><a name="l00075"></a><span class="lineno"> 75</span>  <span class="keyword">const</span> TNetworkAddress& statestore_address,</div> |
| <div class="line"><a name="l00076"></a><span class="lineno"> 76</span>  <a class="code" href="classimpala_1_1MetricGroup.html">MetricGroup</a>* metrics);</div> |
| <div class="line"><a name="l00077"></a><span class="lineno"> 77</span> </div> |
| <div class="line"><a name="l00079"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2"> 79</a></span>  <span class="keyword">typedef</span> std::map<Statestore::TopicId, TTopicDelta> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2">TopicDeltaMap</a>;</div> |
| <div class="line"><a name="l00080"></a><span class="lineno"> 80</span> </div> |
| <div class="line"><a name="l00083"></a><span class="lineno"> 83</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00088"></a><span class="lineno"> 88</span> <span class="comment"></span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00094"></a><span class="lineno"> 94</span> <span class="comment"></span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00098"></a><span class="lineno"> 98</span> <span class="comment"></span> <span class="keyword">typedef</span> boost::function<void (<span class="keyword">const</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2">TopicDeltaMap</a>& state,</div> |
| <div class="line"><a name="l00099"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#afbaf06f3e5f1f339801d522b0091fc0c"> 99</a></span>  std::vector<TTopicDelta>* topic_updates)> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afbaf06f3e5f1f339801d522b0091fc0c">UpdateCallback</a>;</div> |
| <div class="line"><a name="l00100"></a><span class="lineno"> 100</span> </div> |
| <div class="line"><a name="l00107"></a><span class="lineno"> 107</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00110"></a><span class="lineno"> 110</span> <span class="comment"></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afc9a9b084411e93362c65e7b6a5b1ff2">AddTopic</a>(<span class="keyword">const</span> <a class="code" href="classimpala_1_1Statestore.html#aa0a261a02804c62cb4b204a498e2e3ed">Statestore::TopicId</a>& topic_id, <span class="keywordtype">bool</span> is_transient,</div> |
| <div class="line"><a name="l00111"></a><span class="lineno"> 111</span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afbaf06f3e5f1f339801d522b0091fc0c">UpdateCallback</a>& callback);</div> |
| <div class="line"><a name="l00112"></a><span class="lineno"> 112</span> </div> |
| <div class="line"><a name="l00116"></a><span class="lineno"> 116</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00118"></a><span class="lineno"> 118</span> <span class="comment"></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae362f9dfb8bf27163c4362f31a308772">Start</a>();</div> |
| <div class="line"><a name="l00119"></a><span class="lineno"> 119</span> </div> |
| <div class="line"><a name="l00120"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#afed23c0b16a5e1ada4bbea0015748999"> 120</a></span>  <span class="keyword">const</span> std::string& <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afed23c0b16a5e1ada4bbea0015748999">id</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#abc056863a86ea547bbd54656c9a0575c">subscriber_id_</a>; }</div> |
| <div class="line"><a name="l00121"></a><span class="lineno"> 121</span> </div> |
| <div class="line"><a name="l00122"></a><span class="lineno"> 122</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00124"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#abc056863a86ea547bbd54656c9a0575c"> 124</a></span>  <span class="keyword">const</span> std::string <a class="code" href="classimpala_1_1StatestoreSubscriber.html#abc056863a86ea547bbd54656c9a0575c">subscriber_id_</a>;</div> |
| <div class="line"><a name="l00125"></a><span class="lineno"> 125</span> </div> |
| <div class="line"><a name="l00127"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#acf7ae93ff26655b854e7a98fdd719541"> 127</a></span>  TNetworkAddress <a class="code" href="classimpala_1_1StatestoreSubscriber.html#acf7ae93ff26655b854e7a98fdd719541">heartbeat_address_</a>;</div> |
| <div class="line"><a name="l00128"></a><span class="lineno"> 128</span> </div> |
| <div class="line"><a name="l00130"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a0f11b1888b0d856e01d289efa6077e63"> 130</a></span>  TNetworkAddress <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a0f11b1888b0d856e01d289efa6077e63">statestore_address_</a>;</div> |
| <div class="line"><a name="l00131"></a><span class="lineno"> 131</span> </div> |
| <div class="line"><a name="l00134"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#adb79a2b995e5328fe4b0bd673ca10d9a"> 134</a></span>  boost::shared_ptr<StatestoreSubscriberIf> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#adb79a2b995e5328fe4b0bd673ca10d9a">thrift_iface_</a>;</div> |
| <div class="line"><a name="l00135"></a><span class="lineno"> 135</span> </div> |
| <div class="line"><a name="l00137"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ae7c3999eac69077548f22772c80192d8"> 137</a></span>  boost::shared_ptr<ThriftServer> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae7c3999eac69077548f22772c80192d8">heartbeat_server_</a>;</div> |
| <div class="line"><a name="l00138"></a><span class="lineno"> 138</span> </div> |
| <div class="line"><a name="l00140"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1"> 140</a></span>  boost::scoped_ptr<impala::TimeoutFailureDetector> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1">failure_detector_</a>;</div> |
| <div class="line"><a name="l00141"></a><span class="lineno"> 141</span> </div> |
| <div class="line"><a name="l00143"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a10cf593e773daad628aa64d6b31cfd96"> 143</a></span>  boost::scoped_ptr<Thread> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a10cf593e773daad628aa64d6b31cfd96">recovery_mode_thread_</a>;</div> |
| <div class="line"><a name="l00144"></a><span class="lineno"> 144</span> </div> |
| <div class="line"><a name="l00147"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410"> 147</a></span>  boost::mutex <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410">lock_</a>;</div> |
| <div class="line"><a name="l00148"></a><span class="lineno"> 148</span> </div> |
| <div class="line"><a name="l00151"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ae5be8d3382d65898e0310fac283771fb"> 151</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae5be8d3382d65898e0310fac283771fb">is_registered_</a>;</div> |
| <div class="line"><a name="l00152"></a><span class="lineno"> 152</span> </div> |
| <div class="line"><a name="l00155"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#aa45b5d93dfc88e3ac54e62e522427b7e"> 155</a></span>  boost::mutex <a class="code" href="classimpala_1_1StatestoreSubscriber.html#aa45b5d93dfc88e3ac54e62e522427b7e">registration_id_lock_</a>;</div> |
| <div class="line"><a name="l00156"></a><span class="lineno"> 156</span> </div> |
| <div class="line"><a name="l00162"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40"> 162</a></span>  TUniqueId <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">registration_id_</a>;</div> |
| <div class="line"><a name="l00163"></a><span class="lineno"> 163</span> </div> |
| <div class="line"><a name="l00164"></a><span class="lineno"><a class="line" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html"> 164</a></span>  <span class="keyword">struct </span><a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html">Callbacks</a> {</div> |
| <div class="line"><a name="l00167"></a><span class="lineno"><a class="line" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#abe5c5214b13614f615c3ba560996498a"> 167</a></span>  <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>* <a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#abe5c5214b13614f615c3ba560996498a">processing_time_metric</a>;</div> |
| <div class="line"><a name="l00168"></a><span class="lineno"> 168</span> </div> |
| <div class="line"><a name="l00170"></a><span class="lineno"><a class="line" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#a0d5d67608c46a564ddaf3ec8a4339774"> 170</a></span>  std::vector<UpdateCallback> <a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#a0d5d67608c46a564ddaf3ec8a4339774">callbacks</a>;</div> |
| <div class="line"><a name="l00171"></a><span class="lineno"> 171</span>  };</div> |
| <div class="line"><a name="l00172"></a><span class="lineno"> 172</span> </div> |
| <div class="line"><a name="l00177"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ab5b87989c7c4d22b507efef072411980"> 177</a></span>  <span class="keyword">typedef</span> boost::unordered_map<Statestore::TopicId, Callbacks> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab5b87989c7c4d22b507efef072411980">UpdateCallbacks</a>;</div> |
| <div class="line"><a name="l00178"></a><span class="lineno"> 178</span> </div> |
| <div class="line"><a name="l00181"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4"> 181</a></span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab5b87989c7c4d22b507efef072411980">UpdateCallbacks</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4">update_callbacks_</a>;</div> |
| <div class="line"><a name="l00182"></a><span class="lineno"> 182</span> </div> |
| <div class="line"><a name="l00186"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a2c211908c8ab573e26307b6c513d53a3"> 186</a></span>  std::map<Statestore::TopicId, bool> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a2c211908c8ab573e26307b6c513d53a3">topic_registrations_</a>;</div> |
| <div class="line"><a name="l00187"></a><span class="lineno"> 187</span> </div> |
| <div class="line"><a name="l00190"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a8afab83e01741458ef3aa8370c883398"> 190</a></span>  <span class="keyword">typedef</span> boost::unordered_map<Statestore::TopicId, int64_t> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a8afab83e01741458ef3aa8370c883398">TopicVersionMap</a>;</div> |
| <div class="line"><a name="l00191"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a65b14aaee673a6bfe44495358f0c7f41"> 191</a></span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a8afab83e01741458ef3aa8370c883398">TopicVersionMap</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a65b14aaee673a6bfe44495358f0c7f41">current_topic_versions_</a>;</div> |
| <div class="line"><a name="l00192"></a><span class="lineno"> 192</span> </div> |
| <div class="line"><a name="l00194"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a58a05e063a904a32064a2053e3c604ff"> 194</a></span>  boost::scoped_ptr<StatestoreClientCache> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a58a05e063a904a32064a2053e3c604ff">client_cache_</a>;</div> |
| <div class="line"><a name="l00195"></a><span class="lineno"> 195</span> </div> |
| <div class="line"><a name="l00197"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac"> 197</a></span>  <a class="code" href="classimpala_1_1MetricGroup.html">MetricGroup</a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">metrics_</a>;</div> |
| <div class="line"><a name="l00198"></a><span class="lineno"> 198</span> </div> |
| <div class="line"><a name="l00200"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a608844261bc61fbc3a5f323b39f6fc6e"> 200</a></span>  <a class="code" href="namespaceimpala.html#a67659fb7ecbc7faa1705c0fde687076f">BooleanProperty</a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a608844261bc61fbc3a5f323b39f6fc6e">connected_to_statestore_metric_</a>;</div> |
| <div class="line"><a name="l00201"></a><span class="lineno"> 201</span> </div> |
| <div class="line"><a name="l00203"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#afeb39f5e2fa795db5d46df4f2e4e8a93"> 203</a></span>  <a class="code" href="namespaceimpala.html#af291a879430eef445a800397361bc690">DoubleGauge</a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afeb39f5e2fa795db5d46df4f2e4e8a93">last_recovery_duration_metric_</a>;</div> |
| <div class="line"><a name="l00204"></a><span class="lineno"> 204</span> </div> |
| <div class="line"><a name="l00206"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#afe503b062fff002d6544a0d5182fa1ac"> 206</a></span>  <a class="code" href="namespaceimpala.html#afcf5d0484c3833cf0f4f6c681412e398">StringProperty</a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afe503b062fff002d6544a0d5182fa1ac">last_recovery_time_metric_</a>;</div> |
| <div class="line"><a name="l00207"></a><span class="lineno"> 207</span> </div> |
| <div class="line"><a name="l00209"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ae3a0727dfbe61b9c62913e6ecbd91348"> 209</a></span>  <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae3a0727dfbe61b9c62913e6ecbd91348">topic_update_interval_metric_</a>;</div> |
| <div class="line"><a name="l00210"></a><span class="lineno"> 210</span> </div> |
| <div class="line"><a name="l00212"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#acb98cfad8aabf894a0df39be04bdc477"> 212</a></span>  <a class="code" href="classimpala_1_1MonotonicStopWatch.html">MonotonicStopWatch</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#acb98cfad8aabf894a0df39be04bdc477">topic_update_interval_timer_</a>;</div> |
| <div class="line"><a name="l00213"></a><span class="lineno"> 213</span> </div> |
| <div class="line"><a name="l00216"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a0fa88fd4d81890b88e9a4d9e3e573992"> 216</a></span>  <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a0fa88fd4d81890b88e9a4d9e3e573992">topic_update_duration_metric_</a>;</div> |
| <div class="line"><a name="l00217"></a><span class="lineno"> 217</span> </div> |
| <div class="line"><a name="l00219"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a00b32439e297666cdd5ba1052ee04309"> 219</a></span>  <a class="code" href="classimpala_1_1MonotonicStopWatch.html">MonotonicStopWatch</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a00b32439e297666cdd5ba1052ee04309">heartbeat_interval_timer_</a>;</div> |
| <div class="line"><a name="l00220"></a><span class="lineno"> 220</span> </div> |
| <div class="line"><a name="l00222"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#aaf036a4c0f68d974fc04146bcd9152be"> 222</a></span>  <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#aaf036a4c0f68d974fc04146bcd9152be">heartbeat_interval_metric_</a>;</div> |
| <div class="line"><a name="l00223"></a><span class="lineno"> 223</span> </div> |
| <div class="line"><a name="l00225"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a56bc5af9989d57bdc89fc5b61484a8d0"> 225</a></span>  <a class="code" href="namespaceimpala.html#afcf5d0484c3833cf0f4f6c681412e398">StringProperty</a>* <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a56bc5af9989d57bdc89fc5b61484a8d0">registration_id_metric_</a>;</div> |
| <div class="line"><a name="l00226"></a><span class="lineno"> 226</span> </div> |
| <div class="line"><a name="l00228"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#aaf307b7060c34c9ec4fc080b870dcd3f"> 228</a></span>  <span class="keyword">friend</span> <span class="keyword">class </span><a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html">StatestoreSubscriberThriftIf</a>;</div> |
| <div class="line"><a name="l00229"></a><span class="lineno"> 229</span> </div> |
| <div class="line"><a name="l00243"></a><span class="lineno"> 243</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00249"></a><span class="lineno"> 249</span> <span class="comment"></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ad5803fa31f6a5738fb7ded4a43b349cc">UpdateState</a>(<span class="keyword">const</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2">TopicDeltaMap</a>& incoming_topic_deltas,</div> |
| <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  <span class="keyword">const</span> TUniqueId& registration_id,</div> |
| <div class="line"><a name="l00251"></a><span class="lineno"> 251</span>  std::vector<TTopicDelta>* subscriber_topic_updates, <span class="keywordtype">bool</span>* skipped);</div> |
| <div class="line"><a name="l00252"></a><span class="lineno"> 252</span> </div> |
| <div class="line"><a name="l00254"></a><span class="lineno"> 254</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#af3d6f3b8bec22de9521526aa62ad064c">Heartbeat</a>(<span class="keyword">const</span> TUniqueId& registration_id);</div> |
| <div class="line"><a name="l00255"></a><span class="lineno"> 255</span> </div> |
| <div class="line"><a name="l00260"></a><span class="lineno"> 260</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00264"></a><span class="lineno"> 264</span> <span class="comment"></span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a9484addc4e8c80aca6a10b584a404642">RecoveryModeChecker</a>();</div> |
| <div class="line"><a name="l00265"></a><span class="lineno"> 265</span> </div> |
| <div class="line"><a name="l00269"></a><span class="lineno"> 269</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab926c3659fa0dfa7ca419d410eb8305f">Register</a>();</div> |
| <div class="line"><a name="l00270"></a><span class="lineno"> 270</span> </div> |
| <div class="line"><a name="l00274"></a><span class="lineno"> 274</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a190aff056caef5690f3066f0f54e6a41">CheckRegistrationId</a>(<span class="keyword">const</span> TUniqueId& registration_id);</div> |
| <div class="line"><a name="l00275"></a><span class="lineno"> 275</span> };</div> |
| <div class="line"><a name="l00276"></a><span class="lineno"> 276</span> </div> |
| <div class="line"><a name="l00277"></a><span class="lineno"> 277</span> }</div> |
| <div class="line"><a name="l00278"></a><span class="lineno"> 278</span> </div> |
| <div class="line"><a name="l00279"></a><span class="lineno"> 279</span> <span class="preprocessor">#endif</span></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ae36a7a9bae5f9bb10a52ed6214ca1a5a"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ae36a7a9bae5f9bb10a52ed6214ca1a5a">impala::StatestoreSubscriber::StatestoreSubscriber</a></div><div class="ttdeci">StatestoreSubscriber(const std::string &subscriber_id, const TNetworkAddress &heartbeat_address, const TNetworkAddress &statestore_address, MetricGroup *metrics)</div><div class="ttdoc">statestore_address - the address of the statestore to register with </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00089">statestore-subscriber.cc:89</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a659c52f90869723e50ab81a161965cac"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">impala::StatestoreSubscriber::metrics_</a></div><div class="ttdeci">MetricGroup * metrics_</div><div class="ttdoc">MetricGroup instance that all metrics are registered in. Not owned by this class. ...</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00197">statestore-subscriber.h:197</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_adb79a2b995e5328fe4b0bd673ca10d9a"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#adb79a2b995e5328fe4b0bd673ca10d9a">impala::StatestoreSubscriber::thrift_iface_</a></div><div class="ttdeci">boost::shared_ptr< StatestoreSubscriberIf > thrift_iface_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00134">statestore-subscriber.h:134</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_af3d6f3b8bec22de9521526aa62ad064c"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#af3d6f3b8bec22de9521526aa62ad064c">impala::StatestoreSubscriber::Heartbeat</a></div><div class="ttdeci">void Heartbeat(const TUniqueId &registration_id)</div><div class="ttdoc">Called when the statestore sends a heartbeat message. Updates the failure detector. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00279">statestore-subscriber.cc:279</a></div></div> |
| <div class="ttc" id="structimpala_1_1StatestoreSubscriber_1_1Callbacks_html_a0d5d67608c46a564ddaf3ec8a4339774"><div class="ttname"><a href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#a0d5d67608c46a564ddaf3ec8a4339774">impala::StatestoreSubscriber::Callbacks::callbacks</a></div><div class="ttdeci">std::vector< UpdateCallback > callbacks</div><div class="ttdoc">List of callbacks to invoke for this topic. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00170">statestore-subscriber.h:170</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a0f11b1888b0d856e01d289efa6077e63"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a0f11b1888b0d856e01d289efa6077e63">impala::StatestoreSubscriber::statestore_address_</a></div><div class="ttdeci">TNetworkAddress statestore_address_</div><div class="ttdoc">Address of the statestore. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00130">statestore-subscriber.h:130</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_afcf5d0484c3833cf0f4f6c681412e398"><div class="ttname"><a href="namespaceimpala.html#afcf5d0484c3833cf0f4f6c681412e398">impala::StringProperty</a></div><div class="ttdeci">class SimpleMetric< std::string, TMetricKind::PROPERTY > StringProperty</div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00323">metrics.h:323</a></div></div> |
| <div class="ttc" id="classimpala_1_1MonotonicStopWatch_html"><div class="ttname"><a href="classimpala_1_1MonotonicStopWatch.html">impala::MonotonicStopWatch</a></div><div class="ttdef"><b>Definition:</b> <a href="stopwatch_8h_source.html#l00074">stopwatch.h:74</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_ac468011cd4f6868b9b7e1f2acb56c94e"><div class="ttname"><a href="namespaceimpala.html#ac468011cd4f6868b9b7e1f2acb56c94e">impala::StatestoreClientCache</a></div><div class="ttdeci">ClientCache< StatestoreServiceClient > StatestoreClientCache</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00040">statestore-subscriber.h:40</a></div></div> |
| <div class="ttc" id="structimpala_1_1StatestoreSubscriber_1_1Callbacks_html"><div class="ttname"><a href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html">impala::StatestoreSubscriber::Callbacks</a></div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00164">statestore-subscriber.h:164</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a10cf593e773daad628aa64d6b31cfd96"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a10cf593e773daad628aa64d6b31cfd96">impala::StatestoreSubscriber::recovery_mode_thread_</a></div><div class="ttdeci">boost::scoped_ptr< Thread > recovery_mode_thread_</div><div class="ttdoc">Thread in which RecoveryModeChecker runs. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00143">statestore-subscriber.h:143</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_afed23c0b16a5e1ada4bbea0015748999"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#afed23c0b16a5e1ada4bbea0015748999">impala::StatestoreSubscriber::id</a></div><div class="ttdeci">const std::string & id() const </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00120">statestore-subscriber.h:120</a></div></div> |
| <div class="ttc" id="classimpala_1_1MetricGroup_html"><div class="ttname"><a href="classimpala_1_1MetricGroup.html">impala::MetricGroup</a></div><div class="ttdoc">MetricGroups may be organised hierarchically as a tree. </div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00200">metrics.h:200</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a190aff056caef5690f3066f0f54e6a41"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a190aff056caef5690f3066f0f54e6a41">impala::StatestoreSubscriber::CheckRegistrationId</a></div><div class="ttdeci">Status CheckRegistrationId(const TUniqueId &registration_id)</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00263">statestore-subscriber.cc:263</a></div></div> |
| <div class="ttc" id="statestore_8h_html"><div class="ttname"><a href="statestore_8h.html">statestore.h</a></div></div> |
| <div class="ttc" id="stopwatch_8h_html"><div class="ttname"><a href="stopwatch_8h.html">stopwatch.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a6850007d07f73b300509be1fd3f40bb1"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1">impala::StatestoreSubscriber::failure_detector_</a></div><div class="ttdeci">boost::scoped_ptr< impala::TimeoutFailureDetector > failure_detector_</div><div class="ttdoc">Failure detector that tracks heartbeat messages from the statestore. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00140">statestore-subscriber.h:140</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatsMetric_html"><div class="ttname"><a href="classimpala_1_1StatsMetric.html">impala::StatsMetric< double ></a></div></div> |
| <div class="ttc" id="structimpala_1_1StatestoreSubscriber_1_1Callbacks_html_abe5c5214b13614f615c3ba560996498a"><div class="ttname"><a href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#abe5c5214b13614f615c3ba560996498a">impala::StatestoreSubscriber::Callbacks::processing_time_metric</a></div><div class="ttdeci">StatsMetric< double > * processing_time_metric</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00167">statestore-subscriber.h:167</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html">impala::StatestoreSubscriber</a></div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00064">statestore-subscriber.h:64</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a23618aa4345cce55d83f33011af603b4"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4">impala::StatestoreSubscriber::update_callbacks_</a></div><div class="ttdeci">UpdateCallbacks update_callbacks_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00181">statestore-subscriber.h:181</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_afeb39f5e2fa795db5d46df4f2e4e8a93"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#afeb39f5e2fa795db5d46df4f2e4e8a93">impala::StatestoreSubscriber::last_recovery_duration_metric_</a></div><div class="ttdeci">DoubleGauge * last_recovery_duration_metric_</div><div class="ttdoc">Amount of time last spent in recovery mode. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00203">statestore-subscriber.h:203</a></div></div> |
| <div class="ttc" id="thread_8h_html"><div class="ttname"><a href="thread_8h.html">thread.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ae5be8d3382d65898e0310fac283771fb"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ae5be8d3382d65898e0310fac283771fb">impala::StatestoreSubscriber::is_registered_</a></div><div class="ttdeci">bool is_registered_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00151">statestore-subscriber.h:151</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_aa45b5d93dfc88e3ac54e62e522427b7e"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#aa45b5d93dfc88e3ac54e62e522427b7e">impala::StatestoreSubscriber::registration_id_lock_</a></div><div class="ttdeci">boost::mutex registration_id_lock_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00155">statestore-subscriber.h:155</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_acf7ae93ff26655b854e7a98fdd719541"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#acf7ae93ff26655b854e7a98fdd719541">impala::StatestoreSubscriber::heartbeat_address_</a></div><div class="ttdeci">TNetworkAddress heartbeat_address_</div><div class="ttdoc">Address that the heartbeat service should be started on. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00127">statestore-subscriber.h:127</a></div></div> |
| <div class="ttc" id="classimpala_1_1Status_html"><div class="ttname"><a href="classimpala_1_1Status.html">impala::Status</a></div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00081">status.h:81</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a56bc5af9989d57bdc89fc5b61484a8d0"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a56bc5af9989d57bdc89fc5b61484a8d0">impala::StatestoreSubscriber::registration_id_metric_</a></div><div class="ttdeci">StringProperty * registration_id_metric_</div><div class="ttdoc">Current registration ID, in string form. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00225">statestore-subscriber.h:225</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_afbaf06f3e5f1f339801d522b0091fc0c"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#afbaf06f3e5f1f339801d522b0091fc0c">impala::StatestoreSubscriber::UpdateCallback</a></div><div class="ttdeci">boost::function< void(const TopicDeltaMap &state, std::vector< TTopicDelta > *topic_updates)> UpdateCallback</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00099">statestore-subscriber.h:99</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_afe503b062fff002d6544a0d5182fa1ac"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#afe503b062fff002d6544a0d5182fa1ac">impala::StatestoreSubscriber::last_recovery_time_metric_</a></div><div class="ttdeci">StringProperty * last_recovery_time_metric_</div><div class="ttdoc">When the last recovery happened. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00206">statestore-subscriber.h:206</a></div></div> |
| <div class="ttc" id="classimpala_1_1Statestore_html_aa0a261a02804c62cb4b204a498e2e3ed"><div class="ttname"><a href="classimpala_1_1Statestore.html#aa0a261a02804c62cb4b204a498e2e3ed">impala::Statestore::TopicId</a></div><div class="ttdeci">std::string TopicId</div><div class="ttdoc">A TopicId uniquely identifies a single topic. </div><div class="ttdef"><b>Definition:</b> <a href="statestore_8h_source.html#l00086">statestore.h:86</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_acb98cfad8aabf894a0df39be04bdc477"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#acb98cfad8aabf894a0df39be04bdc477">impala::StatestoreSubscriber::topic_update_interval_timer_</a></div><div class="ttdeci">MonotonicStopWatch topic_update_interval_timer_</div><div class="ttdoc">Tracks the time between topic-update mesages. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00212">statestore-subscriber.h:212</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a58a05e063a904a32064a2053e3c604ff"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a58a05e063a904a32064a2053e3c604ff">impala::StatestoreSubscriber::client_cache_</a></div><div class="ttdeci">boost::scoped_ptr< StatestoreClientCache > client_cache_</div><div class="ttdoc">statestore client cache - only one client is ever used. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00194">statestore-subscriber.h:194</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ab972143162e20f1758457e6758c04410"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410">impala::StatestoreSubscriber::lock_</a></div><div class="ttdeci">boost::mutex lock_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00147">statestore-subscriber.h:147</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a2c211908c8ab573e26307b6c513d53a3"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a2c211908c8ab573e26307b6c513d53a3">impala::StatestoreSubscriber::topic_registrations_</a></div><div class="ttdeci">std::map< Statestore::TopicId, bool > topic_registrations_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00186">statestore-subscriber.h:186</a></div></div> |
| <div class="ttc" id="thrift-util_8h_html"><div class="ttname"><a href="thrift-util_8h.html">thrift-util.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriberThriftIf_html"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriberThriftIf.html">impala::StatestoreSubscriberThriftIf</a></div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00064">statestore-subscriber.cc:64</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a892cd79b5b97edc1a4d0cb692be151d2"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a892cd79b5b97edc1a4d0cb692be151d2">impala::StatestoreSubscriber::TopicDeltaMap</a></div><div class="ttdeci">std::map< Statestore::TopicId, TTopicDelta > TopicDeltaMap</div><div class="ttdoc">A TopicDeltaMap is passed to each callback. See UpdateCallback for more details. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00079">statestore-subscriber.h:79</a></div></div> |
| <div class="ttc" id="classimpala_1_1ThriftServer_html"><div class="ttname"><a href="classimpala_1_1ThriftServer.html">impala::ThriftServer</a></div><div class="ttdef"><b>Definition:</b> <a href="thrift-server_8h_source.html#l00039">thrift-server.h:39</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_abc056863a86ea547bbd54656c9a0575c"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#abc056863a86ea547bbd54656c9a0575c">impala::StatestoreSubscriber::subscriber_id_</a></div><div class="ttdeci">const std::string subscriber_id_</div><div class="ttdoc">Unique, but opaque, identifier for this subscriber. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00124">statestore-subscriber.h:124</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ad5803fa31f6a5738fb7ded4a43b349cc"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ad5803fa31f6a5738fb7ded4a43b349cc">impala::StatestoreSubscriber::UpdateState</a></div><div class="ttdeci">Status UpdateState(const TopicDeltaMap &incoming_topic_deltas, const TUniqueId &registration_id, std::vector< TTopicDelta > *subscriber_topic_updates, bool *skipped)</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00290">statestore-subscriber.cc:290</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a0fa88fd4d81890b88e9a4d9e3e573992"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a0fa88fd4d81890b88e9a4d9e3e573992">impala::StatestoreSubscriber::topic_update_duration_metric_</a></div><div class="ttdeci">StatsMetric< double > * topic_update_duration_metric_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00216">statestore-subscriber.h:216</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a67659fb7ecbc7faa1705c0fde687076f"><div class="ttname"><a href="namespaceimpala.html#a67659fb7ecbc7faa1705c0fde687076f">impala::BooleanProperty</a></div><div class="ttdeci">class SimpleMetric< bool, TMetricKind::PROPERTY > BooleanProperty</div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00322">metrics.h:322</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a8afab83e01741458ef3aa8370c883398"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a8afab83e01741458ef3aa8370c883398">impala::StatestoreSubscriber::TopicVersionMap</a></div><div class="ttdeci">boost::unordered_map< Statestore::TopicId, int64_t > TopicVersionMap</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00190">statestore-subscriber.h:190</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a9484addc4e8c80aca6a10b584a404642"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a9484addc4e8c80aca6a10b584a404642">impala::StatestoreSubscriber::RecoveryModeChecker</a></div><div class="ttdeci">void RecoveryModeChecker()</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00211">statestore-subscriber.cc:211</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_af291a879430eef445a800397361bc690"><div class="ttname"><a href="namespaceimpala.html#af291a879430eef445a800397361bc690">impala::DoubleGauge</a></div><div class="ttdeci">class SimpleMetric< double, TMetricKind::GAUGE > DoubleGauge</div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00319">metrics.h:319</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ab5b87989c7c4d22b507efef072411980"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ab5b87989c7c4d22b507efef072411980">impala::StatestoreSubscriber::UpdateCallbacks</a></div><div class="ttdeci">boost::unordered_map< Statestore::TopicId, Callbacks > UpdateCallbacks</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00177">statestore-subscriber.h:177</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a65b14aaee673a6bfe44495358f0c7f41"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a65b14aaee673a6bfe44495358f0c7f41">impala::StatestoreSubscriber::current_topic_versions_</a></div><div class="ttdeci">TopicVersionMap current_topic_versions_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00191">statestore-subscriber.h:191</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a6168307fe4ede47191ecb7c44d941b40"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">impala::StatestoreSubscriber::registration_id_</a></div><div class="ttdeci">TUniqueId registration_id_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00162">statestore-subscriber.h:162</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ae3a0727dfbe61b9c62913e6ecbd91348"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ae3a0727dfbe61b9c62913e6ecbd91348">impala::StatestoreSubscriber::topic_update_interval_metric_</a></div><div class="ttdeci">StatsMetric< double > * topic_update_interval_metric_</div><div class="ttdoc">Accumulated statistics on the frequency of topic-update messages. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00209">statestore-subscriber.h:209</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ab926c3659fa0dfa7ca419d410eb8305f"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ab926c3659fa0dfa7ca419d410eb8305f">impala::StatestoreSubscriber::Register</a></div><div class="ttdeci">Status Register()</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00141">statestore-subscriber.cc:141</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a608844261bc61fbc3a5f323b39f6fc6e"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a608844261bc61fbc3a5f323b39f6fc6e">impala::StatestoreSubscriber::connected_to_statestore_metric_</a></div><div class="ttdeci">BooleanProperty * connected_to_statestore_metric_</div><div class="ttdoc">Metric to indicate if we are successfully registered with the statestore. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00200">statestore-subscriber.h:200</a></div></div> |
| <div class="ttc" id="thrift-client_8h_html"><div class="ttname"><a href="thrift-client_8h.html">thrift-client.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1ClientCache_html"><div class="ttname"><a href="classimpala_1_1ClientCache.html">impala::ClientCache</a></div><div class="ttdef"><b>Definition:</b> <a href="client-cache_8h_source.html#l00187">client-cache.h:187</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_aaf036a4c0f68d974fc04146bcd9152be"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#aaf036a4c0f68d974fc04146bcd9152be">impala::StatestoreSubscriber::heartbeat_interval_metric_</a></div><div class="ttdeci">StatsMetric< double > * heartbeat_interval_metric_</div><div class="ttdoc">Accumulated statistics on the frequency of heartbeat messages. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00222">statestore-subscriber.h:222</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ae362f9dfb8bf27163c4362f31a308772"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ae362f9dfb8bf27163c4362f31a308772">impala::StatestoreSubscriber::Start</a></div><div class="ttdeci">Status Start()</div><div class="ttdoc">Returns OK unless some error occurred, like a failure to connect. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00176">statestore-subscriber.cc:176</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_afc9a9b084411e93362c65e7b6a5b1ff2"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#afc9a9b084411e93362c65e7b6a5b1ff2">impala::StatestoreSubscriber::AddTopic</a></div><div class="ttdeci">Status AddTopic(const Statestore::TopicId &topic_id, bool is_transient, const UpdateCallback &callback)</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00126">statestore-subscriber.cc:126</a></div></div> |
| <div class="ttc" id="metrics_8h_html"><div class="ttname"><a href="metrics_8h.html">metrics.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_ae7c3999eac69077548f22772c80192d8"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#ae7c3999eac69077548f22772c80192d8">impala::StatestoreSubscriber::heartbeat_server_</a></div><div class="ttdeci">boost::shared_ptr< ThriftServer > heartbeat_server_</div><div class="ttdoc">Container for the heartbeat server. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00137">statestore-subscriber.h:137</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriber_html_a00b32439e297666cdd5ba1052ee04309"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriber.html#a00b32439e297666cdd5ba1052ee04309">impala::StatestoreSubscriber::heartbeat_interval_timer_</a></div><div class="ttdeci">MonotonicStopWatch heartbeat_interval_timer_</div><div class="ttdoc">Tracks the time between heartbeat mesages. </div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8h_source.html#l00219">statestore-subscriber.h:219</a></div></div> |
| </div><!-- fragment --></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="dir_e5d120be6b5e8a44336cbfd013b25604.html">be</a></li><li class="navelem"><a class="el" href="dir_68cf7cafb51a962d5bc4848b83cab0de.html">src</a></li><li class="navelem"><a class="el" href="dir_aa61820f947c9a81fdd16b1964e72790.html">statestore</a></li><li class="navelem"><a class="el" href="statestore-subscriber_8h.html">statestore-subscriber.h</a></li> |
| <li class="footer">Generated on Thu May 7 2015 16:10:37 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> |
