| <!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.cc 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_8cc_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.cc</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="statestore-subscriber_8cc.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> <span class="preprocessor">#include "<a class="code" href="statestore-subscriber_8h.html">statestore/statestore-subscriber.h</a>"</span></div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> </div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="preprocessor">#include <sstream></span></div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor">#include <utility></span></div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> </div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#include <boost/algorithm/string/join.hpp></span></div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include <boost/foreach.hpp></span></div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <boost/date_time/posix_time/posix_time.hpp></span></div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> <span class="preprocessor">#include <boost/thread/shared_mutex.hpp></span></div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include <gutil/strings/substitute.h></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="logging_8h.html">common/logging.h</a>"</span></div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">common/status.h</a>"</span></div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="preprocessor">#include "<a class="code" href="failure-detector_8h.html">statestore/failure-detector.h</a>"</span></div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "gen-cpp/StatestoreService_types.h"</span></div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="rpc-trace_8h.html">rpc/rpc-trace.h</a>"</span></div> |
| <div class="line"><a name="l00031"></a><span class="lineno"> 31</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="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "<a class="code" href="time_8h.html">util/time.h</a>"</span></div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="preprocessor">#include "<a class="code" href="debug-util_8h.html">util/debug-util.h</a>"</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="preprocessor">#include "<a class="code" href="names_8h.html">common/names.h</a>"</span></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">using</span> boost::posix_time::seconds;</div> |
| <div class="line"><a name="l00038"></a><span class="lineno"> 38</span> <span class="keyword">using namespace </span>apache::thrift;</div> |
| <div class="line"><a name="l00039"></a><span class="lineno"> 39</span> <span class="keyword">using namespace </span>strings;</div> |
| <div class="line"><a name="l00040"></a><span class="lineno"> 40</span> </div> |
| <div class="line"><a name="l00041"></a><span class="lineno"> 41</span> <a class="code" href="statestore-subscriber_8cc.html#addac98f4e6a09c6d1c8eebfe20dd46d4">DEFINE_int32</a>(statestore_subscriber_timeout_seconds, 30, <span class="stringliteral">"The amount of time (in seconds)"</span></div> |
| <div class="line"><a name="l00042"></a><span class="lineno"> 42</span>  <span class="stringliteral">" that may elapse before the connection with the statestore is considered lost."</span>);</div> |
| <div class="line"><a name="l00043"></a><span class="lineno"> 43</span> <a class="code" href="statestore-subscriber_8cc.html#addac98f4e6a09c6d1c8eebfe20dd46d4">DEFINE_int32</a>(statestore_subscriber_cnxn_attempts, 10, <span class="stringliteral">"The number of times to retry an "</span></div> |
| <div class="line"><a name="l00044"></a><span class="lineno"> 44</span>  <span class="stringliteral">"RPC connection to the statestore. A setting of 0 means retry indefinitely"</span>);</div> |
| <div class="line"><a name="l00045"></a><span class="lineno"> 45</span> <a class="code" href="statestore-subscriber_8cc.html#addac98f4e6a09c6d1c8eebfe20dd46d4">DEFINE_int32</a>(statestore_subscriber_cnxn_retry_interval_ms, 3000, <span class="stringliteral">"The interval, in ms, "</span></div> |
| <div class="line"><a name="l00046"></a><span class="lineno"> 46</span>  <span class="stringliteral">"to wait between attempts to make an RPC connection to the statestore."</span>);</div> |
| <div class="line"><a name="l00047"></a><span class="lineno"> 47</span> </div> |
| <div class="line"><a name="l00048"></a><span class="lineno"> 48</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00049"></a><span class="lineno"> 49</span> </div> |
| <div class="line"><a name="l00050"></a><span class="lineno"> 50</span> <span class="comment">// Used to identify the statestore in the failure detector</span></div> |
| <div class="line"><a name="l00051"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0"> 51</a></span> <span class="keyword">const</span> <span class="keywordtype">string</span> <a class="code" href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0">STATESTORE_ID</a> = <span class="stringliteral">"STATESTORE"</span>;</div> |
| <div class="line"><a name="l00052"></a><span class="lineno"> 52</span> </div> |
| <div class="line"><a name="l00053"></a><span class="lineno"> 53</span> <span class="comment">// Template for metrics that measure the processing time for individual topics.</span></div> |
| <div class="line"><a name="l00054"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a992d29b9f14e8f27cfa2a73de4b969f1"> 54</a></span> <span class="keyword">const</span> <span class="keywordtype">string</span> <a class="code" href="namespaceimpala.html#a992d29b9f14e8f27cfa2a73de4b969f1">CALLBACK_METRIC_PATTERN</a> = <span class="stringliteral">"statestore-subscriber.topic-$0.processing-time-s"</span>;</div> |
| <div class="line"><a name="l00055"></a><span class="lineno"> 55</span> </div> |
| <div class="line"><a name="l00056"></a><span class="lineno"> 56</span> <span class="comment">// Duration, in ms, to sleep between attempts to reconnect to the</span></div> |
| <div class="line"><a name="l00057"></a><span class="lineno"> 57</span> <span class="comment">// statestore after a failure.</span></div> |
| <div class="line"><a name="l00058"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a035bc6fb88ad7130d82267ef051d4bf2"> 58</a></span> <span class="keyword">const</span> int32_t <a class="code" href="namespaceimpala.html#a035bc6fb88ad7130d82267ef051d4bf2">SLEEP_INTERVAL_MS</a> = 5000;</div> |
| <div class="line"><a name="l00059"></a><span class="lineno"> 59</span> </div> |
| <div class="line"><a name="l00060"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a563ea3461b2bc1849f85f6ee3dea845d"> 60</a></span> <span class="keyword">typedef</span> <a class="code" href="classimpala_1_1ClientConnection.html">ClientConnection<StatestoreServiceClient></a> <a class="code" href="namespaceimpala.html#a563ea3461b2bc1849f85f6ee3dea845d">StatestoreConnection</a>;</div> |
| <div class="line"><a name="l00061"></a><span class="lineno"> 61</span> </div> |
| <div class="line"><a name="l00062"></a><span class="lineno"> 62</span> <span class="comment">// Proxy class for the subscriber heartbeat thrift API, which</span></div> |
| <div class="line"><a name="l00063"></a><span class="lineno"> 63</span> <span class="comment">// translates RPCs into method calls on the local subscriber object.</span></div> |
| <div class="line"><a name="l00064"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriberThriftIf.html"> 64</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html">StatestoreSubscriberThriftIf</a> : <span class="keyword">public</span> <a class="code" href="classStatestoreSubscriberIf.html">StatestoreSubscriberIf</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="l00066"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a5874291979dbcd391be2f1a35d10ef25"> 66</a></span>  <a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a5874291979dbcd391be2f1a35d10ef25">StatestoreSubscriberThriftIf</a>(<a class="code" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a>* subscriber)</div> |
| <div class="line"><a name="l00067"></a><span class="lineno"> 67</span>  : subscriber_(subscriber) { DCHECK(subscriber != NULL); }</div> |
| <div class="line"><a name="l00068"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a05b942fe1b2e0b049193c5e3e71914e1"> 68</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a05b942fe1b2e0b049193c5e3e71914e1">UpdateState</a>(TUpdateStateResponse& response,</div> |
| <div class="line"><a name="l00069"></a><span class="lineno"> 69</span>  <span class="keyword">const</span> TUpdateStateRequest& params) {</div> |
| <div class="line"><a name="l00070"></a><span class="lineno"> 70</span>  TUniqueId registration_id;</div> |
| <div class="line"><a name="l00071"></a><span class="lineno"> 71</span>  <span class="keywordflow">if</span> (params.__isset.registration_id) {</div> |
| <div class="line"><a name="l00072"></a><span class="lineno"> 72</span>  registration_id = params.registration_id;</div> |
| <div class="line"><a name="l00073"></a><span class="lineno"> 73</span>  }</div> |
| <div class="line"><a name="l00074"></a><span class="lineno"> 74</span> </div> |
| <div class="line"><a name="l00075"></a><span class="lineno"> 75</span>  subscriber_->UpdateState(params.topic_deltas, registration_id,</div> |
| <div class="line"><a name="l00076"></a><span class="lineno"> 76</span>  &response.topic_updates, &response.skipped).ToThrift(&response.status);</div> |
| <div class="line"><a name="l00077"></a><span class="lineno"> 77</span>  <span class="comment">// Make sure Thrift thinks the field is set.</span></div> |
| <div class="line"><a name="l00078"></a><span class="lineno"> 78</span>  response.__set_skipped(response.skipped);</div> |
| <div class="line"><a name="l00079"></a><span class="lineno"> 79</span>  }</div> |
| <div class="line"><a name="l00080"></a><span class="lineno"> 80</span> </div> |
| <div class="line"><a name="l00081"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a5c8a151d4ff080cedf53474d00b2b5a7"> 81</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a5c8a151d4ff080cedf53474d00b2b5a7">Heartbeat</a>(THeartbeatResponse& response, <span class="keyword">const</span> THeartbeatRequest& request) {</div> |
| <div class="line"><a name="l00082"></a><span class="lineno"> 82</span>  subscriber_->Heartbeat(request.registration_id);</div> |
| <div class="line"><a name="l00083"></a><span class="lineno"> 83</span>  }</div> |
| <div class="line"><a name="l00084"></a><span class="lineno"> 84</span> </div> |
| <div class="line"><a name="l00085"></a><span class="lineno"> 85</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00086"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a3533358f98b2a89a5d4cb597967f08cf"> 86</a></span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html">StatestoreSubscriber</a>* <a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html#a3533358f98b2a89a5d4cb597967f08cf">subscriber_</a>;</div> |
| <div class="line"><a name="l00087"></a><span class="lineno"> 87</span> };</div> |
| <div class="line"><a name="l00088"></a><span class="lineno"> 88</span> </div> |
| <div class="line"><a name="l00089"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ae36a7a9bae5f9bb10a52ed6214ca1a5a"> 89</a></span> StatestoreSubscriber::StatestoreSubscriber(<span class="keyword">const</span> std::string& subscriber_id,</div> |
| <div class="line"><a name="l00090"></a><span class="lineno"> 90</span>  <span class="keyword">const</span> TNetworkAddress& heartbeat_address, <span class="keyword">const</span> TNetworkAddress& statestore_address,</div> |
| <div class="line"><a name="l00091"></a><span class="lineno"> 91</span>  <a class="code" href="classimpala_1_1MetricGroup.html">MetricGroup</a>* metrics)</div> |
| <div class="line"><a name="l00092"></a><span class="lineno"> 92</span>  : subscriber_id_(subscriber_id), heartbeat_address_(heartbeat_address),</div> |
| <div class="line"><a name="l00093"></a><span class="lineno"> 93</span>  statestore_address_(statestore_address),</div> |
| <div class="line"><a name="l00094"></a><span class="lineno"> 94</span>  thrift_iface_(new <a class="code" href="classimpala_1_1StatestoreSubscriberThriftIf.html">StatestoreSubscriberThriftIf</a>(this)),</div> |
| <div class="line"><a name="l00095"></a><span class="lineno"> 95</span>  failure_detector_(new <a class="code" href="classimpala_1_1TimeoutFailureDetector.html">TimeoutFailureDetector</a>(</div> |
| <div class="line"><a name="l00096"></a><span class="lineno"> 96</span>  seconds(FLAGS_statestore_subscriber_timeout_seconds),</div> |
| <div class="line"><a name="l00097"></a><span class="lineno"> 97</span>  seconds(FLAGS_statestore_subscriber_timeout_seconds / 2))),</div> |
| <div class="line"><a name="l00098"></a><span class="lineno"> 98</span>  is_registered_(false),</div> |
| <div class="line"><a name="l00099"></a><span class="lineno"> 99</span>  client_cache_(new <a class="code" href="classimpala_1_1ClientCache.html">StatestoreClientCache</a>(FLAGS_statestore_subscriber_cnxn_attempts,</div> |
| <div class="line"><a name="l00100"></a><span class="lineno"> 100</span>  FLAGS_statestore_subscriber_cnxn_retry_interval_ms)),</div> |
| <div class="line"><a name="l00101"></a><span class="lineno"> 101</span>  metrics_(metrics->GetChildGroup(<span class="stringliteral">"statestore-subscriber"</span>)) {</div> |
| <div class="line"><a name="l00102"></a><span class="lineno"> 102</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a608844261bc61fbc3a5f323b39f6fc6e">connected_to_statestore_metric_</a> =</div> |
| <div class="line"><a name="l00103"></a><span class="lineno"> 103</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">metrics_</a>-><a class="code" href="classimpala_1_1MetricGroup.html#acb181cc1e3e171a504b28756a5aa5110">AddProperty</a>(<span class="stringliteral">"statestore-subscriber.connected"</span>, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00104"></a><span class="lineno"> 104</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afeb39f5e2fa795db5d46df4f2e4e8a93">last_recovery_duration_metric_</a> = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">metrics_</a>-><a class="code" href="classimpala_1_1MetricGroup.html#a32616eb20d4069c50427dfde1f89c376">AddGauge</a>(</div> |
| <div class="line"><a name="l00105"></a><span class="lineno"> 105</span>  <span class="stringliteral">"statestore-subscriber.last-recovery-duration"</span>, 0.0);</div> |
| <div class="line"><a name="l00106"></a><span class="lineno"> 106</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afe503b062fff002d6544a0d5182fa1ac">last_recovery_time_metric_</a> = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">metrics_</a>-><a class="code" href="classimpala_1_1MetricGroup.html#acb181cc1e3e171a504b28756a5aa5110">AddProperty</a><<span class="keywordtype">string</span>>(</div> |
| <div class="line"><a name="l00107"></a><span class="lineno"> 107</span>  <span class="stringliteral">"statestore-subscriber.last-recovery-time"</span>, <span class="stringliteral">"N/A"</span>);</div> |
| <div class="line"><a name="l00108"></a><span class="lineno"> 108</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae3a0727dfbe61b9c62913e6ecbd91348">topic_update_interval_metric_</a> = metrics-><a class="code" href="classimpala_1_1MetricGroup.html#a7b6ae979dcd7b3929354a1b23272e759">RegisterMetric</a>(</div> |
| <div class="line"><a name="l00109"></a><span class="lineno"> 109</span>  <span class="keyword">new</span> <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>(<span class="stringliteral">"statestore-subscriber.topic-update-interval-time"</span>,</div> |
| <div class="line"><a name="l00110"></a><span class="lineno"> 110</span>  TUnit::TIME_S));</div> |
| <div class="line"><a name="l00111"></a><span class="lineno"> 111</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a0fa88fd4d81890b88e9a4d9e3e573992">topic_update_duration_metric_</a> = metrics-><a class="code" href="classimpala_1_1MetricGroup.html#a7b6ae979dcd7b3929354a1b23272e759">RegisterMetric</a>(</div> |
| <div class="line"><a name="l00112"></a><span class="lineno"> 112</span>  <span class="keyword">new</span> <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>(<span class="stringliteral">"statestore-subscriber.topic-update-duration"</span>,</div> |
| <div class="line"><a name="l00113"></a><span class="lineno"> 113</span>  TUnit::TIME_S));</div> |
| <div class="line"><a name="l00114"></a><span class="lineno"> 114</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#aaf036a4c0f68d974fc04146bcd9152be">heartbeat_interval_metric_</a> = metrics-><a class="code" href="classimpala_1_1MetricGroup.html#a7b6ae979dcd7b3929354a1b23272e759">RegisterMetric</a>(</div> |
| <div class="line"><a name="l00115"></a><span class="lineno"> 115</span>  <span class="keyword">new</span> <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>(<span class="stringliteral">"statestore-subscriber.heartbeat-interval-time"</span>,</div> |
| <div class="line"><a name="l00116"></a><span class="lineno"> 116</span>  TUnit::TIME_S));</div> |
| <div class="line"><a name="l00117"></a><span class="lineno"> 117</span> </div> |
| <div class="line"><a name="l00118"></a><span class="lineno"> 118</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a56bc5af9989d57bdc89fc5b61484a8d0">registration_id_metric_</a> = metrics-><a class="code" href="classimpala_1_1MetricGroup.html#acb181cc1e3e171a504b28756a5aa5110">AddProperty</a><<span class="keywordtype">string</span>>(</div> |
| <div class="line"><a name="l00119"></a><span class="lineno"> 119</span>  <span class="stringliteral">"statestore-subscriber.registration-id"</span>, <span class="stringliteral">"N/A"</span>,</div> |
| <div class="line"><a name="l00120"></a><span class="lineno"> 120</span>  <span class="stringliteral">"The most recent registration ID for this subscriber with the statestore. Set to "</span></div> |
| <div class="line"><a name="l00121"></a><span class="lineno"> 121</span>  <span class="stringliteral">"'N/A' if no registration has been completed"</span>);</div> |
| <div class="line"><a name="l00122"></a><span class="lineno"> 122</span> </div> |
| <div class="line"><a name="l00123"></a><span class="lineno"> 123</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a58a05e063a904a32064a2053e3c604ff">client_cache_</a>->InitMetrics(metrics, <span class="stringliteral">"statestore-subscriber.statestore"</span>);</div> |
| <div class="line"><a name="l00124"></a><span class="lineno"> 124</span> }</div> |
| <div class="line"><a name="l00125"></a><span class="lineno"> 125</span> </div> |
| <div class="line"><a name="l00126"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#afc9a9b084411e93362c65e7b6a5b1ff2"> 126</a></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afc9a9b084411e93362c65e7b6a5b1ff2">StatestoreSubscriber::AddTopic</a>(<span class="keyword">const</span> <a class="code" href="classimpala_1_1Statestore.html#aa0a261a02804c62cb4b204a498e2e3ed">Statestore::TopicId</a>& topic_id,</div> |
| <div class="line"><a name="l00127"></a><span class="lineno"> 127</span>  <span class="keywordtype">bool</span> is_transient, <span class="keyword">const</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afbaf06f3e5f1f339801d522b0091fc0c">UpdateCallback</a>& callback) {</div> |
| <div class="line"><a name="l00128"></a><span class="lineno"> 128</span>  lock_guard<mutex> l(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410">lock_</a>);</div> |
| <div class="line"><a name="l00129"></a><span class="lineno"> 129</span>  <span class="keywordflow">if</span> (<a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae5be8d3382d65898e0310fac283771fb">is_registered_</a>) <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">"Subscriber already started, can't add new topic"</span>);</div> |
| <div class="line"><a name="l00130"></a><span class="lineno"> 130</span>  <a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html">Callbacks</a>* cb = &(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4">update_callbacks_</a>[topic_id]);</div> |
| <div class="line"><a name="l00131"></a><span class="lineno"> 131</span>  cb-><a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#a0d5d67608c46a564ddaf3ec8a4339774">callbacks</a>.push_back(callback);</div> |
| <div class="line"><a name="l00132"></a><span class="lineno"> 132</span>  <span class="keywordflow">if</span> (cb-><a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#abe5c5214b13614f615c3ba560996498a">processing_time_metric</a> == NULL) {</div> |
| <div class="line"><a name="l00133"></a><span class="lineno"> 133</span>  <span class="keyword">const</span> <span class="keywordtype">string</span>& metric_name = Substitute(<a class="code" href="namespaceimpala.html#a992d29b9f14e8f27cfa2a73de4b969f1">CALLBACK_METRIC_PATTERN</a>, topic_id);</div> |
| <div class="line"><a name="l00134"></a><span class="lineno"> 134</span>  cb-><a class="code" href="structimpala_1_1StatestoreSubscriber_1_1Callbacks.html#abe5c5214b13614f615c3ba560996498a">processing_time_metric</a> = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">metrics_</a>-><a class="code" href="classimpala_1_1MetricGroup.html#a7b6ae979dcd7b3929354a1b23272e759">RegisterMetric</a>(</div> |
| <div class="line"><a name="l00135"></a><span class="lineno"> 135</span>  <span class="keyword">new</span> <a class="code" href="classimpala_1_1StatsMetric.html">StatsMetric<double></a>(metric_name, TUnit::TIME_S));</div> |
| <div class="line"><a name="l00136"></a><span class="lineno"> 136</span>  }</div> |
| <div class="line"><a name="l00137"></a><span class="lineno"> 137</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a2c211908c8ab573e26307b6c513d53a3">topic_registrations_</a>[topic_id] = is_transient;</div> |
| <div class="line"><a name="l00138"></a><span class="lineno"> 138</span>  <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div> |
| <div class="line"><a name="l00139"></a><span class="lineno"> 139</span> }</div> |
| <div class="line"><a name="l00140"></a><span class="lineno"> 140</span> </div> |
| <div class="line"><a name="l00141"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ab926c3659fa0dfa7ca419d410eb8305f"> 141</a></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab926c3659fa0dfa7ca419d410eb8305f">StatestoreSubscriber::Register</a>() {</div> |
| <div class="line"><a name="l00142"></a><span class="lineno"> 142</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> client_status;</div> |
| <div class="line"><a name="l00143"></a><span class="lineno"> 143</span>  <a class="code" href="classimpala_1_1ClientConnection.html">StatestoreConnection</a> client(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a58a05e063a904a32064a2053e3c604ff">client_cache_</a>.get(), <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a0f11b1888b0d856e01d289efa6077e63">statestore_address_</a>, &client_status);</div> |
| <div class="line"><a name="l00144"></a><span class="lineno"> 144</span>  <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(client_status);</div> |
| <div class="line"><a name="l00145"></a><span class="lineno"> 145</span> </div> |
| <div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  TRegisterSubscriberRequest request;</div> |
| <div class="line"><a name="l00147"></a><span class="lineno"> 147</span>  request.topic_registrations.reserve(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4">update_callbacks_</a>.size());</div> |
| <div class="line"><a name="l00148"></a><span class="lineno"> 148</span>  BOOST_FOREACH(<span class="keyword">const</span> UpdateCallbacks::value_type& topic, <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4">update_callbacks_</a>) {</div> |
| <div class="line"><a name="l00149"></a><span class="lineno"> 149</span>  TTopicRegistration thrift_topic;</div> |
| <div class="line"><a name="l00150"></a><span class="lineno"> 150</span>  thrift_topic.topic_name = topic.first;</div> |
| <div class="line"><a name="l00151"></a><span class="lineno"> 151</span>  thrift_topic.is_transient = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a2c211908c8ab573e26307b6c513d53a3">topic_registrations_</a>[topic.first];</div> |
| <div class="line"><a name="l00152"></a><span class="lineno"> 152</span>  request.topic_registrations.push_back(thrift_topic);</div> |
| <div class="line"><a name="l00153"></a><span class="lineno"> 153</span>  }</div> |
| <div class="line"><a name="l00154"></a><span class="lineno"> 154</span> </div> |
| <div class="line"><a name="l00155"></a><span class="lineno"> 155</span>  request.subscriber_location = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#acf7ae93ff26655b854e7a98fdd719541">heartbeat_address_</a>;</div> |
| <div class="line"><a name="l00156"></a><span class="lineno"> 156</span>  request.subscriber_id = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#abc056863a86ea547bbd54656c9a0575c">subscriber_id_</a>;</div> |
| <div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  TRegisterSubscriberResponse response;</div> |
| <div class="line"><a name="l00158"></a><span class="lineno"> 158</span>  <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(</div> |
| <div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  client.DoRpc(&StatestoreServiceClient::RegisterSubscriber, request, &response));</div> |
| <div class="line"><a name="l00160"></a><span class="lineno"> 160</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = <a class="code" href="classimpala_1_1Status.html">Status</a>(response.status);</div> |
| <div class="line"><a name="l00161"></a><span class="lineno"> 161</span>  <span class="keywordflow">if</span> (status.ok()) <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a608844261bc61fbc3a5f323b39f6fc6e">connected_to_statestore_metric_</a>->set_value(<span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00162"></a><span class="lineno"> 162</span>  <span class="keywordflow">if</span> (response.__isset.registration_id) {</div> |
| <div class="line"><a name="l00163"></a><span class="lineno"> 163</span>  lock_guard<mutex> l(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#aa45b5d93dfc88e3ac54e62e522427b7e">registration_id_lock_</a>);</div> |
| <div class="line"><a name="l00164"></a><span class="lineno"> 164</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">registration_id_</a> = response.registration_id;</div> |
| <div class="line"><a name="l00165"></a><span class="lineno"> 165</span>  <span class="keyword">const</span> <span class="keywordtype">string</span>& registration_string = <a class="code" href="namespaceimpala.html#a19e01fc90bc956ac7e1a735d2bea5a5e">PrintId</a>(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">registration_id_</a>);</div> |
| <div class="line"><a name="l00166"></a><span class="lineno"> 166</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a56bc5af9989d57bdc89fc5b61484a8d0">registration_id_metric_</a>->set_value(registration_string);</div> |
| <div class="line"><a name="l00167"></a><span class="lineno"> 167</span>  VLOG(1) << <span class="stringliteral">"Subscriber registration ID: "</span> << registration_string;</div> |
| <div class="line"><a name="l00168"></a><span class="lineno"> 168</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00169"></a><span class="lineno"> 169</span>  VLOG(1) << <span class="stringliteral">"No subscriber registration ID received from statestore"</span>;</div> |
| <div class="line"><a name="l00170"></a><span class="lineno"> 170</span>  }</div> |
| <div class="line"><a name="l00171"></a><span class="lineno"> 171</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#acb98cfad8aabf894a0df39be04bdc477">topic_update_interval_timer_</a>.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a5f42e96a173893f40aac4fb1e787faac">Start</a>();</div> |
| <div class="line"><a name="l00172"></a><span class="lineno"> 172</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a00b32439e297666cdd5ba1052ee04309">heartbeat_interval_timer_</a>.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a5f42e96a173893f40aac4fb1e787faac">Start</a>();</div> |
| <div class="line"><a name="l00173"></a><span class="lineno"> 173</span>  <span class="keywordflow">return</span> status;</div> |
| <div class="line"><a name="l00174"></a><span class="lineno"> 174</span> }</div> |
| <div class="line"><a name="l00175"></a><span class="lineno"> 175</span> </div> |
| <div class="line"><a name="l00176"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ae362f9dfb8bf27163c4362f31a308772"> 176</a></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae362f9dfb8bf27163c4362f31a308772">StatestoreSubscriber::Start</a>() {</div> |
| <div class="line"><a name="l00177"></a><span class="lineno"> 177</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status;</div> |
| <div class="line"><a name="l00178"></a><span class="lineno"> 178</span>  {</div> |
| <div class="line"><a name="l00179"></a><span class="lineno"> 179</span>  <span class="comment">// Take the lock to ensure that, if a topic-update is received during registration</span></div> |
| <div class="line"><a name="l00180"></a><span class="lineno"> 180</span>  <span class="comment">// (perhaps because Register() has succeeded, but we haven't finished setting up state</span></div> |
| <div class="line"><a name="l00181"></a><span class="lineno"> 181</span>  <span class="comment">// on the client side), UpdateState() will reject the message.</span></div> |
| <div class="line"><a name="l00182"></a><span class="lineno"> 182</span>  lock_guard<mutex> l(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410">lock_</a>);</div> |
| <div class="line"><a name="l00183"></a><span class="lineno"> 183</span>  LOG(INFO) << <span class="stringliteral">"Starting statestore subscriber"</span>;</div> |
| <div class="line"><a name="l00184"></a><span class="lineno"> 184</span> </div> |
| <div class="line"><a name="l00185"></a><span class="lineno"> 185</span>  <span class="comment">// Backend must be started before registration</span></div> |
| <div class="line"><a name="l00186"></a><span class="lineno"> 186</span>  shared_ptr<TProcessor> processor(<span class="keyword">new</span> StatestoreSubscriberProcessor(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#adb79a2b995e5328fe4b0bd673ca10d9a">thrift_iface_</a>));</div> |
| <div class="line"><a name="l00187"></a><span class="lineno"> 187</span>  shared_ptr<TProcessorEventHandler> event_handler(</div> |
| <div class="line"><a name="l00188"></a><span class="lineno"> 188</span>  <span class="keyword">new</span> <a class="code" href="classimpala_1_1RpcEventHandler.html">RpcEventHandler</a>(<span class="stringliteral">"statestore-subscriber"</span>, <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a659c52f90869723e50ab81a161965cac">metrics_</a>));</div> |
| <div class="line"><a name="l00189"></a><span class="lineno"> 189</span>  processor->setEventHandler(event_handler);</div> |
| <div class="line"><a name="l00190"></a><span class="lineno"> 190</span> </div> |
| <div class="line"><a name="l00191"></a><span class="lineno"> 191</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae7c3999eac69077548f22772c80192d8">heartbeat_server_</a>.reset(<span class="keyword">new</span> <a class="code" href="classimpala_1_1ThriftServer.html">ThriftServer</a>(<span class="stringliteral">"StatestoreSubscriber"</span>, processor,</div> |
| <div class="line"><a name="l00192"></a><span class="lineno"> 192</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#acf7ae93ff26655b854e7a98fdd719541">heartbeat_address_</a>.port, NULL, NULL, 5));</div> |
| <div class="line"><a name="l00193"></a><span class="lineno"> 193</span>  <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae7c3999eac69077548f22772c80192d8">heartbeat_server_</a>->Start());</div> |
| <div class="line"><a name="l00194"></a><span class="lineno"> 194</span>  LOG(INFO) << <span class="stringliteral">"Registering with statestore"</span>;</div> |
| <div class="line"><a name="l00195"></a><span class="lineno"> 195</span>  status = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab926c3659fa0dfa7ca419d410eb8305f">Register</a>();</div> |
| <div class="line"><a name="l00196"></a><span class="lineno"> 196</span>  <span class="keywordflow">if</span> (status.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>()) {</div> |
| <div class="line"><a name="l00197"></a><span class="lineno"> 197</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae5be8d3382d65898e0310fac283771fb">is_registered_</a> = <span class="keyword">true</span>;</div> |
| <div class="line"><a name="l00198"></a><span class="lineno"> 198</span>  LOG(INFO) << <span class="stringliteral">"statestore registration successful"</span>;</div> |
| <div class="line"><a name="l00199"></a><span class="lineno"> 199</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00200"></a><span class="lineno"> 200</span>  LOG(INFO) << <span class="stringliteral">"statestore registration unsuccessful: "</span> << status.<a class="code" href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">GetDetail</a>();</div> |
| <div class="line"><a name="l00201"></a><span class="lineno"> 201</span>  }</div> |
| <div class="line"><a name="l00202"></a><span class="lineno"> 202</span>  }</div> |
| <div class="line"><a name="l00203"></a><span class="lineno"> 203</span> </div> |
| <div class="line"><a name="l00204"></a><span class="lineno"> 204</span>  <span class="comment">// Registration is finished at this point, so it's fine to release the lock.</span></div> |
| <div class="line"><a name="l00205"></a><span class="lineno"> 205</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a10cf593e773daad628aa64d6b31cfd96">recovery_mode_thread_</a>.reset(<span class="keyword">new</span> <a class="code" href="classimpala_1_1Thread.html">Thread</a>(<span class="stringliteral">"statestore-subscriber"</span>, <span class="stringliteral">"recovery-mode-thread"</span>,</div> |
| <div class="line"><a name="l00206"></a><span class="lineno"> 206</span>  &<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a9484addc4e8c80aca6a10b584a404642">StatestoreSubscriber::RecoveryModeChecker</a>, <span class="keyword">this</span>));</div> |
| <div class="line"><a name="l00207"></a><span class="lineno"> 207</span> </div> |
| <div class="line"><a name="l00208"></a><span class="lineno"> 208</span>  <span class="keywordflow">return</span> status;</div> |
| <div class="line"><a name="l00209"></a><span class="lineno"> 209</span> }</div> |
| <div class="line"><a name="l00210"></a><span class="lineno"> 210</span> </div> |
| <div class="line"><a name="l00211"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a9484addc4e8c80aca6a10b584a404642"> 211</a></span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a9484addc4e8c80aca6a10b584a404642">StatestoreSubscriber::RecoveryModeChecker</a>() {</div> |
| <div class="line"><a name="l00212"></a><span class="lineno"> 212</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1">failure_detector_</a>->UpdateHeartbeat(<a class="code" href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0">STATESTORE_ID</a>, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00213"></a><span class="lineno"> 213</span> </div> |
| <div class="line"><a name="l00214"></a><span class="lineno"> 214</span>  <span class="comment">// Every few seconds, wake up and check if the failure detector has determined</span></div> |
| <div class="line"><a name="l00215"></a><span class="lineno"> 215</span>  <span class="comment">// that the statestore has failed from our perspective. If so, enter recovery</span></div> |
| <div class="line"><a name="l00216"></a><span class="lineno"> 216</span>  <span class="comment">// mode and try to reconnect, followed by reregistering all subscriptions.</span></div> |
| <div class="line"><a name="l00217"></a><span class="lineno"> 217</span>  <span class="keywordflow">while</span> (<span class="keyword">true</span>) {</div> |
| <div class="line"><a name="l00218"></a><span class="lineno"> 218</span>  <span class="keywordflow">if</span> (<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1">failure_detector_</a>->GetPeerState(<a class="code" href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0">STATESTORE_ID</a>) == <a class="code" href="classimpala_1_1FailureDetector.html#ab1f72b41f370a931fd4e44dd90fdf7e1a7c97d056ffa22a9374fe409d077d435b">FailureDetector::FAILED</a>) {</div> |
| <div class="line"><a name="l00219"></a><span class="lineno"> 219</span>  <span class="comment">// When entering recovery mode, the class-wide lock_ is taken to</span></div> |
| <div class="line"><a name="l00220"></a><span class="lineno"> 220</span>  <span class="comment">// ensure mutual exclusion with any operations in flight.</span></div> |
| <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  lock_guard<mutex> l(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410">lock_</a>);</div> |
| <div class="line"><a name="l00222"></a><span class="lineno"> 222</span>  <a class="code" href="classimpala_1_1MonotonicStopWatch.html">MonotonicStopWatch</a> recovery_timer;</div> |
| <div class="line"><a name="l00223"></a><span class="lineno"> 223</span>  recovery_timer.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a5f42e96a173893f40aac4fb1e787faac">Start</a>();</div> |
| <div class="line"><a name="l00224"></a><span class="lineno"> 224</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a608844261bc61fbc3a5f323b39f6fc6e">connected_to_statestore_metric_</a>->set_value(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00225"></a><span class="lineno"> 225</span>  LOG(INFO) << <a class="code" href="classimpala_1_1StatestoreSubscriber.html#abc056863a86ea547bbd54656c9a0575c">subscriber_id_</a></div> |
| <div class="line"><a name="l00226"></a><span class="lineno"> 226</span>  << <span class="stringliteral">": Connection with statestore lost, entering recovery mode"</span>;</div> |
| <div class="line"><a name="l00227"></a><span class="lineno"> 227</span>  uint32_t attempt_count = 1;</div> |
| <div class="line"><a name="l00228"></a><span class="lineno"> 228</span>  <span class="keywordflow">while</span> (<span class="keyword">true</span>) {</div> |
| <div class="line"><a name="l00229"></a><span class="lineno"> 229</span>  LOG(INFO) << <span class="stringliteral">"Trying to re-register with statestore, attempt: "</span></div> |
| <div class="line"><a name="l00230"></a><span class="lineno"> 230</span>  << attempt_count++;</div> |
| <div class="line"><a name="l00231"></a><span class="lineno"> 231</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab926c3659fa0dfa7ca419d410eb8305f">Register</a>();</div> |
| <div class="line"><a name="l00232"></a><span class="lineno"> 232</span>  <span class="keywordflow">if</span> (status.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>()) {</div> |
| <div class="line"><a name="l00233"></a><span class="lineno"> 233</span>  <span class="comment">// Make sure to update failure detector so that we don't immediately fail on the</span></div> |
| <div class="line"><a name="l00234"></a><span class="lineno"> 234</span>  <span class="comment">// next loop while we're waiting for heartbeat messages to resume.</span></div> |
| <div class="line"><a name="l00235"></a><span class="lineno"> 235</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1">failure_detector_</a>->UpdateHeartbeat(<a class="code" href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0">STATESTORE_ID</a>, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00236"></a><span class="lineno"> 236</span>  LOG(INFO) << <span class="stringliteral">"Reconnected to statestore. Exiting recovery mode"</span>;</div> |
| <div class="line"><a name="l00237"></a><span class="lineno"> 237</span> </div> |
| <div class="line"><a name="l00238"></a><span class="lineno"> 238</span>  <span class="comment">// Break out of enclosing while (true) to top of outer-scope loop.</span></div> |
| <div class="line"><a name="l00239"></a><span class="lineno"> 239</span>  <span class="keywordflow">break</span>;</div> |
| <div class="line"><a name="l00240"></a><span class="lineno"> 240</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00241"></a><span class="lineno"> 241</span>  <span class="comment">// Don't exit recovery mode, continue</span></div> |
| <div class="line"><a name="l00242"></a><span class="lineno"> 242</span>  LOG(WARNING) << <span class="stringliteral">"Failed to re-register with statestore: "</span></div> |
| <div class="line"><a name="l00243"></a><span class="lineno"> 243</span>  << status.<a class="code" href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">GetDetail</a>();</div> |
| <div class="line"><a name="l00244"></a><span class="lineno"> 244</span>  <a class="code" href="namespaceimpala.html#a57debe017e657e4692b405fa183f7ca8">SleepForMs</a>(<a class="code" href="namespaceimpala.html#a035bc6fb88ad7130d82267ef051d4bf2">SLEEP_INTERVAL_MS</a>);</div> |
| <div class="line"><a name="l00245"></a><span class="lineno"> 245</span>  }</div> |
| <div class="line"><a name="l00246"></a><span class="lineno"> 246</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afeb39f5e2fa795db5d46df4f2e4e8a93">last_recovery_duration_metric_</a>->set_value(</div> |
| <div class="line"><a name="l00247"></a><span class="lineno"> 247</span>  recovery_timer.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a4a5fdb04f9b13278b9c636e472330976">ElapsedTime</a>() / (1000.0 * 1000.0 * 1000.0));</div> |
| <div class="line"><a name="l00248"></a><span class="lineno"> 248</span>  }</div> |
| <div class="line"><a name="l00249"></a><span class="lineno"> 249</span>  <span class="comment">// When we're successful in re-registering, we don't do anything</span></div> |
| <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  <span class="comment">// to re-send our updates to the statestore. It is the</span></div> |
| <div class="line"><a name="l00251"></a><span class="lineno"> 251</span>  <span class="comment">// responsibility of individual clients to post missing updates</span></div> |
| <div class="line"><a name="l00252"></a><span class="lineno"> 252</span>  <span class="comment">// back to the statestore. This saves a lot of complexity where</span></div> |
| <div class="line"><a name="l00253"></a><span class="lineno"> 253</span>  <span class="comment">// we would otherwise have to cache updates here.</span></div> |
| <div class="line"><a name="l00254"></a><span class="lineno"> 254</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afeb39f5e2fa795db5d46df4f2e4e8a93">last_recovery_duration_metric_</a>->set_value(</div> |
| <div class="line"><a name="l00255"></a><span class="lineno"> 255</span>  recovery_timer.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a4a5fdb04f9b13278b9c636e472330976">ElapsedTime</a>() / (1000.0 * 1000.0 * 1000.0));</div> |
| <div class="line"><a name="l00256"></a><span class="lineno"> 256</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afe503b062fff002d6544a0d5182fa1ac">last_recovery_time_metric_</a>->set_value(<a class="code" href="classimpala_1_1TimestampValue.html#ab9e0cd56dbef646bcf8bdba06ae775b3">TimestampValue::LocalTime</a>().<a class="code" href="namespaceimpala__udf.html#aa263bafd77b9eb6acc16458d70d160a4">DebugString</a>());</div> |
| <div class="line"><a name="l00257"></a><span class="lineno"> 257</span>  }</div> |
| <div class="line"><a name="l00258"></a><span class="lineno"> 258</span> </div> |
| <div class="line"><a name="l00259"></a><span class="lineno"> 259</span>  <a class="code" href="namespaceimpala.html#a57debe017e657e4692b405fa183f7ca8">SleepForMs</a>(<a class="code" href="namespaceimpala.html#a035bc6fb88ad7130d82267ef051d4bf2">SLEEP_INTERVAL_MS</a>);</div> |
| <div class="line"><a name="l00260"></a><span class="lineno"> 260</span>  }</div> |
| <div class="line"><a name="l00261"></a><span class="lineno"> 261</span> }</div> |
| <div class="line"><a name="l00262"></a><span class="lineno"> 262</span> </div> |
| <div class="line"><a name="l00263"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#a190aff056caef5690f3066f0f54e6a41"> 263</a></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a190aff056caef5690f3066f0f54e6a41">StatestoreSubscriber::CheckRegistrationId</a>(<span class="keyword">const</span> TUniqueId& registration_id) {</div> |
| <div class="line"><a name="l00264"></a><span class="lineno"> 264</span>  {</div> |
| <div class="line"><a name="l00265"></a><span class="lineno"> 265</span>  lock_guard<mutex> r(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#aa45b5d93dfc88e3ac54e62e522427b7e">registration_id_lock_</a>);</div> |
| <div class="line"><a name="l00266"></a><span class="lineno"> 266</span>  <span class="comment">// If this subscriber has just started, the registration_id_ may not have been set</span></div> |
| <div class="line"><a name="l00267"></a><span class="lineno"> 267</span>  <span class="comment">// despite the statestore starting to send updates. The 'unset' TUniqueId is 0:0, so</span></div> |
| <div class="line"><a name="l00268"></a><span class="lineno"> 268</span>  <span class="comment">// we can differentiate between a) an early message from an eager statestore, and b)</span></div> |
| <div class="line"><a name="l00269"></a><span class="lineno"> 269</span>  <span class="comment">// a message that's targeted to a previous registration.</span></div> |
| <div class="line"><a name="l00270"></a><span class="lineno"> 270</span>  <span class="keywordflow">if</span> (<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">registration_id_</a> != TUniqueId() && registration_id != <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">registration_id_</a>) {</div> |
| <div class="line"><a name="l00271"></a><span class="lineno"> 271</span>  <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(Substitute(<span class="stringliteral">"Unexpected registration ID: $0, was expecting $1"</span>,</div> |
| <div class="line"><a name="l00272"></a><span class="lineno"> 272</span>  <a class="code" href="namespaceimpala.html#a19e01fc90bc956ac7e1a735d2bea5a5e">PrintId</a>(registration_id), <a class="code" href="namespaceimpala.html#a19e01fc90bc956ac7e1a735d2bea5a5e">PrintId</a>(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6168307fe4ede47191ecb7c44d941b40">registration_id_</a>)));</div> |
| <div class="line"><a name="l00273"></a><span class="lineno"> 273</span>  }</div> |
| <div class="line"><a name="l00274"></a><span class="lineno"> 274</span>  }</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>  <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</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"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#af3d6f3b8bec22de9521526aa62ad064c"> 279</a></span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#af3d6f3b8bec22de9521526aa62ad064c">StatestoreSubscriber::Heartbeat</a>(<span class="keyword">const</span> TUniqueId& registration_id) {</div> |
| <div class="line"><a name="l00280"></a><span class="lineno"> 280</span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1Status.html">Status</a>& status = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a190aff056caef5690f3066f0f54e6a41">CheckRegistrationId</a>(registration_id);</div> |
| <div class="line"><a name="l00281"></a><span class="lineno"> 281</span>  <span class="keywordflow">if</span> (status.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>()) {</div> |
| <div class="line"><a name="l00282"></a><span class="lineno"> 282</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#aaf036a4c0f68d974fc04146bcd9152be">heartbeat_interval_metric_</a>-><a class="code" href="classimpala_1_1StatsMetric.html#a63e36e6ce39c43df7144d970dd0be733">Update</a>(</div> |
| <div class="line"><a name="l00283"></a><span class="lineno"> 283</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a00b32439e297666cdd5ba1052ee04309">heartbeat_interval_timer_</a>.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#ab1811a1b7b6050a2f2d021fca6c89cea">Reset</a>() / (1000.0 * 1000.0 * 1000.0));</div> |
| <div class="line"><a name="l00284"></a><span class="lineno"> 284</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a6850007d07f73b300509be1fd3f40bb1">failure_detector_</a>->UpdateHeartbeat(<a class="code" href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0">STATESTORE_ID</a>, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00285"></a><span class="lineno"> 285</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00286"></a><span class="lineno"> 286</span>  <a class="code" href="logging_8h.html#a24efb6b382d3e1bdd7817e5e31dc5c1d">VLOG_RPC</a> << <span class="stringliteral">"Heartbeat: "</span> << status.<a class="code" href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">GetDetail</a>();</div> |
| <div class="line"><a name="l00287"></a><span class="lineno"> 287</span>  }</div> |
| <div class="line"><a name="l00288"></a><span class="lineno"> 288</span> }</div> |
| <div class="line"><a name="l00289"></a><span class="lineno"> 289</span> </div> |
| <div class="line"><a name="l00290"></a><span class="lineno"><a class="line" href="classimpala_1_1StatestoreSubscriber.html#ad5803fa31f6a5738fb7ded4a43b349cc"> 290</a></span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ad5803fa31f6a5738fb7ded4a43b349cc">StatestoreSubscriber::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="l00291"></a><span class="lineno"> 291</span>  <span class="keyword">const</span> TUniqueId& registration_id, vector<TTopicDelta>* subscriber_topic_updates,</div> |
| <div class="line"><a name="l00292"></a><span class="lineno"> 292</span>  <span class="keywordtype">bool</span>* skipped) {</div> |
| <div class="line"><a name="l00293"></a><span class="lineno"> 293</span>  <span class="comment">// We don't want to block here because this is an RPC, and delaying the return causes</span></div> |
| <div class="line"><a name="l00294"></a><span class="lineno"> 294</span>  <span class="comment">// the statestore to delay sending further messages. The only time that lock_ might be</span></div> |
| <div class="line"><a name="l00295"></a><span class="lineno"> 295</span>  <span class="comment">// taken concurrently is if:</span></div> |
| <div class="line"><a name="l00296"></a><span class="lineno"> 296</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00297"></a><span class="lineno"> 297</span>  <span class="comment">// a) another update is still being processed (i.e. is still in UpdateState()). This</span></div> |
| <div class="line"><a name="l00298"></a><span class="lineno"> 298</span>  <span class="comment">// could happen only when the subscriber has re-registered, and the statestore is still</span></div> |
| <div class="line"><a name="l00299"></a><span class="lineno"> 299</span>  <span class="comment">// sending an update for the previous registration. In this case, return OK but set</span></div> |
| <div class="line"><a name="l00300"></a><span class="lineno"> 300</span>  <span class="comment">// *skipped = true to tell the statestore to retry this update in the future.</span></div> |
| <div class="line"><a name="l00301"></a><span class="lineno"> 301</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00302"></a><span class="lineno"> 302</span>  <span class="comment">// b) the subscriber is recovering, and has the lock held during</span></div> |
| <div class="line"><a name="l00303"></a><span class="lineno"> 303</span>  <span class="comment">// RecoveryModeChecker(). Similarly, we set *skipped = true.</span></div> |
| <div class="line"><a name="l00304"></a><span class="lineno"> 304</span>  <span class="comment">// TODO: Consider returning an error in this case so that the statestore will eventually</span></div> |
| <div class="line"><a name="l00305"></a><span class="lineno"> 305</span>  <span class="comment">// stop sending updates even if re-registration fails.</span></div> |
| <div class="line"><a name="l00306"></a><span class="lineno"> 306</span>  try_mutex::scoped_try_lock l(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#ab972143162e20f1758457e6758c04410">lock_</a>);</div> |
| <div class="line"><a name="l00307"></a><span class="lineno"> 307</span>  <span class="keywordflow">if</span> (l) {</div> |
| <div class="line"><a name="l00308"></a><span class="lineno"> 308</span>  *skipped = <span class="keyword">false</span>;</div> |
| <div class="line"><a name="l00309"></a><span class="lineno"> 309</span>  <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1StatestoreSubscriber.html#a190aff056caef5690f3066f0f54e6a41">CheckRegistrationId</a>(registration_id));</div> |
| <div class="line"><a name="l00310"></a><span class="lineno"> 310</span> </div> |
| <div class="line"><a name="l00311"></a><span class="lineno"> 311</span>  <span class="comment">// Only record updates received when not in recovery mode</span></div> |
| <div class="line"><a name="l00312"></a><span class="lineno"> 312</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#ae3a0727dfbe61b9c62913e6ecbd91348">topic_update_interval_metric_</a>-><a class="code" href="classimpala_1_1StatsMetric.html#a63e36e6ce39c43df7144d970dd0be733">Update</a>(</div> |
| <div class="line"><a name="l00313"></a><span class="lineno"> 313</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#acb98cfad8aabf894a0df39be04bdc477">topic_update_interval_timer_</a>.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#ab1811a1b7b6050a2f2d021fca6c89cea">Reset</a>() / (1000.0 * 1000.0 * 1000.0));</div> |
| <div class="line"><a name="l00314"></a><span class="lineno"> 314</span>  <a class="code" href="classimpala_1_1MonotonicStopWatch.html">MonotonicStopWatch</a> sw;</div> |
| <div class="line"><a name="l00315"></a><span class="lineno"> 315</span>  sw.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a5f42e96a173893f40aac4fb1e787faac">Start</a>();</div> |
| <div class="line"><a name="l00316"></a><span class="lineno"> 316</span> </div> |
| <div class="line"><a name="l00317"></a><span class="lineno"> 317</span>  <span class="comment">// Check the version ranges of all delta updates to ensure they can be applied</span></div> |
| <div class="line"><a name="l00318"></a><span class="lineno"> 318</span>  <span class="comment">// to this subscriber. If any invalid ranges are found, request new update(s) with</span></div> |
| <div class="line"><a name="l00319"></a><span class="lineno"> 319</span>  <span class="comment">// version ranges applicable to this subscriber.</span></div> |
| <div class="line"><a name="l00320"></a><span class="lineno"> 320</span>  <span class="keywordtype">bool</span> found_unexpected_delta = <span class="keyword">false</span>;</div> |
| <div class="line"><a name="l00321"></a><span class="lineno"> 321</span>  BOOST_FOREACH(<span class="keyword">const</span> TopicDeltaMap::value_type& delta, incoming_topic_deltas) {</div> |
| <div class="line"><a name="l00322"></a><span class="lineno"> 322</span>  TopicVersionMap::const_iterator itr = <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a65b14aaee673a6bfe44495358f0c7f41">current_topic_versions_</a>.find(delta.first);</div> |
| <div class="line"><a name="l00323"></a><span class="lineno"> 323</span>  <span class="keywordflow">if</span> (itr != <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a65b14aaee673a6bfe44495358f0c7f41">current_topic_versions_</a>.end()) {</div> |
| <div class="line"><a name="l00324"></a><span class="lineno"> 324</span>  <span class="keywordflow">if</span> (delta.second.is_delta && delta.second.from_version != itr->second) {</div> |
| <div class="line"><a name="l00325"></a><span class="lineno"> 325</span>  LOG(ERROR) << <span class="stringliteral">"Unexpected delta update to topic '"</span> << delta.first << <span class="stringliteral">"' of "</span></div> |
| <div class="line"><a name="l00326"></a><span class="lineno"> 326</span>  << <span class="stringliteral">"version range ("</span> << delta.second.from_version << <span class="stringliteral">":"</span></div> |
| <div class="line"><a name="l00327"></a><span class="lineno"> 327</span>  << delta.second.to_version << <span class="stringliteral">"]. Expected delta start version: "</span></div> |
| <div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  << itr->second;</div> |
| <div class="line"><a name="l00329"></a><span class="lineno"> 329</span> </div> |
| <div class="line"><a name="l00330"></a><span class="lineno"> 330</span>  subscriber_topic_updates->push_back(TTopicDelta());</div> |
| <div class="line"><a name="l00331"></a><span class="lineno"> 331</span>  TTopicDelta& update = subscriber_topic_updates->back();</div> |
| <div class="line"><a name="l00332"></a><span class="lineno"> 332</span>  update.topic_name = delta.second.topic_name;</div> |
| <div class="line"><a name="l00333"></a><span class="lineno"> 333</span>  update.__set_from_version(itr->second);</div> |
| <div class="line"><a name="l00334"></a><span class="lineno"> 334</span>  found_unexpected_delta = <span class="keyword">true</span>;</div> |
| <div class="line"><a name="l00335"></a><span class="lineno"> 335</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00336"></a><span class="lineno"> 336</span>  <span class="comment">// Update the current topic version</span></div> |
| <div class="line"><a name="l00337"></a><span class="lineno"> 337</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a65b14aaee673a6bfe44495358f0c7f41">current_topic_versions_</a>[delta.first] = delta.second.to_version;</div> |
| <div class="line"><a name="l00338"></a><span class="lineno"> 338</span>  }</div> |
| <div class="line"><a name="l00339"></a><span class="lineno"> 339</span>  }</div> |
| <div class="line"><a name="l00340"></a><span class="lineno"> 340</span>  }</div> |
| <div class="line"><a name="l00341"></a><span class="lineno"> 341</span> </div> |
| <div class="line"><a name="l00342"></a><span class="lineno"> 342</span>  <span class="comment">// Skip calling the callbacks when an unexpected delta update is found.</span></div> |
| <div class="line"><a name="l00343"></a><span class="lineno"> 343</span>  <span class="keywordflow">if</span> (!found_unexpected_delta) {</div> |
| <div class="line"><a name="l00344"></a><span class="lineno"> 344</span>  BOOST_FOREACH(<span class="keyword">const</span> UpdateCallbacks::value_type& callbacks, <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a23618aa4345cce55d83f33011af603b4">update_callbacks_</a>) {</div> |
| <div class="line"><a name="l00345"></a><span class="lineno"> 345</span>  <a class="code" href="classimpala_1_1MonotonicStopWatch.html">MonotonicStopWatch</a> sw;</div> |
| <div class="line"><a name="l00346"></a><span class="lineno"> 346</span>  sw.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a5f42e96a173893f40aac4fb1e787faac">Start</a>();</div> |
| <div class="line"><a name="l00347"></a><span class="lineno"> 347</span>  BOOST_FOREACH(<span class="keyword">const</span> <a class="code" href="classimpala_1_1StatestoreSubscriber.html#afbaf06f3e5f1f339801d522b0091fc0c">UpdateCallback</a>& callback, callbacks.second.callbacks) {</div> |
| <div class="line"><a name="l00348"></a><span class="lineno"> 348</span>  <span class="comment">// TODO: Consider filtering the topics to only send registered topics to</span></div> |
| <div class="line"><a name="l00349"></a><span class="lineno"> 349</span>  <span class="comment">// callbacks</span></div> |
| <div class="line"><a name="l00350"></a><span class="lineno"> 350</span>  callback(incoming_topic_deltas, subscriber_topic_updates);</div> |
| <div class="line"><a name="l00351"></a><span class="lineno"> 351</span>  }</div> |
| <div class="line"><a name="l00352"></a><span class="lineno"> 352</span>  callbacks.second.processing_time_metric->Update(</div> |
| <div class="line"><a name="l00353"></a><span class="lineno"> 353</span>  sw.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a4a5fdb04f9b13278b9c636e472330976">ElapsedTime</a>() / (1000.0 * 1000.0 * 1000.0));</div> |
| <div class="line"><a name="l00354"></a><span class="lineno"> 354</span>  }</div> |
| <div class="line"><a name="l00355"></a><span class="lineno"> 355</span>  }</div> |
| <div class="line"><a name="l00356"></a><span class="lineno"> 356</span>  sw.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#ad51faa4e584e78430b2620572dd715b5">Stop</a>();</div> |
| <div class="line"><a name="l00357"></a><span class="lineno"> 357</span>  <a class="code" href="classimpala_1_1StatestoreSubscriber.html#a0fa88fd4d81890b88e9a4d9e3e573992">topic_update_duration_metric_</a>-><a class="code" href="classimpala_1_1StatsMetric.html#a63e36e6ce39c43df7144d970dd0be733">Update</a>(sw.<a class="code" href="classimpala_1_1MonotonicStopWatch.html#a4a5fdb04f9b13278b9c636e472330976">ElapsedTime</a>() / (1000.0 * 1000.0 * 1000.0));</div> |
| <div class="line"><a name="l00358"></a><span class="lineno"> 358</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00359"></a><span class="lineno"> 359</span>  *skipped = <span class="keyword">true</span>;</div> |
| <div class="line"><a name="l00360"></a><span class="lineno"> 360</span>  }</div> |
| <div class="line"><a name="l00361"></a><span class="lineno"> 361</span>  <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div> |
| <div class="line"><a name="l00362"></a><span class="lineno"> 362</span> }</div> |
| <div class="line"><a name="l00363"></a><span class="lineno"> 363</span> </div> |
| <div class="line"><a name="l00364"></a><span class="lineno"> 364</span> </div> |
| <div class="line"><a name="l00365"></a><span class="lineno"> 365</span> }</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_1Status_html_adf1a3ee82776f6102bfe873925183159"><div class="ttname"><a href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">impala::Status::GetDetail</a></div><div class="ttdeci">const std::string GetDetail() const </div><div class="ttdef"><b>Definition:</b> <a href="status_8cc_source.html#l00184">status.cc:184</a></div></div> |
| <div class="ttc" id="classimpala_1_1MonotonicStopWatch_html_ad51faa4e584e78430b2620572dd715b5"><div class="ttname"><a href="classimpala_1_1MonotonicStopWatch.html#ad51faa4e584e78430b2620572dd715b5">impala::MonotonicStopWatch::Stop</a></div><div class="ttdeci">void Stop()</div><div class="ttdef"><b>Definition:</b> <a href="stopwatch_8h_source.html#l00088">stopwatch.h:88</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="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_a992d29b9f14e8f27cfa2a73de4b969f1"><div class="ttname"><a href="namespaceimpala.html#a992d29b9f14e8f27cfa2a73de4b969f1">impala::CALLBACK_METRIC_PATTERN</a></div><div class="ttdeci">const string CALLBACK_METRIC_PATTERN</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00054">statestore-subscriber.cc:54</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_1Thread_html"><div class="ttname"><a href="classimpala_1_1Thread.html">impala::Thread</a></div><div class="ttdoc">TODO: Consider allowing fragment IDs as category parameters. </div><div class="ttdef"><b>Definition:</b> <a href="thread_8h_source.html#l00045">thread.h:45</a></div></div> |
| <div class="ttc" id="time_8h_html"><div class="ttname"><a href="time_8h.html">time.h</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a563ea3461b2bc1849f85f6ee3dea845d"><div class="ttname"><a href="namespaceimpala.html#a563ea3461b2bc1849f85f6ee3dea845d">impala::StatestoreConnection</a></div><div class="ttdeci">ClientConnection< StatestoreServiceClient > StatestoreConnection</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00060">statestore-subscriber.cc:60</a></div></div> |
| <div class="ttc" id="classimpala_1_1ClientConnection_html"><div class="ttname"><a href="classimpala_1_1ClientConnection.html">impala::ClientConnection</a></div><div class="ttdef"><b>Definition:</b> <a href="client-cache_8h_source.html#l00192">client-cache.h:192</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_1FailureDetector_html_ab1f72b41f370a931fd4e44dd90fdf7e1a7c97d056ffa22a9374fe409d077d435b"><div class="ttname"><a href="classimpala_1_1FailureDetector.html#ab1f72b41f370a931fd4e44dd90fdf7e1a7c97d056ffa22a9374fe409d077d435b">impala::FailureDetector::FAILED</a></div><div class="ttdef"><b>Definition:</b> <a href="failure-detector_8h_source.html#l00036">failure-detector.h:36</a></div></div> |
| <div class="ttc" id="status_8h_html_a85f7d0e774e15eb35b74f53264305e16"><div class="ttname"><a href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a></div><div class="ttdeci">#define RETURN_IF_ERROR(stmt)</div><div class="ttdoc">some generally useful macros </div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00242">status.h:242</a></div></div> |
| <div class="ttc" id="classimpala_1_1MetricGroup_html_a7b6ae979dcd7b3929354a1b23272e759"><div class="ttname"><a href="classimpala_1_1MetricGroup.html#a7b6ae979dcd7b3929354a1b23272e759">impala::MetricGroup::RegisterMetric</a></div><div class="ttdeci">M * RegisterMetric(M *metric)</div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00211">metrics.h:211</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="classimpala_1_1StatestoreSubscriberThriftIf_html_a05b942fe1b2e0b049193c5e3e71914e1"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriberThriftIf.html#a05b942fe1b2e0b049193c5e3e71914e1">impala::StatestoreSubscriberThriftIf::UpdateState</a></div><div class="ttdeci">virtual void UpdateState(TUpdateStateResponse &response, const TUpdateStateRequest &params)</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00068">statestore-subscriber.cc:68</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_1RpcEventHandler_html"><div class="ttname"><a href="classimpala_1_1RpcEventHandler.html">impala::RpcEventHandler</a></div><div class="ttdef"><b>Definition:</b> <a href="rpc-trace_8h_source.html#l00036">rpc-trace.h:36</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a19e01fc90bc956ac7e1a735d2bea5a5e"><div class="ttname"><a href="namespaceimpala.html#a19e01fc90bc956ac7e1a735d2bea5a5e">impala::PrintId</a></div><div class="ttdeci">string PrintId(const TUniqueId &id, const string &separator)</div><div class="ttdef"><b>Definition:</b> <a href="debug-util_8cc_source.html#l00097">debug-util.cc:97</a></div></div> |
| <div class="ttc" id="logging_8h_html"><div class="ttname"><a href="logging_8h.html">logging.h</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a035bc6fb88ad7130d82267ef051d4bf2"><div class="ttname"><a href="namespaceimpala.html#a035bc6fb88ad7130d82267ef051d4bf2">impala::SLEEP_INTERVAL_MS</a></div><div class="ttdeci">const int32_t SLEEP_INTERVAL_MS</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00058">statestore-subscriber.cc:58</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a57debe017e657e4692b405fa183f7ca8"><div class="ttname"><a href="namespaceimpala.html#a57debe017e657e4692b405fa183f7ca8">impala::SleepForMs</a></div><div class="ttdeci">void SleepForMs(const int64_t duration_ms)</div><div class="ttdoc">Sleeps the current thread for at least duration_ms milliseconds. </div><div class="ttdef"><b>Definition:</b> <a href="time_8cc_source.html#l00021">time.cc:21</a></div></div> |
| <div class="ttc" id="rpc-trace_8h_html"><div class="ttname"><a href="rpc-trace_8h.html">rpc-trace.h</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="classimpala_1_1StatestoreSubscriberThriftIf_html_a3533358f98b2a89a5d4cb597967f08cf"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriberThriftIf.html#a3533358f98b2a89a5d4cb597967f08cf">impala::StatestoreSubscriberThriftIf::subscriber_</a></div><div class="ttdeci">StatestoreSubscriber * subscriber_</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00086">statestore-subscriber.cc:86</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_1MonotonicStopWatch_html_ab1811a1b7b6050a2f2d021fca6c89cea"><div class="ttname"><a href="classimpala_1_1MonotonicStopWatch.html#ab1811a1b7b6050a2f2d021fca6c89cea">impala::MonotonicStopWatch::Reset</a></div><div class="ttdeci">uint64_t Reset()</div><div class="ttdoc">Restarts the timer. Returns the elapsed time until this point. </div><div class="ttdef"><b>Definition:</b> <a href="stopwatch_8h_source.html#l00096">stopwatch.h:96</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_1MetricGroup_html_acb181cc1e3e171a504b28756a5aa5110"><div class="ttname"><a href="classimpala_1_1MetricGroup.html#acb181cc1e3e171a504b28756a5aa5110">impala::MetricGroup::AddProperty</a></div><div class="ttdeci">SimpleMetric< T, TMetricKind::PROPERTY > * AddProperty(const std::string &key, const T &value, const std::string &description="")</div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00231">metrics.h:231</a></div></div> |
| <div class="ttc" id="classStatestoreSubscriberIf_html"><div class="ttname"><a href="classStatestoreSubscriberIf.html">StatestoreSubscriberIf</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="debug-util_8h_html"><div class="ttname"><a href="debug-util_8h.html">debug-util.h</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="statestore-subscriber_8cc_html_addac98f4e6a09c6d1c8eebfe20dd46d4"><div class="ttname"><a href="statestore-subscriber_8cc.html#addac98f4e6a09c6d1c8eebfe20dd46d4">DEFINE_int32</a></div><div class="ttdeci">DEFINE_int32(statestore_subscriber_timeout_seconds, 30,"The amount of time (in seconds)"" that may elapse before the connection with the statestore is considered lost.")</div></div> |
| <div class="ttc" id="namespaceimpala__udf_html_aa263bafd77b9eb6acc16458d70d160a4"><div class="ttname"><a href="namespaceimpala__udf.html#aa263bafd77b9eb6acc16458d70d160a4">impala_udf::DebugString</a></div><div class="ttdeci">std::string DebugString(const T &val)</div><div class="ttdef"><b>Definition:</b> <a href="udf-debug_8h_source.html#l00027">udf-debug.h:27</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_1StatsMetric_html_a63e36e6ce39c43df7144d970dd0be733"><div class="ttname"><a href="classimpala_1_1StatsMetric.html#a63e36e6ce39c43df7144d970dd0be733">impala::StatsMetric::Update</a></div><div class="ttdeci">void Update(const T &value)</div><div class="ttdef"><b>Definition:</b> <a href="collection-metrics_8h_source.html#l00112">collection-metrics.h:112</a></div></div> |
| <div class="ttc" id="classimpala_1_1MonotonicStopWatch_html_a5f42e96a173893f40aac4fb1e787faac"><div class="ttname"><a href="classimpala_1_1MonotonicStopWatch.html#a5f42e96a173893f40aac4fb1e787faac">impala::MonotonicStopWatch::Start</a></div><div class="ttdeci">void Start()</div><div class="ttdef"><b>Definition:</b> <a href="stopwatch_8h_source.html#l00081">stopwatch.h:81</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_1TimeoutFailureDetector_html"><div class="ttname"><a href="classimpala_1_1TimeoutFailureDetector.html">impala::TimeoutFailureDetector</a></div><div class="ttdef"><b>Definition:</b> <a href="failure-detector_8h_source.html#l00072">failure-detector.h:72</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="failure-detector_8h_html"><div class="ttname"><a href="failure-detector_8h.html">failure-detector.h</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_1MonotonicStopWatch_html_a4a5fdb04f9b13278b9c636e472330976"><div class="ttname"><a href="classimpala_1_1MonotonicStopWatch.html#a4a5fdb04f9b13278b9c636e472330976">impala::MonotonicStopWatch::ElapsedTime</a></div><div class="ttdeci">uint64_t ElapsedTime() const </div><div class="ttdoc">Returns time in nanosecond. </div><div class="ttdef"><b>Definition:</b> <a href="stopwatch_8h_source.html#l00105">stopwatch.h:105</a></div></div> |
| <div class="ttc" id="classimpala_1_1StatestoreSubscriberThriftIf_html_a5c8a151d4ff080cedf53474d00b2b5a7"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriberThriftIf.html#a5c8a151d4ff080cedf53474d00b2b5a7">impala::StatestoreSubscriberThriftIf::Heartbeat</a></div><div class="ttdeci">virtual void Heartbeat(THeartbeatResponse &response, const THeartbeatRequest &request)</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00081">statestore-subscriber.cc:81</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="status_8h_html"><div class="ttname"><a href="status_8h.html">status.h</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="classimpala_1_1MetricGroup_html_a32616eb20d4069c50427dfde1f89c376"><div class="ttname"><a href="classimpala_1_1MetricGroup.html#a32616eb20d4069c50427dfde1f89c376">impala::MetricGroup::AddGauge</a></div><div class="ttdeci">SimpleMetric< T > * AddGauge(const std::string &key, const T &value, const TUnit::type unit=TUnit::NONE, const std::string &description="")</div><div class="ttdoc">Create a gauge metric object with given key and initial value (owned by this object) ...</div><div class="ttdef"><b>Definition:</b> <a href="metrics_8h_source.html#l00223">metrics.h:223</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_1Status_html_a580565665ea944eb64f3f495b1bee1e0"><div class="ttname"><a href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">impala::Status::OK</a></div><div class="ttdeci">static const Status OK</div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00087">status.h:87</a></div></div> |
| <div class="ttc" id="logging_8h_html_a24efb6b382d3e1bdd7817e5e31dc5c1d"><div class="ttname"><a href="logging_8h.html#a24efb6b382d3e1bdd7817e5e31dc5c1d">VLOG_RPC</a></div><div class="ttdeci">#define VLOG_RPC</div><div class="ttdef"><b>Definition:</b> <a href="logging_8h_source.html#l00056">logging.h:56</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="names_8h_html"><div class="ttname"><a href="names_8h.html">names.h</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="statestore-subscriber_8h_html"><div class="ttname"><a href="statestore-subscriber_8h.html">statestore-subscriber.h</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="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_1Status_html_a95ba859e42fe93445b340533220836ac"><div class="ttname"><a href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">impala::Status::ok</a></div><div class="ttdeci">bool ok() const </div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00172">status.h:172</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_1StatestoreSubscriberThriftIf_html_a5874291979dbcd391be2f1a35d10ef25"><div class="ttname"><a href="classimpala_1_1StatestoreSubscriberThriftIf.html#a5874291979dbcd391be2f1a35d10ef25">impala::StatestoreSubscriberThriftIf::StatestoreSubscriberThriftIf</a></div><div class="ttdeci">StatestoreSubscriberThriftIf(StatestoreSubscriber *subscriber)</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00066">statestore-subscriber.cc:66</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a51fcf7493aea18da7a7d2882f9d7fbe0"><div class="ttname"><a href="namespaceimpala.html#a51fcf7493aea18da7a7d2882f9d7fbe0">impala::STATESTORE_ID</a></div><div class="ttdeci">const string STATESTORE_ID</div><div class="ttdef"><b>Definition:</b> <a href="statestore-subscriber_8cc_source.html#l00051">statestore-subscriber.cc:51</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="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 class="ttc" id="classimpala_1_1TimestampValue_html_ab9e0cd56dbef646bcf8bdba06ae775b3"><div class="ttname"><a href="classimpala_1_1TimestampValue.html#ab9e0cd56dbef646bcf8bdba06ae775b3">impala::TimestampValue::LocalTime</a></div><div class="ttdeci">static TimestampValue LocalTime()</div><div class="ttdef"><b>Definition:</b> <a href="timestamp-value_8h_source.html#l00105">timestamp-value.h:105</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_8cc.html">statestore-subscriber.cc</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> |
