| <!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/buffered-tuple-stream.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('buffered-tuple-stream_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">buffered-tuple-stream.h</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="buffered-tuple-stream_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 2013 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">#ifndef IMPALA_RUNTIME_BUFFERED_TUPLE_STREAM_H</span></div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="preprocessor"></span><span class="preprocessor">#define IMPALA_RUNTIME_BUFFERED_TUPLE_STREAM_H</span></div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="preprocessor"></span></div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">common/status.h</a>"</span></div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#include "<a class="code" href="buffered-block-mgr_8h.html">runtime/buffered-block-mgr.h</a>"</span></div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> </div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> <span class="keyword">class </span>BufferedBlockMgr;</div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="keyword">class </span>RuntimeProfile;</div> |
| <div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="keyword">class </span>RuntimeState;</div> |
| <div class="line"><a name="l00026"></a><span class="lineno"> 26</span> <span class="keyword">class </span>RowBatch;</div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="keyword">class </span>RowDescriptor;</div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="keyword">class </span>SlotDescriptor;</div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="keyword">class </span>TupleRow;</div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> </div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00047"></a><span class="lineno"> 47</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00051"></a><span class="lineno"> 51</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00056"></a><span class="lineno"> 56</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00062"></a><span class="lineno"> 62</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00070"></a><span class="lineno"> 70</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00086"></a><span class="lineno"> 86</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00109"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html"> 109</a></span> <span class="comment"></span><span class="keyword">class </span><a class="code" href="classimpala_1_1BufferedTupleStream.html">BufferedTupleStream</a> {</div> |
| <div class="line"><a name="l00110"></a><span class="lineno"> 110</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00121"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html"> 121</a></span>  <span class="keyword">struct </span><a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html">RowIdx</a> {</div> |
| <div class="line"><a name="l00122"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aa78a147b1cd7d4364fcbebcc261cae84"> 122</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aa78a147b1cd7d4364fcbebcc261cae84">BLOCK_MASK</a> = 0xFFFF;</div> |
| <div class="line"><a name="l00123"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a4fcb7ad8bfd26184ba80ff7ced27d5a5"> 123</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a4fcb7ad8bfd26184ba80ff7ced27d5a5">BLOCK_SHIFT</a> = 0;</div> |
| <div class="line"><a name="l00124"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3cb5b0f579f7dc19c7076e34c97b0b9b"> 124</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3cb5b0f579f7dc19c7076e34c97b0b9b">OFFSET_MASK</a> = 0xFFFFFF0000;</div> |
| <div class="line"><a name="l00125"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ae4195c988c503e4de241e32036ca1b65"> 125</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ae4195c988c503e4de241e32036ca1b65">OFFSET_SHIFT</a> = 16;</div> |
| <div class="line"><a name="l00126"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a5a31e51ff14da66121477a191964703a"> 126</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a5a31e51ff14da66121477a191964703a">IDX_MASK</a> = 0xFFFFFF0000000000;</div> |
| <div class="line"><a name="l00127"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a0ec2ebd3590dcfdcfadd34d534a0261e"> 127</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a0ec2ebd3590dcfdcfadd34d534a0261e">IDX_SHIFT</a> = 40;</div> |
| <div class="line"><a name="l00128"></a><span class="lineno"> 128</span> </div> |
| <div class="line"><a name="l00129"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a2096ee0339acea32229f87193c97524c"> 129</a></span>  <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a2096ee0339acea32229f87193c97524c">block</a>()<span class="keyword"> const </span>{</div> |
| <div class="line"><a name="l00130"></a><span class="lineno"> 130</span>  <span class="keywordflow">return</span> (<a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">data</a> & <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aa78a147b1cd7d4364fcbebcc261cae84">BLOCK_MASK</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"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a33740864c957e97c08eb42eee3015c68"> 133</a></span>  <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a33740864c957e97c08eb42eee3015c68">offset</a>()<span class="keyword"> const </span>{</div> |
| <div class="line"><a name="l00134"></a><span class="lineno"> 134</span>  <span class="keywordflow">return</span> (<a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">data</a> & <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3cb5b0f579f7dc19c7076e34c97b0b9b">OFFSET_MASK</a>) >> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ae4195c988c503e4de241e32036ca1b65">OFFSET_SHIFT</a>;</div> |
| <div class="line"><a name="l00135"></a><span class="lineno"> 135</span>  };</div> |
| <div class="line"><a name="l00136"></a><span class="lineno"> 136</span> </div> |
| <div class="line"><a name="l00137"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ad17c1138f8d4468aa082f6363b892788"> 137</a></span>  <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ad17c1138f8d4468aa082f6363b892788">idx</a>()<span class="keyword"> const </span>{</div> |
| <div class="line"><a name="l00138"></a><span class="lineno"> 138</span>  <span class="keywordflow">return</span> (<a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">data</a> & <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a5a31e51ff14da66121477a191964703a">IDX_MASK</a>) >> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a0ec2ebd3590dcfdcfadd34d534a0261e">IDX_SHIFT</a>;</div> |
| <div class="line"><a name="l00139"></a><span class="lineno"> 139</span>  }</div> |
| <div class="line"><a name="l00140"></a><span class="lineno"> 140</span> </div> |
| <div class="line"><a name="l00141"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3464e57c0b69fda3fc0f3727358af5d3"> 141</a></span>  <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3464e57c0b69fda3fc0f3727358af5d3">set</a>(<a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a2096ee0339acea32229f87193c97524c">block</a>, <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a33740864c957e97c08eb42eee3015c68">offset</a>, <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ad17c1138f8d4468aa082f6363b892788">idx</a>) {</div> |
| <div class="line"><a name="l00142"></a><span class="lineno"> 142</span>  DCHECK_LE(block, <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aa78a147b1cd7d4364fcbebcc261cae84">BLOCK_MASK</a>)</div> |
| <div class="line"><a name="l00143"></a><span class="lineno"> 143</span>  << <span class="stringliteral">"Cannot have more than 2^16 = 64K blocks in a tuple stream."</span>;</div> |
| <div class="line"><a name="l00144"></a><span class="lineno"> 144</span>  DCHECK_LE(offset, <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3cb5b0f579f7dc19c7076e34c97b0b9b">OFFSET_MASK</a> >> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ae4195c988c503e4de241e32036ca1b65">OFFSET_SHIFT</a>)</div> |
| <div class="line"><a name="l00145"></a><span class="lineno"> 145</span>  << <span class="stringliteral">"Cannot have blocks larger than 2^24 = 16MB"</span>;</div> |
| <div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  DCHECK_LE(idx, <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a5a31e51ff14da66121477a191964703a">IDX_MASK</a> >> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a0ec2ebd3590dcfdcfadd34d534a0261e">IDX_SHIFT</a>)</div> |
| <div class="line"><a name="l00147"></a><span class="lineno"> 147</span>  << <span class="stringliteral">"Cannot have more than 2^24 = 16M rows in a block."</span>;</div> |
| <div class="line"><a name="l00148"></a><span class="lineno"> 148</span>  <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">data</a> = block | (offset << <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ae4195c988c503e4de241e32036ca1b65">OFFSET_SHIFT</a>) | (idx << <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a0ec2ebd3590dcfdcfadd34d534a0261e">IDX_SHIFT</a>);</div> |
| <div class="line"><a name="l00149"></a><span class="lineno"> 149</span>  <span class="keywordflow">return</span> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">data</a>;</div> |
| <div class="line"><a name="l00150"></a><span class="lineno"> 150</span>  }</div> |
| <div class="line"><a name="l00151"></a><span class="lineno"> 151</span> </div> |
| <div class="line"><a name="l00152"></a><span class="lineno"> 152</span>  std::string <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a431215848544ca0af04357ff722c5f80">DebugString</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00153"></a><span class="lineno"> 153</span> </div> |
| <div class="line"><a name="l00154"></a><span class="lineno"><a class="line" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42"> 154</a></span>  <a class="code" href="classuint64__t.html">uint64_t</a> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">data</a>;</div> |
| <div class="line"><a name="l00155"></a><span class="lineno"> 155</span>  };</div> |
| <div class="line"><a name="l00156"></a><span class="lineno"> 156</span> </div> |
| <div class="line"><a name="l00165"></a><span class="lineno"> 165</span>  <a class="code" href="classimpala_1_1BufferedTupleStream.html#abe18798dd236710e215baec9902023bb">BufferedTupleStream</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state, <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>,</div> |
| <div class="line"><a name="l00166"></a><span class="lineno"> 166</span>  <a class="code" href="classimpala_1_1BufferedBlockMgr.html">BufferedBlockMgr</a>* block_mgr, <a class="code" href="structimpala_1_1BufferedBlockMgr_1_1Client.html">BufferedBlockMgr::Client</a>* client,</div> |
| <div class="line"><a name="l00167"></a><span class="lineno"> 167</span>  <span class="keywordtype">bool</span> use_initial_small_buffers = <span class="keyword">true</span>,</div> |
| <div class="line"><a name="l00168"></a><span class="lineno"> 168</span>  <span class="keywordtype">bool</span> delete_on_read = <span class="keyword">false</span>, <span class="keywordtype">bool</span> read_write = <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00169"></a><span class="lineno"> 169</span> </div> |
| <div class="line"><a name="l00174"></a><span class="lineno"> 174</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ae4e2e76ff44f09a358c6c36827da9f50">Init</a>(<a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* profile = NULL, <span class="keywordtype">bool</span> pinned = <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00175"></a><span class="lineno"> 175</span> </div> |
| <div class="line"><a name="l00178"></a><span class="lineno"> 178</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a21cc752d4db27e53c163e155f5da61e9">SwitchToIoBuffers</a>(<span class="keywordtype">bool</span>* got_buffer);</div> |
| <div class="line"><a name="l00179"></a><span class="lineno"> 179</span> </div> |
| <div class="line"><a name="l00184"></a><span class="lineno"> 184</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#aa9ec745ca549f76bce14872acfbd58c3">AddRow</a>(<a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row, uint8_t** dst = NULL);</div> |
| <div class="line"><a name="l00185"></a><span class="lineno"> 185</span> </div> |
| <div class="line"><a name="l00188"></a><span class="lineno"> 188</span>  uint8_t* <a class="code" href="classimpala_1_1BufferedTupleStream.html#abf2195dea963d8d7bea71dda65db61da">AllocateRow</a>(<span class="keywordtype">int</span> size);</div> |
| <div class="line"><a name="l00189"></a><span class="lineno"> 189</span> </div> |
| <div class="line"><a name="l00192"></a><span class="lineno"> 192</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a87909f60c4efe1aae47471ce668136ec">GetTupleRow</a>(<span class="keyword">const</span> <a class="code" href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html">RowIdx</a>& <a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a>, <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00193"></a><span class="lineno"> 193</span> </div> |
| <div class="line"><a name="l00200"></a><span class="lineno"> 200</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a4f537ea0c46ce3dfc77a5b3bf58a07af">PrepareForRead</a>(<span class="keywordtype">bool</span>* got_buffer = NULL);</div> |
| <div class="line"><a name="l00201"></a><span class="lineno"> 201</span> </div> |
| <div class="line"><a name="l00206"></a><span class="lineno"> 206</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a066d00bdf6f36be1f08bc8a6d64154ac">PinStream</a>(<span class="keywordtype">bool</span> already_reserved, <span class="keywordtype">bool</span>* pinned);</div> |
| <div class="line"><a name="l00207"></a><span class="lineno"> 207</span> </div> |
| <div class="line"><a name="l00210"></a><span class="lineno"> 210</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a9d2f211df83a684b2a644d2b8a179026">UnpinStream</a>(<span class="keywordtype">bool</span> all = <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00211"></a><span class="lineno"> 211</span> </div> |
| <div class="line"><a name="l00216"></a><span class="lineno"> 216</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a5277d4ff9fdeb7b31bdf4d520739582d">GetNext</a>(<a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch, <span class="keywordtype">bool</span>* eos, std::vector<RowIdx>* indices = NULL);</div> |
| <div class="line"><a name="l00217"></a><span class="lineno"> 217</span> </div> |
| <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#acff79f0ded3d6752e2d28c9399c6d0b1">GetRows</a>(boost::scoped_ptr<RowBatch>* batch, <span class="keywordtype">bool</span>* got_rows);</div> |
| <div class="line"><a name="l00222"></a><span class="lineno"> 222</span> </div> |
| <div class="line"><a name="l00224"></a><span class="lineno"> 224</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a9cb6b2be78a2bff4d5dafd164c3dc0b7">Close</a>();</div> |
| <div class="line"><a name="l00225"></a><span class="lineno"> 225</span> </div> |
| <div class="line"><a name="l00228"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a1df0eb41c554ed098af8d81637b4f615"> 228</a></span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a1df0eb41c554ed098af8d81637b4f615">status</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a3225a777414cf8650062a18add9dc204">status_</a>; }</div> |
| <div class="line"><a name="l00229"></a><span class="lineno"> 229</span> </div> |
| <div class="line"><a name="l00231"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#af5796ba9a36c8485227b810b343aec47"> 231</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#af5796ba9a36c8485227b810b343aec47">num_rows</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ae35acc9106a9bc881e8a1127cc57a198">num_rows_</a>; }</div> |
| <div class="line"><a name="l00232"></a><span class="lineno"> 232</span> </div> |
| <div class="line"><a name="l00234"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ac290526c52cbd7996e9bd435cfa38cce"> 234</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#ac290526c52cbd7996e9bd435cfa38cce">rows_returned</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ab6fc6d8b3e3aa42fcaba7f3821ed2c33">rows_returned_</a>; }</div> |
| <div class="line"><a name="l00235"></a><span class="lineno"> 235</span> </div> |
| <div class="line"><a name="l00237"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a6846f309cc28f0d6b6d6caebd033cdec"> 237</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#a6846f309cc28f0d6b6d6caebd033cdec">byte_size</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ad905a907a64f8cd48cfebac638200c99">total_byte_size_</a>; }</div> |
| <div class="line"><a name="l00238"></a><span class="lineno"> 238</span> </div> |
| <div class="line"><a name="l00241"></a><span class="lineno"> 241</span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#ac034f1be3983f354b5b7170e4e5afd62">bytes_in_mem</a>(<span class="keywordtype">bool</span> ignore_current) <span class="keyword">const</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"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a3b47a81d368ad14edaf0256f2779189a"> 243</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a3b47a81d368ad14edaf0256f2779189a">is_pinned</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a707b3fddb8c72b48232682dee77cb06c">pinned_</a>; }</div> |
| <div class="line"><a name="l00244"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#afccb3ea6e79e38e8d4c16472248d6d18"> 244</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#afccb3ea6e79e38e8d4c16472248d6d18">blocks_pinned</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a54c7376a284c281622eb888ae277d558">num_pinned_</a>; }</div> |
| <div class="line"><a name="l00245"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ad2aeaf7b3790a34697dd682544ae9af7"> 245</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ad2aeaf7b3790a34697dd682544ae9af7">blocks_unpinned</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#acee73ea9a28e990c2dd08d7720ebb209">blocks_</a>.size() - <a class="code" href="classimpala_1_1BufferedTupleStream.html#a54c7376a284c281622eb888ae277d558">num_pinned_</a> - <a class="code" href="classimpala_1_1BufferedTupleStream.html#a115418648d4c9755e7dbd0cfa2c0b9f0">num_small_blocks_</a>; }</div> |
| <div class="line"><a name="l00246"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#abb1902c704be038600e5c5a4209396e8"> 246</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#abb1902c704be038600e5c5a4209396e8">has_read_block</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a7f864ab630476a8d77b5a4b51a81604b">read_block_</a> != <a class="code" href="classimpala_1_1BufferedTupleStream.html#acee73ea9a28e990c2dd08d7720ebb209">blocks_</a>.end(); }</div> |
| <div class="line"><a name="l00247"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a35a832736a10de3486abe8661bfbe58d"> 247</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a35a832736a10de3486abe8661bfbe58d">has_write_block</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a1253dcec8226c94833f74bc80a2b90b3">write_block_</a> != NULL; }</div> |
| <div class="line"><a name="l00248"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ad9fe5f5d1dfbf451a340c46a163dd9df"> 248</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ad9fe5f5d1dfbf451a340c46a163dd9df">using_small_buffers</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a0c6479bc0cba32fa1f053c29200c473b">use_small_buffers_</a>; }</div> |
| <div class="line"><a name="l00249"></a><span class="lineno"> 249</span> </div> |
| <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  std::string <a class="code" href="classimpala_1_1BufferedTupleStream.html#a4121e3bb85a9a0c2612930a7aed61807">DebugString</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00251"></a><span class="lineno"> 251</span> </div> |
| <div class="line"><a name="l00252"></a><span class="lineno"> 252</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00254"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a0c6479bc0cba32fa1f053c29200c473b"> 254</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a0c6479bc0cba32fa1f053c29200c473b">use_small_buffers_</a>;</div> |
| <div class="line"><a name="l00255"></a><span class="lineno"> 255</span> </div> |
| <div class="line"><a name="l00257"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a2882935e6094afad5fc930f2a757e547"> 257</a></span>  <span class="keyword">const</span> <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a2882935e6094afad5fc930f2a757e547">delete_on_read_</a>;</div> |
| <div class="line"><a name="l00258"></a><span class="lineno"> 258</span> </div> |
| <div class="line"><a name="l00262"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#adbe5ffb56ce04fb412628dfa8fa3ff84"> 262</a></span>  <span class="keyword">const</span> <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#adbe5ffb56ce04fb412628dfa8fa3ff84">read_write_</a>;</div> |
| <div class="line"><a name="l00263"></a><span class="lineno"> 263</span> </div> |
| <div class="line"><a name="l00265"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a3688c23c42e5d8d9f779a3b1a3e74a94"> 265</a></span>  <a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* <span class="keyword">const</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a3688c23c42e5d8d9f779a3b1a3e74a94">state_</a>;</div> |
| <div class="line"><a name="l00266"></a><span class="lineno"> 266</span> </div> |
| <div class="line"><a name="l00268"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#aadb29f0e9d4e4693e1716158eee829ec"> 268</a></span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>& <a class="code" href="classimpala_1_1BufferedTupleStream.html#aadb29f0e9d4e4693e1716158eee829ec">desc_</a>;</div> |
| <div class="line"><a name="l00269"></a><span class="lineno"> 269</span> </div> |
| <div class="line"><a name="l00271"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a862e2da773f1d3ba0114df6a6fbc7e0a"> 271</a></span>  <span class="keyword">const</span> <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a862e2da773f1d3ba0114df6a6fbc7e0a">nullable_tuple_</a>;</div> |
| <div class="line"><a name="l00272"></a><span class="lineno"> 272</span> </div> |
| <div class="line"><a name="l00274"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a2dcdf8dc3f624e131420e4f010d8fb83"> 274</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a2dcdf8dc3f624e131420e4f010d8fb83">fixed_tuple_row_size_</a>;</div> |
| <div class="line"><a name="l00275"></a><span class="lineno"> 275</span> </div> |
| <div class="line"><a name="l00281"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#acfed70ae36697f861227e5f55c6a7d9a"> 281</a></span>  uint32_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#acfed70ae36697f861227e5f55c6a7d9a">null_indicators_read_block_</a>;</div> |
| <div class="line"><a name="l00282"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ab0313f195d91db86e2d86eeeda553e7a"> 282</a></span>  uint32_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#ab0313f195d91db86e2d86eeeda553e7a">null_indicators_write_block_</a>;</div> |
| <div class="line"><a name="l00283"></a><span class="lineno"> 283</span> </div> |
| <div class="line"><a name="l00285"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a08beb5c3c7bded04f1de51c3da10c89a"> 285</a></span>  std::vector<std::pair<int, std::vector<SlotDescriptor*> > > <a class="code" href="classimpala_1_1BufferedTupleStream.html#a08beb5c3c7bded04f1de51c3da10c89a">string_slots_</a>;</div> |
| <div class="line"><a name="l00286"></a><span class="lineno"> 286</span> </div> |
| <div class="line"><a name="l00288"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a691dc8b7d5efbb60c41e7301dc5a63b6"> 288</a></span>  <a class="code" href="classimpala_1_1BufferedBlockMgr.html">BufferedBlockMgr</a>* <a class="code" href="classimpala_1_1BufferedTupleStream.html#a691dc8b7d5efbb60c41e7301dc5a63b6">block_mgr_</a>;</div> |
| <div class="line"><a name="l00289"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ada77a4e348b105775fd52e8e39743998"> 289</a></span>  <a class="code" href="structimpala_1_1BufferedBlockMgr_1_1Client.html">BufferedBlockMgr::Client</a>* <a class="code" href="classimpala_1_1BufferedTupleStream.html#ada77a4e348b105775fd52e8e39743998">block_mgr_client_</a>;</div> |
| <div class="line"><a name="l00290"></a><span class="lineno"> 290</span> </div> |
| <div class="line"><a name="l00292"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#acee73ea9a28e990c2dd08d7720ebb209"> 292</a></span>  std::list<BufferedBlockMgr::Block*> <a class="code" href="classimpala_1_1BufferedTupleStream.html#acee73ea9a28e990c2dd08d7720ebb209">blocks_</a>;</div> |
| <div class="line"><a name="l00293"></a><span class="lineno"> 293</span> </div> |
| <div class="line"><a name="l00295"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ad905a907a64f8cd48cfebac638200c99"> 295</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#ad905a907a64f8cd48cfebac638200c99">total_byte_size_</a>;</div> |
| <div class="line"><a name="l00296"></a><span class="lineno"> 296</span> </div> |
| <div class="line"><a name="l00299"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a7f864ab630476a8d77b5a4b51a81604b"> 299</a></span>  std::list<BufferedBlockMgr::Block*>::iterator <a class="code" href="classimpala_1_1BufferedTupleStream.html#a7f864ab630476a8d77b5a4b51a81604b">read_block_</a>;</div> |
| <div class="line"><a name="l00300"></a><span class="lineno"> 300</span> </div> |
| <div class="line"><a name="l00304"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a1b9da094a3d35db33e21cd581e4c762d"> 304</a></span>  std::vector<uint8_t*> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a1b9da094a3d35db33e21cd581e4c762d">block_start_idx_</a>;</div> |
| <div class="line"><a name="l00305"></a><span class="lineno"> 305</span> </div> |
| <div class="line"><a name="l00307"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#adb1ca6bf40ac1b240a0c50923e4d7f24"> 307</a></span>  uint8_t* <a class="code" href="classimpala_1_1BufferedTupleStream.html#adb1ca6bf40ac1b240a0c50923e4d7f24">read_ptr_</a>;</div> |
| <div class="line"><a name="l00308"></a><span class="lineno"> 308</span> </div> |
| <div class="line"><a name="l00310"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a68aaaeaae3c217e698ce2ca6097d0e43"> 310</a></span>  uint32_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#a68aaaeaae3c217e698ce2ca6097d0e43">read_tuple_idx_</a>;</div> |
| <div class="line"><a name="l00311"></a><span class="lineno"> 311</span> </div> |
| <div class="line"><a name="l00313"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a85fea074aae6b4f949280df51ccb233c"> 313</a></span>  uint32_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#a85fea074aae6b4f949280df51ccb233c">write_tuple_idx_</a>;</div> |
| <div class="line"><a name="l00314"></a><span class="lineno"> 314</span> </div> |
| <div class="line"><a name="l00316"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#aa2229061216f10cfa13936bb38d88cd0"> 316</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#aa2229061216f10cfa13936bb38d88cd0">read_bytes_</a>;</div> |
| <div class="line"><a name="l00317"></a><span class="lineno"> 317</span> </div> |
| <div class="line"><a name="l00319"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ab6fc6d8b3e3aa42fcaba7f3821ed2c33"> 319</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#ab6fc6d8b3e3aa42fcaba7f3821ed2c33">rows_returned_</a>;</div> |
| <div class="line"><a name="l00320"></a><span class="lineno"> 320</span> </div> |
| <div class="line"><a name="l00322"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a79f040358dacbbab993af134f709ca0a"> 322</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a79f040358dacbbab993af134f709ca0a">read_block_idx_</a>;</div> |
| <div class="line"><a name="l00323"></a><span class="lineno"> 323</span> </div> |
| <div class="line"><a name="l00325"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a1253dcec8226c94833f74bc80a2b90b3"> 325</a></span>  <a class="code" href="classimpala_1_1BufferedBlockMgr_1_1Block.html">BufferedBlockMgr::Block</a>* <a class="code" href="classimpala_1_1BufferedTupleStream.html#a1253dcec8226c94833f74bc80a2b90b3">write_block_</a>;</div> |
| <div class="line"><a name="l00326"></a><span class="lineno"> 326</span> </div> |
| <div class="line"><a name="l00330"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a54c7376a284c281622eb888ae277d558"> 330</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a54c7376a284c281622eb888ae277d558">num_pinned_</a>;</div> |
| <div class="line"><a name="l00331"></a><span class="lineno"> 331</span> </div> |
| <div class="line"><a name="l00333"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a115418648d4c9755e7dbd0cfa2c0b9f0"> 333</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a115418648d4c9755e7dbd0cfa2c0b9f0">num_small_blocks_</a>;</div> |
| <div class="line"><a name="l00334"></a><span class="lineno"> 334</span> </div> |
| <div class="line"><a name="l00335"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a2a42e34f0b5faaa053704b93287f1df7"> 335</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a2a42e34f0b5faaa053704b93287f1df7">closed_</a>; <span class="comment">// Used for debugging.</span></div> |
| <div class="line"><a name="l00336"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a3225a777414cf8650062a18add9dc204"> 336</a></span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a3225a777414cf8650062a18add9dc204">status_</a>;</div> |
| <div class="line"><a name="l00337"></a><span class="lineno"> 337</span> </div> |
| <div class="line"><a name="l00339"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#ae35acc9106a9bc881e8a1127cc57a198"> 339</a></span>  int64_t <a class="code" href="classimpala_1_1BufferedTupleStream.html#ae35acc9106a9bc881e8a1127cc57a198">num_rows_</a>;</div> |
| <div class="line"><a name="l00340"></a><span class="lineno"> 340</span> </div> |
| <div class="line"><a name="l00345"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a707b3fddb8c72b48232682dee77cb06c"> 345</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a707b3fddb8c72b48232682dee77cb06c">pinned_</a>;</div> |
| <div class="line"><a name="l00346"></a><span class="lineno"> 346</span> </div> |
| <div class="line"><a name="l00348"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a09839179a512779b0c1a584ba96be59f"> 348</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1BufferedTupleStream.html#a09839179a512779b0c1a584ba96be59f">pin_timer_</a>;</div> |
| <div class="line"><a name="l00349"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a758fc2bf68fb5a11145b606a93122820"> 349</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1BufferedTupleStream.html#a758fc2bf68fb5a11145b606a93122820">unpin_timer_</a>;</div> |
| <div class="line"><a name="l00350"></a><span class="lineno"><a class="line" href="classimpala_1_1BufferedTupleStream.html#a7265887dc92e2d30d36cd92de6dfcfe0"> 350</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* <a class="code" href="classimpala_1_1BufferedTupleStream.html#a7265887dc92e2d30d36cd92de6dfcfe0">get_new_block_timer_</a>;</div> |
| <div class="line"><a name="l00351"></a><span class="lineno"> 351</span> </div> |
| <div class="line"><a name="l00356"></a><span class="lineno"> 356</span>  <span class="keyword">template</span> <<span class="keywordtype">bool</span> HasNullableTuple></div> |
| <div class="line"><a name="l00357"></a><span class="lineno"> 357</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ae583fd3d7ac52ac0ff15acd10fe1101c">DeepCopyInternal</a>(<a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row, uint8_t** dst);</div> |
| <div class="line"><a name="l00358"></a><span class="lineno"> 358</span> </div> |
| <div class="line"><a name="l00360"></a><span class="lineno"> 360</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ab71350bb64c7d989df93ee539acba3f2">DeepCopy</a>(<a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row, uint8_t** dst);</div> |
| <div class="line"><a name="l00361"></a><span class="lineno"> 361</span> </div> |
| <div class="line"><a name="l00366"></a><span class="lineno"> 366</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#afe2947af8d8829e0aa56df12eb32da87">NewBlockForWrite</a>(<span class="keywordtype">int</span> min_size, <span class="keywordtype">bool</span>* got_block);</div> |
| <div class="line"><a name="l00367"></a><span class="lineno"> 367</span> </div> |
| <div class="line"><a name="l00370"></a><span class="lineno"> 370</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a4f0d29df7e0a357db35ad63230833d5d">NextBlockForRead</a>();</div> |
| <div class="line"><a name="l00371"></a><span class="lineno"> 371</span> </div> |
| <div class="line"><a name="l00373"></a><span class="lineno"> 373</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#ab2947eeec41d97443113b05585273683">ComputeRowSize</a>(<a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00374"></a><span class="lineno"> 374</span> </div> |
| <div class="line"><a name="l00376"></a><span class="lineno"> 376</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a5e3173eca7b0c50e2ef87c02947e69c8">UnpinBlock</a>(<a class="code" href="classimpala_1_1BufferedBlockMgr_1_1Block.html">BufferedBlockMgr::Block</a>* block);</div> |
| <div class="line"><a name="l00377"></a><span class="lineno"> 377</span> </div> |
| <div class="line"><a name="l00379"></a><span class="lineno"> 379</span>  <span class="keyword">template</span> <<span class="keywordtype">bool</span> HasNullableTuple></div> |
| <div class="line"><a name="l00380"></a><span class="lineno"> 380</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a266d30769c4ddb37c15112c6f0dc9168">GetNextInternal</a>(<a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch, <span class="keywordtype">bool</span>* eos, std::vector<RowIdx>* indices);</div> |
| <div class="line"><a name="l00381"></a><span class="lineno"> 381</span> </div> |
| <div class="line"><a name="l00383"></a><span class="lineno"> 383</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1BufferedTupleStream.html#a456ca7b067874e762d10212703de1498">ComputeNumNullIndicatorBytes</a>(<span class="keywordtype">int</span> block_size) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00384"></a><span class="lineno"> 384</span> };</div> |
| <div class="line"><a name="l00385"></a><span class="lineno"> 385</span> </div> |
| <div class="line"><a name="l00386"></a><span class="lineno"> 386</span> }</div> |
| <div class="line"><a name="l00387"></a><span class="lineno"> 387</span> </div> |
| <div class="line"><a name="l00388"></a><span class="lineno"> 388</span> <span class="preprocessor">#endif</span></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a54c7376a284c281622eb888ae277d558"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a54c7376a284c281622eb888ae277d558">impala::BufferedTupleStream::num_pinned_</a></div><div class="ttdeci">int num_pinned_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00330">buffered-tuple-stream.h:330</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html">impala::BufferedTupleStream</a></div><div class="ttdoc">The underlying memory management is done by the BufferedBlockMgr. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00109">buffered-tuple-stream.h:109</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_adb1ca6bf40ac1b240a0c50923e4d7f24"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#adb1ca6bf40ac1b240a0c50923e4d7f24">impala::BufferedTupleStream::read_ptr_</a></div><div class="ttdeci">uint8_t * read_ptr_</div><div class="ttdoc">Current ptr offset in read_block_'s buffer. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00307">buffered-tuple-stream.h:307</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_acfed70ae36697f861227e5f55c6a7d9a"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#acfed70ae36697f861227e5f55c6a7d9a">impala::BufferedTupleStream::null_indicators_read_block_</a></div><div class="ttdeci">uint32_t null_indicators_read_block_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00281">buffered-tuple-stream.h:281</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_ae4195c988c503e4de241e32036ca1b65"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ae4195c988c503e4de241e32036ca1b65">impala::BufferedTupleStream::RowIdx::OFFSET_SHIFT</a></div><div class="ttdeci">static const uint64_t OFFSET_SHIFT</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00125">buffered-tuple-stream.h:125</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ad905a907a64f8cd48cfebac638200c99"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ad905a907a64f8cd48cfebac638200c99">impala::BufferedTupleStream::total_byte_size_</a></div><div class="ttdeci">int64_t total_byte_size_</div><div class="ttdoc">Total size of blocks_, including small blocks. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00295">buffered-tuple-stream.h:295</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a35a832736a10de3486abe8661bfbe58d"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a35a832736a10de3486abe8661bfbe58d">impala::BufferedTupleStream::has_write_block</a></div><div class="ttdeci">bool has_write_block() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00247">buffered-tuple-stream.h:247</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a9cb6b2be78a2bff4d5dafd164c3dc0b7"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a9cb6b2be78a2bff4d5dafd164c3dc0b7">impala::BufferedTupleStream::Close</a></div><div class="ttdeci">void Close()</div><div class="ttdoc">Must be called once at the end to cleanup all resources. Idempotent. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00145">buffered-tuple-stream.cc:145</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a1b9da094a3d35db33e21cd581e4c762d"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a1b9da094a3d35db33e21cd581e4c762d">impala::BufferedTupleStream::block_start_idx_</a></div><div class="ttdeci">std::vector< uint8_t * > block_start_idx_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00304">buffered-tuple-stream.h:304</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a7f864ab630476a8d77b5a4b51a81604b"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a7f864ab630476a8d77b5a4b51a81604b">impala::BufferedTupleStream::read_block_</a></div><div class="ttdeci">std::list< BufferedBlockMgr::Block * >::iterator read_block_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00299">buffered-tuple-stream.h:299</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_afccb3ea6e79e38e8d4c16472248d6d18"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#afccb3ea6e79e38e8d4c16472248d6d18">impala::BufferedTupleStream::blocks_pinned</a></div><div class="ttdeci">int blocks_pinned() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00244">buffered-tuple-stream.h:244</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedBlockMgr_html"><div class="ttname"><a href="classimpala_1_1BufferedBlockMgr.html">impala::BufferedBlockMgr</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-block-mgr_8h_source.html#l00092">buffered-block-mgr.h:92</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a431215848544ca0af04357ff722c5f80"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a431215848544ca0af04357ff722c5f80">impala::BufferedTupleStream::RowIdx::DebugString</a></div><div class="ttdeci">std::string DebugString() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00037">buffered-tuple-stream.cc:37</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ac290526c52cbd7996e9bd435cfa38cce"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ac290526c52cbd7996e9bd435cfa38cce">impala::BufferedTupleStream::rows_returned</a></div><div class="ttdeci">int64_t rows_returned() const </div><div class="ttdoc">Number of rows returned via GetNext(). </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00234">buffered-tuple-stream.h:234</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a066d00bdf6f36be1f08bc8a6d64154ac"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a066d00bdf6f36be1f08bc8a6d64154ac">impala::BufferedTupleStream::PinStream</a></div><div class="ttdeci">Status PinStream(bool already_reserved, bool *pinned)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00357">buffered-tuple-stream.cc:357</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a266d30769c4ddb37c15112c6f0dc9168"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a266d30769c4ddb37c15112c6f0dc9168">impala::BufferedTupleStream::GetNextInternal</a></div><div class="ttdeci">Status GetNextInternal(RowBatch *batch, bool *eos, std::vector< RowIdx > *indices)</div><div class="ttdoc">Templated GetNext implementation. </div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a4fcb7ad8bfd26184ba80ff7ced27d5a5"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a4fcb7ad8bfd26184ba80ff7ced27d5a5">impala::BufferedTupleStream::RowIdx::BLOCK_SHIFT</a></div><div class="ttdeci">static const uint64_t BLOCK_SHIFT</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00123">buffered-tuple-stream.h:123</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a33740864c957e97c08eb42eee3015c68"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a33740864c957e97c08eb42eee3015c68">impala::BufferedTupleStream::RowIdx::offset</a></div><div class="ttdeci">uint64_t offset() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00133">buffered-tuple-stream.h:133</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a758fc2bf68fb5a11145b606a93122820"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a758fc2bf68fb5a11145b606a93122820">impala::BufferedTupleStream::unpin_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * unpin_timer_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00349">buffered-tuple-stream.h:349</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedBlockMgr_1_1Client_html"><div class="ttname"><a href="structimpala_1_1BufferedBlockMgr_1_1Client.html">impala::BufferedBlockMgr::Client</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-block-mgr_8cc_source.html#l00045">buffered-block-mgr.cc:45</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_abe18798dd236710e215baec9902023bb"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#abe18798dd236710e215baec9902023bb">impala::BufferedTupleStream::BufferedTupleStream</a></div><div class="ttdeci">BufferedTupleStream(RuntimeState *state, const RowDescriptor &row_desc, BufferedBlockMgr *block_mgr, BufferedBlockMgr::Client *client, bool use_initial_small_buffers=true, bool delete_on_read=false, bool read_write=false)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00043">buffered-tuple-stream.cc:43</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a3225a777414cf8650062a18add9dc204"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a3225a777414cf8650062a18add9dc204">impala::BufferedTupleStream::status_</a></div><div class="ttdeci">Status status_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00336">buffered-tuple-stream.h:336</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_1BufferedTupleStream_html_ab71350bb64c7d989df93ee539acba3f2"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ab71350bb64c7d989df93ee539acba3f2">impala::BufferedTupleStream::DeepCopy</a></div><div class="ttdeci">bool DeepCopy(TupleRow *row, uint8_t **dst)</div><div class="ttdoc">Wrapper of the templated DeepCopyInternal() function. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-ir_8cc_source.html#l00022">buffered-tuple-stream-ir.cc:22</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a2dcdf8dc3f624e131420e4f010d8fb83"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a2dcdf8dc3f624e131420e4f010d8fb83">impala::BufferedTupleStream::fixed_tuple_row_size_</a></div><div class="ttdeci">int fixed_tuple_row_size_</div><div class="ttdoc">Sum of the fixed length portion of all the tuples in desc_. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00274">buffered-tuple-stream.h:274</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a3464e57c0b69fda3fc0f3727358af5d3"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3464e57c0b69fda3fc0f3727358af5d3">impala::BufferedTupleStream::RowIdx::set</a></div><div class="ttdeci">uint64_t set(uint64_t block, uint64_t offset, uint64_t idx)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00141">buffered-tuple-stream.h:141</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a2a42e34f0b5faaa053704b93287f1df7"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a2a42e34f0b5faaa053704b93287f1df7">impala::BufferedTupleStream::closed_</a></div><div class="ttdeci">bool closed_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00335">buffered-tuple-stream.h:335</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a4f0d29df7e0a357db35ad63230833d5d"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a4f0d29df7e0a357db35ad63230833d5d">impala::BufferedTupleStream::NextBlockForRead</a></div><div class="ttdeci">Status NextBlockForRead()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00248">buffered-tuple-stream.cc:248</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a08beb5c3c7bded04f1de51c3da10c89a"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a08beb5c3c7bded04f1de51c3da10c89a">impala::BufferedTupleStream::string_slots_</a></div><div class="ttdeci">std::vector< std::pair< int, std::vector< SlotDescriptor * > > > string_slots_</div><div class="ttdoc">Vector of all the strings slots grouped by tuple_idx. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00285">buffered-tuple-stream.h:285</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_aadb29f0e9d4e4693e1716158eee829ec"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#aadb29f0e9d4e4693e1716158eee829ec">impala::BufferedTupleStream::desc_</a></div><div class="ttdeci">const RowDescriptor & desc_</div><div class="ttdoc">Description of rows stored in the stream. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00268">buffered-tuple-stream.h:268</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a0c6479bc0cba32fa1f053c29200c473b"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a0c6479bc0cba32fa1f053c29200c473b">impala::BufferedTupleStream::use_small_buffers_</a></div><div class="ttdeci">bool use_small_buffers_</div><div class="ttdoc">If true, this stream is still using small buffers. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00254">buffered-tuple-stream.h:254</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_adbe5ffb56ce04fb412628dfa8fa3ff84"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#adbe5ffb56ce04fb412628dfa8fa3ff84">impala::BufferedTupleStream::read_write_</a></div><div class="ttdeci">const bool read_write_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00262">buffered-tuple-stream.h:262</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="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="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_aa78a147b1cd7d4364fcbebcc261cae84"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aa78a147b1cd7d4364fcbebcc261cae84">impala::BufferedTupleStream::RowIdx::BLOCK_MASK</a></div><div class="ttdeci">static const uint64_t BLOCK_MASK</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00122">buffered-tuple-stream.h:122</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a6846f309cc28f0d6b6d6caebd033cdec"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a6846f309cc28f0d6b6d6caebd033cdec">impala::BufferedTupleStream::byte_size</a></div><div class="ttdeci">int64_t byte_size() const </div><div class="ttdoc">Returns the byte size necessary to store the entire stream in memory. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00237">buffered-tuple-stream.h:237</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedBlockMgr_1_1Block_html"><div class="ttname"><a href="classimpala_1_1BufferedBlockMgr_1_1Block.html">impala::BufferedBlockMgr::Block</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-block-mgr_8h_source.html#l00136">buffered-block-mgr.h:136</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a5a31e51ff14da66121477a191964703a"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a5a31e51ff14da66121477a191964703a">impala::BufferedTupleStream::RowIdx::IDX_MASK</a></div><div class="ttdeci">static const uint64_t IDX_MASK</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00126">buffered-tuple-stream.h:126</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a0ec2ebd3590dcfdcfadd34d534a0261e"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a0ec2ebd3590dcfdcfadd34d534a0261e">impala::BufferedTupleStream::RowIdx::IDX_SHIFT</a></div><div class="ttdeci">static const uint64_t IDX_SHIFT</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00127">buffered-tuple-stream.h:127</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a79f040358dacbbab993af134f709ca0a"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a79f040358dacbbab993af134f709ca0a">impala::BufferedTupleStream::read_block_idx_</a></div><div class="ttdeci">int read_block_idx_</div><div class="ttdoc">The block index of the current read block. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00322">buffered-tuple-stream.h:322</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_1BufferedTupleStream_html_ad2aeaf7b3790a34697dd682544ae9af7"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ad2aeaf7b3790a34697dd682544ae9af7">impala::BufferedTupleStream::blocks_unpinned</a></div><div class="ttdeci">int blocks_unpinned() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00245">buffered-tuple-stream.h:245</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ae583fd3d7ac52ac0ff15acd10fe1101c"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ae583fd3d7ac52ac0ff15acd10fe1101c">impala::BufferedTupleStream::DeepCopyInternal</a></div><div class="ttdeci">bool DeepCopyInternal(TupleRow *row, uint8_t **dst)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-ir_8cc_source.html#l00032">buffered-tuple-stream-ir.cc:32</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a85fea074aae6b4f949280df51ccb233c"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a85fea074aae6b4f949280df51ccb233c">impala::BufferedTupleStream::write_tuple_idx_</a></div><div class="ttdeci">uint32_t write_tuple_idx_</div><div class="ttdoc">Current idx of the tuple written at the write_block_ buffer. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00313">buffered-tuple-stream.h:313</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a456ca7b067874e762d10212703de1498"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a456ca7b067874e762d10212703de1498">impala::BufferedTupleStream::ComputeNumNullIndicatorBytes</a></div><div class="ttdeci">int ComputeNumNullIndicatorBytes(int block_size) const </div><div class="ttdoc">Computes the number of bytes needed for null indicators for a block of 'block_size'. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00415">buffered-tuple-stream.cc:415</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ada77a4e348b105775fd52e8e39743998"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ada77a4e348b105775fd52e8e39743998">impala::BufferedTupleStream::block_mgr_client_</a></div><div class="ttdeci">BufferedBlockMgr::Client * block_mgr_client_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00289">buffered-tuple-stream.h:289</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a68aaaeaae3c217e698ce2ca6097d0e43"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a68aaaeaae3c217e698ce2ca6097d0e43">impala::BufferedTupleStream::read_tuple_idx_</a></div><div class="ttdeci">uint32_t read_tuple_idx_</div><div class="ttdoc">Current idx of the tuple read from the read_block_ buffer. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00310">buffered-tuple-stream.h:310</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_1BufferedTupleStream_1_1RowIdx_html_a3cb5b0f579f7dc19c7076e34c97b0b9b"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a3cb5b0f579f7dc19c7076e34c97b0b9b">impala::BufferedTupleStream::RowIdx::OFFSET_MASK</a></div><div class="ttdeci">static const uint64_t OFFSET_MASK</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00124">buffered-tuple-stream.h:124</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_abb1902c704be038600e5c5a4209396e8"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#abb1902c704be038600e5c5a4209396e8">impala::BufferedTupleStream::has_read_block</a></div><div class="ttdeci">bool has_read_block() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00246">buffered-tuple-stream.h:246</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a2882935e6094afad5fc930f2a757e547"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a2882935e6094afad5fc930f2a757e547">impala::BufferedTupleStream::delete_on_read_</a></div><div class="ttdeci">const bool delete_on_read_</div><div class="ttdoc">If true, blocks are deleted after they are read. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00257">buffered-tuple-stream.h:257</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a862e2da773f1d3ba0114df6a6fbc7e0a"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a862e2da773f1d3ba0114df6a6fbc7e0a">impala::BufferedTupleStream::nullable_tuple_</a></div><div class="ttdeci">const bool nullable_tuple_</div><div class="ttdoc">Whether any tuple in the rows is nullable. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00271">buffered-tuple-stream.h:271</a></div></div> |
| <div class="ttc" id="classuint64__t_html"><div class="ttname"><a href="classuint64__t.html">uint64_t</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a1253dcec8226c94833f74bc80a2b90b3"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a1253dcec8226c94833f74bc80a2b90b3">impala::BufferedTupleStream::write_block_</a></div><div class="ttdeci">BufferedBlockMgr::Block * write_block_</div><div class="ttdoc">The current block for writing. NULL if there is no available block to write to. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00325">buffered-tuple-stream.h:325</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ad9fe5f5d1dfbf451a340c46a163dd9df"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ad9fe5f5d1dfbf451a340c46a163dd9df">impala::BufferedTupleStream::using_small_buffers</a></div><div class="ttdeci">bool using_small_buffers() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00248">buffered-tuple-stream.h:248</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_1BufferedTupleStream_html_acff79f0ded3d6752e2d28c9399c6d0b1"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#acff79f0ded3d6752e2d28c9399c6d0b1">impala::BufferedTupleStream::GetRows</a></div><div class="ttdeci">Status GetRows(boost::scoped_ptr< RowBatch > *batch, bool *got_rows)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00431">buffered-tuple-stream.cc:431</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_1BufferedTupleStream_html_a707b3fddb8c72b48232682dee77cb06c"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a707b3fddb8c72b48232682dee77cb06c">impala::BufferedTupleStream::pinned_</a></div><div class="ttdeci">bool pinned_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00345">buffered-tuple-stream.h:345</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a5e3173eca7b0c50e2ef87c02947e69c8"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a5e3173eca7b0c50e2ef87c02947e69c8">impala::BufferedTupleStream::UnpinBlock</a></div><div class="ttdeci">Status UnpinBlock(BufferedBlockMgr::Block *block)</div><div class="ttdoc">Unpins block if it is an io sized block and updates tracking stats. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00168">buffered-tuple-stream.cc:168</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_1BufferedTupleStream_html_a691dc8b7d5efbb60c41e7301dc5a63b6"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a691dc8b7d5efbb60c41e7301dc5a63b6">impala::BufferedTupleStream::block_mgr_</a></div><div class="ttdeci">BufferedBlockMgr * block_mgr_</div><div class="ttdoc">Block manager and client used to allocate, pin and release blocks. Not owned. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00288">buffered-tuple-stream.h:288</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_1BufferedTupleStream_html_a09839179a512779b0c1a584ba96be59f"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a09839179a512779b0c1a584ba96be59f">impala::BufferedTupleStream::pin_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * pin_timer_</div><div class="ttdoc">Counters added by this object to the parent runtime profile. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00348">buffered-tuple-stream.h:348</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ab0313f195d91db86e2d86eeeda553e7a"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ab0313f195d91db86e2d86eeeda553e7a">impala::BufferedTupleStream::null_indicators_write_block_</a></div><div class="ttdeci">uint32_t null_indicators_write_block_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00282">buffered-tuple-stream.h:282</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a3688c23c42e5d8d9f779a3b1a3e74a94"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a3688c23c42e5d8d9f779a3b1a3e74a94">impala::BufferedTupleStream::state_</a></div><div class="ttdeci">RuntimeState *const state_</div><div class="ttdoc">Runtime state instance used to check for cancellation. Not owned. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00265">buffered-tuple-stream.h:265</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ae4e2e76ff44f09a358c6c36827da9f50"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ae4e2e76ff44f09a358c6c36827da9f50">impala::BufferedTupleStream::Init</a></div><div class="ttdeci">Status Init(RuntimeProfile *profile=NULL, bool pinned=true)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00116">buffered-tuple-stream.cc:116</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a1df0eb41c554ed098af8d81637b4f615"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a1df0eb41c554ed098af8d81637b4f615">impala::BufferedTupleStream::status</a></div><div class="ttdeci">Status status() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00228">buffered-tuple-stream.h:228</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_aa9ec745ca549f76bce14872acfbd58c3"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#aa9ec745ca549f76bce14872acfbd58c3">impala::BufferedTupleStream::AddRow</a></div><div class="ttdeci">bool AddRow(TupleRow *row, uint8_t **dst=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8inline_8h_source.html#l00025">buffered-tuple-stream.inline.h:25</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_abf2195dea963d8d7bea71dda65db61da"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#abf2195dea963d8d7bea71dda65db61da">impala::BufferedTupleStream::AllocateRow</a></div><div class="ttdeci">uint8_t * AllocateRow(int size)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8inline_8h_source.html#l00034">buffered-tuple-stream.inline.h:34</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a4121e3bb85a9a0c2612930a7aed61807"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a4121e3bb85a9a0c2612930a7aed61807">impala::BufferedTupleStream::DebugString</a></div><div class="ttdeci">std::string DebugString() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00093">buffered-tuple-stream.cc:93</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a4f537ea0c46ce3dfc77a5b3bf58a07af"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a4f537ea0c46ce3dfc77a5b3bf58a07af">impala::BufferedTupleStream::PrepareForRead</a></div><div class="ttdeci">Status PrepareForRead(bool *got_buffer=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00314">buffered-tuple-stream.cc:314</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a3b47a81d368ad14edaf0256f2779189a"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a3b47a81d368ad14edaf0256f2779189a">impala::BufferedTupleStream::is_pinned</a></div><div class="ttdeci">bool is_pinned() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00243">buffered-tuple-stream.h:243</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_aff0617d1de9e9b0bc735ba970f8c7f42"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#aff0617d1de9e9b0bc735ba970f8c7f42">impala::BufferedTupleStream::RowIdx::data</a></div><div class="ttdeci">uint64_t data</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00154">buffered-tuple-stream.h:154</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_aa2229061216f10cfa13936bb38d88cd0"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#aa2229061216f10cfa13936bb38d88cd0">impala::BufferedTupleStream::read_bytes_</a></div><div class="ttdeci">int64_t read_bytes_</div><div class="ttdoc">Bytes read in read_block_. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00316">buffered-tuple-stream.h:316</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_acee73ea9a28e990c2dd08d7720ebb209"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#acee73ea9a28e990c2dd08d7720ebb209">impala::BufferedTupleStream::blocks_</a></div><div class="ttdeci">std::list< BufferedBlockMgr::Block * > blocks_</div><div class="ttdoc">List of blocks in the stream. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00292">buffered-tuple-stream.h:292</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_af5796ba9a36c8485227b810b343aec47"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#af5796ba9a36c8485227b810b343aec47">impala::BufferedTupleStream::num_rows</a></div><div class="ttdeci">int64_t num_rows() const </div><div class="ttdoc">Number of rows in the stream. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00231">buffered-tuple-stream.h:231</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_afe2947af8d8829e0aa56df12eb32da87"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#afe2947af8d8829e0aa56df12eb32da87">impala::BufferedTupleStream::NewBlockForWrite</a></div><div class="ttdeci">Status NewBlockForWrite(int min_size, bool *got_block)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00178">buffered-tuple-stream.cc:178</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a7265887dc92e2d30d36cd92de6dfcfe0"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a7265887dc92e2d30d36cd92de6dfcfe0">impala::BufferedTupleStream::get_new_block_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * get_new_block_timer_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00350">buffered-tuple-stream.h:350</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a9d2f211df83a684b2a644d2b8a179026"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a9d2f211df83a684b2a644d2b8a179026">impala::BufferedTupleStream::UnpinStream</a></div><div class="ttdeci">Status UnpinStream(bool all=false)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00396">buffered-tuple-stream.cc:396</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a21cc752d4db27e53c163e155f5da61e9"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a21cc752d4db27e53c163e155f5da61e9">impala::BufferedTupleStream::SwitchToIoBuffers</a></div><div class="ttdeci">Status SwitchToIoBuffers(bool *got_buffer)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00136">buffered-tuple-stream.cc:136</a></div></div> |
| <div class="ttc" id="buffered-block-mgr_8h_html"><div class="ttname"><a href="buffered-block-mgr_8h.html">buffered-block-mgr.h</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="structimpala_1_1BufferedTupleStream_1_1RowIdx_html"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html">impala::BufferedTupleStream::RowIdx</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00121">buffered-tuple-stream.h:121</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_ad17c1138f8d4468aa082f6363b892788"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#ad17c1138f8d4468aa082f6363b892788">impala::BufferedTupleStream::RowIdx::idx</a></div><div class="ttdeci">uint64_t idx() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00137">buffered-tuple-stream.h:137</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a115418648d4c9755e7dbd0cfa2c0b9f0"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a115418648d4c9755e7dbd0cfa2c0b9f0">impala::BufferedTupleStream::num_small_blocks_</a></div><div class="ttdeci">int num_small_blocks_</div><div class="ttdoc">The total number of small blocks in blocks_;. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00333">buffered-tuple-stream.h:333</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ae35acc9106a9bc881e8a1127cc57a198"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ae35acc9106a9bc881e8a1127cc57a198">impala::BufferedTupleStream::num_rows_</a></div><div class="ttdeci">int64_t num_rows_</div><div class="ttdoc">Number of rows stored in the stream. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00339">buffered-tuple-stream.h:339</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a5277d4ff9fdeb7b31bdf4d520739582d"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a5277d4ff9fdeb7b31bdf4d520739582d">impala::BufferedTupleStream::GetNext</a></div><div class="ttdeci">Status GetNext(RowBatch *batch, bool *eos, std::vector< RowIdx > *indices=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00447">buffered-tuple-stream.cc:447</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ab2947eeec41d97443113b05585273683"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ab2947eeec41d97443113b05585273683">impala::BufferedTupleStream::ComputeRowSize</a></div><div class="ttdeci">int ComputeRowSize(TupleRow *row) const </div><div class="ttdoc">Returns the byte size of this row when encoded in a block. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00595">buffered-tuple-stream.cc:595</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ab6fc6d8b3e3aa42fcaba7f3821ed2c33"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ab6fc6d8b3e3aa42fcaba7f3821ed2c33">impala::BufferedTupleStream::rows_returned_</a></div><div class="ttdeci">int64_t rows_returned_</div><div class="ttdoc">Number of rows returned to the caller from GetNext(). </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00319">buffered-tuple-stream.h:319</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_ac034f1be3983f354b5b7170e4e5afd62"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#ac034f1be3983f354b5b7170e4e5afd62">impala::BufferedTupleStream::bytes_in_mem</a></div><div class="ttdeci">int64_t bytes_in_mem(bool ignore_current) const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00156">buffered-tuple-stream.cc:156</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedTupleStream_1_1RowIdx_html_a2096ee0339acea32229f87193c97524c"><div class="ttname"><a href="structimpala_1_1BufferedTupleStream_1_1RowIdx.html#a2096ee0339acea32229f87193c97524c">impala::BufferedTupleStream::RowIdx::block</a></div><div class="ttdeci">uint64_t block() const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00129">buffered-tuple-stream.h:129</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a87909f60c4efe1aae47471ce668136ec"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a87909f60c4efe1aae47471ce668136ec">impala::BufferedTupleStream::GetTupleRow</a></div><div class="ttdeci">void GetTupleRow(const RowIdx &idx, TupleRow *row) const </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8inline_8h_source.html#l00049">buffered-tuple-stream.inline.h:49</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="buffered-tuple-stream_8h.html">buffered-tuple-stream.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> |
