| <!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/runtime/data-stream-test.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('data-stream-test_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">data-stream-test.cc</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="data-stream-test_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 <boost/thread/thread.hpp></span></div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="preprocessor">#include <gtest/gtest.h></span></div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> </div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor">#include "<a class="code" href="init_8h.html">common/init.h</a>"</span></div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#include "<a class="code" href="logging_8h.html">common/logging.h</a>"</span></div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">common/status.h</a>"</span></div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include "<a class="code" href="llvm-codegen_8h.html">codegen/llvm-codegen.h</a>"</span></div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include "<a class="code" href="slot-ref_8h.html">exprs/slot-ref.h</a>"</span></div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> <span class="preprocessor">#include "<a class="code" href="auth-provider_8h.html">rpc/auth-provider.h</a>"</span></div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include "<a class="code" href="thrift-server_8h.html">rpc/thrift-server.h</a>"</span></div> |
| <div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include "<a class="code" href="row-batch_8h.html">runtime/row-batch.h</a>"</span></div> |
| <div class="line"><a name="l00026"></a><span class="lineno"> 26</span> <span class="preprocessor">#include "<a class="code" href="runtime-state_8h.html">runtime/runtime-state.h</a>"</span></div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include "<a class="code" href="data-stream-mgr_8h.html">runtime/data-stream-mgr.h</a>"</span></div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="preprocessor">#include "<a class="code" href="data-stream-sender_8h.html">runtime/data-stream-sender.h</a>"</span></div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "<a class="code" href="data-stream-recvr_8h.html">runtime/data-stream-recvr.h</a>"</span></div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="descriptors_8h.html">runtime/descriptors.h</a>"</span></div> |
| <div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include "<a class="code" href="client-cache_8h.html">runtime/client-cache.h</a>"</span></div> |
| <div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "<a class="code" href="raw-value_8h.html">runtime/raw-value.h</a>"</span></div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="preprocessor">#include "<a class="code" href="fe-support_8h.html">service/fe-support.h</a>"</span></div> |
| <div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="preprocessor">#include "<a class="code" href="cpu-info_8h.html">util/cpu-info.h</a>"</span></div> |
| <div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="preprocessor">#include "<a class="code" href="disk-info_8h.html">util/disk-info.h</a>"</span></div> |
| <div class="line"><a name="l00036"></a><span class="lineno"> 36</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="l00037"></a><span class="lineno"> 37</span> <span class="preprocessor">#include "<a class="code" href="thread_8h.html">util/thread.h</a>"</span></div> |
| <div class="line"><a name="l00038"></a><span class="lineno"> 38</span> <span class="preprocessor">#include "<a class="code" href="time_8h.html">util/time.h</a>"</span></div> |
| <div class="line"><a name="l00039"></a><span class="lineno"> 39</span> <span class="preprocessor">#include "<a class="code" href="mem-info_8h.html">util/mem-info.h</a>"</span></div> |
| <div class="line"><a name="l00040"></a><span class="lineno"> 40</span> <span class="preprocessor">#include "<a class="code" href="test-info_8h.html">util/test-info.h</a>"</span></div> |
| <div class="line"><a name="l00041"></a><span class="lineno"> 41</span> <span class="preprocessor">#include "<a class="code" href="tuple-row-compare_8h.html">util/tuple-row-compare.h</a>"</span></div> |
| <div class="line"><a name="l00042"></a><span class="lineno"> 42</span> <span class="preprocessor">#include "gen-cpp/ImpalaInternalService.h"</span></div> |
| <div class="line"><a name="l00043"></a><span class="lineno"> 43</span> <span class="preprocessor">#include "gen-cpp/ImpalaInternalService_types.h"</span></div> |
| <div class="line"><a name="l00044"></a><span class="lineno"> 44</span> <span class="preprocessor">#include "gen-cpp/Types_types.h"</span></div> |
| <div class="line"><a name="l00045"></a><span class="lineno"> 45</span> <span class="preprocessor">#include "gen-cpp/Descriptors_types.h"</span></div> |
| <div class="line"><a name="l00046"></a><span class="lineno"> 46</span> <span class="preprocessor">#include "<a class="code" href="fe-support_8h.html">service/fe-support.h</a>"</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="preprocessor">#include <iostream></span></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="preprocessor">#include "<a class="code" href="names_8h.html">common/names.h</a>"</span></div> |
| <div class="line"><a name="l00051"></a><span class="lineno"> 51</span> </div> |
| <div class="line"><a name="l00052"></a><span class="lineno"> 52</span> <span class="keyword">using namespace </span>impala;</div> |
| <div class="line"><a name="l00053"></a><span class="lineno"> 53</span> <span class="keyword">using namespace </span>apache::thrift;</div> |
| <div class="line"><a name="l00054"></a><span class="lineno"> 54</span> <span class="keyword">using namespace </span><a class="code" href="namespaceimpala.html#a8cf06290ff145eec23570a8b9790f412">apache::thrift::protocol</a>;</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> <a class="code" href="namespaceimpala.html#aad7a37594ae12dd0bd87ca15f06b4ac8">DEFINE_int32</a>(port, 20001, <span class="stringliteral">"port on which to run Impala test backend"</span>);</div> |
| <div class="line"><a name="l00057"></a><span class="lineno"> 57</span> <a class="code" href="data-stream-test_8cc.html#a67c89cbcfa13431bd5f921ddc84defd9">DECLARE_string</a>(principal);</div> |
| <div class="line"><a name="l00058"></a><span class="lineno"> 58</span> </div> |
| <div class="line"><a name="l00059"></a><span class="lineno"> 59</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00060"></a><span class="lineno"> 60</span> </div> |
| <div class="line"><a name="l00061"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html"> 61</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1ImpalaTestBackend.html">ImpalaTestBackend</a> : <span class="keyword">public</span> <a class="code" href="classImpalaInternalServiceIf.html">ImpalaInternalServiceIf</a> {</div> |
| <div class="line"><a name="l00062"></a><span class="lineno"> 62</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00063"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#a93966c57c91dbac1ec4e14991992531b"> 63</a></span>  <a class="code" href="classimpala_1_1ImpalaTestBackend.html#a93966c57c91dbac1ec4e14991992531b">ImpalaTestBackend</a>(<a class="code" href="classimpala_1_1DataStreamMgr.html">DataStreamMgr</a>* stream_mgr): mgr_(stream_mgr) {}</div> |
| <div class="line"><a name="l00064"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#acf4d2486bc794306a98feee7bdfa6fbc"> 64</a></span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1ImpalaTestBackend.html#acf4d2486bc794306a98feee7bdfa6fbc">~ImpalaTestBackend</a>() {}</div> |
| <div class="line"><a name="l00065"></a><span class="lineno"> 65</span> </div> |
| <div class="line"><a name="l00066"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#a4e8dd5bb69f6793e87ebac7aadb1c6dd"> 66</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1ImpalaTestBackend.html#a4e8dd5bb69f6793e87ebac7aadb1c6dd">ExecPlanFragment</a>(</div> |
| <div class="line"><a name="l00067"></a><span class="lineno"> 67</span>  TExecPlanFragmentResult& return_val, <span class="keyword">const</span> TExecPlanFragmentParams& params) {}</div> |
| <div class="line"><a name="l00068"></a><span class="lineno"> 68</span> </div> |
| <div class="line"><a name="l00069"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#a5496f66cded945d3574eb060d764cd45"> 69</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1ImpalaTestBackend.html#a5496f66cded945d3574eb060d764cd45">ReportExecStatus</a>(</div> |
| <div class="line"><a name="l00070"></a><span class="lineno"> 70</span>  TReportExecStatusResult& return_val, <span class="keyword">const</span> TReportExecStatusParams& params) {}</div> |
| <div class="line"><a name="l00071"></a><span class="lineno"> 71</span> </div> |
| <div class="line"><a name="l00072"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#ae95b35478c3c2f5c6fcdda226b1ef96b"> 72</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1ImpalaTestBackend.html#ae95b35478c3c2f5c6fcdda226b1ef96b">CancelPlanFragment</a>(</div> |
| <div class="line"><a name="l00073"></a><span class="lineno"> 73</span>  TCancelPlanFragmentResult& return_val, <span class="keyword">const</span> TCancelPlanFragmentParams& params) {}</div> |
| <div class="line"><a name="l00074"></a><span class="lineno"> 74</span> </div> |
| <div class="line"><a name="l00075"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#aed33f6ac5ef326029b85e6c86e9e42b5"> 75</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1ImpalaTestBackend.html#aed33f6ac5ef326029b85e6c86e9e42b5">TransmitData</a>(</div> |
| <div class="line"><a name="l00076"></a><span class="lineno"> 76</span>  TTransmitDataResult& return_val, <span class="keyword">const</span> TTransmitDataParams& params) {</div> |
| <div class="line"><a name="l00077"></a><span class="lineno"> 77</span>  <span class="keywordflow">if</span> (!params.eos) {</div> |
| <div class="line"><a name="l00078"></a><span class="lineno"> 78</span>  mgr_->AddData(params.dest_fragment_instance_id, params.dest_node_id,</div> |
| <div class="line"><a name="l00079"></a><span class="lineno"> 79</span>  params.row_batch, params.sender_id).SetTStatus(&return_val);</div> |
| <div class="line"><a name="l00080"></a><span class="lineno"> 80</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00081"></a><span class="lineno"> 81</span>  mgr_->CloseSender(params.dest_fragment_instance_id, params.dest_node_id,</div> |
| <div class="line"><a name="l00082"></a><span class="lineno"> 82</span>  params.sender_id).SetTStatus(&return_val);</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> </div> |
| <div class="line"><a name="l00086"></a><span class="lineno"> 86</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00087"></a><span class="lineno"><a class="line" href="classimpala_1_1ImpalaTestBackend.html#ad020c6ef386dbc1d029430bf656bafef"> 87</a></span>  <a class="code" href="classimpala_1_1DataStreamMgr.html">DataStreamMgr</a>* <a class="code" href="classimpala_1_1ImpalaTestBackend.html#ad020c6ef386dbc1d029430bf656bafef">mgr_</a>;</div> |
| <div class="line"><a name="l00088"></a><span class="lineno"> 88</span> };</div> |
| <div class="line"><a name="l00089"></a><span class="lineno"> 89</span> </div> |
| <div class="line"><a name="l00090"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html"> 90</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1DataStreamTest.html">DataStreamTest</a> : <span class="keyword">public</span> <a class="code" href="cache-hash-test_8cc.html#a18269e3eecadb27e79614c02d898173e">testing::Test</a> {</div> |
| <div class="line"><a name="l00091"></a><span class="lineno"> 91</span>  <span class="keyword">protected</span>:</div> |
| <div class="line"><a name="l00092"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a57c967a17a4ed1d4f5ee1bffdba69d6a"> 92</a></span>  <a class="code" href="classimpala_1_1DataStreamTest.html#a57c967a17a4ed1d4f5ee1bffdba69d6a">DataStreamTest</a>()</div> |
| <div class="line"><a name="l00093"></a><span class="lineno"> 93</span>  : runtime_state_(TPlanFragmentInstanceCtx(), <span class="stringliteral">""</span>, &<a class="code" href="namespaceimpala.html#a57eaecb97c9c87e4c57c8a8a81211422">exec_env_</a>),</div> |
| <div class="line"><a name="l00094"></a><span class="lineno"> 94</span>  next_val_(0) {</div> |
| <div class="line"><a name="l00095"></a><span class="lineno"> 95</span>  <span class="comment">// Initialize Mem trackers for use by the data stream receiver.</span></div> |
| <div class="line"><a name="l00096"></a><span class="lineno"> 96</span>  <a class="code" href="namespaceimpala.html#a57eaecb97c9c87e4c57c8a8a81211422">exec_env_</a>.<a class="code" href="classimpala_1_1ExecEnv.html#a96fe8303b423faaeb2278c48fd1fe679">InitForFeTests</a>();</div> |
| <div class="line"><a name="l00097"></a><span class="lineno"> 97</span>  runtime_state_.InitMemTrackers(TUniqueId(), NULL, -1);</div> |
| <div class="line"><a name="l00098"></a><span class="lineno"> 98</span>  }</div> |
| <div class="line"><a name="l00099"></a><span class="lineno"> 99</span> </div> |
| <div class="line"><a name="l00100"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ae25f80e36f8dddd7e87bcdbc0faa4cd4"> 100</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#ae25f80e36f8dddd7e87bcdbc0faa4cd4">SetUp</a>() {</div> |
| <div class="line"><a name="l00101"></a><span class="lineno"> 101</span>  CreateRowDesc();</div> |
| <div class="line"><a name="l00102"></a><span class="lineno"> 102</span>  CreateTupleComparator();</div> |
| <div class="line"><a name="l00103"></a><span class="lineno"> 103</span>  CreateRowBatch();</div> |
| <div class="line"><a name="l00104"></a><span class="lineno"> 104</span> </div> |
| <div class="line"><a name="l00105"></a><span class="lineno"> 105</span>  next_instance_id_.lo = 0;</div> |
| <div class="line"><a name="l00106"></a><span class="lineno"> 106</span>  next_instance_id_.hi = 0;</div> |
| <div class="line"><a name="l00107"></a><span class="lineno"> 107</span>  stream_mgr_ = <span class="keyword">new</span> <a class="code" href="classimpala_1_1DataStreamMgr.html">DataStreamMgr</a>();</div> |
| <div class="line"><a name="l00108"></a><span class="lineno"> 108</span> </div> |
| <div class="line"><a name="l00109"></a><span class="lineno"> 109</span>  broadcast_sink_.dest_node_id = DEST_NODE_ID;</div> |
| <div class="line"><a name="l00110"></a><span class="lineno"> 110</span>  broadcast_sink_.output_partition.type = TPartitionType::UNPARTITIONED;</div> |
| <div class="line"><a name="l00111"></a><span class="lineno"> 111</span> </div> |
| <div class="line"><a name="l00112"></a><span class="lineno"> 112</span>  random_sink_.dest_node_id = DEST_NODE_ID;</div> |
| <div class="line"><a name="l00113"></a><span class="lineno"> 113</span>  random_sink_.output_partition.type = TPartitionType::RANDOM;</div> |
| <div class="line"><a name="l00114"></a><span class="lineno"> 114</span> </div> |
| <div class="line"><a name="l00115"></a><span class="lineno"> 115</span>  hash_sink_.dest_node_id = DEST_NODE_ID;</div> |
| <div class="line"><a name="l00116"></a><span class="lineno"> 116</span>  hash_sink_.output_partition.type = TPartitionType::HASH_PARTITIONED;</div> |
| <div class="line"><a name="l00117"></a><span class="lineno"> 117</span>  <span class="comment">// there's only one column to partition on</span></div> |
| <div class="line"><a name="l00118"></a><span class="lineno"> 118</span>  TExprNode expr_node;</div> |
| <div class="line"><a name="l00119"></a><span class="lineno"> 119</span>  expr_node.node_type = TExprNodeType::SLOT_REF;</div> |
| <div class="line"><a name="l00120"></a><span class="lineno"> 120</span>  expr_node.type.types.push_back(TTypeNode());</div> |
| <div class="line"><a name="l00121"></a><span class="lineno"> 121</span>  expr_node.type.types.back().__isset.scalar_type = <span class="keyword">true</span>;</div> |
| <div class="line"><a name="l00122"></a><span class="lineno"> 122</span>  expr_node.type.types.back().scalar_type.type = TPrimitiveType::BIGINT;</div> |
| <div class="line"><a name="l00123"></a><span class="lineno"> 123</span>  expr_node.num_children = 0;</div> |
| <div class="line"><a name="l00124"></a><span class="lineno"> 124</span>  TSlotRef slot_ref;</div> |
| <div class="line"><a name="l00125"></a><span class="lineno"> 125</span>  slot_ref.slot_id = 0;</div> |
| <div class="line"><a name="l00126"></a><span class="lineno"> 126</span>  expr_node.__set_slot_ref(slot_ref);</div> |
| <div class="line"><a name="l00127"></a><span class="lineno"> 127</span>  TExpr expr;</div> |
| <div class="line"><a name="l00128"></a><span class="lineno"> 128</span>  expr.nodes.push_back(expr_node);</div> |
| <div class="line"><a name="l00129"></a><span class="lineno"> 129</span>  hash_sink_.output_partition.__isset.partition_exprs = <span class="keyword">true</span>;</div> |
| <div class="line"><a name="l00130"></a><span class="lineno"> 130</span>  hash_sink_.output_partition.partition_exprs.push_back(expr);</div> |
| <div class="line"><a name="l00131"></a><span class="lineno"> 131</span> </div> |
| <div class="line"><a name="l00132"></a><span class="lineno"> 132</span>  <span class="comment">// Ensure that individual sender info addresses don't change</span></div> |
| <div class="line"><a name="l00133"></a><span class="lineno"> 133</span>  sender_info_.reserve(MAX_SENDERS);</div> |
| <div class="line"><a name="l00134"></a><span class="lineno"> 134</span>  receiver_info_.reserve(MAX_RECEIVERS);</div> |
| <div class="line"><a name="l00135"></a><span class="lineno"> 135</span>  StartBackend();</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> </div> |
| <div class="line"><a name="l00138"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a05f2e5343e40e8f955459e810dd160c4"> 138</a></span>  <span class="keyword">const</span> TDataStreamSink& <a class="code" href="classimpala_1_1DataStreamTest.html#a05f2e5343e40e8f955459e810dd160c4">GetSink</a>(TPartitionType::type partition_type) {</div> |
| <div class="line"><a name="l00139"></a><span class="lineno"> 139</span>  <span class="keywordflow">switch</span> (partition_type) {</div> |
| <div class="line"><a name="l00140"></a><span class="lineno"> 140</span>  <span class="keywordflow">case</span> TPartitionType::UNPARTITIONED: <span class="keywordflow">return</span> broadcast_sink_;</div> |
| <div class="line"><a name="l00141"></a><span class="lineno"> 141</span>  <span class="keywordflow">case</span> TPartitionType::RANDOM: <span class="keywordflow">return</span> random_sink_;</div> |
| <div class="line"><a name="l00142"></a><span class="lineno"> 142</span>  <span class="keywordflow">case</span> TPartitionType::HASH_PARTITIONED: <span class="keywordflow">return</span> hash_sink_;</div> |
| <div class="line"><a name="l00143"></a><span class="lineno"> 143</span>  <span class="keywordflow">default</span>: DCHECK(<span class="keyword">false</span>) << <span class="stringliteral">"Unhandled sink type: "</span> << partition_type;</div> |
| <div class="line"><a name="l00144"></a><span class="lineno"> 144</span>  }</div> |
| <div class="line"><a name="l00145"></a><span class="lineno"> 145</span>  <span class="comment">// Should never reach this.</span></div> |
| <div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  <span class="keywordflow">return</span> broadcast_sink_;</div> |
| <div class="line"><a name="l00147"></a><span class="lineno"> 147</span>  }</div> |
| <div class="line"><a name="l00148"></a><span class="lineno"> 148</span> </div> |
| <div class="line"><a name="l00149"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#abb8130f77401171e4cd470f8a7eafcc8"> 149</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#abb8130f77401171e4cd470f8a7eafcc8">TearDown</a>() {</div> |
| <div class="line"><a name="l00150"></a><span class="lineno"> 150</span>  lhs_slot_ctx_->Close(NULL);</div> |
| <div class="line"><a name="l00151"></a><span class="lineno"> 151</span>  rhs_slot_ctx_->Close(NULL);</div> |
| <div class="line"><a name="l00152"></a><span class="lineno"> 152</span>  <a class="code" href="namespaceimpala.html#a57eaecb97c9c87e4c57c8a8a81211422">exec_env_</a>.<a class="code" href="classimpala_1_1ExecEnv.html#a4e470b8606b776eb409005c95c575361">impalad_client_cache</a>()-><a class="code" href="classimpala_1_1ClientCache.html#a8f13cf7cc55cadae632ec2d7801731b5">TestShutdown</a>();</div> |
| <div class="line"><a name="l00153"></a><span class="lineno"> 153</span>  StopBackend();</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> </div> |
| <div class="line"><a name="l00156"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a4d5df6139d66b718aa61dfa6575f922c"> 156</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a4d5df6139d66b718aa61dfa6575f922c">Reset</a>() {</div> |
| <div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  sender_info_.clear();</div> |
| <div class="line"><a name="l00158"></a><span class="lineno"> 158</span>  receiver_info_.clear();</div> |
| <div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  dest_.clear();</div> |
| <div class="line"><a name="l00160"></a><span class="lineno"> 160</span>  }</div> |
| <div class="line"><a name="l00161"></a><span class="lineno"> 161</span> </div> |
| <div class="line"><a name="l00162"></a><span class="lineno"> 162</span>  <span class="comment">// We reserve contiguous memory for senders in SetUp. If a test uses more</span></div> |
| <div class="line"><a name="l00163"></a><span class="lineno"> 163</span>  <span class="comment">// senders, a DCHECK will fail and you should increase this value.</span></div> |
| <div class="line"><a name="l00164"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a385ef931d8a0142a38e29bd276d624fa"> 164</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> MAX_SENDERS = 16;</div> |
| <div class="line"><a name="l00165"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a5d3cb123891e25dd95abc8ad2cef5cf8"> 165</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> MAX_RECEIVERS = 16;</div> |
| <div class="line"><a name="l00166"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#af7db14e7ae3fb06741e73ec9761d6bdd"> 166</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> DEST_NODE_ID = 1;</div> |
| <div class="line"><a name="l00167"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ab7d93ea73285b91497cb1c00730d7c83"> 167</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> BATCH_CAPACITY = 100; <span class="comment">// rows</span></div> |
| <div class="line"><a name="l00168"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a41a3f0edb75cc122d38915622d877024"> 168</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> PER_ROW_DATA = 8;</div> |
| <div class="line"><a name="l00169"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a1c1d2d261ebd4d3092c44ad282f26ba2"> 169</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> TOTAL_DATA_SIZE = 8 * 1024;</div> |
| <div class="line"><a name="l00170"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a8f8215e6469869c7005ebdbb87b917d8"> 170</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> NUM_BATCHES = TOTAL_DATA_SIZE / BATCH_CAPACITY / PER_ROW_DATA;</div> |
| <div class="line"><a name="l00171"></a><span class="lineno"> 171</span> </div> |
| <div class="line"><a name="l00172"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ada64bb855cc0f1f92ca60c38be8ca07c"> 172</a></span>  <a class="code" href="classimpala_1_1ObjectPool.html">ObjectPool</a> <a class="code" href="classimpala_1_1DataStreamTest.html#ada64bb855cc0f1f92ca60c38be8ca07c">obj_pool_</a>;</div> |
| <div class="line"><a name="l00173"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a59b3847f48981215061c401950dbd0f4"> 173</a></span>  <a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a> <a class="code" href="classimpala_1_1DataStreamTest.html#a59b3847f48981215061c401950dbd0f4">tracker_</a>;</div> |
| <div class="line"><a name="l00174"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#adf889510ae92e3de691ecb990adbacb6"> 174</a></span>  <a class="code" href="classimpala_1_1DescriptorTbl.html">DescriptorTbl</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#adf889510ae92e3de691ecb990adbacb6">desc_tbl_</a>;</div> |
| <div class="line"><a name="l00175"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#abfb11c9a164c883f065532cef685c2a2"> 175</a></span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#abfb11c9a164c883f065532cef685c2a2">row_desc_</a>;</div> |
| <div class="line"><a name="l00176"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a0360190c40a92add13872add675eec76"> 176</a></span>  <a class="code" href="classimpala_1_1TupleRowComparator.html">TupleRowComparator</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#a0360190c40a92add13872add675eec76">less_than_</a>;</div> |
| <div class="line"><a name="l00177"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a2ea6c9bf9da67b2baaca76dfde05c9a5"> 177</a></span>  <a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a> <a class="code" href="classimpala_1_1DataStreamTest.html#a2ea6c9bf9da67b2baaca76dfde05c9a5">dummy_mem_tracker_</a>;</div> |
| <div class="line"><a name="l00178"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a9101d1f39c7e9e540eb5d96238408431"> 178</a></span>  <a class="code" href="classimpala_1_1ExecEnv.html">ExecEnv</a> <a class="code" href="classimpala_1_1DataStreamTest.html#a9101d1f39c7e9e540eb5d96238408431">exec_env_</a>;</div> |
| <div class="line"><a name="l00179"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a9abfa397b4c91aa5a92a812d6d9d478f"> 179</a></span>  <a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a> <a class="code" href="classimpala_1_1DataStreamTest.html#a9abfa397b4c91aa5a92a812d6d9d478f">runtime_state_</a>;</div> |
| <div class="line"><a name="l00180"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a712a03c97458ee80018c7c77db7f4fe1"> 180</a></span>  TUniqueId <a class="code" href="classimpala_1_1DataStreamTest.html#a712a03c97458ee80018c7c77db7f4fe1">next_instance_id_</a>;</div> |
| <div class="line"><a name="l00181"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#add3ac6e494a210ff7f5a722ed32904f0"> 181</a></span>  <span class="keywordtype">string</span> <a class="code" href="classimpala_1_1DataStreamTest.html#add3ac6e494a210ff7f5a722ed32904f0">stmt_</a>;</div> |
| <div class="line"><a name="l00182"></a><span class="lineno"> 182</span> </div> |
| <div class="line"><a name="l00183"></a><span class="lineno"> 183</span>  <span class="comment">// RowBatch generation</span></div> |
| <div class="line"><a name="l00184"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#aeef4fa014a7ca6a028dcfa1d27ecee31"> 184</a></span>  scoped_ptr<RowBatch> <a class="code" href="classimpala_1_1DataStreamTest.html#aeef4fa014a7ca6a028dcfa1d27ecee31">batch_</a>;</div> |
| <div class="line"><a name="l00185"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#af3ad73326080e178fa233ff5ef17cd41"> 185</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DataStreamTest.html#af3ad73326080e178fa233ff5ef17cd41">next_val_</a>;</div> |
| <div class="line"><a name="l00186"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a6d1ee6e44e6fb8481699487dfdaf507d"> 186</a></span>  int64_t* <a class="code" href="classimpala_1_1DataStreamTest.html#a6d1ee6e44e6fb8481699487dfdaf507d">tuple_mem_</a>;</div> |
| <div class="line"><a name="l00187"></a><span class="lineno"> 187</span> </div> |
| <div class="line"><a name="l00188"></a><span class="lineno"> 188</span>  <span class="comment">// receiving node</span></div> |
| <div class="line"><a name="l00189"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ad7e3881f26a6f89b60ad2f4770e1be98"> 189</a></span>  <a class="code" href="classimpala_1_1DataStreamMgr.html">DataStreamMgr</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#ad7e3881f26a6f89b60ad2f4770e1be98">stream_mgr_</a>;</div> |
| <div class="line"><a name="l00190"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ac3d95322465950447544f928819f9446"> 190</a></span>  <a class="code" href="classimpala_1_1ThriftServer.html">ThriftServer</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#ac3d95322465950447544f928819f9446">server_</a>;</div> |
| <div class="line"><a name="l00191"></a><span class="lineno"> 191</span> </div> |
| <div class="line"><a name="l00192"></a><span class="lineno"> 192</span>  <span class="comment">// sending node(s)</span></div> |
| <div class="line"><a name="l00193"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a670fc5c10025d0cce53eebc5d6d0a72a"> 193</a></span>  TDataStreamSink <a class="code" href="classimpala_1_1DataStreamTest.html#a670fc5c10025d0cce53eebc5d6d0a72a">broadcast_sink_</a>;</div> |
| <div class="line"><a name="l00194"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ac3cc5e16a7ba1cc87edf3f0b28bedc4d"> 194</a></span>  TDataStreamSink <a class="code" href="classimpala_1_1DataStreamTest.html#ac3cc5e16a7ba1cc87edf3f0b28bedc4d">random_sink_</a>;</div> |
| <div class="line"><a name="l00195"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a84e848bfa8bd5071f4df33ab0676e026"> 195</a></span>  TDataStreamSink <a class="code" href="classimpala_1_1DataStreamTest.html#a84e848bfa8bd5071f4df33ab0676e026">hash_sink_</a>;</div> |
| <div class="line"><a name="l00196"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a959b8ff1471b2dc67adc900ac13354bc"> 196</a></span>  vector<TPlanFragmentDestination> <a class="code" href="classimpala_1_1DataStreamTest.html#a959b8ff1471b2dc67adc900ac13354bc">dest_</a>;</div> |
| <div class="line"><a name="l00197"></a><span class="lineno"> 197</span> </div> |
| <div class="line"><a name="l00198"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html"> 198</a></span>  <span class="keyword">struct </span><a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html">SenderInfo</a> {</div> |
| <div class="line"><a name="l00199"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#adead5c848da6d8a13a2a31114c1ef8e8"> 199</a></span>  thread* <a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#adead5c848da6d8a13a2a31114c1ef8e8">thread_handle</a>;</div> |
| <div class="line"><a name="l00200"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a28b83da3011974cfff63e16631efcc2f"> 200</a></span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a28b83da3011974cfff63e16631efcc2f">status</a>;</div> |
| <div class="line"><a name="l00201"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#ab673cac8bb65a73ba3ac5ebe1cc4817e"> 201</a></span>  <span class="keywordtype">int</span> <a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#ab673cac8bb65a73ba3ac5ebe1cc4817e">num_bytes_sent</a>;</div> |
| <div class="line"><a name="l00202"></a><span class="lineno"> 202</span> </div> |
| <div class="line"><a name="l00203"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a7a0069ce5f61af2e543eba6fd36898de"> 203</a></span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a7a0069ce5f61af2e543eba6fd36898de">SenderInfo</a>(): thread_handle(NULL), num_bytes_sent(0) {}</div> |
| <div class="line"><a name="l00204"></a><span class="lineno"> 204</span>  };</div> |
| <div class="line"><a name="l00205"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a4d2fe9ac8ac20e48426222ae49e2fc0b"> 205</a></span>  vector<SenderInfo> <a class="code" href="classimpala_1_1DataStreamTest.html#a4d2fe9ac8ac20e48426222ae49e2fc0b">sender_info_</a>;</div> |
| <div class="line"><a name="l00206"></a><span class="lineno"> 206</span> </div> |
| <div class="line"><a name="l00207"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html"> 207</a></span>  <span class="keyword">struct </span><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">ReceiverInfo</a> {</div> |
| <div class="line"><a name="l00208"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a41a4a41472f7d7b3807ede1524d2f63f"> 208</a></span>  TPartitionType::type <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a41a4a41472f7d7b3807ede1524d2f63f">stream_type</a>;</div> |
| <div class="line"><a name="l00209"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ab8ac82d64131f546638d41fe4def99f4"> 209</a></span>  <span class="keywordtype">int</span> <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ab8ac82d64131f546638d41fe4def99f4">num_senders</a>;</div> |
| <div class="line"><a name="l00210"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a8bafa8e37b26499341ca2ad69d152c74"> 210</a></span>  <span class="keywordtype">int</span> <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a8bafa8e37b26499341ca2ad69d152c74">receiver_num</a>;</div> |
| <div class="line"><a name="l00211"></a><span class="lineno"> 211</span> </div> |
| <div class="line"><a name="l00212"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a0685f4cb46790076c1ab37c2bb714c2e"> 212</a></span>  thread* <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a0685f4cb46790076c1ab37c2bb714c2e">thread_handle</a>;</div> |
| <div class="line"><a name="l00213"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f"> 213</a></span>  shared_ptr<DataStreamRecvr> <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f">stream_recvr</a>;</div> |
| <div class="line"><a name="l00214"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989"> 214</a></span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a>;</div> |
| <div class="line"><a name="l00215"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#aff1b707da01bc61c2ac22fff960e8a73"> 215</a></span>  <span class="keywordtype">int</span> <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#aff1b707da01bc61c2ac22fff960e8a73">num_rows_received</a>;</div> |
| <div class="line"><a name="l00216"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17"> 216</a></span>  multiset<int64_t> <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>;</div> |
| <div class="line"><a name="l00217"></a><span class="lineno"> 217</span> </div> |
| <div class="line"><a name="l00218"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a6f0b95af26c4f77c7fd894d0acffecac"> 218</a></span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a6f0b95af26c4f77c7fd894d0acffecac">ReceiverInfo</a>(TPartitionType::type stream_type, <span class="keywordtype">int</span> num_senders, <span class="keywordtype">int</span> receiver_num)</div> |
| <div class="line"><a name="l00219"></a><span class="lineno"> 219</span>  : stream_type(stream_type),</div> |
| <div class="line"><a name="l00220"></a><span class="lineno"> 220</span>  num_senders(num_senders),</div> |
| <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  receiver_num(receiver_num),</div> |
| <div class="line"><a name="l00222"></a><span class="lineno"> 222</span>  thread_handle(NULL),</div> |
| <div class="line"><a name="l00223"></a><span class="lineno"> 223</span>  num_rows_received(0) {}</div> |
| <div class="line"><a name="l00224"></a><span class="lineno"> 224</span> </div> |
| <div class="line"><a name="l00225"></a><span class="lineno"><a class="line" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#af9b56335668202e9d272c1125b841a6b"> 225</a></span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#af9b56335668202e9d272c1125b841a6b">~ReceiverInfo</a>() {</div> |
| <div class="line"><a name="l00226"></a><span class="lineno"> 226</span>  <span class="keyword">delete</span> thread_handle;</div> |
| <div class="line"><a name="l00227"></a><span class="lineno"> 227</span>  stream_recvr.reset();</div> |
| <div class="line"><a name="l00228"></a><span class="lineno"> 228</span>  }</div> |
| <div class="line"><a name="l00229"></a><span class="lineno"> 229</span>  };</div> |
| <div class="line"><a name="l00230"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a51cf2fe60fdaae767f019b8c43eab200"> 230</a></span>  vector<ReceiverInfo> <a class="code" href="classimpala_1_1DataStreamTest.html#a51cf2fe60fdaae767f019b8c43eab200">receiver_info_</a>;</div> |
| <div class="line"><a name="l00231"></a><span class="lineno"> 231</span> </div> |
| <div class="line"><a name="l00232"></a><span class="lineno"> 232</span>  <span class="comment">// Create an instance id and add it to dest_</span></div> |
| <div class="line"><a name="l00233"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a3104dcdb257e9367b7fcdc96585d6d58"> 233</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a3104dcdb257e9367b7fcdc96585d6d58">GetNextInstanceId</a>(TUniqueId* instance_id) {</div> |
| <div class="line"><a name="l00234"></a><span class="lineno"> 234</span>  dest_.push_back(TPlanFragmentDestination());</div> |
| <div class="line"><a name="l00235"></a><span class="lineno"> 235</span>  TPlanFragmentDestination& dest = dest_.back();</div> |
| <div class="line"><a name="l00236"></a><span class="lineno"> 236</span>  dest.fragment_instance_id = next_instance_id_;</div> |
| <div class="line"><a name="l00237"></a><span class="lineno"> 237</span>  dest.server.hostname = <span class="stringliteral">"127.0.0.1"</span>;</div> |
| <div class="line"><a name="l00238"></a><span class="lineno"> 238</span>  dest.server.port = FLAGS_port;</div> |
| <div class="line"><a name="l00239"></a><span class="lineno"> 239</span>  *instance_id = next_instance_id_;</div> |
| <div class="line"><a name="l00240"></a><span class="lineno"> 240</span>  ++next_instance_id_.lo;</div> |
| <div class="line"><a name="l00241"></a><span class="lineno"> 241</span>  }</div> |
| <div class="line"><a name="l00242"></a><span class="lineno"> 242</span> </div> |
| <div class="line"><a name="l00243"></a><span class="lineno"> 243</span>  <span class="comment">// RowDescriptor to mimic "select bigint_col from alltypesagg", except the slot</span></div> |
| <div class="line"><a name="l00244"></a><span class="lineno"> 244</span>  <span class="comment">// isn't nullable</span></div> |
| <div class="line"><a name="l00245"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a739023ade1afbe1c8e5194ffe7eddab7"> 245</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a739023ade1afbe1c8e5194ffe7eddab7">CreateRowDesc</a>() {</div> |
| <div class="line"><a name="l00246"></a><span class="lineno"> 246</span>  <span class="comment">// create DescriptorTbl</span></div> |
| <div class="line"><a name="l00247"></a><span class="lineno"> 247</span>  TTupleDescriptor tuple_desc;</div> |
| <div class="line"><a name="l00248"></a><span class="lineno"> 248</span>  tuple_desc.__set_id(0);</div> |
| <div class="line"><a name="l00249"></a><span class="lineno"> 249</span>  tuple_desc.__set_byteSize(8);</div> |
| <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  tuple_desc.__set_numNullBytes(0);</div> |
| <div class="line"><a name="l00251"></a><span class="lineno"> 251</span>  TDescriptorTable thrift_desc_tbl;</div> |
| <div class="line"><a name="l00252"></a><span class="lineno"> 252</span>  thrift_desc_tbl.tupleDescriptors.push_back(tuple_desc);</div> |
| <div class="line"><a name="l00253"></a><span class="lineno"> 253</span>  TSlotDescriptor slot_desc;</div> |
| <div class="line"><a name="l00254"></a><span class="lineno"> 254</span>  slot_desc.__set_id(0);</div> |
| <div class="line"><a name="l00255"></a><span class="lineno"> 255</span>  slot_desc.__set_parent(0);</div> |
| <div class="line"><a name="l00256"></a><span class="lineno"> 256</span>  <a class="code" href="structimpala_1_1ColumnType.html">ColumnType</a> type(<a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871ac5602f92ce48738739f551df8ff3e4a7">TYPE_BIGINT</a>);</div> |
| <div class="line"><a name="l00257"></a><span class="lineno"> 257</span>  slot_desc.__set_slotType(type.<a class="code" href="structimpala_1_1ColumnType.html#a059c63313ce5120b5b33cd6b607a404d">ToThrift</a>());</div> |
| <div class="line"><a name="l00258"></a><span class="lineno"> 258</span>  slot_desc.__set_columnPath(vector<int>(1, 0));</div> |
| <div class="line"><a name="l00259"></a><span class="lineno"> 259</span>  slot_desc.__set_byteOffset(0);</div> |
| <div class="line"><a name="l00260"></a><span class="lineno"> 260</span>  slot_desc.__set_nullIndicatorByte(0);</div> |
| <div class="line"><a name="l00261"></a><span class="lineno"> 261</span>  slot_desc.__set_nullIndicatorBit(-1);</div> |
| <div class="line"><a name="l00262"></a><span class="lineno"> 262</span>  slot_desc.__set_slotIdx(0);</div> |
| <div class="line"><a name="l00263"></a><span class="lineno"> 263</span>  slot_desc.__set_isMaterialized(<span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00264"></a><span class="lineno"> 264</span>  thrift_desc_tbl.slotDescriptors.push_back(slot_desc);</div> |
| <div class="line"><a name="l00265"></a><span class="lineno"> 265</span>  EXPECT_TRUE(<a class="code" href="classimpala_1_1DescriptorTbl.html#a7eec9a1b9f48220a92e3bdd4fdba44ba">DescriptorTbl::Create</a>(&<a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>, thrift_desc_tbl, &<a class="code" href="namespaceimpala.html#a0a06145acd27005a1c1f482dc2375742">desc_tbl_</a>).ok());</div> |
| <div class="line"><a name="l00266"></a><span class="lineno"> 266</span>  runtime_state_.set_desc_tbl(<a class="code" href="namespaceimpala.html#a0a06145acd27005a1c1f482dc2375742">desc_tbl_</a>);</div> |
| <div class="line"><a name="l00267"></a><span class="lineno"> 267</span> </div> |
| <div class="line"><a name="l00268"></a><span class="lineno"> 268</span>  vector<TTupleId> row_tids;</div> |
| <div class="line"><a name="l00269"></a><span class="lineno"> 269</span>  row_tids.push_back(0);</div> |
| <div class="line"><a name="l00270"></a><span class="lineno"> 270</span>  vector<bool> nullable_tuples;</div> |
| <div class="line"><a name="l00271"></a><span class="lineno"> 271</span>  nullable_tuples.push_back(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00272"></a><span class="lineno"> 272</span>  <a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a> = <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(*<a class="code" href="namespaceimpala.html#a0a06145acd27005a1c1f482dc2375742">desc_tbl_</a>, row_tids, nullable_tuples));</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>  <span class="comment">// Create a tuple comparator to sort in ascending order on the single bigint column.</span></div> |
| <div class="line"><a name="l00276"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#aa1801926107ca7764df29bc3dc09ea88"> 276</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#aa1801926107ca7764df29bc3dc09ea88">CreateTupleComparator</a>() {</div> |
| <div class="line"><a name="l00277"></a><span class="lineno"> 277</span>  <a class="code" href="classimpala_1_1SlotRef.html">SlotRef</a>* lhs_slot = <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1SlotRef.html">SlotRef</a>(<a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871ac5602f92ce48738739f551df8ff3e4a7">TYPE_BIGINT</a>, 0));</div> |
| <div class="line"><a name="l00278"></a><span class="lineno"> 278</span>  lhs_slot_ctx_ = <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1ExprContext.html">ExprContext</a>(lhs_slot));</div> |
| <div class="line"><a name="l00279"></a><span class="lineno"> 279</span>  <a class="code" href="classimpala_1_1SlotRef.html">SlotRef</a>* rhs_slot = <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1SlotRef.html">SlotRef</a>(<a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871ac5602f92ce48738739f551df8ff3e4a7">TYPE_BIGINT</a>, 0));</div> |
| <div class="line"><a name="l00280"></a><span class="lineno"> 280</span>  rhs_slot_ctx_ = <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1ExprContext.html">ExprContext</a>(rhs_slot));</div> |
| <div class="line"><a name="l00281"></a><span class="lineno"> 281</span> </div> |
| <div class="line"><a name="l00282"></a><span class="lineno"> 282</span>  lhs_slot_ctx_->Prepare(NULL, *<a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a>, &tracker_);</div> |
| <div class="line"><a name="l00283"></a><span class="lineno"> 283</span>  rhs_slot_ctx_->Prepare(NULL, *<a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a>, &tracker_);</div> |
| <div class="line"><a name="l00284"></a><span class="lineno"> 284</span>  lhs_slot_ctx_->Open(NULL);</div> |
| <div class="line"><a name="l00285"></a><span class="lineno"> 285</span>  rhs_slot_ctx_->Open(NULL);</div> |
| <div class="line"><a name="l00286"></a><span class="lineno"> 286</span>  less_than_ = <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1TupleRowComparator.html">TupleRowComparator</a>(</div> |
| <div class="line"><a name="l00287"></a><span class="lineno"> 287</span>  vector<ExprContext*>(1, lhs_slot_ctx_), vector<ExprContext*>(1, rhs_slot_ctx_),</div> |
| <div class="line"><a name="l00288"></a><span class="lineno"> 288</span>  vector<bool>(1, <span class="keyword">true</span>), vector<bool>(1, <span class="keyword">false</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"> 290</span> </div> |
| <div class="line"><a name="l00291"></a><span class="lineno"> 291</span>  <span class="comment">// Create batch_, but don't fill it with data yet. Assumes we created row_desc_.</span></div> |
| <div class="line"><a name="l00292"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#aecbb0e06bf1301155b38a5e175c74d08"> 292</a></span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#aecbb0e06bf1301155b38a5e175c74d08">CreateRowBatch</a>() {</div> |
| <div class="line"><a name="l00293"></a><span class="lineno"> 293</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = <span class="keyword">new</span> <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>(*<a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a>, BATCH_CAPACITY, &tracker_);</div> |
| <div class="line"><a name="l00294"></a><span class="lineno"> 294</span>  int64_t* tuple_mem = <span class="keyword">reinterpret_cast<</span>int64_t*<span class="keyword">></span>(</div> |
| <div class="line"><a name="l00295"></a><span class="lineno"> 295</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#a82611d227a12dd5c2e1ca1ba77d86736">tuple_data_pool</a>()-><a class="code" href="classimpala_1_1MemPool.html#a190eb28e39279c901eda3d831a9fe726">Allocate</a>(BATCH_CAPACITY * 8));</div> |
| <div class="line"><a name="l00296"></a><span class="lineno"> 296</span>  bzero(tuple_mem, BATCH_CAPACITY * 8);</div> |
| <div class="line"><a name="l00297"></a><span class="lineno"> 297</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < BATCH_CAPACITY; ++i) {</div> |
| <div class="line"><a name="l00298"></a><span class="lineno"> 298</span>  <span class="keywordtype">int</span> <a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a> = batch-><a class="code" href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">AddRow</a>();</div> |
| <div class="line"><a name="l00299"></a><span class="lineno"> 299</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(idx);</div> |
| <div class="line"><a name="l00300"></a><span class="lineno"> 300</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(0, reinterpret_cast<Tuple*>(&tuple_mem[i]));</div> |
| <div class="line"><a name="l00301"></a><span class="lineno"> 301</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">CommitLastRow</a>();</div> |
| <div class="line"><a name="l00302"></a><span class="lineno"> 302</span>  }</div> |
| <div class="line"><a name="l00303"></a><span class="lineno"> 303</span>  <span class="keywordflow">return</span> batch;</div> |
| <div class="line"><a name="l00304"></a><span class="lineno"> 304</span>  }</div> |
| <div class="line"><a name="l00305"></a><span class="lineno"> 305</span> </div> |
| <div class="line"><a name="l00306"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ad4d4e2859c9d65cecc27b74b7acf450e"> 306</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#ad4d4e2859c9d65cecc27b74b7acf450e">GetNextBatch</a>(<a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch, <span class="keywordtype">int</span>* next_val) {</div> |
| <div class="line"><a name="l00307"></a><span class="lineno"> 307</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < BATCH_CAPACITY; ++i) {</div> |
| <div class="line"><a name="l00308"></a><span class="lineno"> 308</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(i);</div> |
| <div class="line"><a name="l00309"></a><span class="lineno"> 309</span>  int64_t* val = <span class="keyword">reinterpret_cast<</span>int64_t*<span class="keyword">></span>(row-><a class="code" href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">GetTuple</a>(0)-><a class="code" href="classimpala_1_1Tuple.html#a5c9d7d0ca31caed74224c97bf55a1a5c">GetSlot</a>(0));</div> |
| <div class="line"><a name="l00310"></a><span class="lineno"> 310</span>  *val = (*next_val)++;</div> |
| <div class="line"><a name="l00311"></a><span class="lineno"> 311</span>  }</div> |
| <div class="line"><a name="l00312"></a><span class="lineno"> 312</span>  }</div> |
| <div class="line"><a name="l00313"></a><span class="lineno"> 313</span> </div> |
| <div class="line"><a name="l00314"></a><span class="lineno"> 314</span>  <span class="comment">// Start receiver (expecting given number of senders) in separate thread.</span></div> |
| <div class="line"><a name="l00315"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a8052911b92de3bb0ed1686ddd83c1ccb"> 315</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a8052911b92de3bb0ed1686ddd83c1ccb">StartReceiver</a>(TPartitionType::type stream_type, <span class="keywordtype">int</span> num_senders, <span class="keywordtype">int</span> receiver_num,</div> |
| <div class="line"><a name="l00316"></a><span class="lineno"> 316</span>  <span class="keywordtype">int</span> buffer_size, <span class="keywordtype">bool</span> is_merging, TUniqueId* out_id = NULL) {</div> |
| <div class="line"><a name="l00317"></a><span class="lineno"> 317</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"start receiver"</span>;</div> |
| <div class="line"><a name="l00318"></a><span class="lineno"> 318</span>  <a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* profile =</div> |
| <div class="line"><a name="l00319"></a><span class="lineno"> 319</span>  <a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>.Add(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>(&<a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>, <span class="stringliteral">"TestReceiver"</span>));</div> |
| <div class="line"><a name="l00320"></a><span class="lineno"> 320</span>  TUniqueId instance_id;</div> |
| <div class="line"><a name="l00321"></a><span class="lineno"> 321</span>  GetNextInstanceId(&instance_id);</div> |
| <div class="line"><a name="l00322"></a><span class="lineno"> 322</span>  receiver_info_.push_back(<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">ReceiverInfo</a>(stream_type, num_senders, receiver_num));</div> |
| <div class="line"><a name="l00323"></a><span class="lineno"> 323</span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">ReceiverInfo</a>& info = receiver_info_.back();</div> |
| <div class="line"><a name="l00324"></a><span class="lineno"> 324</span>  info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f">stream_recvr</a> =</div> |
| <div class="line"><a name="l00325"></a><span class="lineno"> 325</span>  stream_mgr_->CreateRecvr(&runtime_state_,</div> |
| <div class="line"><a name="l00326"></a><span class="lineno"> 326</span>  *<a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a>, instance_id, DEST_NODE_ID, num_senders, buffer_size, profile,</div> |
| <div class="line"><a name="l00327"></a><span class="lineno"> 327</span>  is_merging);</div> |
| <div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  <span class="keywordflow">if</span> (!is_merging) {</div> |
| <div class="line"><a name="l00329"></a><span class="lineno"> 329</span>  info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a0685f4cb46790076c1ab37c2bb714c2e">thread_handle</a> = <span class="keyword">new</span> thread(&<a class="code" href="classimpala_1_1DataStreamTest.html#a4844ae2641026fbde84ff40f9e059c9a">DataStreamTest::ReadStream</a>, <span class="keyword">this</span>, &info);</div> |
| <div class="line"><a name="l00330"></a><span class="lineno"> 330</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00331"></a><span class="lineno"> 331</span>  info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a0685f4cb46790076c1ab37c2bb714c2e">thread_handle</a> = <span class="keyword">new</span> thread(&<a class="code" href="classimpala_1_1DataStreamTest.html#a4f0b4921c0b8edf7d86a7c9735f11783">DataStreamTest::ReadStreamMerging</a>, <span class="keyword">this</span>, &info,</div> |
| <div class="line"><a name="l00332"></a><span class="lineno"> 332</span>  profile);</div> |
| <div class="line"><a name="l00333"></a><span class="lineno"> 333</span>  }</div> |
| <div class="line"><a name="l00334"></a><span class="lineno"> 334</span>  <span class="keywordflow">if</span> (out_id != NULL) *out_id = instance_id;</div> |
| <div class="line"><a name="l00335"></a><span class="lineno"> 335</span>  }</div> |
| <div class="line"><a name="l00336"></a><span class="lineno"> 336</span> </div> |
| <div class="line"><a name="l00337"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ae51f0a14202ca57b10e781c31307ddbb"> 337</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#ae51f0a14202ca57b10e781c31307ddbb">JoinReceivers</a>() {</div> |
| <div class="line"><a name="l00338"></a><span class="lineno"> 338</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"join receiver\n"</span>;</div> |
| <div class="line"><a name="l00339"></a><span class="lineno"> 339</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < receiver_info_.size(); ++i) {</div> |
| <div class="line"><a name="l00340"></a><span class="lineno"> 340</span>  receiver_info_[i].thread_handle->join();</div> |
| <div class="line"><a name="l00341"></a><span class="lineno"> 341</span>  receiver_info_[i].stream_recvr->Close();</div> |
| <div class="line"><a name="l00342"></a><span class="lineno"> 342</span>  }</div> |
| <div class="line"><a name="l00343"></a><span class="lineno"> 343</span>  }</div> |
| <div class="line"><a name="l00344"></a><span class="lineno"> 344</span> </div> |
| <div class="line"><a name="l00345"></a><span class="lineno"> 345</span>  <span class="comment">// Deplete stream and print batches</span></div> |
| <div class="line"><a name="l00346"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a4844ae2641026fbde84ff40f9e059c9a"> 346</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a4844ae2641026fbde84ff40f9e059c9a">ReadStream</a>(<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">ReceiverInfo</a>* info) {</div> |
| <div class="line"><a name="l00347"></a><span class="lineno"> 347</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch;</div> |
| <div class="line"><a name="l00348"></a><span class="lineno"> 348</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"start reading"</span>;</div> |
| <div class="line"><a name="l00349"></a><span class="lineno"> 349</span>  <span class="keywordflow">while</span> (!(info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a> = info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f">stream_recvr</a>->GetBatch(&batch)).IsCancelled() &&</div> |
| <div class="line"><a name="l00350"></a><span class="lineno"> 350</span>  (batch != NULL)) {</div> |
| <div class="line"><a name="l00351"></a><span class="lineno"> 351</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"read batch #rows="</span> << batch-><a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>();</div> |
| <div class="line"><a name="l00352"></a><span class="lineno"> 352</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < batch-><a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>(); ++i) {</div> |
| <div class="line"><a name="l00353"></a><span class="lineno"> 353</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(i);</div> |
| <div class="line"><a name="l00354"></a><span class="lineno"> 354</span>  info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.insert(*static_cast<int64_t*>(row-><a class="code" href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">GetTuple</a>(0)-><a class="code" href="classimpala_1_1Tuple.html#a5c9d7d0ca31caed74224c97bf55a1a5c">GetSlot</a>(0)));</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>  <a class="code" href="namespaceimpala.html#a57debe017e657e4692b405fa183f7ca8">SleepForMs</a>(100); <span class="comment">// slow down receiver to exercise buffering logic</span></div> |
| <div class="line"><a name="l00357"></a><span class="lineno"> 357</span>  }</div> |
| <div class="line"><a name="l00358"></a><span class="lineno"> 358</span>  <span class="keywordflow">if</span> (info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a>.<a class="code" href="classimpala_1_1Status.html#a327e57a4c61d1387f8b52fce20e89a34">IsCancelled</a>()) <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"reader is cancelled"</span>;</div> |
| <div class="line"><a name="l00359"></a><span class="lineno"> 359</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"done reading"</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> </div> |
| <div class="line"><a name="l00362"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a4f0b4921c0b8edf7d86a7c9735f11783"> 362</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a4f0b4921c0b8edf7d86a7c9735f11783">ReadStreamMerging</a>(<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">ReceiverInfo</a>* info, <a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* profile) {</div> |
| <div class="line"><a name="l00363"></a><span class="lineno"> 363</span>  info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a> = info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f">stream_recvr</a>->CreateMerger(*less_than_);</div> |
| <div class="line"><a name="l00364"></a><span class="lineno"> 364</span>  <span class="keywordflow">if</span> (info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a>.<a class="code" href="classimpala_1_1Status.html#a327e57a4c61d1387f8b52fce20e89a34">IsCancelled</a>()) <span class="keywordflow">return</span>;</div> |
| <div class="line"><a name="l00365"></a><span class="lineno"> 365</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a> batch(*<a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a>, 1024, &tracker_);</div> |
| <div class="line"><a name="l00366"></a><span class="lineno"> 366</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"start reading merging"</span>;</div> |
| <div class="line"><a name="l00367"></a><span class="lineno"> 367</span>  <span class="keywordtype">bool</span> eos;</div> |
| <div class="line"><a name="l00368"></a><span class="lineno"> 368</span>  <span class="keywordflow">while</span> (!(info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a> = info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f">stream_recvr</a>->GetNext(&batch, &eos)).IsCancelled()) {</div> |
| <div class="line"><a name="l00369"></a><span class="lineno"> 369</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"read batch #rows="</span> << batch.<a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>();</div> |
| <div class="line"><a name="l00370"></a><span class="lineno"> 370</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < batch.<a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>(); ++i) {</div> |
| <div class="line"><a name="l00371"></a><span class="lineno"> 371</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch.<a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(i);</div> |
| <div class="line"><a name="l00372"></a><span class="lineno"> 372</span>  info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.insert(*static_cast<int64_t*>(row-><a class="code" href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">GetTuple</a>(0)-><a class="code" href="classimpala_1_1Tuple.html#a5c9d7d0ca31caed74224c97bf55a1a5c">GetSlot</a>(0)));</div> |
| <div class="line"><a name="l00373"></a><span class="lineno"> 373</span>  }</div> |
| <div class="line"><a name="l00374"></a><span class="lineno"> 374</span>  <a class="code" href="namespaceimpala.html#a57debe017e657e4692b405fa183f7ca8">SleepForMs</a>(100);</div> |
| <div class="line"><a name="l00375"></a><span class="lineno"> 375</span>  batch.<a class="code" href="classimpala_1_1RowBatch.html#ac351eaf211eb53882564b604db07b824">Reset</a>();</div> |
| <div class="line"><a name="l00376"></a><span class="lineno"> 376</span>  <span class="keywordflow">if</span> (eos) <span class="keywordflow">break</span>;</div> |
| <div class="line"><a name="l00377"></a><span class="lineno"> 377</span>  }</div> |
| <div class="line"><a name="l00378"></a><span class="lineno"> 378</span>  <span class="keywordflow">if</span> (info-><a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a>.<a class="code" href="classimpala_1_1Status.html#a327e57a4c61d1387f8b52fce20e89a34">IsCancelled</a>()) <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"reader is cancelled"</span>;</div> |
| <div class="line"><a name="l00379"></a><span class="lineno"> 379</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"done reading"</span>;</div> |
| <div class="line"><a name="l00380"></a><span class="lineno"> 380</span>  }</div> |
| <div class="line"><a name="l00381"></a><span class="lineno"> 381</span> </div> |
| <div class="line"><a name="l00382"></a><span class="lineno"> 382</span>  <span class="comment">// Verify correctness of receivers' data values.</span></div> |
| <div class="line"><a name="l00383"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a4a6ff9dc4d0805d1031c47fba5d4c6a4"> 383</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a4a6ff9dc4d0805d1031c47fba5d4c6a4">CheckReceivers</a>(TPartitionType::type stream_type, <span class="keywordtype">int</span> num_senders) {</div> |
| <div class="line"><a name="l00384"></a><span class="lineno"> 384</span>  int64_t total = 0;</div> |
| <div class="line"><a name="l00385"></a><span class="lineno"> 385</span>  multiset<int64_t> all_data_values;</div> |
| <div class="line"><a name="l00386"></a><span class="lineno"> 386</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < receiver_info_.size(); ++i) {</div> |
| <div class="line"><a name="l00387"></a><span class="lineno"> 387</span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">ReceiverInfo</a>& info = receiver_info_[i];</div> |
| <div class="line"><a name="l00388"></a><span class="lineno"> 388</span>  EXPECT_TRUE(info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">status</a>.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>());</div> |
| <div class="line"><a name="l00389"></a><span class="lineno"> 389</span>  total += info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.size();</div> |
| <div class="line"><a name="l00390"></a><span class="lineno"> 390</span>  DCHECK_EQ(info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a41a4a41472f7d7b3807ede1524d2f63f">stream_type</a>, stream_type);</div> |
| <div class="line"><a name="l00391"></a><span class="lineno"> 391</span>  DCHECK_EQ(info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ab8ac82d64131f546638d41fe4def99f4">num_senders</a>, num_senders);</div> |
| <div class="line"><a name="l00392"></a><span class="lineno"> 392</span>  <span class="keywordflow">if</span> (stream_type == TPartitionType::UNPARTITIONED) {</div> |
| <div class="line"><a name="l00393"></a><span class="lineno"> 393</span>  EXPECT_EQ(</div> |
| <div class="line"><a name="l00394"></a><span class="lineno"> 394</span>  NUM_BATCHES * BATCH_CAPACITY * num_senders, info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.size());</div> |
| <div class="line"><a name="l00395"></a><span class="lineno"> 395</span>  }</div> |
| <div class="line"><a name="l00396"></a><span class="lineno"> 396</span>  all_data_values.insert(info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.begin(), info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.end());</div> |
| <div class="line"><a name="l00397"></a><span class="lineno"> 397</span> </div> |
| <div class="line"><a name="l00398"></a><span class="lineno"> 398</span>  <span class="keywordtype">int</span> k = 0;</div> |
| <div class="line"><a name="l00399"></a><span class="lineno"> 399</span>  <span class="keywordflow">for</span> (multiset<int64_t>::iterator j = info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.begin();</div> |
| <div class="line"><a name="l00400"></a><span class="lineno"> 400</span>  j != info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">data_values</a>.end(); ++j, ++k) {</div> |
| <div class="line"><a name="l00401"></a><span class="lineno"> 401</span>  <span class="keywordflow">if</span> (stream_type == TPartitionType::UNPARTITIONED) {</div> |
| <div class="line"><a name="l00402"></a><span class="lineno"> 402</span>  <span class="comment">// unpartitioned streams contain all values as many times as there are</span></div> |
| <div class="line"><a name="l00403"></a><span class="lineno"> 403</span>  <span class="comment">// senders</span></div> |
| <div class="line"><a name="l00404"></a><span class="lineno"> 404</span>  EXPECT_EQ(k / num_senders, *j);</div> |
| <div class="line"><a name="l00405"></a><span class="lineno"> 405</span>  } <span class="keywordflow">else</span> <span class="keywordflow">if</span> (stream_type == TPartitionType::HASH_PARTITIONED) {</div> |
| <div class="line"><a name="l00406"></a><span class="lineno"> 406</span>  <span class="comment">// hash-partitioned streams send values to the right partition</span></div> |
| <div class="line"><a name="l00407"></a><span class="lineno"> 407</span>  int64_t value = *j;</div> |
| <div class="line"><a name="l00408"></a><span class="lineno"> 408</span>  uint32_t hash_val =</div> |
| <div class="line"><a name="l00409"></a><span class="lineno"> 409</span>  <a class="code" href="classimpala_1_1RawValue.html#ade36561a0ea59fde387ff49f6565c6ec">RawValue::GetHashValueFnv</a>(&value, <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871ac5602f92ce48738739f551df8ff3e4a7">TYPE_BIGINT</a>, <a class="code" href="classimpala_1_1HashUtil.html#ad47e5dcaf416f05760be732dfbc66651">HashUtil::FNV_SEED</a>);</div> |
| <div class="line"><a name="l00410"></a><span class="lineno"> 410</span>  EXPECT_EQ(hash_val % receiver_info_.size(), info.<a class="code" href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a8bafa8e37b26499341ca2ad69d152c74">receiver_num</a>);</div> |
| <div class="line"><a name="l00411"></a><span class="lineno"> 411</span>  }</div> |
| <div class="line"><a name="l00412"></a><span class="lineno"> 412</span>  }</div> |
| <div class="line"><a name="l00413"></a><span class="lineno"> 413</span>  }</div> |
| <div class="line"><a name="l00414"></a><span class="lineno"> 414</span> </div> |
| <div class="line"><a name="l00415"></a><span class="lineno"> 415</span>  <span class="keywordflow">if</span> (stream_type == TPartitionType::HASH_PARTITIONED) {</div> |
| <div class="line"><a name="l00416"></a><span class="lineno"> 416</span>  EXPECT_EQ(NUM_BATCHES * BATCH_CAPACITY * num_senders, total);</div> |
| <div class="line"><a name="l00417"></a><span class="lineno"> 417</span> </div> |
| <div class="line"><a name="l00418"></a><span class="lineno"> 418</span>  <span class="keywordtype">int</span> k = 0;</div> |
| <div class="line"><a name="l00419"></a><span class="lineno"> 419</span>  <span class="keywordflow">for</span> (multiset<int64_t>::iterator j = all_data_values.begin();</div> |
| <div class="line"><a name="l00420"></a><span class="lineno"> 420</span>  j != all_data_values.end(); ++j, ++k) {</div> |
| <div class="line"><a name="l00421"></a><span class="lineno"> 421</span>  <span class="comment">// each sender sent all values</span></div> |
| <div class="line"><a name="l00422"></a><span class="lineno"> 422</span>  EXPECT_EQ(k / num_senders, *j);</div> |
| <div class="line"><a name="l00423"></a><span class="lineno"> 423</span>  <span class="keywordflow">if</span> (k/num_senders != *j) <span class="keywordflow">break</span>;</div> |
| <div class="line"><a name="l00424"></a><span class="lineno"> 424</span>  }</div> |
| <div class="line"><a name="l00425"></a><span class="lineno"> 425</span>  }</div> |
| <div class="line"><a name="l00426"></a><span class="lineno"> 426</span>  }</div> |
| <div class="line"><a name="l00427"></a><span class="lineno"> 427</span> </div> |
| <div class="line"><a name="l00428"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a05ed79930a7121c4d21f5423801b76e2"> 428</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a05ed79930a7121c4d21f5423801b76e2">CheckSenders</a>() {</div> |
| <div class="line"><a name="l00429"></a><span class="lineno"> 429</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < sender_info_.size(); ++i) {</div> |
| <div class="line"><a name="l00430"></a><span class="lineno"> 430</span>  EXPECT_TRUE(sender_info_[i].status.ok());</div> |
| <div class="line"><a name="l00431"></a><span class="lineno"> 431</span>  EXPECT_GT(sender_info_[i].num_bytes_sent, 0);</div> |
| <div class="line"><a name="l00432"></a><span class="lineno"> 432</span>  }</div> |
| <div class="line"><a name="l00433"></a><span class="lineno"> 433</span>  }</div> |
| <div class="line"><a name="l00434"></a><span class="lineno"> 434</span> </div> |
| <div class="line"><a name="l00435"></a><span class="lineno"> 435</span>  <span class="comment">// Start backend in separate thread.</span></div> |
| <div class="line"><a name="l00436"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ab6f0d5e2c4cd0ab8e8a6f5e4380d8f59"> 436</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#ab6f0d5e2c4cd0ab8e8a6f5e4380d8f59">StartBackend</a>() {</div> |
| <div class="line"><a name="l00437"></a><span class="lineno"> 437</span>  shared_ptr<ImpalaTestBackend> handler(<span class="keyword">new</span> <a class="code" href="classimpala_1_1ImpalaTestBackend.html">ImpalaTestBackend</a>(stream_mgr_));</div> |
| <div class="line"><a name="l00438"></a><span class="lineno"> 438</span>  shared_ptr<TProcessor> processor(<span class="keyword">new</span> ImpalaInternalServiceProcessor(handler));</div> |
| <div class="line"><a name="l00439"></a><span class="lineno"> 439</span>  server_ = <span class="keyword">new</span> <a class="code" href="classimpala_1_1ThriftServer.html">ThriftServer</a>(<span class="stringliteral">"DataStreamTest backend"</span>, processor, FLAGS_port, NULL);</div> |
| <div class="line"><a name="l00440"></a><span class="lineno"> 440</span>  server_->Start();</div> |
| <div class="line"><a name="l00441"></a><span class="lineno"> 441</span>  }</div> |
| <div class="line"><a name="l00442"></a><span class="lineno"> 442</span> </div> |
| <div class="line"><a name="l00443"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a38aca1d23adb809a4fda78d5e78a5178"> 443</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a38aca1d23adb809a4fda78d5e78a5178">StopBackend</a>() {</div> |
| <div class="line"><a name="l00444"></a><span class="lineno"> 444</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"stop backend\n"</span>;</div> |
| <div class="line"><a name="l00445"></a><span class="lineno"> 445</span>  server_->StopForTesting();</div> |
| <div class="line"><a name="l00446"></a><span class="lineno"> 446</span>  <span class="keyword">delete</span> server_;</div> |
| <div class="line"><a name="l00447"></a><span class="lineno"> 447</span>  }</div> |
| <div class="line"><a name="l00448"></a><span class="lineno"> 448</span> </div> |
| <div class="line"><a name="l00449"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ada07d1806b1b06f37ff403505444a4a8"> 449</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#ada07d1806b1b06f37ff403505444a4a8">StartSender</a>(TPartitionType::type partition_type = TPartitionType::UNPARTITIONED,</div> |
| <div class="line"><a name="l00450"></a><span class="lineno"> 450</span>  <span class="keywordtype">int</span> channel_buffer_size = 1024) {</div> |
| <div class="line"><a name="l00451"></a><span class="lineno"> 451</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"start sender"</span>;</div> |
| <div class="line"><a name="l00452"></a><span class="lineno"> 452</span>  <span class="keywordtype">int</span> num_senders = sender_info_.size();</div> |
| <div class="line"><a name="l00453"></a><span class="lineno"> 453</span>  DCHECK_LT(num_senders, MAX_SENDERS);</div> |
| <div class="line"><a name="l00454"></a><span class="lineno"> 454</span>  sender_info_.push_back(<a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html">SenderInfo</a>());</div> |
| <div class="line"><a name="l00455"></a><span class="lineno"> 455</span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html">SenderInfo</a>& info = sender_info_.back();</div> |
| <div class="line"><a name="l00456"></a><span class="lineno"> 456</span>  info.<a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#adead5c848da6d8a13a2a31114c1ef8e8">thread_handle</a> =</div> |
| <div class="line"><a name="l00457"></a><span class="lineno"> 457</span>  <span class="keyword">new</span> thread(&<a class="code" href="classimpala_1_1DataStreamTest.html#a254bb451910193a6964b61a8df75d019">DataStreamTest::Sender</a>, <span class="keyword">this</span>, num_senders, channel_buffer_size,</div> |
| <div class="line"><a name="l00458"></a><span class="lineno"> 458</span>  partition_type);</div> |
| <div class="line"><a name="l00459"></a><span class="lineno"> 459</span>  }</div> |
| <div class="line"><a name="l00460"></a><span class="lineno"> 460</span> </div> |
| <div class="line"><a name="l00461"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#abb1caf4d38947d932566cf415b06ffbd"> 461</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#abb1caf4d38947d932566cf415b06ffbd">JoinSenders</a>() {</div> |
| <div class="line"><a name="l00462"></a><span class="lineno"> 462</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"join senders\n"</span>;</div> |
| <div class="line"><a name="l00463"></a><span class="lineno"> 463</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < sender_info_.size(); ++i) {</div> |
| <div class="line"><a name="l00464"></a><span class="lineno"> 464</span>  sender_info_[i].thread_handle->join();</div> |
| <div class="line"><a name="l00465"></a><span class="lineno"> 465</span>  }</div> |
| <div class="line"><a name="l00466"></a><span class="lineno"> 466</span>  }</div> |
| <div class="line"><a name="l00467"></a><span class="lineno"> 467</span> </div> |
| <div class="line"><a name="l00468"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a254bb451910193a6964b61a8df75d019"> 468</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a254bb451910193a6964b61a8df75d019">Sender</a>(<span class="keywordtype">int</span> sender_num, <span class="keywordtype">int</span> channel_buffer_size,</div> |
| <div class="line"><a name="l00469"></a><span class="lineno"> 469</span>  TPartitionType::type partition_type) {</div> |
| <div class="line"><a name="l00470"></a><span class="lineno"> 470</span>  <a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a> state(TPlanFragmentInstanceCtx(), <span class="stringliteral">""</span>, &<a class="code" href="namespaceimpala.html#a57eaecb97c9c87e4c57c8a8a81211422">exec_env_</a>);</div> |
| <div class="line"><a name="l00471"></a><span class="lineno"> 471</span>  state.<a class="code" href="classimpala_1_1RuntimeState.html#a6548724bfda2e15f0fcbec40aa5f2704">set_desc_tbl</a>(<a class="code" href="namespaceimpala.html#a0a06145acd27005a1c1f482dc2375742">desc_tbl_</a>);</div> |
| <div class="line"><a name="l00472"></a><span class="lineno"> 472</span>  state.<a class="code" href="classimpala_1_1RuntimeState.html#a5266fa82fd51cd6b2da82113fc1c7461">InitMemTrackers</a>(TUniqueId(), NULL, -1);</div> |
| <div class="line"><a name="l00473"></a><span class="lineno"> 473</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"create sender "</span> << sender_num;</div> |
| <div class="line"><a name="l00474"></a><span class="lineno"> 474</span>  <span class="keyword">const</span> TDataStreamSink& sink = GetSink(partition_type);</div> |
| <div class="line"><a name="l00475"></a><span class="lineno"> 475</span>  <a class="code" href="classimpala_1_1DataStreamSender.html">DataStreamSender</a> sender(</div> |
| <div class="line"><a name="l00476"></a><span class="lineno"> 476</span>  &<a class="code" href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">obj_pool_</a>, sender_num, *<a class="code" href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">row_desc_</a>, sink, dest_, channel_buffer_size);</div> |
| <div class="line"><a name="l00477"></a><span class="lineno"> 477</span>  EXPECT_TRUE(sender.<a class="code" href="classimpala_1_1DataStreamSender.html#acef39c14c7ed4b85122aa3c0cde80247">Prepare</a>(&state).<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>());</div> |
| <div class="line"><a name="l00478"></a><span class="lineno"> 478</span>  EXPECT_TRUE(sender.<a class="code" href="classimpala_1_1DataStreamSender.html#a441b986df33ba936a2de32af7e84c9d8">Open</a>(&state).<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>());</div> |
| <div class="line"><a name="l00479"></a><span class="lineno"> 479</span>  scoped_ptr<RowBatch> batch(CreateRowBatch());</div> |
| <div class="line"><a name="l00480"></a><span class="lineno"> 480</span>  <a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html">SenderInfo</a>& info = sender_info_[sender_num];</div> |
| <div class="line"><a name="l00481"></a><span class="lineno"> 481</span>  <span class="keywordtype">int</span> next_val = 0;</div> |
| <div class="line"><a name="l00482"></a><span class="lineno"> 482</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < NUM_BATCHES; ++i) {</div> |
| <div class="line"><a name="l00483"></a><span class="lineno"> 483</span>  GetNextBatch(batch.get(), &next_val);</div> |
| <div class="line"><a name="l00484"></a><span class="lineno"> 484</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"sender "</span> << sender_num << <span class="stringliteral">": #rows="</span> << batch->num_rows();</div> |
| <div class="line"><a name="l00485"></a><span class="lineno"> 485</span>  info.<a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a28b83da3011974cfff63e16631efcc2f">status</a> = sender.<a class="code" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send</a>(&state, batch.get(), <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00486"></a><span class="lineno"> 486</span>  <span class="keywordflow">if</span> (!info.<a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a28b83da3011974cfff63e16631efcc2f">status</a>.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>()) <span class="keywordflow">break</span>;</div> |
| <div class="line"><a name="l00487"></a><span class="lineno"> 487</span>  }</div> |
| <div class="line"><a name="l00488"></a><span class="lineno"> 488</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"closing sender"</span> << sender_num;</div> |
| <div class="line"><a name="l00489"></a><span class="lineno"> 489</span>  sender.<a class="code" href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">Close</a>(&state);</div> |
| <div class="line"><a name="l00490"></a><span class="lineno"> 490</span>  info.<a class="code" href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#ab673cac8bb65a73ba3ac5ebe1cc4817e">num_bytes_sent</a> = sender.<a class="code" href="classimpala_1_1DataStreamSender.html#ae93db027f9d0cb4c50e8dd962d92a624">GetNumDataBytesSent</a>();</div> |
| <div class="line"><a name="l00491"></a><span class="lineno"> 491</span> </div> |
| <div class="line"><a name="l00492"></a><span class="lineno"> 492</span>  batch->Reset();</div> |
| <div class="line"><a name="l00493"></a><span class="lineno"> 493</span>  }</div> |
| <div class="line"><a name="l00494"></a><span class="lineno"> 494</span> </div> |
| <div class="line"><a name="l00495"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a36a5d2a479c1863f04ac7629d96c1d9a"> 495</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamTest.html#a36a5d2a479c1863f04ac7629d96c1d9a">TestStream</a>(TPartitionType::type stream_type, <span class="keywordtype">int</span> num_senders,</div> |
| <div class="line"><a name="l00496"></a><span class="lineno"> 496</span>  <span class="keywordtype">int</span> num_receivers, <span class="keywordtype">int</span> buffer_size, <span class="keywordtype">bool</span> is_merging) {</div> |
| <div class="line"><a name="l00497"></a><span class="lineno"> 497</span>  <a class="code" href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a> << <span class="stringliteral">"Testing stream="</span> << stream_type << <span class="stringliteral">" #senders="</span> << num_senders</div> |
| <div class="line"><a name="l00498"></a><span class="lineno"> 498</span>  << <span class="stringliteral">" #receivers="</span> << num_receivers << <span class="stringliteral">" buffer_size="</span> << buffer_size</div> |
| <div class="line"><a name="l00499"></a><span class="lineno"> 499</span>  << <span class="stringliteral">" is_merging="</span> << is_merging;</div> |
| <div class="line"><a name="l00500"></a><span class="lineno"> 500</span>  Reset();</div> |
| <div class="line"><a name="l00501"></a><span class="lineno"> 501</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_receivers; ++i) {</div> |
| <div class="line"><a name="l00502"></a><span class="lineno"> 502</span>  StartReceiver(stream_type, num_senders, i, buffer_size, is_merging);</div> |
| <div class="line"><a name="l00503"></a><span class="lineno"> 503</span>  }</div> |
| <div class="line"><a name="l00504"></a><span class="lineno"> 504</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_senders; ++i) {</div> |
| <div class="line"><a name="l00505"></a><span class="lineno"> 505</span>  StartSender(stream_type, buffer_size);</div> |
| <div class="line"><a name="l00506"></a><span class="lineno"> 506</span>  }</div> |
| <div class="line"><a name="l00507"></a><span class="lineno"> 507</span>  JoinSenders();</div> |
| <div class="line"><a name="l00508"></a><span class="lineno"> 508</span>  CheckSenders();</div> |
| <div class="line"><a name="l00509"></a><span class="lineno"> 509</span>  JoinReceivers();</div> |
| <div class="line"><a name="l00510"></a><span class="lineno"> 510</span>  CheckReceivers(stream_type, num_senders);</div> |
| <div class="line"><a name="l00511"></a><span class="lineno"> 511</span>  }</div> |
| <div class="line"><a name="l00512"></a><span class="lineno"> 512</span> </div> |
| <div class="line"><a name="l00513"></a><span class="lineno"> 513</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00514"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#a5befc2f953e389e9846bd2f3bc7e3a5e"> 514</a></span>  <a class="code" href="classimpala_1_1ExprContext.html">ExprContext</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#a5befc2f953e389e9846bd2f3bc7e3a5e">lhs_slot_ctx_</a>;</div> |
| <div class="line"><a name="l00515"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamTest.html#ac0cc74d6fb80dd4c02226822343c58e2"> 515</a></span>  <a class="code" href="classimpala_1_1ExprContext.html">ExprContext</a>* <a class="code" href="classimpala_1_1DataStreamTest.html#ac0cc74d6fb80dd4c02226822343c58e2">rhs_slot_ctx_</a>;</div> |
| <div class="line"><a name="l00516"></a><span class="lineno"> 516</span> };</div> |
| <div class="line"><a name="l00517"></a><span class="lineno"> 517</span> </div> |
| <div class="line"><a name="l00518"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a3633c84532254bfb7651390ff6b4bd72"> 518</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1DataStreamTest.html">DataStreamTest</a>, UnknownSenderSmallResult) {</div> |
| <div class="line"><a name="l00519"></a><span class="lineno"> 519</span>  <span class="comment">// starting a sender w/o a corresponding receiver does not result in an error because</span></div> |
| <div class="line"><a name="l00520"></a><span class="lineno"> 520</span>  <span class="comment">// we cannot distinguish whether a receiver was never created or the receiver</span></div> |
| <div class="line"><a name="l00521"></a><span class="lineno"> 521</span>  <span class="comment">// willingly tore down the stream</span></div> |
| <div class="line"><a name="l00522"></a><span class="lineno"> 522</span>  <span class="comment">// case 1: entire query result fits in single buffer, close() returns ok</span></div> |
| <div class="line"><a name="l00523"></a><span class="lineno"> 523</span>  TUniqueId dummy_id;</div> |
| <div class="line"><a name="l00524"></a><span class="lineno"> 524</span>  GetNextInstanceId(&dummy_id);</div> |
| <div class="line"><a name="l00525"></a><span class="lineno"> 525</span>  StartSender(TPartitionType::UNPARTITIONED, TOTAL_DATA_SIZE + 1024);</div> |
| <div class="line"><a name="l00526"></a><span class="lineno"> 526</span>  JoinSenders();</div> |
| <div class="line"><a name="l00527"></a><span class="lineno"> 527</span>  EXPECT_TRUE(sender_info_[0].status.ok());</div> |
| <div class="line"><a name="l00528"></a><span class="lineno"> 528</span>  EXPECT_GT(sender_info_[0].num_bytes_sent, 0);</div> |
| <div class="line"><a name="l00529"></a><span class="lineno"> 529</span> }</div> |
| <div class="line"><a name="l00530"></a><span class="lineno"> 530</span> </div> |
| <div class="line"><a name="l00531"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a9175c590302bbcce6983650140d8445b"> 531</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1DataStreamTest.html">DataStreamTest</a>, UnknownSenderLargeResult) {</div> |
| <div class="line"><a name="l00532"></a><span class="lineno"> 532</span>  <span class="comment">// case 2: query result requires multiple buffers, send() returns ok</span></div> |
| <div class="line"><a name="l00533"></a><span class="lineno"> 533</span>  TUniqueId dummy_id;</div> |
| <div class="line"><a name="l00534"></a><span class="lineno"> 534</span>  GetNextInstanceId(&dummy_id);</div> |
| <div class="line"><a name="l00535"></a><span class="lineno"> 535</span>  StartSender();</div> |
| <div class="line"><a name="l00536"></a><span class="lineno"> 536</span>  JoinSenders();</div> |
| <div class="line"><a name="l00537"></a><span class="lineno"> 537</span>  EXPECT_TRUE(sender_info_[0].status.ok());</div> |
| <div class="line"><a name="l00538"></a><span class="lineno"> 538</span>  EXPECT_GT(sender_info_[0].num_bytes_sent, 0);</div> |
| <div class="line"><a name="l00539"></a><span class="lineno"> 539</span> }</div> |
| <div class="line"><a name="l00540"></a><span class="lineno"> 540</span> </div> |
| <div class="line"><a name="l00541"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a1b9cc81d131a91b6d58537b3cc6621b2"> 541</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1DataStreamTest.html">DataStreamTest</a>, <a class="code" href="namespaceimpala.html#a508481848105bae62dd5722fd747572a">Cancel</a>) {</div> |
| <div class="line"><a name="l00542"></a><span class="lineno"> 542</span>  TUniqueId instance_id;</div> |
| <div class="line"><a name="l00543"></a><span class="lineno"> 543</span>  StartReceiver(TPartitionType::UNPARTITIONED, 1, 1, 1024, <span class="keyword">false</span>, &instance_id);</div> |
| <div class="line"><a name="l00544"></a><span class="lineno"> 544</span>  stream_mgr_->Cancel(instance_id);</div> |
| <div class="line"><a name="l00545"></a><span class="lineno"> 545</span>  StartReceiver(TPartitionType::UNPARTITIONED, 1, 1, 1024, <span class="keyword">true</span>, &instance_id);</div> |
| <div class="line"><a name="l00546"></a><span class="lineno"> 546</span>  stream_mgr_->Cancel(instance_id);</div> |
| <div class="line"><a name="l00547"></a><span class="lineno"> 547</span>  JoinReceivers();</div> |
| <div class="line"><a name="l00548"></a><span class="lineno"> 548</span>  EXPECT_TRUE(receiver_info_[0].status.IsCancelled());</div> |
| <div class="line"><a name="l00549"></a><span class="lineno"> 549</span>  EXPECT_TRUE(receiver_info_[1].status.IsCancelled());</div> |
| <div class="line"><a name="l00550"></a><span class="lineno"> 550</span> }</div> |
| <div class="line"><a name="l00551"></a><span class="lineno"> 551</span> </div> |
| <div class="line"><a name="l00552"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a00b024ac5f467ea452f81fdbe98d3b7a"> 552</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1DataStreamTest.html">DataStreamTest</a>, BasicTest) {</div> |
| <div class="line"><a name="l00553"></a><span class="lineno"> 553</span>  <span class="comment">// TODO: also test that all client connections have been returned</span></div> |
| <div class="line"><a name="l00554"></a><span class="lineno"> 554</span>  TPartitionType::type stream_types[] =</div> |
| <div class="line"><a name="l00555"></a><span class="lineno"> 555</span>  {TPartitionType::UNPARTITIONED, TPartitionType::RANDOM,</div> |
| <div class="line"><a name="l00556"></a><span class="lineno"> 556</span>  TPartitionType::HASH_PARTITIONED};</div> |
| <div class="line"><a name="l00557"></a><span class="lineno"> 557</span>  <span class="keywordtype">int</span> sender_nums[] = {1, 4};</div> |
| <div class="line"><a name="l00558"></a><span class="lineno"> 558</span>  <span class="keywordtype">int</span> receiver_nums[] = {1, 4};</div> |
| <div class="line"><a name="l00559"></a><span class="lineno"> 559</span>  <span class="keywordtype">int</span> buffer_sizes[] = {1024, 1024 * 1024};</div> |
| <div class="line"><a name="l00560"></a><span class="lineno"> 560</span>  <span class="keywordtype">bool</span> merging[] = {<span class="keyword">false</span>, <span class="keyword">true</span>};</div> |
| <div class="line"><a name="l00561"></a><span class="lineno"> 561</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < <span class="keyword">sizeof</span>(stream_types) / <span class="keyword">sizeof</span>(*stream_types); ++i) {</div> |
| <div class="line"><a name="l00562"></a><span class="lineno"> 562</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < <span class="keyword">sizeof</span>(sender_nums) / <span class="keyword">sizeof</span>(<span class="keywordtype">int</span>); ++j) {</div> |
| <div class="line"><a name="l00563"></a><span class="lineno"> 563</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> k = 0; k < <span class="keyword">sizeof</span>(receiver_nums) / <span class="keyword">sizeof</span>(<span class="keywordtype">int</span>); ++k) {</div> |
| <div class="line"><a name="l00564"></a><span class="lineno"> 564</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> l = 0; l < <span class="keyword">sizeof</span>(buffer_sizes) / <span class="keyword">sizeof</span>(<span class="keywordtype">int</span>); ++l) {</div> |
| <div class="line"><a name="l00565"></a><span class="lineno"> 565</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> m = 0; m < <span class="keyword">sizeof</span>(merging) / <span class="keyword">sizeof</span>(<span class="keywordtype">bool</span>); ++m) {</div> |
| <div class="line"><a name="l00566"></a><span class="lineno"> 566</span>  TestStream(stream_types[i], sender_nums[j], receiver_nums[k],</div> |
| <div class="line"><a name="l00567"></a><span class="lineno"> 567</span>  buffer_sizes[l], merging[m]);</div> |
| <div class="line"><a name="l00568"></a><span class="lineno"> 568</span>  }</div> |
| <div class="line"><a name="l00569"></a><span class="lineno"> 569</span>  }</div> |
| <div class="line"><a name="l00570"></a><span class="lineno"> 570</span>  }</div> |
| <div class="line"><a name="l00571"></a><span class="lineno"> 571</span>  }</div> |
| <div class="line"><a name="l00572"></a><span class="lineno"> 572</span>  }</div> |
| <div class="line"><a name="l00573"></a><span class="lineno"> 573</span> }</div> |
| <div class="line"><a name="l00574"></a><span class="lineno"> 574</span> </div> |
| <div class="line"><a name="l00575"></a><span class="lineno"> 575</span> <span class="comment">// TODO: more tests:</span></div> |
| <div class="line"><a name="l00576"></a><span class="lineno"> 576</span> <span class="comment">// - test case for transmission error in last batch</span></div> |
| <div class="line"><a name="l00577"></a><span class="lineno"> 577</span> <span class="comment">// - receivers getting created concurrently</span></div> |
| <div class="line"><a name="l00578"></a><span class="lineno"> 578</span> </div> |
| <div class="line"><a name="l00579"></a><span class="lineno"> 579</span> }</div> |
| <div class="line"><a name="l00580"></a><span class="lineno"> 580</span> </div> |
| <div class="line"><a name="l00581"></a><span class="lineno"><a class="line" href="data-stream-test_8cc.html#a3c04138a5bfe5d72780bb7e82a18e627"> 581</a></span> <span class="keywordtype">int</span> <a class="code" href="data-stream-test_8cc.html#a3c04138a5bfe5d72780bb7e82a18e627">main</a>(<span class="keywordtype">int</span> argc, <span class="keywordtype">char</span> **argv) {</div> |
| <div class="line"><a name="l00582"></a><span class="lineno"> 582</span>  ::testing::InitGoogleTest(&argc, argv);</div> |
| <div class="line"><a name="l00583"></a><span class="lineno"> 583</span>  <a class="code" href="namespaceimpala.html#ad1fa91f70d2090b45d7799aa8ba5a3bc">InitCommonRuntime</a>(argc, argv, <span class="keyword">true</span>, <a class="code" href="classimpala_1_1TestInfo.html#a199d4f93fdaffc93187e901cc512a8e3a220e0a091d5c561103a1b0e38c3ba542">TestInfo::BE_TEST</a>);</div> |
| <div class="line"><a name="l00584"></a><span class="lineno"> 584</span>  <a class="code" href="namespaceimpala.html#ab54e43e58ae94049bdf5010584ee3fb2">InitFeSupport</a>();</div> |
| <div class="line"><a name="l00585"></a><span class="lineno"> 585</span>  <a class="code" href="classimpala_1_1LlvmCodeGen.html#af99b272408ffba7f0efd7e704e386d76">impala::LlvmCodeGen::InitializeLlvm</a>();</div> |
| <div class="line"><a name="l00586"></a><span class="lineno"> 586</span>  <span class="keywordflow">return</span> RUN_ALL_TESTS();</div> |
| <div class="line"><a name="l00587"></a><span class="lineno"> 587</span> }</div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html">impala::DataStreamTest</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00090">data-stream-test.cc:90</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a8052911b92de3bb0ed1686ddd83c1ccb"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a8052911b92de3bb0ed1686ddd83c1ccb">impala::DataStreamTest::StartReceiver</a></div><div class="ttdeci">void StartReceiver(TPartitionType::type stream_type, int num_senders, int receiver_num, int buffer_size, bool is_merging, TUniqueId *out_id=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00315">data-stream-test.cc:315</a></div></div> |
| <div class="ttc" id="row-batch_8h_html"><div class="ttname"><a href="row-batch_8h.html">row-batch.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DescriptorTbl_html"><div class="ttname"><a href="classimpala_1_1DescriptorTbl.html">impala::DescriptorTbl</a></div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00338">descriptors.h:338</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1SenderInfo_html_ab673cac8bb65a73ba3ac5ebe1cc4817e"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#ab673cac8bb65a73ba3ac5ebe1cc4817e">impala::DataStreamTest::SenderInfo::num_bytes_sent</a></div><div class="ttdeci">int num_bytes_sent</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00201">data-stream-test.cc:201</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a712a03c97458ee80018c7c77db7f4fe1"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a712a03c97458ee80018c7c77db7f4fe1">impala::DataStreamTest::next_instance_id_</a></div><div class="ttdeci">TUniqueId next_instance_id_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00180">data-stream-test.cc:180</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a959b8ff1471b2dc67adc900ac13354bc"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a959b8ff1471b2dc67adc900ac13354bc">impala::DataStreamTest::dest_</a></div><div class="ttdeci">vector< TPlanFragmentDestination > dest_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00196">data-stream-test.cc:196</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_aff1b707da01bc61c2ac22fff960e8a73"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#aff1b707da01bc61c2ac22fff960e8a73">impala::DataStreamTest::ReceiverInfo::num_rows_received</a></div><div class="ttdeci">int num_rows_received</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00215">data-stream-test.cc:215</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_a9f224be6892e31a4fccb7dca8d6f4f17"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a9f224be6892e31a4fccb7dca8d6f4f17">impala::DataStreamTest::ReceiverInfo::data_values</a></div><div class="ttdeci">multiset< int64_t > data_values</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00216">data-stream-test.cc:216</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_ac695df3b85ee416b3d99844813ae813d"><div class="ttname"><a href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">impala::RowBatch::num_rows</a></div><div class="ttdeci">int num_rows() const </div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00215">row-batch.h:215</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1SenderInfo_html_a28b83da3011974cfff63e16631efcc2f"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a28b83da3011974cfff63e16631efcc2f">impala::DataStreamTest::SenderInfo::status</a></div><div class="ttdeci">Status status</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00200">data-stream-test.cc:200</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ad7e3881f26a6f89b60ad2f4770e1be98"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ad7e3881f26a6f89b60ad2f4770e1be98">impala::DataStreamTest::stream_mgr_</a></div><div class="ttdeci">DataStreamMgr * stream_mgr_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00189">data-stream-test.cc:189</a></div></div> |
| <div class="ttc" id="init_8h_html"><div class="ttname"><a href="init_8h.html">init.h</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_aca80061c98b44477ea84e4332993b7e7"><div class="ttname"><a href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">impala::PlanNodeId</a></div><div class="ttdeci">int PlanNodeId</div><div class="ttdef"><b>Definition:</b> <a href="global-types_8h_source.html#l00026">global-types.h:26</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_ab54e43e58ae94049bdf5010584ee3fb2"><div class="ttname"><a href="namespaceimpala.html#ab54e43e58ae94049bdf5010584ee3fb2">impala::InitFeSupport</a></div><div class="ttdeci">void InitFeSupport()</div><div class="ttdef"><b>Definition:</b> <a href="fe-support_8cc_source.html#l00346">fe-support.cc:346</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_af9b56335668202e9d272c1125b841a6b"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#af9b56335668202e9d272c1125b841a6b">impala::DataStreamTest::ReceiverInfo::~ReceiverInfo</a></div><div class="ttdeci">~ReceiverInfo()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00225">data-stream-test.cc:225</a></div></div> |
| <div class="ttc" id="classimpala_1_1TupleRowComparator_html"><div class="ttname"><a href="classimpala_1_1TupleRowComparator.html">impala::TupleRowComparator</a></div><div class="ttdef"><b>Definition:</b> <a href="tuple-row-compare_8h_source.html#l00027">tuple-row-compare.h:27</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a948c2ae3514c507725410a2de0e64634"><div class="ttname"><a href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">impala::TEST_F</a></div><div class="ttdeci">TEST_F(InstructionCounterTest, Count)</div><div class="ttdef"><b>Definition:</b> <a href="instruction-counter-test_8cc_source.html#l00069">instruction-counter-test.cc:69</a></div></div> |
| <div class="ttc" id="classimpala_1_1TupleRow_html_aed3092e531291470b27fc48afa901600"><div class="ttname"><a href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">impala::TupleRow::GetTuple</a></div><div class="ttdeci">Tuple * GetTuple(int tuple_idx)</div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00030">tuple-row.h:30</a></div></div> |
| <div class="ttc" id="classimpala_1_1ClientCache_html_a8f13cf7cc55cadae632ec2d7801731b5"><div class="ttname"><a href="classimpala_1_1ClientCache.html#a8f13cf7cc55cadae632ec2d7801731b5">impala::ClientCache::TestShutdown</a></div><div class="ttdeci">void TestShutdown()</div><div class="ttdoc">For testing only: shutdown all clients. </div><div class="ttdef"><b>Definition:</b> <a href="client-cache_8h_source.html#l00287">client-cache.h:287</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a8cf06290ff145eec23570a8b9790f412"><div class="ttname"><a href="namespaceimpala.html#a8cf06290ff145eec23570a8b9790f412">impala::protocol</a></div><div class="ttdeci">const StringSearch UrlParser::protocol_search & protocol</div><div class="ttdef"><b>Definition:</b> <a href="url-parser_8cc_source.html#l00036">url-parser.cc:36</a></div></div> |
| <div class="ttc" id="slot-ref_8h_html"><div class="ttname"><a href="slot-ref_8h.html">slot-ref.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a4a6ff9dc4d0805d1031c47fba5d4c6a4"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a4a6ff9dc4d0805d1031c47fba5d4c6a4">impala::DataStreamTest::CheckReceivers</a></div><div class="ttdeci">void CheckReceivers(TPartitionType::type stream_type, int num_senders)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00383">data-stream-test.cc:383</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="classimpala_1_1ExecEnv_html_a96fe8303b423faaeb2278c48fd1fe679"><div class="ttname"><a href="classimpala_1_1ExecEnv.html#a96fe8303b423faaeb2278c48fd1fe679">impala::ExecEnv::InitForFeTests</a></div><div class="ttdeci">Status InitForFeTests()</div><div class="ttdoc">Initializes the exec env for running FE tests. </div><div class="ttdef"><b>Definition:</b> <a href="exec-env_8cc_source.html#l00276">exec-env.cc:276</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ab6f0d5e2c4cd0ab8e8a6f5e4380d8f59"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ab6f0d5e2c4cd0ab8e8a6f5e4380d8f59">impala::DataStreamTest::StartBackend</a></div><div class="ttdeci">void StartBackend()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00436">data-stream-test.cc:436</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a1c183dc242f42291fbf439e78bebc8fa"><div class="ttname"><a href="namespaceimpala.html#a1c183dc242f42291fbf439e78bebc8fa">impala::obj_pool_</a></div><div class="ttdeci">boost::scoped_ptr< ObjectPool > obj_pool_</div><div class="ttdoc">Object pool owned by the coordinator. Any executor will have its own pool. </div><div class="ttdef"><b>Definition:</b> <a href="coordinator_8h_source.html#l00296">coordinator.h:296</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1SenderInfo_html_a7a0069ce5f61af2e543eba6fd36898de"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#a7a0069ce5f61af2e543eba6fd36898de">impala::DataStreamTest::SenderInfo::SenderInfo</a></div><div class="ttdeci">SenderInfo()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00203">data-stream-test.cc:203</a></div></div> |
| <div class="ttc" id="classimpala_1_1RuntimeState_html_a5266fa82fd51cd6b2da82113fc1c7461"><div class="ttname"><a href="classimpala_1_1RuntimeState.html#a5266fa82fd51cd6b2da82113fc1c7461">impala::RuntimeState::InitMemTrackers</a></div><div class="ttdeci">void InitMemTrackers(const TUniqueId &query_id, const std::string *request_pool, int64_t query_bytes_limit, int64_t query_rm_reservation_limit_bytes=-1)</div><div class="ttdef"><b>Definition:</b> <a href="runtime-state_8cc_source.html#l00152">runtime-state.cc:152</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a05f2e5343e40e8f955459e810dd160c4"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a05f2e5343e40e8f955459e810dd160c4">impala::DataStreamTest::GetSink</a></div><div class="ttdeci">const TDataStreamSink & GetSink(TPartitionType::type partition_type)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00138">data-stream-test.cc:138</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_a41a4a41472f7d7b3807ede1524d2f63f"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a41a4a41472f7d7b3807ede1524d2f63f">impala::DataStreamTest::ReceiverInfo::stream_type</a></div><div class="ttdeci">TPartitionType::type stream_type</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00208">data-stream-test.cc:208</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_aecbb0e06bf1301155b38a5e175c74d08"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#aecbb0e06bf1301155b38a5e175c74d08">impala::DataStreamTest::CreateRowBatch</a></div><div class="ttdeci">RowBatch * CreateRowBatch()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00292">data-stream-test.cc:292</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a57c967a17a4ed1d4f5ee1bffdba69d6a"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a57c967a17a4ed1d4f5ee1bffdba69d6a">impala::DataStreamTest::DataStreamTest</a></div><div class="ttdeci">DataStreamTest()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00092">data-stream-test.cc:92</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a9abfa397b4c91aa5a92a812d6d9d478f"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a9abfa397b4c91aa5a92a812d6d9d478f">impala::DataStreamTest::runtime_state_</a></div><div class="ttdeci">RuntimeState runtime_state_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00179">data-stream-test.cc:179</a></div></div> |
| <div class="ttc" id="raw-value_8h_html"><div class="ttname"><a href="raw-value_8h.html">raw-value.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1RuntimeState_html_a6548724bfda2e15f0fcbec40aa5f2704"><div class="ttname"><a href="classimpala_1_1RuntimeState.html#a6548724bfda2e15f0fcbec40aa5f2704">impala::RuntimeState::set_desc_tbl</a></div><div class="ttdeci">void set_desc_tbl(DescriptorTbl *desc_tbl)</div><div class="ttdef"><b>Definition:</b> <a href="runtime-state_8h_source.html#l00094">runtime-state.h:94</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_ad1fa91f70d2090b45d7799aa8ba5a3bc"><div class="ttname"><a href="namespaceimpala.html#ad1fa91f70d2090b45d7799aa8ba5a3bc">impala::InitCommonRuntime</a></div><div class="ttdeci">void InitCommonRuntime(int argc, char **argv, bool init_jvm, TestInfo::Mode m=TestInfo::NON_TEST)</div><div class="ttdef"><b>Definition:</b> <a href="init_8cc_source.html#l00122">init.cc:122</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_a9320ed986b0717ef26d73d871f3b3a42"><div class="ttname"><a href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">impala::RowBatch::GetRow</a></div><div class="ttdeci">TupleRow * GetRow(int row_idx)</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00140">row-batch.h:140</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ae51f0a14202ca57b10e781c31307ddbb"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ae51f0a14202ca57b10e781c31307ddbb">impala::DataStreamTest::JoinReceivers</a></div><div class="ttdeci">void JoinReceivers()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00337">data-stream-test.cc:337</a></div></div> |
| <div class="ttc" id="classimpala_1_1ExprContext_html"><div class="ttname"><a href="classimpala_1_1ExprContext.html">impala::ExprContext</a></div><div class="ttdef"><b>Definition:</b> <a href="expr-context_8h_source.html#l00040">expr-context.h:40</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_ad020c6ef386dbc1d029430bf656bafef"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#ad020c6ef386dbc1d029430bf656bafef">impala::ImpalaTestBackend::mgr_</a></div><div class="ttdeci">DataStreamMgr * mgr_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00087">data-stream-test.cc:87</a></div></div> |
| <div class="ttc" id="data-stream-mgr_8h_html"><div class="ttname"><a href="data-stream-mgr_8h.html">data-stream-mgr.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a4f0b4921c0b8edf7d86a7c9735f11783"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a4f0b4921c0b8edf7d86a7c9735f11783">impala::DataStreamTest::ReadStreamMerging</a></div><div class="ttdeci">void ReadStreamMerging(ReceiverInfo *info, RuntimeProfile *profile)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00362">data-stream-test.cc:362</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html">impala::ImpalaTestBackend</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00061">data-stream-test.cc:61</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a4d5df6139d66b718aa61dfa6575f922c"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a4d5df6139d66b718aa61dfa6575f922c">impala::DataStreamTest::Reset</a></div><div class="ttdeci">void Reset()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00156">data-stream-test.cc:156</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_a0685f4cb46790076c1ab37c2bb714c2e"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a0685f4cb46790076c1ab37c2bb714c2e">impala::DataStreamTest::ReceiverInfo::thread_handle</a></div><div class="ttdeci">thread * thread_handle</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00212">data-stream-test.cc:212</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ac0cc74d6fb80dd4c02226822343c58e2"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ac0cc74d6fb80dd4c02226822343c58e2">impala::DataStreamTest::rhs_slot_ctx_</a></div><div class="ttdeci">ExprContext * rhs_slot_ctx_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00515">data-stream-test.cc:515</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_acef39c14c7ed4b85122aa3c0cde80247"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#acef39c14c7ed4b85122aa3c0cde80247">impala::DataStreamSender::Prepare</a></div><div class="ttdeci">virtual Status Prepare(RuntimeState *state)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00362">data-stream-sender.cc:362</a></div></div> |
| <div class="ttc" id="mem-info_8h_html"><div class="ttname"><a href="mem-info_8h.html">mem-info.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a36a5d2a479c1863f04ac7629d96c1d9a"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a36a5d2a479c1863f04ac7629d96c1d9a">impala::DataStreamTest::TestStream</a></div><div class="ttdeci">void TestStream(TPartitionType::type stream_type, int num_senders, int num_receivers, int buffer_size, bool is_merging)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00495">data-stream-test.cc:495</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_ab8ac82d64131f546638d41fe4def99f4"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ab8ac82d64131f546638d41fe4def99f4">impala::DataStreamTest::ReceiverInfo::num_senders</a></div><div class="ttdeci">int num_senders</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00209">data-stream-test.cc:209</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a0a06145acd27005a1c1f482dc2375742"><div class="ttname"><a href="namespaceimpala.html#a0a06145acd27005a1c1f482dc2375742">impala::desc_tbl_</a></div><div class="ttdeci">TDescriptorTable desc_tbl_</div><div class="ttdoc">copied from TQueryExecRequest; constant across all fragments </div><div class="ttdef"><b>Definition:</b> <a href="coordinator_8h_source.html#l00197">coordinator.h:197</a></div></div> |
| <div class="ttc" id="classimpala_1_1Tuple_html_a5c9d7d0ca31caed74224c97bf55a1a5c"><div class="ttname"><a href="classimpala_1_1Tuple.html#a5c9d7d0ca31caed74224c97bf55a1a5c">impala::Tuple::GetSlot</a></div><div class="ttdeci">void * GetSlot(int offset)</div><div class="ttdef"><b>Definition:</b> <a href="tuple_8h_source.html#l00118">tuple.h:118</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowDescriptor_html"><div class="ttname"><a href="classimpala_1_1RowDescriptor.html">impala::RowDescriptor</a></div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00373">descriptors.h:373</a></div></div> |
| <div class="ttc" id="client-cache_8h_html"><div class="ttname"><a href="client-cache_8h.html">client-cache.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1ObjectPool_html"><div class="ttname"><a href="classimpala_1_1ObjectPool.html">impala::ObjectPool</a></div><div class="ttdef"><b>Definition:</b> <a href="object-pool_8h_source.html#l00030">object-pool.h:30</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_a1b3fc3d9da054eb0e081505ebcc1c70f"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a1b3fc3d9da054eb0e081505ebcc1c70f">impala::DataStreamTest::ReceiverInfo::stream_recvr</a></div><div class="ttdeci">shared_ptr< DataStreamRecvr > stream_recvr</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00213">data-stream-test.cc:213</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a670fc5c10025d0cce53eebc5d6d0a72a"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a670fc5c10025d0cce53eebc5d6d0a72a">impala::DataStreamTest::broadcast_sink_</a></div><div class="ttdeci">TDataStreamSink broadcast_sink_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00193">data-stream-test.cc:193</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ad4d4e2859c9d65cecc27b74b7acf450e"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ad4d4e2859c9d65cecc27b74b7acf450e">impala::DataStreamTest::GetNextBatch</a></div><div class="ttdeci">void GetNextBatch(RowBatch *batch, int *next_val)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00306">data-stream-test.cc:306</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a441b986df33ba936a2de32af7e84c9d8"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a441b986df33ba936a2de32af7e84c9d8">impala::DataStreamSender::Open</a></div><div class="ttdeci">virtual Status Open(RuntimeState *state)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00397">data-stream-sender.cc:397</a></div></div> |
| <div class="ttc" id="llvm-codegen_8h_html"><div class="ttname"><a href="llvm-codegen_8h.html">llvm-codegen.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a59b3847f48981215061c401950dbd0f4"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a59b3847f48981215061c401950dbd0f4">impala::DataStreamTest::tracker_</a></div><div class="ttdeci">MemTracker tracker_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00173">data-stream-test.cc:173</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="classimpala_1_1TupleRow_html"><div class="ttname"><a href="classimpala_1_1TupleRow.html">impala::TupleRow</a></div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00028">tuple-row.h:28</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a508481848105bae62dd5722fd747572a"><div class="ttname"><a href="namespaceimpala.html#a508481848105bae62dd5722fd747572a">impala::Cancel</a></div><div class="ttdeci">void Cancel(const Status *cause=NULL)</div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a9101d1f39c7e9e540eb5d96238408431"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a9101d1f39c7e9e540eb5d96238408431">impala::DataStreamTest::exec_env_</a></div><div class="ttdeci">ExecEnv exec_env_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00178">data-stream-test.cc:178</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="classimpala_1_1DataStreamTest_html_a05ed79930a7121c4d21f5423801b76e2"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a05ed79930a7121c4d21f5423801b76e2">impala::DataStreamTest::CheckSenders</a></div><div class="ttdeci">void CheckSenders()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00428">data-stream-test.cc:428</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamMgr_html"><div class="ttname"><a href="classimpala_1_1DataStreamMgr.html">impala::DataStreamMgr</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-mgr_8h_source.html#l00056">data-stream-mgr.h:56</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_abb8130f77401171e4cd470f8a7eafcc8"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#abb8130f77401171e4cd470f8a7eafcc8">impala::DataStreamTest::TearDown</a></div><div class="ttdeci">virtual void TearDown()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00149">data-stream-test.cc:149</a></div></div> |
| <div class="ttc" id="classimpala_1_1RawValue_html_ade36561a0ea59fde387ff49f6565c6ec"><div class="ttname"><a href="classimpala_1_1RawValue.html#ade36561a0ea59fde387ff49f6565c6ec">impala::RawValue::GetHashValueFnv</a></div><div class="ttdeci">static uint32_t GetHashValueFnv(const void *v, const ColumnType &type, uint32_t seed)</div><div class="ttdef"><b>Definition:</b> <a href="raw-value_8h_source.html#l00196">raw-value.h:196</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a5befc2f953e389e9846bd2f3bc7e3a5e"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a5befc2f953e389e9846bd2f3bc7e3a5e">impala::DataStreamTest::lhs_slot_ctx_</a></div><div class="ttdeci">ExprContext * lhs_slot_ctx_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00514">data-stream-test.cc:514</a></div></div> |
| <div class="ttc" id="data-stream-test_8cc_html_a67c89cbcfa13431bd5f921ddc84defd9"><div class="ttname"><a href="data-stream-test_8cc.html#a67c89cbcfa13431bd5f921ddc84defd9">DECLARE_string</a></div><div class="ttdeci">DECLARE_string(principal)</div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_a4e8dd5bb69f6793e87ebac7aadb1c6dd"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#a4e8dd5bb69f6793e87ebac7aadb1c6dd">impala::ImpalaTestBackend::ExecPlanFragment</a></div><div class="ttdeci">virtual void ExecPlanFragment(TExecPlanFragmentResult &return_val, const TExecPlanFragmentParams &params)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00066">data-stream-test.cc:66</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_a93966c57c91dbac1ec4e14991992531b"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#a93966c57c91dbac1ec4e14991992531b">impala::ImpalaTestBackend::ImpalaTestBackend</a></div><div class="ttdeci">ImpalaTestBackend(DataStreamMgr *stream_mgr)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00063">data-stream-test.cc:63</a></div></div> |
| <div class="ttc" id="thread_8h_html"><div class="ttname"><a href="thread_8h.html">thread.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a2ea6c9bf9da67b2baaca76dfde05c9a5"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a2ea6c9bf9da67b2baaca76dfde05c9a5">impala::DataStreamTest::dummy_mem_tracker_</a></div><div class="ttdeci">MemTracker dummy_mem_tracker_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00177">data-stream-test.cc:177</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_1DataStreamTest_html_add3ac6e494a210ff7f5a722ed32904f0"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#add3ac6e494a210ff7f5a722ed32904f0">impala::DataStreamTest::stmt_</a></div><div class="ttdeci">string stmt_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00181">data-stream-test.cc:181</a></div></div> |
| <div class="ttc" id="logging_8h_html_a916e38366cee7c32fd5fae7e2ee5e4a9"><div class="ttname"><a href="logging_8h.html#a916e38366cee7c32fd5fae7e2ee5e4a9">VLOG_QUERY</a></div><div class="ttdeci">#define VLOG_QUERY</div><div class="ttdef"><b>Definition:</b> <a href="logging_8h_source.html#l00057">logging.h:57</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ac3d95322465950447544f928819f9446"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ac3d95322465950447544f928819f9446">impala::DataStreamTest::server_</a></div><div class="ttdeci">ThriftServer * server_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00190">data-stream-test.cc:190</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_acf4d2486bc794306a98feee7bdfa6fbc"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#acf4d2486bc794306a98feee7bdfa6fbc">impala::ImpalaTestBackend::~ImpalaTestBackend</a></div><div class="ttdeci">virtual ~ImpalaTestBackend()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00064">data-stream-test.cc:64</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_ae95b35478c3c2f5c6fcdda226b1ef96b"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#ae95b35478c3c2f5c6fcdda226b1ef96b">impala::ImpalaTestBackend::CancelPlanFragment</a></div><div class="ttdeci">virtual void CancelPlanFragment(TCancelPlanFragmentResult &return_val, const TCancelPlanFragmentParams &params)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00072">data-stream-test.cc:72</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a254bb451910193a6964b61a8df75d019"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a254bb451910193a6964b61a8df75d019">impala::DataStreamTest::Sender</a></div><div class="ttdeci">void Sender(int sender_num, int channel_buffer_size, TPartitionType::type partition_type)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00468">data-stream-test.cc:468</a></div></div> |
| <div class="ttc" id="auth-provider_8h_html"><div class="ttname"><a href="auth-provider_8h.html">auth-provider.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_ac351eaf211eb53882564b604db07b824"><div class="ttname"><a href="classimpala_1_1RowBatch.html#ac351eaf211eb53882564b604db07b824">impala::RowBatch::Reset</a></div><div class="ttdeci">void Reset()</div><div class="ttdoc">Resets the row batch, returning all resources it has accumulated. </div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8cc_source.html#l00224">row-batch.cc:224</a></div></div> |
| <div class="ttc" id="classimpala_1_1RuntimeState_html"><div class="ttname"><a href="classimpala_1_1RuntimeState.html">impala::RuntimeState</a></div><div class="ttdef"><b>Definition:</b> <a href="runtime-state_8h_source.html#l00069">runtime-state.h:69</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1SenderInfo_html"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1SenderInfo.html">impala::DataStreamTest::SenderInfo</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00198">data-stream-test.cc:198</a></div></div> |
| <div class="ttc" id="classimpala_1_1Status_html_a327e57a4c61d1387f8b52fce20e89a34"><div class="ttname"><a href="classimpala_1_1Status.html#a327e57a4c61d1387f8b52fce20e89a34">impala::Status::IsCancelled</a></div><div class="ttdeci">bool IsCancelled() const </div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00174">status.h:174</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html">impala::DataStreamSender</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00046">data-stream-sender.h:46</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a9b36b9b654831d4757e22f131196343b"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">impala::DataStreamSender::Send</a></div><div class="ttdeci">virtual Status Send(RuntimeState *state, RowBatch *batch, bool eos)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00401">data-stream-sender.cc:401</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html">impala::DataStreamTest::ReceiverInfo</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00207">data-stream-test.cc:207</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_aa1801926107ca7764df29bc3dc09ea88"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#aa1801926107ca7764df29bc3dc09ea88">impala::DataStreamTest::CreateTupleComparator</a></div><div class="ttdeci">void CreateTupleComparator()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00276">data-stream-test.cc:276</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a84e848bfa8bd5071f4df33ab0676e026"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a84e848bfa8bd5071f4df33ab0676e026">impala::DataStreamTest::hash_sink_</a></div><div class="ttdeci">TDataStreamSink hash_sink_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00195">data-stream-test.cc:195</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="thrift-server_8h_html"><div class="ttname"><a href="thrift-server_8h.html">thrift-server.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ada07d1806b1b06f37ff403505444a4a8"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ada07d1806b1b06f37ff403505444a4a8">impala::DataStreamTest::StartSender</a></div><div class="ttdeci">void StartSender(TPartitionType::type partition_type=TPartitionType::UNPARTITIONED, int channel_buffer_size=1024)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00449">data-stream-test.cc:449</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a4844ae2641026fbde84ff40f9e059c9a"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a4844ae2641026fbde84ff40f9e059c9a">impala::DataStreamTest::ReadStream</a></div><div class="ttdeci">void ReadStream(ReceiverInfo *info)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00346">data-stream-test.cc:346</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_ae93db027f9d0cb4c50e8dd962d92a624"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#ae93db027f9d0cb4c50e8dd962d92a624">impala::DataStreamSender::GetNumDataBytesSent</a></div><div class="ttdeci">int64_t GetNumDataBytesSent() const </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00469">data-stream-sender.cc:469</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ac3cc5e16a7ba1cc87edf3f0b28bedc4d"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ac3cc5e16a7ba1cc87edf3f0b28bedc4d">impala::DataStreamTest::random_sink_</a></div><div class="ttdeci">TDataStreamSink random_sink_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00194">data-stream-test.cc:194</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a51cf2fe60fdaae767f019b8c43eab200"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a51cf2fe60fdaae767f019b8c43eab200">impala::DataStreamTest::receiver_info_</a></div><div class="ttdeci">vector< ReceiverInfo > receiver_info_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00230">data-stream-test.cc:230</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_a5496f66cded945d3574eb060d764cd45"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#a5496f66cded945d3574eb060d764cd45">impala::ImpalaTestBackend::ReportExecStatus</a></div><div class="ttdeci">virtual void ReportExecStatus(TReportExecStatusResult &return_val, const TReportExecStatusParams &params)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00069">data-stream-test.cc:69</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a0360190c40a92add13872add675eec76"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a0360190c40a92add13872add675eec76">impala::DataStreamTest::less_than_</a></div><div class="ttdeci">TupleRowComparator * less_than_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00176">data-stream-test.cc:176</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_af3ad73326080e178fa233ff5ef17cd41"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#af3ad73326080e178fa233ff5ef17cd41">impala::DataStreamTest::next_val_</a></div><div class="ttdeci">int next_val_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00185">data-stream-test.cc:185</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1SenderInfo_html_adead5c848da6d8a13a2a31114c1ef8e8"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1SenderInfo.html#adead5c848da6d8a13a2a31114c1ef8e8">impala::DataStreamTest::SenderInfo::thread_handle</a></div><div class="ttdeci">thread * thread_handle</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00199">data-stream-test.cc:199</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_1DataStreamSender_html_a54b74afd5299ec9465d49cc748485d00"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">impala::DataStreamSender::Close</a></div><div class="ttdeci">virtual void Close(RuntimeState *state)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00450">data-stream-sender.cc:450</a></div></div> |
| <div class="ttc" id="data-stream-recvr_8h_html"><div class="ttname"><a href="data-stream-recvr_8h.html">data-stream-recvr.h</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_aa5bce0d3309643287a67504146c2f871ac5602f92ce48738739f551df8ff3e4a7"><div class="ttname"><a href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871ac5602f92ce48738739f551df8ff3e4a7">impala::TYPE_BIGINT</a></div><div class="ttdef"><b>Definition:</b> <a href="types_8h_source.html#l00034">types.h:34</a></div></div> |
| <div class="ttc" id="classimpala_1_1MemTracker_html"><div class="ttname"><a href="classimpala_1_1MemTracker.html">impala::MemTracker</a></div><div class="ttdoc">This class is thread-safe. </div><div class="ttdef"><b>Definition:</b> <a href="mem-tracker_8h_source.html#l00061">mem-tracker.h:61</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_aef978a61ab3f47c2b9e53e304eead853"><div class="ttname"><a href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">impala::RowBatch::CommitLastRow</a></div><div class="ttdeci">void CommitLastRow()</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00109">row-batch.h:109</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a38aca1d23adb809a4fda78d5e78a5178"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a38aca1d23adb809a4fda78d5e78a5178">impala::DataStreamTest::StopBackend</a></div><div class="ttdeci">void StopBackend()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00443">data-stream-test.cc:443</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_a6f0b95af26c4f77c7fd894d0acffecac"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a6f0b95af26c4f77c7fd894d0acffecac">impala::DataStreamTest::ReceiverInfo::ReceiverInfo</a></div><div class="ttdeci">ReceiverInfo(TPartitionType::type stream_type, int num_senders, int receiver_num)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00218">data-stream-test.cc:218</a></div></div> |
| <div class="ttc" id="runtime-state_8h_html"><div class="ttname"><a href="runtime-state_8h.html">runtime-state.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html"><div class="ttname"><a href="classimpala_1_1RowBatch.html">impala::RowBatch</a></div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00066">row-batch.h:66</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a6d1ee6e44e6fb8481699487dfdaf507d"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a6d1ee6e44e6fb8481699487dfdaf507d">impala::DataStreamTest::tuple_mem_</a></div><div class="ttdeci">int64_t * tuple_mem_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00186">data-stream-test.cc:186</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a739023ade1afbe1c8e5194ffe7eddab7"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a739023ade1afbe1c8e5194ffe7eddab7">impala::DataStreamTest::CreateRowDesc</a></div><div class="ttdeci">void CreateRowDesc()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00245">data-stream-test.cc:245</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_a82611d227a12dd5c2e1ca1ba77d86736"><div class="ttname"><a href="classimpala_1_1RowBatch.html#a82611d227a12dd5c2e1ca1ba77d86736">impala::RowBatch::tuple_data_pool</a></div><div class="ttdeci">MemPool * tuple_data_pool()</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00148">row-batch.h:148</a></div></div> |
| <div class="ttc" id="classimpala_1_1ImpalaTestBackend_html_aed33f6ac5ef326029b85e6c86e9e42b5"><div class="ttname"><a href="classimpala_1_1ImpalaTestBackend.html#aed33f6ac5ef326029b85e6c86e9e42b5">impala::ImpalaTestBackend::TransmitData</a></div><div class="ttdeci">virtual void TransmitData(TTransmitDataResult &return_val, const TTransmitDataParams &params)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00075">data-stream-test.cc:75</a></div></div> |
| <div class="ttc" id="classimpala_1_1HashUtil_html_ad47e5dcaf416f05760be732dfbc66651"><div class="ttname"><a href="classimpala_1_1HashUtil.html#ad47e5dcaf416f05760be732dfbc66651">impala::HashUtil::FNV_SEED</a></div><div class="ttdeci">static const uint32_t FNV_SEED</div><div class="ttdef"><b>Definition:</b> <a href="hash-util_8h_source.html#l00099">hash-util.h:99</a></div></div> |
| <div class="ttc" id="cache-hash-test_8cc_html_a18269e3eecadb27e79614c02d898173e"><div class="ttname"><a href="cache-hash-test_8cc.html#a18269e3eecadb27e79614c02d898173e">Test</a></div><div class="ttdeci">uint64_t Test(T *ht, const ProbeTuple *input, uint64_t num_tuples)</div><div class="ttdef"><b>Definition:</b> <a href="cache-hash-test_8cc_source.html#l00067">cache-hash-test.cc:67</a></div></div> |
| <div class="ttc" id="classImpalaInternalServiceIf_html"><div class="ttname"><a href="classImpalaInternalServiceIf.html">ImpalaInternalServiceIf</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_1RuntimeProfile_html"><div class="ttname"><a href="classimpala_1_1RuntimeProfile.html">impala::RuntimeProfile</a></div><div class="ttdef"><b>Definition:</b> <a href="runtime-profile_8h_source.html#l00083">runtime-profile.h:83</a></div></div> |
| <div class="ttc" id="classimpala_1_1TupleRow_html_aaf1d69b97c90eec7da3d07bdc40f5665"><div class="ttname"><a href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">impala::TupleRow::SetTuple</a></div><div class="ttdeci">void SetTuple(int tuple_idx, Tuple *tuple)</div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00034">tuple-row.h:34</a></div></div> |
| <div class="ttc" id="classimpala_1_1LlvmCodeGen_html_af99b272408ffba7f0efd7e704e386d76"><div class="ttname"><a href="classimpala_1_1LlvmCodeGen.html#af99b272408ffba7f0efd7e704e386d76">impala::LlvmCodeGen::InitializeLlvm</a></div><div class="ttdeci">static void InitializeLlvm(bool load_backend=false)</div><div class="ttdef"><b>Definition:</b> <a href="llvm-codegen_8cc_source.html#l00078">llvm-codegen.cc:78</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ada64bb855cc0f1f92ca60c38be8ca07c"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ada64bb855cc0f1f92ca60c38be8ca07c">impala::DataStreamTest::obj_pool_</a></div><div class="ttdeci">ObjectPool obj_pool_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00172">data-stream-test.cc:172</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a4d2fe9ac8ac20e48426222ae49e2fc0b"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a4d2fe9ac8ac20e48426222ae49e2fc0b">impala::DataStreamTest::sender_info_</a></div><div class="ttdeci">vector< SenderInfo > sender_info_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00205">data-stream-test.cc:205</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_aeef4fa014a7ca6a028dcfa1d27ecee31"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#aeef4fa014a7ca6a028dcfa1d27ecee31">impala::DataStreamTest::batch_</a></div><div class="ttdeci">scoped_ptr< RowBatch > batch_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00184">data-stream-test.cc:184</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_a34b82362d8ad1e89c433e04999a6a0cb"><div class="ttname"><a href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">impala::RowBatch::AddRow</a></div><div class="ttdeci">int AddRow()</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00100">row-batch.h:100</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_a3104dcdb257e9367b7fcdc96585d6d58"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#a3104dcdb257e9367b7fcdc96585d6d58">impala::DataStreamTest::GetNextInstanceId</a></div><div class="ttdeci">void GetNextInstanceId(TUniqueId *instance_id)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00233">data-stream-test.cc:233</a></div></div> |
| <div class="ttc" id="classimpala_1_1SlotRef_html"><div class="ttname"><a href="classimpala_1_1SlotRef.html">impala::SlotRef</a></div><div class="ttdoc">Reference to a single slot of a tuple. </div><div class="ttdef"><b>Definition:</b> <a href="slot-ref_8h_source.html#l00023">slot-ref.h:23</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_adf889510ae92e3de691ecb990adbacb6"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#adf889510ae92e3de691ecb990adbacb6">impala::DataStreamTest::desc_tbl_</a></div><div class="ttdeci">DescriptorTbl * desc_tbl_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00174">data-stream-test.cc:174</a></div></div> |
| <div class="ttc" id="data-stream-sender_8h_html"><div class="ttname"><a href="data-stream-sender_8h.html">data-stream-sender.h</a></div></div> |
| <div class="ttc" id="structimpala_1_1ColumnType_html"><div class="ttname"><a href="structimpala_1_1ColumnType.html">impala::ColumnType</a></div><div class="ttdef"><b>Definition:</b> <a href="types_8h_source.html#l00059">types.h:59</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_abb1caf4d38947d932566cf415b06ffbd"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#abb1caf4d38947d932566cf415b06ffbd">impala::DataStreamTest::JoinSenders</a></div><div class="ttdeci">void JoinSenders()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00461">data-stream-test.cc:461</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_ad393a2093952c5b6f3a61bd3e1302e61"><div class="ttname"><a href="namespaceimpala.html#ad393a2093952c5b6f3a61bd3e1302e61">impala::row_desc_</a></div><div class="ttdeci">const RowDescriptor * row_desc_</div><div class="ttdoc">owned by plan root, which resides in runtime_state_'s pool </div><div class="ttdef"><b>Definition:</b> <a href="coordinator_8h_source.html#l00255">coordinator.h:255</a></div></div> |
| <div class="ttc" id="data-stream-test_8cc_html_a3c04138a5bfe5d72780bb7e82a18e627"><div class="ttname"><a href="data-stream-test_8cc.html#a3c04138a5bfe5d72780bb7e82a18e627">main</a></div><div class="ttdeci">int main(int argc, char **argv)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00581">data-stream-test.cc:581</a></div></div> |
| <div class="ttc" id="classimpala_1_1DescriptorTbl_html_a7eec9a1b9f48220a92e3bdd4fdba44ba"><div class="ttname"><a href="classimpala_1_1DescriptorTbl.html#a7eec9a1b9f48220a92e3bdd4fdba44ba">impala::DescriptorTbl::Create</a></div><div class="ttdeci">static Status Create(ObjectPool *pool, const TDescriptorTable &thrift_tbl, DescriptorTbl **tbl)</div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8cc_source.html#l00378">descriptors.cc:378</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a57eaecb97c9c87e4c57c8a8a81211422"><div class="ttname"><a href="namespaceimpala.html#a57eaecb97c9c87e4c57c8a8a81211422">impala::exec_env_</a></div><div class="ttdeci">ExecEnv * exec_env_</div><div class="ttdef"><b>Definition:</b> <a href="coordinator_8h_source.html#l00193">coordinator.h:193</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="namespaceimpala_html_aad7a37594ae12dd0bd87ca15f06b4ac8"><div class="ttname"><a href="namespaceimpala.html#aad7a37594ae12dd0bd87ca15f06b4ac8">impala::DEFINE_int32</a></div><div class="ttdeci">DEFINE_int32(periodic_counter_update_period_ms, 500,"Period to update rate counters and"" sampling counters in ms")</div></div> |
| <div class="ttc" id="disk-info_8h_html"><div class="ttname"><a href="disk-info_8h.html">disk-info.h</a></div></div> |
| <div class="ttc" id="structimpala_1_1ColumnType_html_a059c63313ce5120b5b33cd6b607a404d"><div class="ttname"><a href="structimpala_1_1ColumnType.html#a059c63313ce5120b5b33cd6b607a404d">impala::ColumnType::ToThrift</a></div><div class="ttdeci">TColumnType ToThrift() const </div><div class="ttdef"><b>Definition:</b> <a href="types_8h_source.html#l00147">types.h:147</a></div></div> |
| <div class="ttc" id="classimpala_1_1ExecEnv_html"><div class="ttname"><a href="classimpala_1_1ExecEnv.html">impala::ExecEnv</a></div><div class="ttdef"><b>Definition:</b> <a href="exec-env_8h_source.html#l00053">exec-env.h:53</a></div></div> |
| <div class="ttc" id="classimpala_1_1TestInfo_html_a199d4f93fdaffc93187e901cc512a8e3a220e0a091d5c561103a1b0e38c3ba542"><div class="ttname"><a href="classimpala_1_1TestInfo.html#a199d4f93fdaffc93187e901cc512a8e3a220e0a091d5c561103a1b0e38c3ba542">impala::TestInfo::BE_TEST</a></div><div class="ttdef"><b>Definition:</b> <a href="test-info_8h_source.html#l00026">test-info.h:26</a></div></div> |
| <div class="ttc" id="namespacegen__ir__descriptions_html_a0d6572990c8dd576a55a21ff11d6deb7"><div class="ttname"><a href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">gen_ir_descriptions.idx</a></div><div class="ttdeci">int idx</div><div class="ttdef"><b>Definition:</b> <a href="gen__ir__descriptions_8py_source.html#l00215">gen_ir_descriptions.py:215</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_abfb11c9a164c883f065532cef685c2a2"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#abfb11c9a164c883f065532cef685c2a2">impala::DataStreamTest::row_desc_</a></div><div class="ttdeci">const RowDescriptor * row_desc_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00175">data-stream-test.cc:175</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamTest_html_ae25f80e36f8dddd7e87bcdbc0faa4cd4"><div class="ttname"><a href="classimpala_1_1DataStreamTest.html#ae25f80e36f8dddd7e87bcdbc0faa4cd4">impala::DataStreamTest::SetUp</a></div><div class="ttdeci">virtual void SetUp()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00100">data-stream-test.cc:100</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="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_a8bafa8e37b26499341ca2ad69d152c74"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#a8bafa8e37b26499341ca2ad69d152c74">impala::DataStreamTest::ReceiverInfo::receiver_num</a></div><div class="ttdeci">int receiver_num</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00210">data-stream-test.cc:210</a></div></div> |
| <div class="ttc" id="tuple-row-compare_8h_html"><div class="ttname"><a href="tuple-row-compare_8h.html">tuple-row-compare.h</a></div></div> |
| <div class="ttc" id="descriptors_8h_html"><div class="ttname"><a href="descriptors_8h.html">descriptors.h</a></div></div> |
| <div class="ttc" id="structimpala_1_1DataStreamTest_1_1ReceiverInfo_html_ae5eb77731ee02333ce1cdc5de8d00989"><div class="ttname"><a href="structimpala_1_1DataStreamTest_1_1ReceiverInfo.html#ae5eb77731ee02333ce1cdc5de8d00989">impala::DataStreamTest::ReceiverInfo::status</a></div><div class="ttdeci">Status status</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-test_8cc_source.html#l00214">data-stream-test.cc:214</a></div></div> |
| <div class="ttc" id="classimpala_1_1MemPool_html_a190eb28e39279c901eda3d831a9fe726"><div class="ttname"><a href="classimpala_1_1MemPool.html#a190eb28e39279c901eda3d831a9fe726">impala::MemPool::Allocate</a></div><div class="ttdeci">uint8_t * Allocate(int size)</div><div class="ttdef"><b>Definition:</b> <a href="mem-pool_8h_source.html#l00092">mem-pool.h:92</a></div></div> |
| <div class="ttc" id="fe-support_8h_html"><div class="ttname"><a href="fe-support_8h.html">fe-support.h</a></div></div> |
| <div class="ttc" id="cpu-info_8h_html"><div class="ttname"><a href="cpu-info_8h.html">cpu-info.h</a></div></div> |
| <div class="ttc" id="test-info_8h_html"><div class="ttname"><a href="test-info_8h.html">test-info.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1ExecEnv_html_a4e470b8606b776eb409005c95c575361"><div class="ttname"><a href="classimpala_1_1ExecEnv.html#a4e470b8606b776eb409005c95c575361">impala::ExecEnv::impalad_client_cache</a></div><div class="ttdeci">ImpalaInternalServiceClientCache * impalad_client_cache()</div><div class="ttdef"><b>Definition:</b> <a href="exec-env_8h_source.html#l00076">exec-env.h:76</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_1ef28ab5153adb64262182d038c65543.html">runtime</a></li><li class="navelem"><a class="el" href="data-stream-test_8cc.html">data-stream-test.cc</a></li> |
| <li class="footer">Generated on Thu May 7 2015 16:10:36 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> |
