| <!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-sender.h Source File</title> |
| <link href="tabs.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="jquery.js"></script> |
| <script type="text/javascript" src="dynsections.js"></script> |
| <link href="navtree.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="resize.js"></script> |
| <script type="text/javascript" src="navtree.js"></script> |
| <script type="text/javascript"> |
| $(document).ready(initResizable); |
| $(window).load(resizeHeight); |
| </script> |
| <link href="search/search.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="search/search.js"></script> |
| <script type="text/javascript"> |
| $(document).ready(function() { searchBox.OnSelectItem(0); }); |
| </script> |
| <link href="doxygen.css" rel="stylesheet" type="text/css" /> |
| </head> |
| <body> |
| <div id="top"><!-- do not remove this div, it is closed by doxygen! --> |
| <div id="titlearea"> |
| <table cellspacing="0" cellpadding="0"> |
| <tbody> |
| <tr style="height: 56px;"> |
| <td style="padding-left: 0.5em;"> |
| <div id="projectname">Impala |
| </div> |
| <div id="projectbrief">Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| <!-- end header part --> |
| <!-- Generated by Doxygen 1.8.6 --> |
| <script type="text/javascript"> |
| var searchBox = new SearchBox("searchBox", "search",false,'Search'); |
| </script> |
| <div id="navrow1" class="tabs"> |
| <ul class="tablist"> |
| <li><a href="index.html"><span>Main Page</span></a></li> |
| <li><a href="namespaces.html"><span>Namespaces</span></a></li> |
| <li><a href="annotated.html"><span>Classes</span></a></li> |
| <li class="current"><a href="files.html"><span>Files</span></a></li> |
| <li> |
| <div id="MSearchBox" class="MSearchBoxInactive"> |
| <span class="left"> |
| <img id="MSearchSelect" src="search/mag_sel.png" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| alt=""/> |
| <input type="text" id="MSearchField" value="Search" accesskey="S" |
| onfocus="searchBox.OnSearchFieldFocus(true)" |
| onblur="searchBox.OnSearchFieldFocus(false)" |
| onkeyup="searchBox.OnSearchFieldChange(event)"/> |
| </span><span class="right"> |
| <a id="MSearchClose" href="javascript:searchBox.CloseResultsWindow()"><img id="MSearchCloseImg" border="0" src="search/close.png" alt=""/></a> |
| </span> |
| </div> |
| </li> |
| </ul> |
| </div> |
| <div id="navrow2" class="tabs2"> |
| <ul class="tablist"> |
| <li><a href="files.html"><span>File List</span></a></li> |
| <li><a href="globals.html"><span>File Members</span></a></li> |
| </ul> |
| </div> |
| </div><!-- top --> |
| <div id="side-nav" class="ui-resizable side-nav-resizable"> |
| <div id="nav-tree"> |
| <div id="nav-tree-contents"> |
| <div id="nav-sync" class="sync"></div> |
| </div> |
| </div> |
| <div id="splitbar" style="-moz-user-select:none;" |
| class="ui-resizable-handle"> |
| </div> |
| </div> |
| <script type="text/javascript"> |
| $(document).ready(function(){initNavTree('data-stream-sender_8h_source.html','');}); |
| </script> |
| <div id="doc-content"> |
| <!-- window showing the filter options --> |
| <div id="MSearchSelectWindow" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| onkeydown="return searchBox.OnSearchSelectKey(event)"> |
| <a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(0)"><span class="SelectionMark"> </span>All</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(1)"><span class="SelectionMark"> </span>Classes</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(2)"><span class="SelectionMark"> </span>Namespaces</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(3)"><span class="SelectionMark"> </span>Files</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(4)"><span class="SelectionMark"> </span>Functions</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(5)"><span class="SelectionMark"> </span>Variables</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(6)"><span class="SelectionMark"> </span>Typedefs</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(7)"><span class="SelectionMark"> </span>Enumerations</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(8)"><span class="SelectionMark"> </span>Enumerator</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(9)"><span class="SelectionMark"> </span>Friends</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(10)"><span class="SelectionMark"> </span>Macros</a></div> |
| |
| <!-- iframe showing the search results (closed by default) --> |
| <div id="MSearchResultsWindow"> |
| <iframe src="javascript:void(0)" frameborder="0" |
| name="MSearchResults" id="MSearchResults"> |
| </iframe> |
| </div> |
| |
| <div class="header"> |
| <div class="headertitle"> |
| <div class="title">data-stream-sender.h</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="data-stream-sender_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">// Copyright 2012 Cloudera Inc.</span></div> |
| <div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// Licensed under the Apache License, Version 2.0 (the "License");</span></div> |
| <div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">// you may not use this file except in compliance with the License.</span></div> |
| <div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// You may obtain a copy of the License at</span></div> |
| <div class="line"><a name="l00006"></a><span class="lineno"> 6</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div> |
| <div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// Unless required by applicable law or agreed to in writing, software</span></div> |
| <div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">// distributed under the License is distributed on an "AS IS" BASIS,</span></div> |
| <div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span></div> |
| <div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// See the License for the specific language governing permissions and</span></div> |
| <div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// limitations under the License.</span></div> |
| <div class="line"><a name="l00014"></a><span class="lineno"> 14</span> </div> |
| <div class="line"><a name="l00015"></a><span class="lineno"> 15</span> </div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="preprocessor">#ifndef IMPALA_RUNTIME_DATA_STREAM_SENDER_H</span></div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="preprocessor"></span><span class="preprocessor">#define IMPALA_RUNTIME_DATA_STREAM_SENDER_H</span></div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor"></span></div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#include <vector></span></div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#include <string></span></div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> </div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include "<a class="code" href="data-sink_8h.html">exec/data-sink.h</a>"</span></div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> <span class="preprocessor">#include "<a class="code" href="global-types_8h.html">common/global-types.h</a>"</span></div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include "<a class="code" href="object-pool_8h.html">common/object-pool.h</a>"</span></div> |
| <div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">common/status.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-profile_8h.html">util/runtime-profile.h</a>"</span></div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include "gen-cpp/Results_types.h"</span> <span class="comment">// for TRowBatch</span></div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> </div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> </div> |
| <div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="keyword">class </span>Expr;</div> |
| <div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="keyword">class </span>RowBatch;</div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="keyword">class </span>RowDescriptor;</div> |
| <div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="keyword">class </span>MemTracker;</div> |
| <div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="keyword">class </span>TDataStreamSink;</div> |
| <div class="line"><a name="l00036"></a><span class="lineno"> 36</span> <span class="keyword">class </span>TNetworkAddress;</div> |
| <div class="line"><a name="l00037"></a><span class="lineno"> 37</span> <span class="keyword">class </span>TPlanFragmentDestination;</div> |
| <div class="line"><a name="l00038"></a><span class="lineno"> 38</span> </div> |
| <div class="line"><a name="l00043"></a><span class="lineno"> 43</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00046"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html"> 46</a></span> <span class="comment"></span><span class="keyword">class </span><a class="code" href="classimpala_1_1DataStreamSender.html">DataStreamSender</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1DataSink.html">DataSink</a> {</div> |
| <div class="line"><a name="l00047"></a><span class="lineno"> 47</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00056"></a><span class="lineno"> 56</span>  <a class="code" href="classimpala_1_1DataStreamSender.html#af0f6ed4d7c05379050ff946652597a70">DataStreamSender</a>(<a class="code" href="classimpala_1_1ObjectPool.html">ObjectPool</a>* <a class="code" href="expr-benchmark_8cc.html#a3a5de7bd423fbc0afc4cf935c166ca6b">pool</a>, <span class="keywordtype">int</span> sender_id,</div> |
| <div class="line"><a name="l00057"></a><span class="lineno"> 57</span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>& <a class="code" href="namespaceimpala.html#aa98447566dd6700a2faaaaf3059f4d95">row_desc</a>, <span class="keyword">const</span> TDataStreamSink& sink,</div> |
| <div class="line"><a name="l00058"></a><span class="lineno"> 58</span>  <span class="keyword">const</span> std::vector<TPlanFragmentDestination>& destinations,</div> |
| <div class="line"><a name="l00059"></a><span class="lineno"> 59</span>  <span class="keywordtype">int</span> per_channel_buffer_size);</div> |
| <div class="line"><a name="l00060"></a><span class="lineno"> 60</span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a9d54e519344431380d62139e583bb6be">~DataStreamSender</a>();</div> |
| <div class="line"><a name="l00061"></a><span class="lineno"> 61</span> </div> |
| <div class="line"><a name="l00064"></a><span class="lineno"> 64</span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DataStreamSender.html#acef39c14c7ed4b85122aa3c0cde80247">Prepare</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state);</div> |
| <div class="line"><a name="l00065"></a><span class="lineno"> 65</span> </div> |
| <div class="line"><a name="l00068"></a><span class="lineno"> 68</span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DataStreamSender.html#a441b986df33ba936a2de32af7e84c9d8">Open</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state);</div> |
| <div class="line"><a name="l00069"></a><span class="lineno"> 69</span> </div> |
| <div class="line"><a name="l00075"></a><span class="lineno"> 75</span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state, <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch, <span class="keywordtype">bool</span> eos);</div> |
| <div class="line"><a name="l00076"></a><span class="lineno"> 76</span> </div> |
| <div class="line"><a name="l00079"></a><span class="lineno"> 79</span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">Close</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state);</div> |
| <div class="line"><a name="l00080"></a><span class="lineno"> 80</span> </div> |
| <div class="line"><a name="l00084"></a><span class="lineno"> 84</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DataStreamSender.html#abbbddecac6016f222fb67ba610050385">SerializeBatch</a>(<a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* src, TRowBatch* dest, <span class="keywordtype">int</span> num_receivers = 1);</div> |
| <div class="line"><a name="l00085"></a><span class="lineno"> 85</span> </div> |
| <div class="line"><a name="l00088"></a><span class="lineno"> 88</span>  int64_t <a class="code" href="classimpala_1_1DataStreamSender.html#ae93db027f9d0cb4c50e8dd962d92a624">GetNumDataBytesSent</a>() <span class="keyword">const</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_1DataStreamSender.html#aad9605700b73457dfec1ce13604ae6d2"> 90</a></span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#aad9605700b73457dfec1ce13604ae6d2">profile</a>() { <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a9c12706a6222a87cb545099a725c3a2b">profile_</a>; }</div> |
| <div class="line"><a name="l00091"></a><span class="lineno"> 91</span> </div> |
| <div class="line"><a name="l00092"></a><span class="lineno"> 92</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00093"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a317d26e2a8aa9dcc15dbe994338bd15d"> 93</a></span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DataStreamSender_1_1Channel.html">Channel</a>;</div> |
| <div class="line"><a name="l00094"></a><span class="lineno"> 94</span> </div> |
| <div class="line"><a name="l00096"></a><span class="lineno"> 96</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a317d26e2a8aa9dcc15dbe994338bd15d">sender_id_</a>;</div> |
| <div class="line"><a name="l00097"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#ac212459ad24f6386484ee23856d8020a"> 97</a></span>  <a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#ac212459ad24f6386484ee23856d8020a">state_</a>;</div> |
| <div class="line"><a name="l00098"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a78b2b85b58341c703f2ae9d1492fc0c2"> 98</a></span>  <a class="code" href="classimpala_1_1ObjectPool.html">ObjectPool</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#a78b2b85b58341c703f2ae9d1492fc0c2">pool_</a>;</div> |
| <div class="line"><a name="l00099"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a29aee1e5cf5534019c438874836c248b"> 99</a></span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>& <a class="code" href="classimpala_1_1DataStreamSender.html#a29aee1e5cf5534019c438874836c248b">row_desc_</a>;</div> |
| <div class="line"><a name="l00100"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a5001d5f3c979d1ac348e964d032d6ce6"> 100</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a5001d5f3c979d1ac348e964d032d6ce6">broadcast_</a>; <span class="comment">// if true, send all rows on all channels</span></div> |
| <div class="line"><a name="l00101"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a9712721a0c91210b32f65329e18edec4"> 101</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a9712721a0c91210b32f65329e18edec4">random_</a>; <span class="comment">// if true, round-robins row batches among channels</span></div> |
| <div class="line"><a name="l00102"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#ad48f0843f4e4db5ed5abf45c68796b0b"> 102</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DataStreamSender.html#ad48f0843f4e4db5ed5abf45c68796b0b">current_channel_idx_</a>; <span class="comment">// index of current channel to send to if random_ == true</span></div> |
| <div class="line"><a name="l00103"></a><span class="lineno"> 103</span> </div> |
| <div class="line"><a name="l00105"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a425142ace64ba49e8122f069c79603e0"> 105</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DataStreamSender.html#a425142ace64ba49e8122f069c79603e0">closed_</a>;</div> |
| <div class="line"><a name="l00106"></a><span class="lineno"> 106</span> </div> |
| <div class="line"><a name="l00109"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a8efd4d7e7db1a831ec30ca0f6b26f23a"> 109</a></span>  TRowBatch <a class="code" href="classimpala_1_1DataStreamSender.html#a8efd4d7e7db1a831ec30ca0f6b26f23a">thrift_batch1_</a>;</div> |
| <div class="line"><a name="l00110"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a33cfb26543180cf9e27ef48595719135"> 110</a></span>  TRowBatch <a class="code" href="classimpala_1_1DataStreamSender.html#a33cfb26543180cf9e27ef48595719135">thrift_batch2_</a>;</div> |
| <div class="line"><a name="l00111"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#af88aec7b54580fa5254895fae593f9ee"> 111</a></span>  TRowBatch* <a class="code" href="classimpala_1_1DataStreamSender.html#af88aec7b54580fa5254895fae593f9ee">current_thrift_batch_</a>; <span class="comment">// the next one to fill in Send()</span></div> |
| <div class="line"><a name="l00112"></a><span class="lineno"> 112</span> </div> |
| <div class="line"><a name="l00113"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a628bdb9621325d09e0d23d0c82c8b651"> 113</a></span>  std::vector<ExprContext*> <a class="code" href="classimpala_1_1DataStreamSender.html#a628bdb9621325d09e0d23d0c82c8b651">partition_expr_ctxs_</a>; <span class="comment">// compute per-row partition values</span></div> |
| <div class="line"><a name="l00114"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#aa7c52712676f0849f95b4913a50432c8"> 114</a></span>  std::vector<Channel*> <a class="code" href="classimpala_1_1DataStreamSender.html#aa7c52712676f0849f95b4913a50432c8">channels_</a>;</div> |
| <div class="line"><a name="l00115"></a><span class="lineno"> 115</span> </div> |
| <div class="line"><a name="l00116"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a9c12706a6222a87cb545099a725c3a2b"> 116</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#a9c12706a6222a87cb545099a725c3a2b">profile_</a>; <span class="comment">// Allocated from pool_</span></div> |
| <div class="line"><a name="l00117"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a267f05a34f49154c4213778f69ca0e02"> 117</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#a267f05a34f49154c4213778f69ca0e02">serialize_batch_timer_</a>;</div> |
| <div class="line"><a name="l00118"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a9af4aaaa29c37202f3d1ee90746058b2"> 118</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#a9af4aaaa29c37202f3d1ee90746058b2">thrift_transmit_timer_</a>;</div> |
| <div class="line"><a name="l00119"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#afb8209f4ee653757ec84277a03734e31"> 119</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#afb8209f4ee653757ec84277a03734e31">bytes_sent_counter_</a>;</div> |
| <div class="line"><a name="l00120"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#ad494bafc728fd45ff9965005c672a023"> 120</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#ad494bafc728fd45ff9965005c672a023">uncompressed_bytes_counter_</a>;</div> |
| <div class="line"><a name="l00121"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#ae79c8af712dd169b821cdb61b761a9bd"> 121</a></span>  boost::scoped_ptr<MemTracker> <a class="code" href="classimpala_1_1DataStreamSender.html#ae79c8af712dd169b821cdb61b761a9bd">mem_tracker_</a>;</div> |
| <div class="line"><a name="l00122"></a><span class="lineno"> 122</span> </div> |
| <div class="line"><a name="l00124"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a96873c121e5ddecadbb7d509b277b413"> 124</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#a96873c121e5ddecadbb7d509b277b413">network_throughput_</a>;</div> |
| <div class="line"><a name="l00125"></a><span class="lineno"> 125</span> </div> |
| <div class="line"><a name="l00127"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#aeb6427e9059b1b7384f78cd25b8cd8d7"> 127</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1DataStreamSender.html#aeb6427e9059b1b7384f78cd25b8cd8d7">overall_throughput_</a>;</div> |
| <div class="line"><a name="l00128"></a><span class="lineno"> 128</span> </div> |
| <div class="line"><a name="l00130"></a><span class="lineno"><a class="line" href="classimpala_1_1DataStreamSender.html#a0da91963ba5b4e8299392661e8215cdd"> 130</a></span>  <a class="code" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> <a class="code" href="classimpala_1_1DataStreamSender.html#a0da91963ba5b4e8299392661e8215cdd">dest_node_id_</a>;</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> </div> |
| <div class="line"><a name="l00133"></a><span class="lineno"> 133</span> }</div> |
| <div class="line"><a name="l00134"></a><span class="lineno"> 134</span> </div> |
| <div class="line"><a name="l00135"></a><span class="lineno"> 135</span> <span class="preprocessor">#endif</span></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a9af4aaaa29c37202f3d1ee90746058b2"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a9af4aaaa29c37202f3d1ee90746058b2">impala::DataStreamSender::thrift_transmit_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * thrift_transmit_timer_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00118">data-stream-sender.h:118</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_ad494bafc728fd45ff9965005c672a023"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#ad494bafc728fd45ff9965005c672a023">impala::DataStreamSender::uncompressed_bytes_counter_</a></div><div class="ttdeci">RuntimeProfile::Counter * uncompressed_bytes_counter_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00120">data-stream-sender.h:120</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a9712721a0c91210b32f65329e18edec4"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a9712721a0c91210b32f65329e18edec4">impala::DataStreamSender::random_</a></div><div class="ttdeci">bool random_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00101">data-stream-sender.h:101</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_afb8209f4ee653757ec84277a03734e31"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#afb8209f4ee653757ec84277a03734e31">impala::DataStreamSender::bytes_sent_counter_</a></div><div class="ttdeci">RuntimeProfile::Counter * bytes_sent_counter_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00119">data-stream-sender.h:119</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="runtime-profile_8h_html"><div class="ttname"><a href="runtime-profile_8h.html">runtime-profile.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a317d26e2a8aa9dcc15dbe994338bd15d"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a317d26e2a8aa9dcc15dbe994338bd15d">impala::DataStreamSender::sender_id_</a></div><div class="ttdeci">int sender_id_</div><div class="ttdoc">Sender instance id, unique within a fragment. </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00093">data-stream-sender.h:93</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a96873c121e5ddecadbb7d509b277b413"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a96873c121e5ddecadbb7d509b277b413">impala::DataStreamSender::network_throughput_</a></div><div class="ttdeci">RuntimeProfile::Counter * network_throughput_</div><div class="ttdoc">Throughput per time spent in TransmitData. </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00124">data-stream-sender.h:124</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="classimpala_1_1DataStreamSender_html_a8efd4d7e7db1a831ec30ca0f6b26f23a"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a8efd4d7e7db1a831ec30ca0f6b26f23a">impala::DataStreamSender::thrift_batch1_</a></div><div class="ttdeci">TRowBatch thrift_batch1_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00109">data-stream-sender.h:109</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="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="classimpala_1_1DataStreamSender_html_aad9605700b73457dfec1ce13604ae6d2"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#aad9605700b73457dfec1ce13604ae6d2">impala::DataStreamSender::profile</a></div><div class="ttdeci">virtual RuntimeProfile * profile()</div><div class="ttdoc">Returns the runtime profile for the sink. </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00090">data-stream-sender.h:90</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="classimpala_1_1RuntimeProfile_1_1Counter_html"><div class="ttname"><a href="classimpala_1_1RuntimeProfile_1_1Counter.html">impala::RuntimeProfile::Counter</a></div><div class="ttdef"><b>Definition:</b> <a href="runtime-profile_8h_source.html#l00085">runtime-profile.h:85</a></div></div> |
| <div class="ttc" id="data-sink_8h_html"><div class="ttname"><a href="data-sink_8h.html">data-sink.h</a></div></div> |
| <div class="ttc" id="object-pool_8h_html"><div class="ttname"><a href="object-pool_8h.html">object-pool.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a29aee1e5cf5534019c438874836c248b"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a29aee1e5cf5534019c438874836c248b">impala::DataStreamSender::row_desc_</a></div><div class="ttdeci">const RowDescriptor & row_desc_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00099">data-stream-sender.h:99</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_1_1Channel_html"><div class="ttname"><a href="classimpala_1_1DataStreamSender_1_1Channel.html">impala::DataStreamSender::Channel</a></div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00057">data-stream-sender.cc:57</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_1DataSink_html"><div class="ttname"><a href="classimpala_1_1DataSink.html">impala::DataSink</a></div><div class="ttdoc">Superclass of all data sinks. </div><div class="ttdef"><b>Definition:</b> <a href="data-sink_8h_source.html#l00039">data-sink.h:39</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a33cfb26543180cf9e27ef48595719135"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a33cfb26543180cf9e27ef48595719135">impala::DataStreamSender::thrift_batch2_</a></div><div class="ttdeci">TRowBatch thrift_batch2_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00110">data-stream-sender.h:110</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="classimpala_1_1DataStreamSender_html_aa7c52712676f0849f95b4913a50432c8"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#aa7c52712676f0849f95b4913a50432c8">impala::DataStreamSender::channels_</a></div><div class="ttdeci">std::vector< Channel * > channels_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00114">data-stream-sender.h:114</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_ad48f0843f4e4db5ed5abf45c68796b0b"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#ad48f0843f4e4db5ed5abf45c68796b0b">impala::DataStreamSender::current_channel_idx_</a></div><div class="ttdeci">int current_channel_idx_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00102">data-stream-sender.h:102</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_abbbddecac6016f222fb67ba610050385"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#abbbddecac6016f222fb67ba610050385">impala::DataStreamSender::SerializeBatch</a></div><div class="ttdeci">void SerializeBatch(RowBatch *src, TRowBatch *dest, int num_receivers=1)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00459">data-stream-sender.cc:459</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="expr-benchmark_8cc_html_a3a5de7bd423fbc0afc4cf935c166ca6b"><div class="ttname"><a href="expr-benchmark_8cc.html#a3a5de7bd423fbc0afc4cf935c166ca6b">pool</a></div><div class="ttdeci">ObjectPool pool</div><div class="ttdef"><b>Definition:</b> <a href="expr-benchmark_8cc_source.html#l00089">expr-benchmark.cc:89</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_1DataStreamSender_html_a9d54e519344431380d62139e583bb6be"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a9d54e519344431380d62139e583bb6be">impala::DataStreamSender::~DataStreamSender</a></div><div class="ttdeci">virtual ~DataStreamSender()</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00354">data-stream-sender.cc:354</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="classimpala_1_1DataStreamSender_html_a5001d5f3c979d1ac348e964d032d6ce6"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a5001d5f3c979d1ac348e964d032d6ce6">impala::DataStreamSender::broadcast_</a></div><div class="ttdeci">bool broadcast_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00100">data-stream-sender.h:100</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_1DataStreamSender_html_aeb6427e9059b1b7384f78cd25b8cd8d7"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#aeb6427e9059b1b7384f78cd25b8cd8d7">impala::DataStreamSender::overall_throughput_</a></div><div class="ttdeci">RuntimeProfile::Counter * overall_throughput_</div><div class="ttdoc">Throughput per total time spent in sender. </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00127">data-stream-sender.h:127</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_aa98447566dd6700a2faaaaf3059f4d95"><div class="ttname"><a href="namespaceimpala.html#aa98447566dd6700a2faaaaf3059f4d95">impala::row_desc</a></div><div class="ttdeci">const RowDescriptor & row_desc() const </div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a425142ace64ba49e8122f069c79603e0"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a425142ace64ba49e8122f069c79603e0">impala::DataStreamSender::closed_</a></div><div class="ttdeci">bool closed_</div><div class="ttdoc">If true, this sender has been closed. Not valid to call Send() anymore. </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00105">data-stream-sender.h:105</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_ac212459ad24f6386484ee23856d8020a"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#ac212459ad24f6386484ee23856d8020a">impala::DataStreamSender::state_</a></div><div class="ttdeci">RuntimeState * state_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00097">data-stream-sender.h:97</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a9c12706a6222a87cb545099a725c3a2b"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a9c12706a6222a87cb545099a725c3a2b">impala::DataStreamSender::profile_</a></div><div class="ttdeci">RuntimeProfile * profile_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00116">data-stream-sender.h:116</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a628bdb9621325d09e0d23d0c82c8b651"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a628bdb9621325d09e0d23d0c82c8b651">impala::DataStreamSender::partition_expr_ctxs_</a></div><div class="ttdeci">std::vector< ExprContext * > partition_expr_ctxs_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00113">data-stream-sender.h:113</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_1DataStreamSender_html_a267f05a34f49154c4213778f69ca0e02"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a267f05a34f49154c4213778f69ca0e02">impala::DataStreamSender::serialize_batch_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * serialize_batch_timer_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00117">data-stream-sender.h:117</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_1DataStreamSender_html_a78b2b85b58341c703f2ae9d1492fc0c2"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a78b2b85b58341c703f2ae9d1492fc0c2">impala::DataStreamSender::pool_</a></div><div class="ttdeci">ObjectPool * pool_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00098">data-stream-sender.h:98</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_af88aec7b54580fa5254895fae593f9ee"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#af88aec7b54580fa5254895fae593f9ee">impala::DataStreamSender::current_thrift_batch_</a></div><div class="ttdeci">TRowBatch * current_thrift_batch_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00111">data-stream-sender.h:111</a></div></div> |
| <div class="ttc" id="global-types_8h_html"><div class="ttname"><a href="global-types_8h.html">global-types.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_af0f6ed4d7c05379050ff946652597a70"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#af0f6ed4d7c05379050ff946652597a70">impala::DataStreamSender::DataStreamSender</a></div><div class="ttdeci">DataStreamSender(ObjectPool *pool, int sender_id, const RowDescriptor &row_desc, const TDataStreamSink &sink, const std::vector< TPlanFragmentDestination > &destinations, int per_channel_buffer_size)</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8cc_source.html#l00310">data-stream-sender.cc:310</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_ae79c8af712dd169b821cdb61b761a9bd"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#ae79c8af712dd169b821cdb61b761a9bd">impala::DataStreamSender::mem_tracker_</a></div><div class="ttdeci">boost::scoped_ptr< MemTracker > mem_tracker_</div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00121">data-stream-sender.h:121</a></div></div> |
| <div class="ttc" id="classimpala_1_1DataStreamSender_html_a0da91963ba5b4e8299392661e8215cdd"><div class="ttname"><a href="classimpala_1_1DataStreamSender.html#a0da91963ba5b4e8299392661e8215cdd">impala::DataStreamSender::dest_node_id_</a></div><div class="ttdeci">PlanNodeId dest_node_id_</div><div class="ttdoc">Identifier of the destination plan node. </div><div class="ttdef"><b>Definition:</b> <a href="data-stream-sender_8h_source.html#l00130">data-stream-sender.h:130</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-sender_8h.html">data-stream-sender.h</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> |
