| <!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/disk-io-mgr.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('disk-io-mgr_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">disk-io-mgr.h</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="disk-io-mgr_8h.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">// Copyright 2012 Cloudera Inc.</span></div> |
| <div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// Licensed under the Apache License, Version 2.0 (the "License");</span></div> |
| <div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">// you may not use this file except in compliance with the License.</span></div> |
| <div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// You may obtain a copy of the License at</span></div> |
| <div class="line"><a name="l00006"></a><span class="lineno"> 6</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div> |
| <div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// Unless required by applicable law or agreed to in writing, software</span></div> |
| <div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">// distributed under the License is distributed on an "AS IS" BASIS,</span></div> |
| <div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span></div> |
| <div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// See the License for the specific language governing permissions and</span></div> |
| <div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// limitations under the License.</span></div> |
| <div class="line"><a name="l00014"></a><span class="lineno"> 14</span> </div> |
| <div class="line"><a name="l00015"></a><span class="lineno"> 15</span> </div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="preprocessor">#ifndef IMPALA_RUNTIME_DISK_IO_MGR_H</span></div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="preprocessor"></span><span class="preprocessor">#define IMPALA_RUNTIME_DISK_IO_MGR_H</span></div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> <span class="preprocessor"></span></div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#include <list></span></div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> <span class="preprocessor">#include <vector></span></div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include <boost/scoped_ptr.hpp></span></div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <boost/unordered_set.hpp></span></div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> <span class="preprocessor">#include <boost/thread/mutex.hpp></span></div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include <boost/thread/condition_variable.hpp></span></div> |
| <div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include <boost/thread/thread.hpp></span></div> |
| <div class="line"><a name="l00026"></a><span class="lineno"> 26</span> </div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include "<a class="code" href="atomic_8h.html">common/atomic.h</a>"</span></div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="preprocessor">#include "<a class="code" href="hdfs_8h.html">common/hdfs.h</a>"</span></div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "<a class="code" href="object-pool_8h.html">common/object-pool.h</a>"</span></div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="status_8h.html">common/status.h</a>"</span></div> |
| <div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include "<a class="code" href="thread-resource-mgr_8h.html">runtime/thread-resource-mgr.h</a>"</span></div> |
| <div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "<a class="code" href="bit-util_8h.html">util/bit-util.h</a>"</span></div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> <span class="preprocessor">#include "<a class="code" href="error-util_8h.html">util/error-util.h</a>"</span></div> |
| <div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="preprocessor">#include "<a class="code" href="internal-queue_8h.html">util/internal-queue.h</a>"</span></div> |
| <div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="preprocessor">#include "<a class="code" href="runtime-profile_8h.html">util/runtime-profile.h</a>"</span></div> |
| <div class="line"><a name="l00036"></a><span class="lineno"> 36</span> <span class="preprocessor">#include "<a class="code" href="thread_8h.html">util/thread.h</a>"</span></div> |
| <div class="line"><a name="l00037"></a><span class="lineno"> 37</span> </div> |
| <div class="line"><a name="l00038"></a><span class="lineno"> 38</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00039"></a><span class="lineno"> 39</span> </div> |
| <div class="line"><a name="l00040"></a><span class="lineno"> 40</span> <span class="keyword">class </span>MemTracker;</div> |
| <div class="line"><a name="l00041"></a><span class="lineno"> 41</span> </div> |
| <div class="line"><a name="l00045"></a><span class="lineno"> 45</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00050"></a><span class="lineno"> 50</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00053"></a><span class="lineno"> 53</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00067"></a><span class="lineno"> 67</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00074"></a><span class="lineno"> 74</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00082"></a><span class="lineno"> 82</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00088"></a><span class="lineno"> 88</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00099"></a><span class="lineno"> 99</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00111"></a><span class="lineno"> 111</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00125"></a><span class="lineno"> 125</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00131"></a><span class="lineno"> 131</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00136"></a><span class="lineno"> 136</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00143"></a><span class="lineno"> 143</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00164"></a><span class="lineno"> 164</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00173"></a><span class="lineno"> 173</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00179"></a><span class="lineno"> 179</span> <span class="comment"></span><span class="comment">//</span></div> |
| <div class="line"><a name="l00188"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html"> 188</a></span> <span class="comment"></span><span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a> {</div> |
| <div class="line"><a name="l00189"></a><span class="lineno"> 189</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00190"></a><span class="lineno"> 190</span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>;</div> |
| <div class="line"><a name="l00191"></a><span class="lineno"> 191</span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>;</div> |
| <div class="line"><a name="l00192"></a><span class="lineno"> 192</span> </div> |
| <div class="line"><a name="l00196"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html"> 196</a></span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a> {</div> |
| <div class="line"><a name="l00197"></a><span class="lineno"> 197</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00198"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a9e7c7ff7fe7fa57e95d006fa9d494b8c"> 198</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a9e7c7ff7fe7fa57e95d006fa9d494b8c">scan_range</a>() { <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a583a2843998adf92297ec9cf8eccbad8">scan_range_</a>; }</div> |
| <div class="line"><a name="l00199"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad40bb3de87b9def5b78f59d3bf38c324"> 199</a></span>  <span class="keywordtype">char</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad40bb3de87b9def5b78f59d3bf38c324">buffer</a>() { <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af803c7fd834cbe217f344bab0edeb1d2">buffer_</a>; }</div> |
| <div class="line"><a name="l00200"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#aae839241cba91ebc6774fc4e2bc384e0"> 200</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#aae839241cba91ebc6774fc4e2bc384e0">buffer_len</a>() { <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a42195373c5e36118e61c50cb128d5744">buffer_len_</a>; }</div> |
| <div class="line"><a name="l00201"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af08c55c6b3ab4aa6f4d062637fd118bb"> 201</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af08c55c6b3ab4aa6f4d062637fd118bb">len</a>() { <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a33247232dd2e5de8196df1179dc29281">len_</a>; }</div> |
| <div class="line"><a name="l00202"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad2a01828c28b87d5f471814ce970c63b"> 202</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad2a01828c28b87d5f471814ce970c63b">eosr</a>() { <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5c61395734db9bf96ee0f7899bec860e">eosr_</a>; }</div> |
| <div class="line"><a name="l00203"></a><span class="lineno"> 203</span> </div> |
| <div class="line"><a name="l00205"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a0a72cf459f78ac1d9c1d81ac2fad0c43"> 205</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a0a72cf459f78ac1d9c1d81ac2fad0c43">scan_range_offset</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a38f1ff36cae54028dc9fb426c49d3283">scan_range_offset_</a>; }</div> |
| <div class="line"><a name="l00206"></a><span class="lineno"> 206</span> </div> |
| <div class="line"><a name="l00209"></a><span class="lineno"> 209</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a434c70e0f6a34982c92eb1deaae3bc2c">SetMemTracker</a>(<a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a>* <a class="code" href="expr-benchmark_8cc.html#ad327327fa716227ff7993880cbc4698f">tracker</a>);</div> |
| <div class="line"><a name="l00210"></a><span class="lineno"> 210</span> </div> |
| <div class="line"><a name="l00213"></a><span class="lineno"> 213</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a258f4e13d2729f1a5fa395376db97cfe">Return</a>();</div> |
| <div class="line"><a name="l00214"></a><span class="lineno"> 214</span> </div> |
| <div class="line"><a name="l00215"></a><span class="lineno"> 215</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00216"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a544ca3cf0abcbff53ea299d0d2da3877"> 216</a></span>  <span class="keyword">friend</span> <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>;</div> |
| <div class="line"><a name="l00217"></a><span class="lineno"> 217</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a8f44409df7a76852f884b5775d28ae2a">BufferDescriptor</a>(<a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>* io_mgr);</div> |
| <div class="line"><a name="l00218"></a><span class="lineno"> 218</span> </div> |
| <div class="line"><a name="l00220"></a><span class="lineno"> 220</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5ac49168b2299c1cb18a58f3d777934d">Reset</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader, <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* range, <span class="keywordtype">char</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad40bb3de87b9def5b78f59d3bf38c324">buffer</a>,</div> |
| <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#aae839241cba91ebc6774fc4e2bc384e0">buffer_len</a>);</div> |
| <div class="line"><a name="l00222"></a><span class="lineno"> 222</span> </div> |
| <div class="line"><a name="l00223"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5cf1068ba03b8c7fca3b4bd4128df54a"> 223</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5cf1068ba03b8c7fca3b4bd4128df54a">io_mgr_</a>;</div> |
| <div class="line"><a name="l00224"></a><span class="lineno"> 224</span> </div> |
| <div class="line"><a name="l00226"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a1f395d25efb9b131b51dba0a540e56b6"> 226</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a1f395d25efb9b131b51dba0a540e56b6">reader_</a>;</div> |
| <div class="line"><a name="l00227"></a><span class="lineno"> 227</span> </div> |
| <div class="line"><a name="l00229"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a997b0e92c73aebaaa7fb71e9615b135a"> 229</a></span>  <a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a997b0e92c73aebaaa7fb71e9615b135a">mem_tracker_</a>;</div> |
| <div class="line"><a name="l00230"></a><span class="lineno"> 230</span> </div> |
| <div class="line"><a name="l00232"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a583a2843998adf92297ec9cf8eccbad8"> 232</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a583a2843998adf92297ec9cf8eccbad8">scan_range_</a>;</div> |
| <div class="line"><a name="l00233"></a><span class="lineno"> 233</span> </div> |
| <div class="line"><a name="l00235"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af803c7fd834cbe217f344bab0edeb1d2"> 235</a></span>  <span class="keywordtype">char</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af803c7fd834cbe217f344bab0edeb1d2">buffer_</a>;</div> |
| <div class="line"><a name="l00236"></a><span class="lineno"> 236</span> </div> |
| <div class="line"><a name="l00238"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a42195373c5e36118e61c50cb128d5744"> 238</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a42195373c5e36118e61c50cb128d5744">buffer_len_</a>;</div> |
| <div class="line"><a name="l00239"></a><span class="lineno"> 239</span> </div> |
| <div class="line"><a name="l00241"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a33247232dd2e5de8196df1179dc29281"> 241</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a33247232dd2e5de8196df1179dc29281">len_</a>;</div> |
| <div class="line"><a name="l00242"></a><span class="lineno"> 242</span> </div> |
| <div class="line"><a name="l00244"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5c61395734db9bf96ee0f7899bec860e"> 244</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5c61395734db9bf96ee0f7899bec860e">eosr_</a>;</div> |
| <div class="line"><a name="l00245"></a><span class="lineno"> 245</span> </div> |
| <div class="line"><a name="l00247"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a64ab1a4cf150fdc1fe0b9881eb1b35c9"> 247</a></span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a64ab1a4cf150fdc1fe0b9881eb1b35c9">status_</a>;</div> |
| <div class="line"><a name="l00248"></a><span class="lineno"> 248</span> </div> |
| <div class="line"><a name="l00249"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a38f1ff36cae54028dc9fb426c49d3283"> 249</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a38f1ff36cae54028dc9fb426c49d3283">scan_range_offset_</a>;</div> |
| <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  };</div> |
| <div class="line"><a name="l00251"></a><span class="lineno"> 251</span> </div> |
| <div class="line"><a name="l00253"></a><span class="lineno"><a class="line" href="structimpala_1_1DiskIoMgr_1_1RequestType.html"> 253</a></span>  <span class="keyword">struct </span><a class="code" href="structimpala_1_1DiskIoMgr_1_1RequestType.html">RequestType</a> {</div> |
| <div class="line"><a name="l00254"></a><span class="lineno"><a class="line" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153"> 254</a></span>  <span class="keyword">enum</span> <a class="code" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153">type</a> {</div> |
| <div class="line"><a name="l00255"></a><span class="lineno"><a class="line" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153ad437bd8b09af2a55106ba81f5887e358"> 255</a></span>  <a class="code" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153ad437bd8b09af2a55106ba81f5887e358">READ</a>,</div> |
| <div class="line"><a name="l00256"></a><span class="lineno"><a class="line" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153a9f43978eee51c41a2b5eea4c302f54eb"> 256</a></span>  <a class="code" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153a9f43978eee51c41a2b5eea4c302f54eb">WRITE</a>,</div> |
| <div class="line"><a name="l00257"></a><span class="lineno"> 257</span>  };</div> |
| <div class="line"><a name="l00258"></a><span class="lineno"> 258</span>  };</div> |
| <div class="line"><a name="l00259"></a><span class="lineno"> 259</span> </div> |
| <div class="line"><a name="l00263"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html"> 263</a></span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html">RequestRange</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1InternalQueue.html">InternalQueue</a><RequestRange>::Node {</div> |
| <div class="line"><a name="l00264"></a><span class="lineno"> 264</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00265"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#ac324726e966f9430196abcdbabd4e907"> 265</a></span>  hdfsFS <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#ac324726e966f9430196abcdbabd4e907">fs</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#adb8c41a4455d2428ae01510d0640d6ff">fs_</a>; }</div> |
| <div class="line"><a name="l00266"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a015237297a1c06eca646fe3370f0e8b9"> 266</a></span>  <span class="keyword">const</span> <span class="keywordtype">char</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a015237297a1c06eca646fe3370f0e8b9">file</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a261c8db8366b023bd76e15c1549e74d0">file_</a>.c_str(); }</div> |
| <div class="line"><a name="l00267"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#aae6c216cb57b76594b0a107555a11ceb"> 267</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#aae6c216cb57b76594b0a107555a11ceb">offset</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a322bf955c04727d26253584f05f7c27f">offset_</a>; }</div> |
| <div class="line"><a name="l00268"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a54e2b168c3a64a9250cac5069f85435d"> 268</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a54e2b168c3a64a9250cac5069f85435d">len</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9e03101c90a31cb522e9f44b008ce9f2">len_</a>; }</div> |
| <div class="line"><a name="l00269"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a5b5c378a1ec75719e7ead0fdd6fb2137"> 269</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a5b5c378a1ec75719e7ead0fdd6fb2137">disk_id</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9c4ffc24f68349da818a4c0519c0e792">disk_id_</a>; }</div> |
| <div class="line"><a name="l00270"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a810f24a718847f2baa96100914e0ae51"> 270</a></span>  <a class="code" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153">RequestType::type</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a810f24a718847f2baa96100914e0ae51">request_type</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a0b8ff464b55bf723767102e4e0bd2c64">request_type_</a>; }</div> |
| <div class="line"><a name="l00271"></a><span class="lineno"> 271</span> </div> |
| <div class="line"><a name="l00272"></a><span class="lineno"> 272</span>  <span class="keyword">protected</span>:</div> |
| <div class="line"><a name="l00274"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#adb8c41a4455d2428ae01510d0640d6ff"> 274</a></span>  hdfsFS <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#adb8c41a4455d2428ae01510d0640d6ff">fs_</a>;</div> |
| <div class="line"><a name="l00275"></a><span class="lineno"> 275</span> </div> |
| <div class="line"><a name="l00277"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a261c8db8366b023bd76e15c1549e74d0"> 277</a></span>  std::string <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a261c8db8366b023bd76e15c1549e74d0">file_</a>;</div> |
| <div class="line"><a name="l00278"></a><span class="lineno"> 278</span> </div> |
| <div class="line"><a name="l00280"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a322bf955c04727d26253584f05f7c27f"> 280</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a322bf955c04727d26253584f05f7c27f">offset_</a>;</div> |
| <div class="line"><a name="l00281"></a><span class="lineno"> 281</span> </div> |
| <div class="line"><a name="l00283"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9e03101c90a31cb522e9f44b008ce9f2"> 283</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9e03101c90a31cb522e9f44b008ce9f2">len_</a>;</div> |
| <div class="line"><a name="l00284"></a><span class="lineno"> 284</span> </div> |
| <div class="line"><a name="l00286"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9c4ffc24f68349da818a4c0519c0e792"> 286</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9c4ffc24f68349da818a4c0519c0e792">disk_id_</a>;</div> |
| <div class="line"><a name="l00287"></a><span class="lineno"> 287</span> </div> |
| <div class="line"><a name="l00289"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a0b8ff464b55bf723767102e4e0bd2c64"> 289</a></span>  <a class="code" href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153">RequestType::type</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a0b8ff464b55bf723767102e4e0bd2c64">request_type_</a>;</div> |
| <div class="line"><a name="l00290"></a><span class="lineno"> 290</span>  };</div> |
| <div class="line"><a name="l00291"></a><span class="lineno"> 291</span> </div> |
| <div class="line"><a name="l00295"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html"> 295</a></span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html">RequestRange</a> {</div> |
| <div class="line"><a name="l00296"></a><span class="lineno"> 296</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00297"></a><span class="lineno"> 297</span> </div> |
| <div class="line"><a name="l00299"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a57983bd0c63fe17cfc4baec245168991"> 299</a></span>  <span class="keyword">const</span> <span class="keyword">static</span> int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a57983bd0c63fe17cfc4baec245168991">NEVER_CACHE</a> = -1;</div> |
| <div class="line"><a name="l00300"></a><span class="lineno"> 300</span> </div> |
| <div class="line"><a name="l00302"></a><span class="lineno"> 302</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa271d83685f923144a12fda4f79e8c7b">ScanRange</a>(<span class="keywordtype">int</span> initial_capacity = -1);</div> |
| <div class="line"><a name="l00303"></a><span class="lineno"> 303</span> </div> |
| <div class="line"><a name="l00304"></a><span class="lineno"> 304</span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a4e9d47a259b26f20c26a425b449c02db">~ScanRange</a>();</div> |
| <div class="line"><a name="l00305"></a><span class="lineno"> 305</span> </div> |
| <div class="line"><a name="l00309"></a><span class="lineno"> 309</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2cf57a30a890667743a870faa5f630a1">Reset</a>(hdfsFS <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#ac324726e966f9430196abcdbabd4e907">fs</a>, <span class="keyword">const</span> <span class="keywordtype">char</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a015237297a1c06eca646fe3370f0e8b9">file</a>, int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a54e2b168c3a64a9250cac5069f85435d">len</a>, int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#aae6c216cb57b76594b0a107555a11ceb">offset</a>, <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a5b5c378a1ec75719e7ead0fdd6fb2137">disk_id</a>,</div> |
| <div class="line"><a name="l00310"></a><span class="lineno"> 310</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa053d1fe13274c31c46108a627e47c34">try_cache</a>, <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2839ff479726a23d097bb36a798f0d37">expected_local</a>, int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a14075f3a05d02ac5fec5e92a33fe3a9f">mtime</a>, <span class="keywordtype">void</span>* metadata = NULL);</div> |
| <div class="line"><a name="l00311"></a><span class="lineno"> 311</span> </div> |
| <div class="line"><a name="l00312"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a5866ae8c5fa197ec221cbd29c02536a5"> 312</a></span>  <span class="keywordtype">void</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a5866ae8c5fa197ec221cbd29c02536a5">meta_data</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a906a37df5140ea49c39632528146c241">meta_data_</a>; }</div> |
| <div class="line"><a name="l00313"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa053d1fe13274c31c46108a627e47c34"> 313</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa053d1fe13274c31c46108a627e47c34">try_cache</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a7d36aced0a014a075a0a726ecc12c978">try_cache_</a>; }</div> |
| <div class="line"><a name="l00314"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2839ff479726a23d097bb36a798f0d37"> 314</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2839ff479726a23d097bb36a798f0d37">expected_local</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af7def730f35abd7963b8776f4d8c8ccd">expected_local_</a>; }</div> |
| <div class="line"><a name="l00315"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a8a6f863fbbfd6ff20f8c34e3164010bf"> 315</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a8a6f863fbbfd6ff20f8c34e3164010bf">ready_buffers_capacity</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad8783219791e9665664c6da018dde5a8">ready_buffers_capacity_</a>; }</div> |
| <div class="line"><a name="l00316"></a><span class="lineno"> 316</span> </div> |
| <div class="line"><a name="l00322"></a><span class="lineno"> 322</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad74e32e4d268c24bcfda3b8d30dd3423">GetNext</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>** buffer);</div> |
| <div class="line"><a name="l00323"></a><span class="lineno"> 323</span> </div> |
| <div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ac06d77ef42b00861c919df2a5cf32722">Cancel</a>(<span class="keyword">const</span> <a class="code" href="classimpala_1_1Status.html">Status</a>& status);</div> |
| <div class="line"><a name="l00329"></a><span class="lineno"> 329</span> </div> |
| <div class="line"><a name="l00331"></a><span class="lineno"> 331</span>  std::string <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a81505e1ed7d182de96996bfb18e62df0">DebugString</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00332"></a><span class="lineno"> 332</span> </div> |
| <div class="line"><a name="l00333"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a14075f3a05d02ac5fec5e92a33fe3a9f"> 333</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a14075f3a05d02ac5fec5e92a33fe3a9f">mtime</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a249dcbdcbefd6f92fc6903a689fc9389">mtime_</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"> 335</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00336"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a544ca3cf0abcbff53ea299d0d2da3877"> 336</a></span>  <span class="keyword">friend</span> <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</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"> 339</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad227f9b82fee46717e902084eabb4d90">InitInternal</a>(<a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>* io_mgr, <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader);</div> |
| <div class="line"><a name="l00340"></a><span class="lineno"> 340</span> </div> |
| <div class="line"><a name="l00343"></a><span class="lineno"> 343</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a481cdceb304b7b12d06537e0e5c1af12">EnqueueBuffer</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>* buffer);</div> |
| <div class="line"><a name="l00344"></a><span class="lineno"> 344</span> </div> |
| <div class="line"><a name="l00347"></a><span class="lineno"> 347</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a06c6694b1023dfad5af3a86a9e4775fa">CleanupQueuedBuffers</a>();</div> |
| <div class="line"><a name="l00348"></a><span class="lineno"> 348</span> </div> |
| <div class="line"><a name="l00351"></a><span class="lineno"> 351</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a5bf1e8da63fa9684a08688f7b94526e3">Validate</a>();</div> |
| <div class="line"><a name="l00352"></a><span class="lineno"> 352</span> </div> |
| <div class="line"><a name="l00354"></a><span class="lineno"> 354</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#afe8b988e8dafada5140b99d7f9688e39">MaxReadChunkSize</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00355"></a><span class="lineno"> 355</span> </div> |
| <div class="line"><a name="l00357"></a><span class="lineno"> 357</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa60da51cc9ffde2e69118edaa67a04c5">Open</a>();</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">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a15f6183f3d2570adb418d200006debc2">Close</a>();</div> |
| <div class="line"><a name="l00361"></a><span class="lineno"> 361</span> </div> |
| <div class="line"><a name="l00364"></a><span class="lineno"> 364</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a69df0692251b2de539072363366e9152">Read</a>(<span class="keywordtype">char</span>* buffer, int64_t* bytes_read, <span class="keywordtype">bool</span>* eosr);</div> |
| <div class="line"><a name="l00365"></a><span class="lineno"> 365</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_1DiskIoMgr_1_1ScanRange.html#ad0c786983470478c771a25f2201212b1">ReadFromCache</a>(<span class="keywordtype">bool</span>* read_succeeded);</div> |
| <div class="line"><a name="l00371"></a><span class="lineno"> 371</span> </div> |
| <div class="line"><a name="l00374"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a906a37df5140ea49c39632528146c241"> 374</a></span>  <span class="keywordtype">void</span>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a906a37df5140ea49c39632528146c241">meta_data_</a>;</div> |
| <div class="line"><a name="l00375"></a><span class="lineno"> 375</span> </div> |
| <div class="line"><a name="l00379"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a7d36aced0a014a075a0a726ecc12c978"> 379</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a7d36aced0a014a075a0a726ecc12c978">try_cache_</a>;</div> |
| <div class="line"><a name="l00380"></a><span class="lineno"> 380</span> </div> |
| <div class="line"><a name="l00386"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af7def730f35abd7963b8776f4d8c8ccd"> 386</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af7def730f35abd7963b8776f4d8c8ccd">expected_local_</a>;</div> |
| <div class="line"><a name="l00387"></a><span class="lineno"> 387</span> </div> |
| <div class="line"><a name="l00388"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a6d28dec81a4ba603b90a39f286e177c0"> 388</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a6d28dec81a4ba603b90a39f286e177c0">io_mgr_</a>;</div> |
| <div class="line"><a name="l00389"></a><span class="lineno"> 389</span> </div> |
| <div class="line"><a name="l00391"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a44291cd2e1ffe1bebffebc531b36aac4"> 391</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a44291cd2e1ffe1bebffebc531b36aac4">reader_</a>;</div> |
| <div class="line"><a name="l00392"></a><span class="lineno"> 392</span> </div> |
| <div class="line"><a name="l00394"></a><span class="lineno"> 394</span>  <span class="keyword">union </span>{</div> |
| <div class="line"><a name="l00395"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af825568af8e740b99ea50ab5ed16f828"> 395</a></span>  FILE* <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af825568af8e740b99ea50ab5ed16f828">local_file_</a>;</div> |
| <div class="line"><a name="l00396"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a362c3f4466b42ff68dbb1aa444953b42"> 396</a></span>  hdfsFile <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a362c3f4466b42ff68dbb1aa444953b42">hdfs_file_</a>;</div> |
| <div class="line"><a name="l00397"></a><span class="lineno"> 397</span>  };</div> |
| <div class="line"><a name="l00398"></a><span class="lineno"> 398</span> </div> |
| <div class="line"><a name="l00401"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a485843dc3adafd9f1080877dc1a4e742"> 401</a></span>  <span class="keyword">struct </span>hadoopRzBuffer* <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a485843dc3adafd9f1080877dc1a4e742">cached_buffer_</a>;</div> |
| <div class="line"><a name="l00402"></a><span class="lineno"> 402</span> </div> |
| <div class="line"><a name="l00405"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a1cb20f7f0890721057179b15e63520c9"> 405</a></span>  boost::mutex <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a1cb20f7f0890721057179b15e63520c9">lock_</a>;</div> |
| <div class="line"><a name="l00406"></a><span class="lineno"> 406</span> </div> |
| <div class="line"><a name="l00408"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a9da7b7ab087a11a5489f533fed8406c6"> 408</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a9da7b7ab087a11a5489f533fed8406c6">bytes_read_</a>;</div> |
| <div class="line"><a name="l00409"></a><span class="lineno"> 409</span> </div> |
| <div class="line"><a name="l00413"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a3491a7be8222094756212884f2f20332"> 413</a></span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a3491a7be8222094756212884f2f20332">status_</a>;</div> |
| <div class="line"><a name="l00414"></a><span class="lineno"> 414</span> </div> |
| <div class="line"><a name="l00416"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a4e51ca7003c842859a63e71930703e67"> 416</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a4e51ca7003c842859a63e71930703e67">eosr_queued_</a>;</div> |
| <div class="line"><a name="l00417"></a><span class="lineno"> 417</span> </div> |
| <div class="line"><a name="l00419"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ae4b537022264309859ed8ac5db3f57db"> 419</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ae4b537022264309859ed8ac5db3f57db">eosr_returned_</a>;</div> |
| <div class="line"><a name="l00420"></a><span class="lineno"> 420</span> </div> |
| <div class="line"><a name="l00423"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ac1667f99ab4e2d534fc6cf0e2cc8e39e"> 423</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ac1667f99ab4e2d534fc6cf0e2cc8e39e">blocked_on_queue_</a>;</div> |
| <div class="line"><a name="l00424"></a><span class="lineno"> 424</span> </div> |
| <div class="line"><a name="l00427"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af4fbe21bd8f85faf34c61abebeebeba5"> 427</a></span>  boost::condition_variable <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af4fbe21bd8f85faf34c61abebeebeba5">buffer_ready_cv_</a>;</div> |
| <div class="line"><a name="l00428"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#adec04dbe4da9c161e451e77e7cb0f4c2"> 428</a></span>  std::list<BufferDescriptor*> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#adec04dbe4da9c161e451e77e7cb0f4c2">ready_buffers_</a>;</div> |
| <div class="line"><a name="l00429"></a><span class="lineno"> 429</span> </div> |
| <div class="line"><a name="l00434"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad8783219791e9665664c6da018dde5a8"> 434</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad8783219791e9665664c6da018dde5a8">ready_buffers_capacity_</a>;</div> |
| <div class="line"><a name="l00435"></a><span class="lineno"> 435</span> </div> |
| <div class="line"><a name="l00442"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#adf902119d8621f63290d6c7335a36ac8"> 442</a></span>  boost::mutex <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#adf902119d8621f63290d6c7335a36ac8">hdfs_lock_</a>;</div> |
| <div class="line"><a name="l00443"></a><span class="lineno"> 443</span> </div> |
| <div class="line"><a name="l00445"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2ca6fafcd74e8d3ccd30ef1dd44a6479"> 445</a></span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2ca6fafcd74e8d3ccd30ef1dd44a6479">is_cancelled_</a>;</div> |
| <div class="line"><a name="l00446"></a><span class="lineno"> 446</span> </div> |
| <div class="line"><a name="l00448"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a249dcbdcbefd6f92fc6903a689fc9389"> 448</a></span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a249dcbdcbefd6f92fc6903a689fc9389">mtime_</a>;</div> |
| <div class="line"><a name="l00449"></a><span class="lineno"> 449</span>  };</div> |
| <div class="line"><a name="l00450"></a><span class="lineno"> 450</span> </div> |
| <div class="line"><a name="l00455"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html"> 455</a></span>  <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html">WriteRange</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html">RequestRange</a> {</div> |
| <div class="line"><a name="l00456"></a><span class="lineno"> 456</span>  <span class="keyword">public</span>:</div> |
| <div class="line"><a name="l00464"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a73ff2b5179a78b844e997741ed02a1e5"> 464</a></span>  <span class="keyword">typedef</span> boost::function<void (const Status&)> <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a73ff2b5179a78b844e997741ed02a1e5">WriteDoneCallback</a>;</div> |
| <div class="line"><a name="l00465"></a><span class="lineno"> 465</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#ae0abd8832dfecba1a5b248140b6bc9a6">WriteRange</a>(<span class="keyword">const</span> std::string& <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a015237297a1c06eca646fe3370f0e8b9">file</a>, int64_t file_offset, <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a5b5c378a1ec75719e7ead0fdd6fb2137">disk_id</a>,</div> |
| <div class="line"><a name="l00466"></a><span class="lineno"> 466</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a73ff2b5179a78b844e997741ed02a1e5">WriteDoneCallback</a> callback);</div> |
| <div class="line"><a name="l00467"></a><span class="lineno"> 467</span> </div> |
| <div class="line"><a name="l00470"></a><span class="lineno"> 470</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a0b3583797f2589762de57408795ddd2f">SetData</a>(<span class="keyword">const</span> uint8_t* buffer, int64_t <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a54e2b168c3a64a9250cac5069f85435d">len</a>);</div> |
| <div class="line"><a name="l00471"></a><span class="lineno"> 471</span> </div> |
| <div class="line"><a name="l00472"></a><span class="lineno"> 472</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00473"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a544ca3cf0abcbff53ea299d0d2da3877"> 473</a></span>  <span class="keyword">friend</span> <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr.html">DiskIoMgr</a>;</div> |
| <div class="line"><a name="l00474"></a><span class="lineno"> 474</span> </div> |
| <div class="line"><a name="l00477"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a10d69ddd36f090121e7a39ca2419ee57"> 477</a></span>  <span class="keyword">const</span> uint8_t* <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a10d69ddd36f090121e7a39ca2419ee57">data_</a>;</div> |
| <div class="line"><a name="l00478"></a><span class="lineno"> 478</span> </div> |
| <div class="line"><a name="l00480"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a82db7375774c322c2d5d9617a69ad352"> 480</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a73ff2b5179a78b844e997741ed02a1e5">WriteDoneCallback</a> <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a82db7375774c322c2d5d9617a69ad352">callback_</a>;</div> |
| <div class="line"><a name="l00481"></a><span class="lineno"> 481</span>  };</div> |
| <div class="line"><a name="l00482"></a><span class="lineno"> 482</span> </div> |
| <div class="line"><a name="l00490"></a><span class="lineno"> 490</span>  <a class="code" href="classimpala_1_1DiskIoMgr.html#a44032d3a2a6760a534540b0d86c52cc6">DiskIoMgr</a>(<span class="keywordtype">int</span> num_disks, <span class="keywordtype">int</span> threads_per_disk, <span class="keywordtype">int</span> min_buffer_size,</div> |
| <div class="line"><a name="l00491"></a><span class="lineno"> 491</span>  <span class="keywordtype">int</span> max_buffer_size);</div> |
| <div class="line"><a name="l00492"></a><span class="lineno"> 492</span> </div> |
| <div class="line"><a name="l00494"></a><span class="lineno"> 494</span>  <a class="code" href="classimpala_1_1DiskIoMgr.html#a44032d3a2a6760a534540b0d86c52cc6">DiskIoMgr</a>();</div> |
| <div class="line"><a name="l00495"></a><span class="lineno"> 495</span> </div> |
| <div class="line"><a name="l00498"></a><span class="lineno"> 498</span>  <a class="code" href="classimpala_1_1DiskIoMgr.html#ac8e9f578c5a9e278add1859d37cbd08a">~DiskIoMgr</a>();</div> |
| <div class="line"><a name="l00499"></a><span class="lineno"> 499</span> </div> |
| <div class="line"><a name="l00501"></a><span class="lineno"> 501</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a1991e70528bab13363e3592d174d7a12">Init</a>(<a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a>* process_mem_tracker);</div> |
| <div class="line"><a name="l00502"></a><span class="lineno"> 502</span> </div> |
| <div class="line"><a name="l00511"></a><span class="lineno"> 511</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a47f9eb99e3e705017d17dffddbea38b2">RegisterContext</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>** request_context,</div> |
| <div class="line"><a name="l00512"></a><span class="lineno"> 512</span>  <a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a>* reader_mem_tracker = NULL);</div> |
| <div class="line"><a name="l00513"></a><span class="lineno"> 513</span> </div> |
| <div class="line"><a name="l00520"></a><span class="lineno"> 520</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#abcb3619688e18e6453177dc8bb85e565">UnregisterContext</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* context);</div> |
| <div class="line"><a name="l00521"></a><span class="lineno"> 521</span> </div> |
| <div class="line"><a name="l00530"></a><span class="lineno"> 530</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a0101ab194607143c4e79baaf7a914a64">CancelContext</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* context, <span class="keywordtype">bool</span> wait_for_disks_completion = <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00531"></a><span class="lineno"> 531</span> </div> |
| <div class="line"><a name="l00538"></a><span class="lineno"> 538</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#aa6a1a246f28ee5f8214cfdfd2dd8aa42">AddScanRanges</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader, <span class="keyword">const</span> std::vector<ScanRange*>& ranges,</div> |
| <div class="line"><a name="l00539"></a><span class="lineno"> 539</span>  <span class="keywordtype">bool</span> schedule_immediately = <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00540"></a><span class="lineno"> 540</span> </div> |
| <div class="line"><a name="l00543"></a><span class="lineno"> 543</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a89284efc0d973c8df0e51ca3238c6b52">AddWriteRange</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* writer, <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html">WriteRange</a>* write_range);</div> |
| <div class="line"><a name="l00544"></a><span class="lineno"> 544</span> </div> |
| <div class="line"><a name="l00550"></a><span class="lineno"> 550</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a3cc61c88ae6cbb96791d71aee1664137">GetNextRange</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader, <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>** range);</div> |
| <div class="line"><a name="l00551"></a><span class="lineno"> 551</span> </div> |
| <div class="line"><a name="l00557"></a><span class="lineno"> 557</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a501f1ef0a0ddce1507c99b8cf78745d2">Read</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader, <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* range, <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>** buffer);</div> |
| <div class="line"><a name="l00558"></a><span class="lineno"> 558</span> </div> |
| <div class="line"><a name="l00563"></a><span class="lineno"> 563</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ab92e887bc1867272f1d0ce80f09bfe11">AssignQueue</a>(<span class="keyword">const</span> <span class="keywordtype">char</span>* file, <span class="keywordtype">int</span> disk_id, <span class="keywordtype">bool</span> expected_local);</div> |
| <div class="line"><a name="l00564"></a><span class="lineno"> 564</span> </div> |
| <div class="line"><a name="l00567"></a><span class="lineno"> 567</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#ac5ce912576b754a61f9e1b61f2d2b4ea">context_status</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* context) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00568"></a><span class="lineno"> 568</span> </div> |
| <div class="line"><a name="l00570"></a><span class="lineno"> 570</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a05a2eca77321958ca3e6e3784ab2efcc">num_unstarted_ranges</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00571"></a><span class="lineno"> 571</span> </div> |
| <div class="line"><a name="l00572"></a><span class="lineno"> 572</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#abcf20ad952f31d948888d9834b64dd94">set_bytes_read_counter</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>*, <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>*);</div> |
| <div class="line"><a name="l00573"></a><span class="lineno"> 573</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a9f81e48ed3492b090a38a8ac9d90cc97">set_read_timer</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>*, <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>*);</div> |
| <div class="line"><a name="l00574"></a><span class="lineno"> 574</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a8b9c885f997c1151fcb889f727d41fdb">set_active_read_thread_counter</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>*, <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>*);</div> |
| <div class="line"><a name="l00575"></a><span class="lineno"> 575</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a7b7a12de61dd80ed3b3163192c3cac19">set_disks_access_bitmap</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>*, <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>*);</div> |
| <div class="line"><a name="l00576"></a><span class="lineno"> 576</span> </div> |
| <div class="line"><a name="l00577"></a><span class="lineno"> 577</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr.html#a263b162de531fc234e80ab3b6fc68d6c">queue_size</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00578"></a><span class="lineno"> 578</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr.html#a22f6b26648d0b3878e417cf087b2ee89">bytes_read_local</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00579"></a><span class="lineno"> 579</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr.html#ab00029212e1b92f2ecb6014c63c204a2">bytes_read_short_circuit</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00580"></a><span class="lineno"> 580</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr.html#a62c6a7658886cefdb5e84e867da6352f">bytes_read_dn_cache</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00581"></a><span class="lineno"> 581</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a79bb53859930e7386542d11490c69cff">num_remote_ranges</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00582"></a><span class="lineno"> 582</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr.html#a1d1b000a66d4456365e4f9fbf6cb896f">unexpected_remote_bytes</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader) <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00583"></a><span class="lineno"> 583</span> </div> |
| <div class="line"><a name="l00587"></a><span class="lineno"> 587</span>  int64_t <a class="code" href="classimpala_1_1DiskIoMgr.html#a8cad7a32492c51d29a1383d5644c7415">GetReadThroughput</a>();</div> |
| <div class="line"><a name="l00588"></a><span class="lineno"> 588</span> </div> |
| <div class="line"><a name="l00590"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a4d68607c8cf8f9003f47891af6627103"> 590</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a4d68607c8cf8f9003f47891af6627103">max_read_buffer_size</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ae45a6778f947e194d7665fa340be2a95">max_buffer_size_</a>; }</div> |
| <div class="line"><a name="l00591"></a><span class="lineno"> 591</span> </div> |
| <div class="line"><a name="l00593"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a3c99177a95caa67739c8815c55eb3491"> 593</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a3c99177a95caa67739c8815c55eb3491">num_total_disks</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a998dafa247fd5bcac1b5a30232fb9d17">disk_queues_</a>.size(); }</div> |
| <div class="line"><a name="l00594"></a><span class="lineno"> 594</span> </div> |
| <div class="line"><a name="l00596"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a2881c4eba0bb95ca79de096e0e68b5b1"> 596</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a2881c4eba0bb95ca79de096e0e68b5b1">num_remote_disks</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075adaf2d4abf2fb7cedd9b81575e18d2a361a">REMOTE_NUM_DISKS</a>; }</div> |
| <div class="line"><a name="l00597"></a><span class="lineno"> 597</span> </div> |
| <div class="line"><a name="l00599"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a3a6605b8b52c766d1489af89f0a2ac43"> 599</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a3a6605b8b52c766d1489af89f0a2ac43">num_local_disks</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a3c99177a95caa67739c8815c55eb3491">num_total_disks</a>() - <a class="code" href="classimpala_1_1DiskIoMgr.html#a2881c4eba0bb95ca79de096e0e68b5b1">num_remote_disks</a>(); }</div> |
| <div class="line"><a name="l00600"></a><span class="lineno"> 600</span> </div> |
| <div class="line"><a name="l00602"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a7f67b5041cef54b924855720f877883f"> 602</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a7f67b5041cef54b924855720f877883f">RemoteS3DiskId</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a3a6605b8b52c766d1489af89f0a2ac43">num_local_disks</a>() + <a class="code" href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075ada4dce4311f2a962cc1e369379f9ffedf2">REMOTE_S3_DISK_OFFSET</a>; }</div> |
| <div class="line"><a name="l00603"></a><span class="lineno"> 603</span> </div> |
| <div class="line"><a name="l00605"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#ab59d92f6e237fcc86112fd39d56196fe"> 605</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ab59d92f6e237fcc86112fd39d56196fe">num_allocated_buffers</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#af197b913784b65e86e0d5601a59c915f">num_allocated_buffers_</a>; }</div> |
| <div class="line"><a name="l00606"></a><span class="lineno"> 606</span> </div> |
| <div class="line"><a name="l00608"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a54bb2885167cd44d2ca2469d28f0fa52"> 608</a></span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a54bb2885167cd44d2ca2469d28f0fa52">num_buffers_in_readers</a>()<span class="keyword"> const </span>{ <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#afc2062330fc1bdd9f1ee14093dbd69b5">num_buffers_in_readers_</a>; }</div> |
| <div class="line"><a name="l00609"></a><span class="lineno"> 609</span> </div> |
| <div class="line"><a name="l00611"></a><span class="lineno"> 611</span>  std::string <a class="code" href="classimpala_1_1DiskIoMgr.html#a38bde6fa6ddcd0ae546a3e52e00cb5ff">DebugString</a>();</div> |
| <div class="line"><a name="l00612"></a><span class="lineno"> 612</span> </div> |
| <div class="line"><a name="l00615"></a><span class="lineno"> 615</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a78c14580725060483f5bbd1aaf24fa29">Validate</a>() <span class="keyword">const</span>;</div> |
| <div class="line"><a name="l00616"></a><span class="lineno"> 616</span> </div> |
| <div class="line"><a name="l00619"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a0ba2f86ddaf75389adb493bdb0001929"> 619</a></span>  <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a0ba2f86ddaf75389adb493bdb0001929">DEFAULT_QUEUE_CAPACITY</a>;</div> |
| <div class="line"><a name="l00620"></a><span class="lineno"> 620</span> </div> |
| <div class="line"><a name="l00623"></a><span class="lineno"> 623</span>  <span class="keyword">enum</span> {</div> |
| <div class="line"><a name="l00624"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075ada4dce4311f2a962cc1e369379f9ffedf2"> 624</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075ada4dce4311f2a962cc1e369379f9ffedf2">REMOTE_S3_DISK_OFFSET</a> = 0,</div> |
| <div class="line"><a name="l00625"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075adaf2d4abf2fb7cedd9b81575e18d2a361a"> 625</a></span>  <a class="code" href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075adaf2d4abf2fb7cedd9b81575e18d2a361a">REMOTE_NUM_DISKS</a></div> |
| <div class="line"><a name="l00626"></a><span class="lineno"> 626</span>  };</div> |
| <div class="line"><a name="l00627"></a><span class="lineno"> 627</span> </div> |
| <div class="line"><a name="l00628"></a><span class="lineno"> 628</span>  <span class="keyword">private</span>:</div> |
| <div class="line"><a name="l00629"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#ac9c5947135e52813c03a9c900161c428"> 629</a></span>  <span class="keyword">friend</span> <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>;</div> |
| <div class="line"><a name="l00630"></a><span class="lineno"> 630</span>  <span class="keyword">struct </span><a class="code" href="structimpala_1_1DiskIoMgr_1_1DiskQueue.html">DiskQueue</a>;</div> |
| <div class="line"><a name="l00631"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#af1c05277e3e3ce9b9b00fecbd7130b31"> 631</a></span>  <span class="keyword">class </span><a class="code" href="classDiskIoMgr_1_1RequestContextCache.html">RequestContextCache</a>;</div> |
| <div class="line"><a name="l00632"></a><span class="lineno"> 632</span> </div> |
| <div class="line"><a name="l00633"></a><span class="lineno"> 633</span>  <span class="keyword">friend</span> <span class="keyword">class </span><a class="code" href="classimpala_1_1DiskIoMgr.html#af1c05277e3e3ce9b9b00fecbd7130b31">DiskIoMgrTest_Buffers_Test</a>;</div> |
| <div class="line"><a name="l00634"></a><span class="lineno"> 634</span> </div> |
| <div class="line"><a name="l00636"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a0ca2db2159fc27588ea77dc43c6b32f1"> 636</a></span>  <a class="code" href="classimpala_1_1ObjectPool.html">ObjectPool</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a0ca2db2159fc27588ea77dc43c6b32f1">pool_</a>;</div> |
| <div class="line"><a name="l00637"></a><span class="lineno"> 637</span> </div> |
| <div class="line"><a name="l00639"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a90831aea936eafbc9ad831dbfddcf25a"> 639</a></span>  <a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a>* <a class="code" href="classimpala_1_1DiskIoMgr.html#a90831aea936eafbc9ad831dbfddcf25a">process_mem_tracker_</a>;</div> |
| <div class="line"><a name="l00640"></a><span class="lineno"> 640</span> </div> |
| <div class="line"><a name="l00643"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a57d6bef4f87965d26ae0f3ebdb2f747b"> 643</a></span>  <span class="keyword">const</span> <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a57d6bef4f87965d26ae0f3ebdb2f747b">num_threads_per_disk_</a>;</div> |
| <div class="line"><a name="l00644"></a><span class="lineno"> 644</span> </div> |
| <div class="line"><a name="l00646"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#ae45a6778f947e194d7665fa340be2a95"> 646</a></span>  <span class="keyword">const</span> <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ae45a6778f947e194d7665fa340be2a95">max_buffer_size_</a>;</div> |
| <div class="line"><a name="l00647"></a><span class="lineno"> 647</span> </div> |
| <div class="line"><a name="l00649"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a1621cf94056e57b8d67cb38e06e6a3b4"> 649</a></span>  <span class="keyword">const</span> <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a1621cf94056e57b8d67cb38e06e6a3b4">min_buffer_size_</a>;</div> |
| <div class="line"><a name="l00650"></a><span class="lineno"> 650</span> </div> |
| <div class="line"><a name="l00652"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a18797d98ff8df6a835c37baab65cddcc"> 652</a></span>  <a class="code" href="classimpala_1_1ThreadGroup.html">ThreadGroup</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a18797d98ff8df6a835c37baab65cddcc">disk_thread_group_</a>;</div> |
| <div class="line"><a name="l00653"></a><span class="lineno"> 653</span> </div> |
| <div class="line"><a name="l00655"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#af3884fdf813f9fb3b2a4b0d6942c45b2"> 655</a></span>  <span class="keyword">struct </span>hadoopRzOptions* <a class="code" href="classimpala_1_1DiskIoMgr.html#af3884fdf813f9fb3b2a4b0d6942c45b2">cached_read_options_</a>;</div> |
| <div class="line"><a name="l00656"></a><span class="lineno"> 656</span> </div> |
| <div class="line"><a name="l00659"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#aa38c0d8f31a90a97cb7aab33592f6a12"> 659</a></span>  <span class="keyword">volatile</span> <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#aa38c0d8f31a90a97cb7aab33592f6a12">shut_down_</a>;</div> |
| <div class="line"><a name="l00660"></a><span class="lineno"> 660</span> </div> |
| <div class="line"><a name="l00662"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#ae98884865bff90f5bad4a6d814ac735a"> 662</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#ae98884865bff90f5bad4a6d814ac735a">total_bytes_read_counter_</a>;</div> |
| <div class="line"><a name="l00663"></a><span class="lineno"> 663</span> </div> |
| <div class="line"><a name="l00665"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a9824ef6a01d96312a2c7a9f7c13b7809"> 665</a></span>  <a class="code" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a9824ef6a01d96312a2c7a9f7c13b7809">read_timer_</a>;</div> |
| <div class="line"><a name="l00666"></a><span class="lineno"> 666</span> </div> |
| <div class="line"><a name="l00671"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a2ddb2e1d5fc8839916e38775875f44d5"> 671</a></span>  boost::scoped_ptr<RequestContextCache> <a class="code" href="classimpala_1_1DiskIoMgr.html#a2ddb2e1d5fc8839916e38775875f44d5">request_context_cache_</a>;</div> |
| <div class="line"><a name="l00672"></a><span class="lineno"> 672</span> </div> |
| <div class="line"><a name="l00674"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a495366bfbc69a8a08eda7f6af084e30d"> 674</a></span>  boost::mutex <a class="code" href="classimpala_1_1DiskIoMgr.html#a495366bfbc69a8a08eda7f6af084e30d">free_buffers_lock_</a>;</div> |
| <div class="line"><a name="l00675"></a><span class="lineno"> 675</span> </div> |
| <div class="line"><a name="l00680"></a><span class="lineno"> 680</span>  <span class="comment">//</span></div> |
| <div class="line"><a name="l00687"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a59189dd1e2ba483252dca9043602e32b"> 687</a></span> <span class="comment"></span> std::vector<std::list<char*> > <a class="code" href="classimpala_1_1DiskIoMgr.html#a59189dd1e2ba483252dca9043602e32b">free_buffers_</a>;</div> |
| <div class="line"><a name="l00688"></a><span class="lineno"> 688</span> </div> |
| <div class="line"><a name="l00690"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a87763baaff5e691c4881d5147795d0d2"> 690</a></span>  std::list<BufferDescriptor*> <a class="code" href="classimpala_1_1DiskIoMgr.html#a87763baaff5e691c4881d5147795d0d2">free_buffer_descs_</a>;</div> |
| <div class="line"><a name="l00691"></a><span class="lineno"> 691</span> </div> |
| <div class="line"><a name="l00693"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#af197b913784b65e86e0d5601a59c915f"> 693</a></span>  <a class="code" href="classimpala_1_1AtomicInt.html">AtomicInt<int></a> <a class="code" href="classimpala_1_1DiskIoMgr.html#af197b913784b65e86e0d5601a59c915f">num_allocated_buffers_</a>;</div> |
| <div class="line"><a name="l00694"></a><span class="lineno"> 694</span> </div> |
| <div class="line"><a name="l00696"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#afc2062330fc1bdd9f1ee14093dbd69b5"> 696</a></span>  <a class="code" href="classimpala_1_1AtomicInt.html">AtomicInt<int></a> <a class="code" href="classimpala_1_1DiskIoMgr.html#afc2062330fc1bdd9f1ee14093dbd69b5">num_buffers_in_readers_</a>;</div> |
| <div class="line"><a name="l00697"></a><span class="lineno"> 697</span> </div> |
| <div class="line"><a name="l00701"></a><span class="lineno"><a class="line" href="classimpala_1_1DiskIoMgr.html#a998dafa247fd5bcac1b5a30232fb9d17"> 701</a></span>  std::vector<DiskQueue*> <a class="code" href="classimpala_1_1DiskIoMgr.html#a998dafa247fd5bcac1b5a30232fb9d17">disk_queues_</a>;</div> |
| <div class="line"><a name="l00702"></a><span class="lineno"> 702</span> </div> |
| <div class="line"><a name="l00704"></a><span class="lineno"> 704</span>  <span class="keywordtype">int</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#aca591719005e7c9a0cd8212d52f5e533">free_buffers_idx</a>(int64_t buffer_size);</div> |
| <div class="line"><a name="l00705"></a><span class="lineno"> 705</span> </div> |
| <div class="line"><a name="l00710"></a><span class="lineno"> 710</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>* <a class="code" href="classimpala_1_1DiskIoMgr.html#a234649f13d6930779d0fd6ae871f7bee">GetBufferDesc</a>(</div> |
| <div class="line"><a name="l00711"></a><span class="lineno"> 711</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader, <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* range, <span class="keywordtype">char</span>* buffer, int64_t buffer_size);</div> |
| <div class="line"><a name="l00712"></a><span class="lineno"> 712</span> </div> |
| <div class="line"><a name="l00714"></a><span class="lineno"> 714</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#af56bacb215e699a478c0a5ceee074712">ReturnBufferDesc</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>* desc);</div> |
| <div class="line"><a name="l00715"></a><span class="lineno"> 715</span> </div> |
| <div class="line"><a name="l00718"></a><span class="lineno"> 718</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a1ce84f3fd78ec5c8492026cd22cd69e0">ReturnBuffer</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>* buffer);</div> |
| <div class="line"><a name="l00719"></a><span class="lineno"> 719</span> </div> |
| <div class="line"><a name="l00724"></a><span class="lineno"> 724</span>  <span class="keywordtype">char</span>* <a class="code" href="classimpala_1_1DiskIoMgr.html#aa3bba021605906306bbbf5daddf95d95">GetFreeBuffer</a>(int64_t* buffer_size);</div> |
| <div class="line"><a name="l00725"></a><span class="lineno"> 725</span> </div> |
| <div class="line"><a name="l00730"></a><span class="lineno"> 730</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a4431510659aedf1fa38e042e4196f415">GcIoBuffers</a>();</div> |
| <div class="line"><a name="l00731"></a><span class="lineno"> 731</span> </div> |
| <div class="line"><a name="l00735"></a><span class="lineno"> 735</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ad69740225431892ddb15723b3e5211c4">ReturnFreeBuffer</a>(<span class="keywordtype">char</span>* buffer, int64_t buffer_size);</div> |
| <div class="line"><a name="l00736"></a><span class="lineno"> 736</span> </div> |
| <div class="line"><a name="l00739"></a><span class="lineno"> 739</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ad69740225431892ddb15723b3e5211c4">ReturnFreeBuffer</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>* desc);</div> |
| <div class="line"><a name="l00740"></a><span class="lineno"> 740</span> </div> |
| <div class="line"><a name="l00744"></a><span class="lineno"> 744</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a83daff34ce9a9d8eadbfff528e28eb56">WorkLoop</a>(<a class="code" href="structimpala_1_1DiskIoMgr_1_1DiskQueue.html">DiskQueue</a>* queue);</div> |
| <div class="line"><a name="l00745"></a><span class="lineno"> 745</span> </div> |
| <div class="line"><a name="l00751"></a><span class="lineno"> 751</span>  <span class="keywordtype">bool</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a8550d90be93435c85ea623ed75c02a6a">GetNextRequestRange</a>(<a class="code" href="structimpala_1_1DiskIoMgr_1_1DiskQueue.html">DiskQueue</a>* disk_queue, <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestRange.html">RequestRange</a>** range,</div> |
| <div class="line"><a name="l00752"></a><span class="lineno"> 752</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>** request_context);</div> |
| <div class="line"><a name="l00753"></a><span class="lineno"> 753</span> </div> |
| <div class="line"><a name="l00756"></a><span class="lineno"> 756</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#ad953550311c262181c52df319cacf540">HandleReadFinished</a>(<a class="code" href="structimpala_1_1DiskIoMgr_1_1DiskQueue.html">DiskQueue</a>*, <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>*, <a class="code" href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">BufferDescriptor</a>*);</div> |
| <div class="line"><a name="l00757"></a><span class="lineno"> 757</span> </div> |
| <div class="line"><a name="l00764"></a><span class="lineno"> 764</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a81d5e5e4dbe9e696deb160e45f6d51fb">HandleWriteFinished</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* writer, <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html">WriteRange</a>* write_range,</div> |
| <div class="line"><a name="l00765"></a><span class="lineno"> 765</span>  <span class="keyword">const</span> <a class="code" href="classimpala_1_1Status.html">Status</a>& write_status);</div> |
| <div class="line"><a name="l00766"></a><span class="lineno"> 766</span> </div> |
| <div class="line"><a name="l00768"></a><span class="lineno"> 768</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#a602c11c00e5824f4b75ca325bcb1ff74">ValidateScanRange</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* range);</div> |
| <div class="line"><a name="l00769"></a><span class="lineno"> 769</span> </div> |
| <div class="line"><a name="l00772"></a><span class="lineno"> 772</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a767af862da36691ad7b4799b5ad82744">Write</a>(<a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* writer_context, <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html">WriteRange</a>* write_range);</div> |
| <div class="line"><a name="l00773"></a><span class="lineno"> 773</span> </div> |
| <div class="line"><a name="l00777"></a><span class="lineno"> 777</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1DiskIoMgr.html#aa2be4e061eae7032c992a901a7670465">WriteRangeHelper</a>(FILE* file_handle, <a class="code" href="classimpala_1_1DiskIoMgr_1_1WriteRange.html">WriteRange</a>* write_range);</div> |
| <div class="line"><a name="l00778"></a><span class="lineno"> 778</span> </div> |
| <div class="line"><a name="l00780"></a><span class="lineno"> 780</span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1DiskIoMgr.html#a053f427bbc4edd04f30c17410ff66a27">ReadRange</a>(<a class="code" href="structimpala_1_1DiskIoMgr_1_1DiskQueue.html">DiskQueue</a>* disk_queue, <a class="code" href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">RequestContext</a>* reader,</div> |
| <div class="line"><a name="l00781"></a><span class="lineno"> 781</span>  <a class="code" href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">ScanRange</a>* range);</div> |
| <div class="line"><a name="l00782"></a><span class="lineno"> 782</span> };</div> |
| <div class="line"><a name="l00783"></a><span class="lineno"> 783</span> </div> |
| <div class="line"><a name="l00784"></a><span class="lineno"> 784</span> }</div> |
| <div class="line"><a name="l00785"></a><span class="lineno"> 785</span> </div> |
| <div class="line"><a name="l00786"></a><span class="lineno"> 786</span> <span class="preprocessor">#endif</span></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_af56bacb215e699a478c0a5ceee074712"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#af56bacb215e699a478c0a5ceee074712">impala::DiskIoMgr::ReturnBufferDesc</a></div><div class="ttdeci">void ReturnBufferDesc(BufferDescriptor *desc)</div><div class="ttdoc">Returns a buffer desc object which can now be used for another reader. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00602">disk-io-mgr.cc:602</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a0101ab194607143c4e79baaf7a914a64"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a0101ab194607143c4e79baaf7a914a64">impala::DiskIoMgr::CancelContext</a></div><div class="ttdeci">void CancelContext(RequestContext *context, bool wait_for_disks_completion=false)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00377">disk-io-mgr.cc:377</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_aa271d83685f923144a12fda4f79e8c7b"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa271d83685f923144a12fda4f79e8c7b">impala::DiskIoMgr::ScanRange::ScanRange</a></div><div class="ttdeci">ScanRange(int initial_capacity=-1)</div><div class="ttdoc">The initial queue capacity for this. Specify -1 to use IoMgr default. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00204">disk-io-mgr-scan-range.cc:204</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a810f24a718847f2baa96100914e0ae51"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a810f24a718847f2baa96100914e0ae51">impala::DiskIoMgr::RequestRange::request_type</a></div><div class="ttdeci">RequestType::type request_type() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00270">disk-io-mgr.h:270</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a79bb53859930e7386542d11490c69cff"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a79bb53859930e7386542d11490c69cff">impala::DiskIoMgr::num_remote_ranges</a></div><div class="ttdeci">int num_remote_ranges(RequestContext *reader) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00432">disk-io-mgr.cc:432</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_afc2062330fc1bdd9f1ee14093dbd69b5"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#afc2062330fc1bdd9f1ee14093dbd69b5">impala::DiskIoMgr::num_buffers_in_readers_</a></div><div class="ttdeci">AtomicInt< int > num_buffers_in_readers_</div><div class="ttdoc">Total number of buffers in readers. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00696">disk-io-mgr.h:696</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a64ab1a4cf150fdc1fe0b9881eb1b35c9"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a64ab1a4cf150fdc1fe0b9881eb1b35c9">impala::DiskIoMgr::BufferDescriptor::status_</a></div><div class="ttdeci">Status status_</div><div class="ttdoc">Status of the read to this buffer. if status is not ok, 'buffer' is NULL. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00247">disk-io-mgr.h:247</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a906a37df5140ea49c39632528146c241"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a906a37df5140ea49c39632528146c241">impala::DiskIoMgr::ScanRange::meta_data_</a></div><div class="ttdeci">void * meta_data_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00374">disk-io-mgr.h:374</a></div></div> |
| <div class="ttc" id="runtime-profile_8h_html"><div class="ttname"><a href="runtime-profile_8h.html">runtime-profile.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_af803c7fd834cbe217f344bab0edeb1d2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af803c7fd834cbe217f344bab0edeb1d2">impala::DiskIoMgr::BufferDescriptor::buffer_</a></div><div class="ttdeci">char * buffer_</div><div class="ttdoc">buffer with the read contents </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00235">disk-io-mgr.h:235</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a767af862da36691ad7b4799b5ad82744"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a767af862da36691ad7b4799b5ad82744">impala::DiskIoMgr::Write</a></div><div class="ttdeci">void Write(RequestContext *writer_context, WriteRange *write_range)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l01041">disk-io-mgr.cc:1041</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a997b0e92c73aebaaa7fb71e9615b135a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a997b0e92c73aebaaa7fb71e9615b135a">impala::DiskIoMgr::BufferDescriptor::mem_tracker_</a></div><div class="ttdeci">MemTracker * mem_tracker_</div><div class="ttdoc">The current tracker this buffer is associated with. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00229">disk-io-mgr.h:229</a></div></div> |
| <div class="ttc" id="expr-benchmark_8cc_html_ad327327fa716227ff7993880cbc4698f"><div class="ttname"><a href="expr-benchmark_8cc.html#ad327327fa716227ff7993880cbc4698f">tracker</a></div><div class="ttdeci">MemTracker tracker</div><div class="ttdef"><b>Definition:</b> <a href="expr-benchmark_8cc_source.html#l00090">expr-benchmark.cc:90</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a322bf955c04727d26253584f05f7c27f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a322bf955c04727d26253584f05f7c27f">impala::DiskIoMgr::RequestRange::offset_</a></div><div class="ttdeci">int64_t offset_</div><div class="ttdoc">Offset within file_ being read or written. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00280">disk-io-mgr.h:280</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_af825568af8e740b99ea50ab5ed16f828"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af825568af8e740b99ea50ab5ed16f828">impala::DiskIoMgr::ScanRange::local_file_</a></div><div class="ttdeci">FILE * local_file_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00395">disk-io-mgr.h:395</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1WriteRange_html_a73ff2b5179a78b844e997741ed02a1e5"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a73ff2b5179a78b844e997741ed02a1e5">impala::DiskIoMgr::WriteRange::WriteDoneCallback</a></div><div class="ttdeci">boost::function< void(const Status &)> WriteDoneCallback</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00464">disk-io-mgr.h:464</a></div></div> |
| <div class="ttc" id="internal-queue_8h_html"><div class="ttname"><a href="internal-queue_8h.html">internal-queue.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ab92e887bc1867272f1d0ce80f09bfe11"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ab92e887bc1867272f1d0ce80f09bfe11">impala::DiskIoMgr::AssignQueue</a></div><div class="ttdeci">int AssignQueue(const char *file, int disk_id, bool expected_local)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l01116">disk-io-mgr.cc:1116</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a8b9c885f997c1151fcb889f727d41fdb"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a8b9c885f997c1151fcb889f727d41fdb">impala::DiskIoMgr::set_active_read_thread_counter</a></div><div class="ttdeci">void set_active_read_thread_counter(RequestContext *, RuntimeProfile::Counter *)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00397">disk-io-mgr.cc:397</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_af197b913784b65e86e0d5601a59c915f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#af197b913784b65e86e0d5601a59c915f">impala::DiskIoMgr::num_allocated_buffers_</a></div><div class="ttdeci">AtomicInt< int > num_allocated_buffers_</div><div class="ttdoc">Total number of allocated buffers, used for debugging. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00693">disk-io-mgr.h:693</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a57d6bef4f87965d26ae0f3ebdb2f747b"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a57d6bef4f87965d26ae0f3ebdb2f747b">impala::DiskIoMgr::num_threads_per_disk_</a></div><div class="ttdeci">const int num_threads_per_disk_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00643">disk-io-mgr.h:643</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a263b162de531fc234e80ab3b6fc68d6c"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a263b162de531fc234e80ab3b6fc68d6c">impala::DiskIoMgr::queue_size</a></div><div class="ttdeci">int64_t queue_size(RequestContext *reader) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00407">disk-io-mgr.cc:407</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a9e03101c90a31cb522e9f44b008ce9f2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9e03101c90a31cb522e9f44b008ce9f2">impala::DiskIoMgr::RequestRange::len_</a></div><div class="ttdeci">int64_t len_</div><div class="ttdoc">Length of data read or written. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00283">disk-io-mgr.h:283</a></div></div> |
| <div class="ttc" id="structimpala_1_1DiskIoMgr_1_1RequestType_html"><div class="ttname"><a href="structimpala_1_1DiskIoMgr_1_1RequestType.html">impala::DiskIoMgr::RequestType</a></div><div class="ttdoc">The request type, read or write associated with a request range. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00253">disk-io-mgr.h:253</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a2ddb2e1d5fc8839916e38775875f44d5"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a2ddb2e1d5fc8839916e38775875f44d5">impala::DiskIoMgr::request_context_cache_</a></div><div class="ttdeci">boost::scoped_ptr< RequestContextCache > request_context_cache_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00671">disk-io-mgr.h:671</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a1621cf94056e57b8d67cb38e06e6a3b4"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a1621cf94056e57b8d67cb38e06e6a3b4">impala::DiskIoMgr::min_buffer_size_</a></div><div class="ttdeci">const int min_buffer_size_</div><div class="ttdoc">The minimum size of each read buffer. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00649">disk-io-mgr.h:649</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a8cad7a32492c51d29a1383d5644c7415"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a8cad7a32492c51d29a1383d5644c7415">impala::DiskIoMgr::GetReadThroughput</a></div><div class="ttdeci">int64_t GetReadThroughput()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00440">disk-io-mgr.cc:440</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a62c6a7658886cefdb5e84e867da6352f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a62c6a7658886cefdb5e84e867da6352f">impala::DiskIoMgr::bytes_read_dn_cache</a></div><div class="ttdeci">int64_t bytes_read_dn_cache(RequestContext *reader) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00428">disk-io-mgr.cc:428</a></div></div> |
| <div class="ttc" id="structimpala_1_1DiskIoMgr_1_1DiskQueue_html"><div class="ttname"><a href="structimpala_1_1DiskIoMgr_1_1DiskQueue.html">impala::DiskIoMgr::DiskQueue</a></div><div class="ttdoc">Per disk state. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-internal_8h_source.html#l00039">disk-io-mgr-internal.h:39</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a1cb20f7f0890721057179b15e63520c9"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a1cb20f7f0890721057179b15e63520c9">impala::DiskIoMgr::ScanRange::lock_</a></div><div class="ttdeci">boost::mutex lock_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00405">disk-io-mgr.h:405</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_af3884fdf813f9fb3b2a4b0d6942c45b2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#af3884fdf813f9fb3b2a4b0d6942c45b2">impala::DiskIoMgr::cached_read_options_</a></div><div class="ttdeci">struct hadoopRzOptions * cached_read_options_</div><div class="ttdoc">Options object for cached hdfs reads. Set on startup and never modified. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00655">disk-io-mgr.h:655</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_af4fbe21bd8f85faf34c61abebeebeba5"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af4fbe21bd8f85faf34c61abebeebeba5">impala::DiskIoMgr::ScanRange::buffer_ready_cv_</a></div><div class="ttdeci">boost::condition_variable buffer_ready_cv_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00427">disk-io-mgr.h:427</a></div></div> |
| <div class="ttc" id="error-util_8h_html"><div class="ttname"><a href="error-util_8h.html">error-util.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1WriteRange_html_ae0abd8832dfecba1a5b248140b6bc9a6"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#ae0abd8832dfecba1a5b248140b6bc9a6">impala::DiskIoMgr::WriteRange::WriteRange</a></div><div class="ttdeci">WriteRange(const std::string &file, int64_t file_offset, int disk_id, WriteDoneCallback callback)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00196">disk-io-mgr.cc:196</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a87763baaff5e691c4881d5147795d0d2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a87763baaff5e691c4881d5147795d0d2">impala::DiskIoMgr::free_buffer_descs_</a></div><div class="ttdeci">std::list< BufferDescriptor * > free_buffer_descs_</div><div class="ttdoc">List of free buffer desc objects that can be handed out to clients. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00690">disk-io-mgr.h:690</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a89284efc0d973c8df0e51ca3238c6b52"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a89284efc0d973c8df0e51ca3238c6b52">impala::DiskIoMgr::AddWriteRange</a></div><div class="ttdeci">Status AddWriteRange(RequestContext *writer, WriteRange *write_range)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l01103">disk-io-mgr.cc:1103</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html">impala::DiskIoMgr::RequestRange</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00263">disk-io-mgr.h:263</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a2881c4eba0bb95ca79de096e0e68b5b1"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a2881c4eba0bb95ca79de096e0e68b5b1">impala::DiskIoMgr::num_remote_disks</a></div><div class="ttdeci">int num_remote_disks() const </div><div class="ttdoc">Returns the total number of remote "disk" queues. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00596">disk-io-mgr.h:596</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a5cf1068ba03b8c7fca3b4bd4128df54a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5cf1068ba03b8c7fca3b4bd4128df54a">impala::DiskIoMgr::BufferDescriptor::io_mgr_</a></div><div class="ttdeci">DiskIoMgr * io_mgr_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00223">disk-io-mgr.h:223</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html">impala::DiskIoMgr::BufferDescriptor</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00196">disk-io-mgr.h:196</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_adf902119d8621f63290d6c7335a36ac8"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#adf902119d8621f63290d6c7335a36ac8">impala::DiskIoMgr::ScanRange::hdfs_lock_</a></div><div class="ttdeci">boost::mutex hdfs_lock_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00442">disk-io-mgr.h:442</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aabb61890cd37be80703ae735e2a075adaf2d4abf2fb7cedd9b81575e18d2a361a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075adaf2d4abf2fb7cedd9b81575e18d2a361a">impala::DiskIoMgr::REMOTE_NUM_DISKS</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00625">disk-io-mgr.h:625</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ad227f9b82fee46717e902084eabb4d90"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad227f9b82fee46717e902084eabb4d90">impala::DiskIoMgr::ScanRange::InitInternal</a></div><div class="ttdeci">void InitInternal(DiskIoMgr *io_mgr, RequestContext *reader)</div><div class="ttdoc">Initialize internal fields. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00233">disk-io-mgr-scan-range.cc:233</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_ad40bb3de87b9def5b78f59d3bf38c324"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad40bb3de87b9def5b78f59d3bf38c324">impala::DiskIoMgr::BufferDescriptor::buffer</a></div><div class="ttdeci">char * buffer()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00199">disk-io-mgr.h:199</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_abcb3619688e18e6453177dc8bb85e565"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#abcb3619688e18e6453177dc8bb85e565">impala::DiskIoMgr::UnregisterContext</a></div><div class="ttdeci">void UnregisterContext(RequestContext *context)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00344">disk-io-mgr.cc:344</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a015237297a1c06eca646fe3370f0e8b9"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a015237297a1c06eca646fe3370f0e8b9">impala::DiskIoMgr::RequestRange::file</a></div><div class="ttdeci">const char * file() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00266">disk-io-mgr.h:266</a></div></div> |
| <div class="ttc" id="classimpala_1_1ObjectPool_html"><div class="ttname"><a href="classimpala_1_1ObjectPool.html">impala::ObjectPool</a></div><div class="ttdef"><b>Definition:</b> <a href="object-pool_8h_source.html#l00030">object-pool.h:30</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a7f67b5041cef54b924855720f877883f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a7f67b5041cef54b924855720f877883f">impala::DiskIoMgr::RemoteS3DiskId</a></div><div class="ttdeci">int RemoteS3DiskId() const </div><div class="ttdoc">The disk ID (and therefore disk_queues_ index) used for S3 accesses. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00602">disk-io-mgr.h:602</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aa2be4e061eae7032c992a901a7670465"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aa2be4e061eae7032c992a901a7670465">impala::DiskIoMgr::WriteRangeHelper</a></div><div class="ttdeci">Status WriteRangeHelper(FILE *file_handle, WriteRange *write_range)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l01061">disk-io-mgr.cc:1061</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aa6a1a246f28ee5f8214cfdfd2dd8aa42"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aa6a1a246f28ee5f8214cfdfd2dd8aa42">impala::DiskIoMgr::AddScanRanges</a></div><div class="ttdeci">Status AddScanRanges(RequestContext *reader, const std::vector< ScanRange * > &ranges, bool schedule_immediately=false)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00455">disk-io-mgr.cc:455</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_aae6c216cb57b76594b0a107555a11ceb"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#aae6c216cb57b76594b0a107555a11ceb">impala::DiskIoMgr::RequestRange::offset</a></div><div class="ttdeci">int64_t offset() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00267">disk-io-mgr.h:267</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_af08c55c6b3ab4aa6f4d062637fd118bb"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#af08c55c6b3ab4aa6f4d062637fd118bb">impala::DiskIoMgr::BufferDescriptor::len</a></div><div class="ttdeci">int64_t len()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00201">disk-io-mgr.h:201</a></div></div> |
| <div class="ttc" id="classimpala_1_1AtomicInt_html"><div class="ttname"><a href="classimpala_1_1AtomicInt.html">impala::AtomicInt< int ></a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a0b8ff464b55bf723767102e4e0bd2c64"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a0b8ff464b55bf723767102e4e0bd2c64">impala::DiskIoMgr::RequestRange::request_type_</a></div><div class="ttdeci">RequestType::type request_type_</div><div class="ttdoc">The type of IO request, READ or WRITE. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00289">disk-io-mgr.h:289</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a3cc61c88ae6cbb96791d71aee1664137"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a3cc61c88ae6cbb96791d71aee1664137">impala::DiskIoMgr::GetNextRange</a></div><div class="ttdeci">Status GetNextRange(RequestContext *reader, ScanRange **range)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00501">disk-io-mgr.cc:501</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aa38c0d8f31a90a97cb7aab33592f6a12"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aa38c0d8f31a90a97cb7aab33592f6a12">impala::DiskIoMgr::shut_down_</a></div><div class="ttdeci">volatile bool shut_down_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00659">disk-io-mgr.h:659</a></div></div> |
| <div class="ttc" id="classimpala_1_1ThreadGroup_html"><div class="ttname"><a href="classimpala_1_1ThreadGroup.html">impala::ThreadGroup</a></div><div class="ttdef"><b>Definition:</b> <a href="thread_8h_source.html#l00161">thread.h:161</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a0a72cf459f78ac1d9c1d81ac2fad0c43"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a0a72cf459f78ac1d9c1d81ac2fad0c43">impala::DiskIoMgr::BufferDescriptor::scan_range_offset</a></div><div class="ttdeci">int64_t scan_range_offset() const </div><div class="ttdoc">Returns the offset within the scan range that this buffer starts at. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00205">disk-io-mgr.h:205</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a06c6694b1023dfad5af3a86a9e4775fa"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a06c6694b1023dfad5af3a86a9e4775fa">impala::DiskIoMgr::ScanRange::CleanupQueuedBuffers</a></div><div class="ttdeci">void CleanupQueuedBuffers()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00165">disk-io-mgr-scan-range.cc:165</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a501f1ef0a0ddce1507c99b8cf78745d2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a501f1ef0a0ddce1507c99b8cf78745d2">impala::DiskIoMgr::Read</a></div><div class="ttdeci">Status Read(RequestContext *reader, ScanRange *range, BufferDescriptor **buffer)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00555">disk-io-mgr.cc:555</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a5ac49168b2299c1cb18a58f3d777934d"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5ac49168b2299c1cb18a58f3d777934d">impala::DiskIoMgr::BufferDescriptor::Reset</a></div><div class="ttdeci">void Reset(RequestContext *reader, ScanRange *range, char *buffer, int64_t buffer_len)</div><div class="ttdoc">Resets the buffer descriptor state for a new reader, range and data buffer. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00165">disk-io-mgr.cc:165</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aca591719005e7c9a0cd8212d52f5e533"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aca591719005e7c9a0cd8212d52f5e533">impala::DiskIoMgr::free_buffers_idx</a></div><div class="ttdeci">int free_buffers_idx(int64_t buffer_size)</div><div class="ttdoc">Returns the index into free_buffers_ for a given buffer size. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l01095">disk-io-mgr.cc:1095</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="classimpala_1_1DiskIoMgr_1_1RequestRange_html_adb8c41a4455d2428ae01510d0640d6ff"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#adb8c41a4455d2428ae01510d0640d6ff">impala::DiskIoMgr::RequestRange::fs_</a></div><div class="ttdeci">hdfsFS fs_</div><div class="ttdoc">Hadoop filesystem that contains file_, or set to NULL for local filesystem. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00274">disk-io-mgr.h:274</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_af7def730f35abd7963b8776f4d8c8ccd"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#af7def730f35abd7963b8776f4d8c8ccd">impala::DiskIoMgr::ScanRange::expected_local_</a></div><div class="ttdeci">bool expected_local_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00386">disk-io-mgr.h:386</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a69df0692251b2de539072363366e9152"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a69df0692251b2de539072363366e9152">impala::DiskIoMgr::ScanRange::Read</a></div><div class="ttdeci">Status Read(char *buffer, int64_t *bytes_read, bool *eosr)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00360">disk-io-mgr-scan-range.cc:360</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ab59d92f6e237fcc86112fd39d56196fe"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ab59d92f6e237fcc86112fd39d56196fe">impala::DiskIoMgr::num_allocated_buffers</a></div><div class="ttdeci">int num_allocated_buffers() const </div><div class="ttdoc">Returns the number of allocated buffers. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00605">disk-io-mgr.h:605</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a1ce84f3fd78ec5c8492026cd22cd69e0"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a1ce84f3fd78ec5c8492026cd22cd69e0">impala::DiskIoMgr::ReturnBuffer</a></div><div class="ttdeci">void ReturnBuffer(BufferDescriptor *buffer)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00575">disk-io-mgr.cc:575</a></div></div> |
| <div class="ttc" id="thread_8h_html"><div class="ttname"><a href="thread_8h.html">thread.h</a></div></div> |
| <div class="ttc" id="object-pool_8h_html"><div class="ttname"><a href="object-pool_8h.html">object-pool.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a481cdceb304b7b12d06537e0e5c1af12"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a481cdceb304b7b12d06537e0e5c1af12">impala::DiskIoMgr::ScanRange::EnqueueBuffer</a></div><div class="ttdeci">bool EnqueueBuffer(BufferDescriptor *buffer)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00036">disk-io-mgr-scan-range.cc:36</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1WriteRange_html_a0b3583797f2589762de57408795ddd2f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a0b3583797f2589762de57408795ddd2f">impala::DiskIoMgr::WriteRange::SetData</a></div><div class="ttdeci">void SetData(const uint8_t *buffer, int64_t len)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00205">disk-io-mgr.cc:205</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_aa60da51cc9ffde2e69118edaa67a04c5"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa60da51cc9ffde2e69118edaa67a04c5">impala::DiskIoMgr::ScanRange::Open</a></div><div class="ttdeci">Status Open()</div><div class="ttdoc">Opens the file for this range. This function only modifies state in this range. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00251">disk-io-mgr-scan-range.cc:251</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a42195373c5e36118e61c50cb128d5744"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a42195373c5e36118e61c50cb128d5744">impala::DiskIoMgr::BufferDescriptor::buffer_len_</a></div><div class="ttdeci">int64_t buffer_len_</div><div class="ttdoc">length of buffer_. For buffers from cached reads, the length is 0. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00238">disk-io-mgr.h:238</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_1DiskIoMgr_1_1WriteRange_html_a10d69ddd36f090121e7a39ca2419ee57"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a10d69ddd36f090121e7a39ca2419ee57">impala::DiskIoMgr::WriteRange::data_</a></div><div class="ttdeci">const uint8_t * data_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00477">disk-io-mgr.h:477</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a5bf1e8da63fa9684a08688f7b94526e3"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a5bf1e8da63fa9684a08688f7b94526e3">impala::DiskIoMgr::ScanRange::Validate</a></div><div class="ttdeci">bool Validate()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00189">disk-io-mgr-scan-range.cc:189</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a9e7c7ff7fe7fa57e95d006fa9d494b8c"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a9e7c7ff7fe7fa57e95d006fa9d494b8c">impala::DiskIoMgr::BufferDescriptor::scan_range</a></div><div class="ttdeci">ScanRange * scan_range()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00198">disk-io-mgr.h:198</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1WriteRange_html_a82db7375774c322c2d5d9617a69ad352"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1WriteRange.html#a82db7375774c322c2d5d9617a69ad352">impala::DiskIoMgr::WriteRange::callback_</a></div><div class="ttdeci">WriteDoneCallback callback_</div><div class="ttdoc">Callback to invoke after the write is complete. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00480">disk-io-mgr.h:480</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a261c8db8366b023bd76e15c1549e74d0"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a261c8db8366b023bd76e15c1549e74d0">impala::DiskIoMgr::RequestRange::file_</a></div><div class="ttdeci">std::string file_</div><div class="ttdoc">Path to file being read or written. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00277">disk-io-mgr.h:277</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestContext_html"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestContext.html">impala::DiskIoMgr::RequestContext</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-internal_8h_source.html#l00122">disk-io-mgr-internal.h:122</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ab00029212e1b92f2ecb6014c63c204a2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ab00029212e1b92f2ecb6014c63c204a2">impala::DiskIoMgr::bytes_read_short_circuit</a></div><div class="ttdeci">int64_t bytes_read_short_circuit(RequestContext *reader) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00424">disk-io-mgr.cc:424</a></div></div> |
| <div class="ttc" id="structimpala_1_1DiskIoMgr_1_1RequestType_html_a9f42b7fd29382e30bae0bed0cefc7153a9f43978eee51c41a2b5eea4c302f54eb"><div class="ttname"><a href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153a9f43978eee51c41a2b5eea4c302f54eb">impala::DiskIoMgr::RequestType::WRITE</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00256">disk-io-mgr.h:256</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ae4b537022264309859ed8ac5db3f57db"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ae4b537022264309859ed8ac5db3f57db">impala::DiskIoMgr::ScanRange::eosr_returned_</a></div><div class="ttdeci">bool eosr_returned_</div><div class="ttdoc">If true, the last buffer for this scan range has been returned. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00419">disk-io-mgr.h:419</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a38f1ff36cae54028dc9fb426c49d3283"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a38f1ff36cae54028dc9fb426c49d3283">impala::DiskIoMgr::BufferDescriptor::scan_range_offset_</a></div><div class="ttdeci">int64_t scan_range_offset_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00249">disk-io-mgr.h:249</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a3a6605b8b52c766d1489af89f0a2ac43"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a3a6605b8b52c766d1489af89f0a2ac43">impala::DiskIoMgr::num_local_disks</a></div><div class="ttdeci">int num_local_disks() const </div><div class="ttdoc">Returns the number of local disks attached to the system. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00599">disk-io-mgr.h:599</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1WriteRange_html"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1WriteRange.html">impala::DiskIoMgr::WriteRange</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00455">disk-io-mgr.h:455</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a3c99177a95caa67739c8815c55eb3491"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a3c99177a95caa67739c8815c55eb3491">impala::DiskIoMgr::num_total_disks</a></div><div class="ttdeci">int num_total_disks() const </div><div class="ttdoc">Returns the total number of disk queues (both local and remote). </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00593">disk-io-mgr.h:593</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a6d28dec81a4ba603b90a39f286e177c0"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a6d28dec81a4ba603b90a39f286e177c0">impala::DiskIoMgr::ScanRange::io_mgr_</a></div><div class="ttdeci">DiskIoMgr * io_mgr_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00388">disk-io-mgr.h:388</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a44032d3a2a6760a534540b0d86c52cc6"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a44032d3a2a6760a534540b0d86c52cc6">impala::DiskIoMgr::DiskIoMgr</a></div><div class="ttdeci">DiskIoMgr()</div><div class="ttdoc">Create DiskIoMgr with default configs. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00219">disk-io-mgr.cc:219</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a5c61395734db9bf96ee0f7899bec860e"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a5c61395734db9bf96ee0f7899bec860e">impala::DiskIoMgr::BufferDescriptor::eosr_</a></div><div class="ttdeci">bool eosr_</div><div class="ttdoc">true if the current scan range is complete </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00244">disk-io-mgr.h:244</a></div></div> |
| <div class="ttc" id="bit-util_8h_html"><div class="ttname"><a href="bit-util_8h.html">bit-util.h</a></div></div> |
| <div class="ttc" id="structimpala_1_1DiskIoMgr_1_1RequestType_html_a9f42b7fd29382e30bae0bed0cefc7153"><div class="ttname"><a href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153">impala::DiskIoMgr::RequestType::type</a></div><div class="ttdeci">type</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00254">disk-io-mgr.h:254</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a0ba2f86ddaf75389adb493bdb0001929"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a0ba2f86ddaf75389adb493bdb0001929">impala::DiskIoMgr::DEFAULT_QUEUE_CAPACITY</a></div><div class="ttdeci">static const int DEFAULT_QUEUE_CAPACITY</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00619">disk-io-mgr.h:619</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_aa053d1fe13274c31c46108a627e47c34"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#aa053d1fe13274c31c46108a627e47c34">impala::DiskIoMgr::ScanRange::try_cache</a></div><div class="ttdeci">bool try_cache() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00313">disk-io-mgr.h:313</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a4e9d47a259b26f20c26a425b449c02db"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a4e9d47a259b26f20c26a425b449c02db">impala::DiskIoMgr::ScanRange::~ScanRange</a></div><div class="ttdeci">virtual ~ScanRange()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00210">disk-io-mgr-scan-range.cc:210</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a434c70e0f6a34982c92eb1deaae3bc2c"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a434c70e0f6a34982c92eb1deaae3bc2c">impala::DiskIoMgr::BufferDescriptor::SetMemTracker</a></div><div class="ttdeci">void SetMemTracker(MemTracker *tracker)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00187">disk-io-mgr.cc:187</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ad69740225431892ddb15723b3e5211c4"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ad69740225431892ddb15723b3e5211c4">impala::DiskIoMgr::ReturnFreeBuffer</a></div><div class="ttdeci">void ReturnFreeBuffer(char *buffer, int64_t buffer_size)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00696">disk-io-mgr.cc:696</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a7b7a12de61dd80ed3b3163192c3cac19"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a7b7a12de61dd80ed3b3163192c3cac19">impala::DiskIoMgr::set_disks_access_bitmap</a></div><div class="ttdeci">void set_disks_access_bitmap(RequestContext *, RuntimeProfile::Counter *)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00402">disk-io-mgr.cc:402</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ad953550311c262181c52df319cacf540"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ad953550311c262181c52df319cacf540">impala::DiskIoMgr::HandleReadFinished</a></div><div class="ttdeci">void HandleReadFinished(DiskQueue *, RequestContext *, BufferDescriptor *)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00866">disk-io-mgr.cc:866</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a4e51ca7003c842859a63e71930703e67"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a4e51ca7003c842859a63e71930703e67">impala::DiskIoMgr::ScanRange::eosr_queued_</a></div><div class="ttdeci">bool eosr_queued_</div><div class="ttdoc">If true, the last buffer for this scan range has been queued. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00416">disk-io-mgr.h:416</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a362c3f4466b42ff68dbb1aa444953b42"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a362c3f4466b42ff68dbb1aa444953b42">impala::DiskIoMgr::ScanRange::hdfs_file_</a></div><div class="ttdeci">hdfsFile hdfs_file_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00396">disk-io-mgr.h:396</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a8a6f863fbbfd6ff20f8c34e3164010bf"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a8a6f863fbbfd6ff20f8c34e3164010bf">impala::DiskIoMgr::ScanRange::ready_buffers_capacity</a></div><div class="ttdeci">int ready_buffers_capacity() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00315">disk-io-mgr.h:315</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a90831aea936eafbc9ad831dbfddcf25a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a90831aea936eafbc9ad831dbfddcf25a">impala::DiskIoMgr::process_mem_tracker_</a></div><div class="ttdeci">MemTracker * process_mem_tracker_</div><div class="ttdoc">Process memory tracker; needed to account for io buffers. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00639">disk-io-mgr.h:639</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a81d5e5e4dbe9e696deb160e45f6d51fb"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a81d5e5e4dbe9e696deb160e45f6d51fb">impala::DiskIoMgr::HandleWriteFinished</a></div><div class="ttdeci">void HandleWriteFinished(RequestContext *writer, WriteRange *write_range, const Status &write_status)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00845">disk-io-mgr.cc:845</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_abcf20ad952f31d948888d9834b64dd94"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#abcf20ad952f31d948888d9834b64dd94">impala::DiskIoMgr::set_bytes_read_counter</a></div><div class="ttdeci">void set_bytes_read_counter(RequestContext *, RuntimeProfile::Counter *)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00393">disk-io-mgr.cc:393</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a54e2b168c3a64a9250cac5069f85435d"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a54e2b168c3a64a9250cac5069f85435d">impala::DiskIoMgr::RequestRange::len</a></div><div class="ttdeci">int64_t len() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00268">disk-io-mgr.h:268</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a18797d98ff8df6a835c37baab65cddcc"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a18797d98ff8df6a835c37baab65cddcc">impala::DiskIoMgr::disk_thread_group_</a></div><div class="ttdeci">ThreadGroup disk_thread_group_</div><div class="ttdoc">Thread group containing all the worker threads. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00652">disk-io-mgr.h:652</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a3491a7be8222094756212884f2f20332"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a3491a7be8222094756212884f2f20332">impala::DiskIoMgr::ScanRange::status_</a></div><div class="ttdeci">Status status_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00413">disk-io-mgr.h:413</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a2cf57a30a890667743a870faa5f630a1"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2cf57a30a890667743a870faa5f630a1">impala::DiskIoMgr::ScanRange::Reset</a></div><div class="ttdeci">void Reset(hdfsFS fs, const char *file, int64_t len, int64_t offset, int disk_id, bool try_cache, bool expected_local, int64_t mtime, void *metadata=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00215">disk-io-mgr-scan-range.cc:215</a></div></div> |
| <div class="ttc" id="atomic_8h_html"><div class="ttname"><a href="atomic_8h.html">atomic.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a495366bfbc69a8a08eda7f6af084e30d"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a495366bfbc69a8a08eda7f6af084e30d">impala::DiskIoMgr::free_buffers_lock_</a></div><div class="ttdeci">boost::mutex free_buffers_lock_</div><div class="ttdoc">Protects free_buffers_ and free_buffer_descs_. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00674">disk-io-mgr.h:674</a></div></div> |
| <div class="ttc" id="classimpala_1_1MemTracker_html"><div class="ttname"><a href="classimpala_1_1MemTracker.html">impala::MemTracker</a></div><div class="ttdoc">This class is thread-safe. </div><div class="ttdef"><b>Definition:</b> <a href="mem-tracker_8h_source.html#l00061">mem-tracker.h:61</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html">impala::DiskIoMgr</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00188">disk-io-mgr.h:188</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ae98884865bff90f5bad4a6d814ac735a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ae98884865bff90f5bad4a6d814ac735a">impala::DiskIoMgr::total_bytes_read_counter_</a></div><div class="ttdeci">RuntimeProfile::Counter total_bytes_read_counter_</div><div class="ttdoc">Total bytes read by the IoMgr. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00662">disk-io-mgr.h:662</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a4431510659aedf1fa38e042e4196f415"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a4431510659aedf1fa38e042e4196f415">impala::DiskIoMgr::GcIoBuffers</a></div><div class="ttdeci">void GcIoBuffers()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00661">disk-io-mgr.cc:661</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a8f44409df7a76852f884b5775d28ae2a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a8f44409df7a76852f884b5775d28ae2a">impala::DiskIoMgr::BufferDescriptor::BufferDescriptor</a></div><div class="ttdeci">BufferDescriptor(DiskIoMgr *io_mgr)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00161">disk-io-mgr.cc:161</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a1f395d25efb9b131b51dba0a540e56b6"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a1f395d25efb9b131b51dba0a540e56b6">impala::DiskIoMgr::BufferDescriptor::reader_</a></div><div class="ttdeci">RequestContext * reader_</div><div class="ttdoc">Reader that this buffer is for. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00226">disk-io-mgr.h:226</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a33247232dd2e5de8196df1179dc29281"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a33247232dd2e5de8196df1179dc29281">impala::DiskIoMgr::BufferDescriptor::len_</a></div><div class="ttdeci">int64_t len_</div><div class="ttdoc">length of read contents </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00241">disk-io-mgr.h:241</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_ad2a01828c28b87d5f471814ce970c63b"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#ad2a01828c28b87d5f471814ce970c63b">impala::DiskIoMgr::BufferDescriptor::eosr</a></div><div class="ttdeci">bool eosr()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00202">disk-io-mgr.h:202</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a44291cd2e1ffe1bebffebc531b36aac4"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a44291cd2e1ffe1bebffebc531b36aac4">impala::DiskIoMgr::ScanRange::reader_</a></div><div class="ttdeci">RequestContext * reader_</div><div class="ttdoc">Reader/owner of the scan range. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00391">disk-io-mgr.h:391</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a998dafa247fd5bcac1b5a30232fb9d17"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a998dafa247fd5bcac1b5a30232fb9d17">impala::DiskIoMgr::disk_queues_</a></div><div class="ttdeci">std::vector< DiskQueue * > disk_queues_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00701">disk-io-mgr.h:701</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ae45a6778f947e194d7665fa340be2a95"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ae45a6778f947e194d7665fa340be2a95">impala::DiskIoMgr::max_buffer_size_</a></div><div class="ttdeci">const int max_buffer_size_</div><div class="ttdoc">Maximum read size. This is also the maximum size of each allocated buffer. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00646">disk-io-mgr.h:646</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a57983bd0c63fe17cfc4baec245168991"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a57983bd0c63fe17cfc4baec245168991">impala::DiskIoMgr::ScanRange::NEVER_CACHE</a></div><div class="ttdeci">static const int64_t NEVER_CACHE</div><div class="ttdoc">If the mtime is set to NEVER_CACHE, the file handle should never be cached. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00299">disk-io-mgr.h:299</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a1991e70528bab13363e3592d174d7a12"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a1991e70528bab13363e3592d174d7a12">impala::DiskIoMgr::Init</a></div><div class="ttdeci">Status Init(MemTracker *process_mem_tracker)</div><div class="ttdoc">Initialize the IoMgr. Must be called once before any of the other APIs. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00296">disk-io-mgr.cc:296</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a22f6b26648d0b3878e417cf087b2ee89"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a22f6b26648d0b3878e417cf087b2ee89">impala::DiskIoMgr::bytes_read_local</a></div><div class="ttdeci">int64_t bytes_read_local(RequestContext *reader) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00420">disk-io-mgr.cc:420</a></div></div> |
| <div class="ttc" id="structimpala_1_1DiskIoMgr_1_1RequestType_html_a9f42b7fd29382e30bae0bed0cefc7153ad437bd8b09af2a55106ba81f5887e358"><div class="ttname"><a href="structimpala_1_1DiskIoMgr_1_1RequestType.html#a9f42b7fd29382e30bae0bed0cefc7153ad437bd8b09af2a55106ba81f5887e358">impala::DiskIoMgr::RequestType::READ</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00255">disk-io-mgr.h:255</a></div></div> |
| <div class="ttc" id="hdfs_8h_html"><div class="ttname"><a href="hdfs_8h.html">hdfs.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a2ca6fafcd74e8d3ccd30ef1dd44a6479"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2ca6fafcd74e8d3ccd30ef1dd44a6479">impala::DiskIoMgr::ScanRange::is_cancelled_</a></div><div class="ttdeci">bool is_cancelled_</div><div class="ttdoc">If true, this scan range has been cancelled. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00445">disk-io-mgr.h:445</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a14075f3a05d02ac5fec5e92a33fe3a9f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a14075f3a05d02ac5fec5e92a33fe3a9f">impala::DiskIoMgr::ScanRange::mtime</a></div><div class="ttdeci">int64_t mtime() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00333">disk-io-mgr.h:333</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a78c14580725060483f5bbd1aaf24fa29"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a78c14580725060483f5bbd1aaf24fa29">impala::DiskIoMgr::Validate</a></div><div class="ttdeci">bool Validate() const </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_1DiskIoMgr_html_af1c05277e3e3ce9b9b00fecbd7130b31"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#af1c05277e3e3ce9b9b00fecbd7130b31">impala::DiskIoMgr::DiskIoMgrTest_Buffers_Test</a></div><div class="ttdeci">friend class DiskIoMgrTest_Buffers_Test</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00631">disk-io-mgr.h:631</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a47f9eb99e3e705017d17dffddbea38b2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a47f9eb99e3e705017d17dffddbea38b2">impala::DiskIoMgr::RegisterContext</a></div><div class="ttdeci">Status RegisterContext(RequestContext **request_context, MemTracker *reader_mem_tracker=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00336">disk-io-mgr.cc:336</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a053f427bbc4edd04f30c17410ff66a27"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a053f427bbc4edd04f30c17410ff66a27">impala::DiskIoMgr::ReadRange</a></div><div class="ttdeci">void ReadRange(DiskQueue *disk_queue, RequestContext *reader, ScanRange *range)</div><div class="ttdoc">Reads the specified scan range and calls HandleReadFinished when done. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00954">disk-io-mgr.cc:954</a></div></div> |
| <div class="ttc" id="classimpala_1_1InternalQueue_html"><div class="ttname"><a href="classimpala_1_1InternalQueue.html">impala::InternalQueue</a></div><div class="ttdoc">T must be a subclass of InternalQueue::Node. </div><div class="ttdef"><b>Definition:</b> <a href="internal-queue_8h_source.html#l00040">internal-queue.h:40</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aa3bba021605906306bbbf5daddf95d95"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aa3bba021605906306bbbf5daddf95d95">impala::DiskIoMgr::GetFreeBuffer</a></div><div class="ttdeci">char * GetFreeBuffer(int64_t *buffer_size)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00627">disk-io-mgr.cc:627</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a5b5c378a1ec75719e7ead0fdd6fb2137"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a5b5c378a1ec75719e7ead0fdd6fb2137">impala::DiskIoMgr::RequestRange::disk_id</a></div><div class="ttdeci">int disk_id() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00269">disk-io-mgr.h:269</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a38bde6fa6ddcd0ae546a3e52e00cb5ff"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a38bde6fa6ddcd0ae546a3e52e00cb5ff">impala::DiskIoMgr::DebugString</a></div><div class="ttdeci">std::string DebugString()</div><div class="ttdoc">Dumps the disk IoMgr queues (for readers and disks) </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00142">disk-io-mgr.cc:142</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ad74e32e4d268c24bcfda3b8d30dd3423"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad74e32e4d268c24bcfda3b8d30dd3423">impala::DiskIoMgr::ScanRange::GetNext</a></div><div class="ttdeci">Status GetNext(BufferDescriptor **buffer)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00070">disk-io-mgr-scan-range.cc:70</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ac1667f99ab4e2d534fc6cf0e2cc8e39e"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ac1667f99ab4e2d534fc6cf0e2cc8e39e">impala::DiskIoMgr::ScanRange::blocked_on_queue_</a></div><div class="ttdeci">bool blocked_on_queue_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00423">disk-io-mgr.h:423</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a2839ff479726a23d097bb36a798f0d37"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a2839ff479726a23d097bb36a798f0d37">impala::DiskIoMgr::ScanRange::expected_local</a></div><div class="ttdeci">bool expected_local() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00314">disk-io-mgr.h:314</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a583a2843998adf92297ec9cf8eccbad8"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a583a2843998adf92297ec9cf8eccbad8">impala::DiskIoMgr::BufferDescriptor::scan_range_</a></div><div class="ttdeci">ScanRange * scan_range_</div><div class="ttdoc">Scan range that this buffer is for. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00232">disk-io-mgr.h:232</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a1d1b000a66d4456365e4f9fbf6cb896f"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a1d1b000a66d4456365e4f9fbf6cb896f">impala::DiskIoMgr::unexpected_remote_bytes</a></div><div class="ttdeci">int64_t unexpected_remote_bytes(RequestContext *reader) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00436">disk-io-mgr.cc:436</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_aae839241cba91ebc6774fc4e2bc384e0"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#aae839241cba91ebc6774fc4e2bc384e0">impala::DiskIoMgr::BufferDescriptor::buffer_len</a></div><div class="ttdeci">int64_t buffer_len()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00200">disk-io-mgr.h:200</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a9f81e48ed3492b090a38a8ac9d90cc97"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a9f81e48ed3492b090a38a8ac9d90cc97">impala::DiskIoMgr::set_read_timer</a></div><div class="ttdeci">void set_read_timer(RequestContext *, RuntimeProfile::Counter *)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00389">disk-io-mgr.cc:389</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_adec04dbe4da9c161e451e77e7cb0f4c2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#adec04dbe4da9c161e451e77e7cb0f4c2">impala::DiskIoMgr::ScanRange::ready_buffers_</a></div><div class="ttdeci">std::list< BufferDescriptor * > ready_buffers_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00428">disk-io-mgr.h:428</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ad8783219791e9665664c6da018dde5a8"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad8783219791e9665664c6da018dde5a8">impala::DiskIoMgr::ScanRange::ready_buffers_capacity_</a></div><div class="ttdeci">int ready_buffers_capacity_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00434">disk-io-mgr.h:434</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a7d36aced0a014a075a0a726ecc12c978"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a7d36aced0a014a075a0a726ecc12c978">impala::DiskIoMgr::ScanRange::try_cache_</a></div><div class="ttdeci">bool try_cache_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00379">disk-io-mgr.h:379</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1BufferDescriptor_html_a258f4e13d2729f1a5fa395376db97cfe"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1BufferDescriptor.html#a258f4e13d2729f1a5fa395376db97cfe">impala::DiskIoMgr::BufferDescriptor::Return</a></div><div class="ttdeci">void Return()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00182">disk-io-mgr.cc:182</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_a9c4ffc24f68349da818a4c0519c0e792"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#a9c4ffc24f68349da818a4c0519c0e792">impala::DiskIoMgr::RequestRange::disk_id_</a></div><div class="ttdeci">int disk_id_</div><div class="ttdoc">Id of disk containing file_;. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00286">disk-io-mgr.h:286</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a234649f13d6930779d0fd6ae871f7bee"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a234649f13d6930779d0fd6ae871f7bee">impala::DiskIoMgr::GetBufferDesc</a></div><div class="ttdeci">BufferDescriptor * GetBufferDesc(RequestContext *reader, ScanRange *range, char *buffer, int64_t buffer_size)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00610">disk-io-mgr.cc:610</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a0ca2db2159fc27588ea77dc43c6b32f1"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a0ca2db2159fc27588ea77dc43c6b32f1">impala::DiskIoMgr::pool_</a></div><div class="ttdeci">ObjectPool pool_</div><div class="ttdoc">Pool to allocate BufferDescriptors. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00636">disk-io-mgr.h:636</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a602c11c00e5824f4b75ca325bcb1ff74"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a602c11c00e5824f4b75ca325bcb1ff74">impala::DiskIoMgr::ValidateScanRange</a></div><div class="ttdeci">Status ValidateScanRange(ScanRange *range)</div><div class="ttdoc">Validates that range is correctly initialized. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00444">disk-io-mgr.cc:444</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a4d68607c8cf8f9003f47891af6627103"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a4d68607c8cf8f9003f47891af6627103">impala::DiskIoMgr::max_read_buffer_size</a></div><div class="ttdeci">int max_read_buffer_size() const </div><div class="ttdoc">Returns the maximum read buffer size. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00590">disk-io-mgr.h:590</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a8550d90be93435c85ea623ed75c02a6a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a8550d90be93435c85ea623ed75c02a6a">impala::DiskIoMgr::GetNextRequestRange</a></div><div class="ttdeci">bool GetNextRequestRange(DiskQueue *disk_queue, RequestRange **range, RequestContext **request_context)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00730">disk-io-mgr.cc:730</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a59189dd1e2ba483252dca9043602e32b"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a59189dd1e2ba483252dca9043602e32b">impala::DiskIoMgr::free_buffers_</a></div><div class="ttdeci">std::vector< std::list< char * > > free_buffers_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00687">disk-io-mgr.h:687</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a9da7b7ab087a11a5489f533fed8406c6"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a9da7b7ab087a11a5489f533fed8406c6">impala::DiskIoMgr::ScanRange::bytes_read_</a></div><div class="ttdeci">int bytes_read_</div><div class="ttdoc">Number of bytes read so far for this scan range. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00408">disk-io-mgr.h:408</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1RequestRange_html_ac324726e966f9430196abcdbabd4e907"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1RequestRange.html#ac324726e966f9430196abcdbabd4e907">impala::DiskIoMgr::RequestRange::fs</a></div><div class="ttdeci">hdfsFS fs() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00265">disk-io-mgr.h:265</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_aabb61890cd37be80703ae735e2a075ada4dce4311f2a962cc1e369379f9ffedf2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#aabb61890cd37be80703ae735e2a075ada4dce4311f2a962cc1e369379f9ffedf2">impala::DiskIoMgr::REMOTE_S3_DISK_OFFSET</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00624">disk-io-mgr.h:624</a></div></div> |
| <div class="ttc" id="thread-resource-mgr_8h_html"><div class="ttname"><a href="thread-resource-mgr_8h.html">thread-resource-mgr.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a485843dc3adafd9f1080877dc1a4e742"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a485843dc3adafd9f1080877dc1a4e742">impala::DiskIoMgr::ScanRange::cached_buffer_</a></div><div class="ttdeci">struct hadoopRzBuffer * cached_buffer_</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00401">disk-io-mgr.h:401</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a5866ae8c5fa197ec221cbd29c02536a5"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a5866ae8c5fa197ec221cbd29c02536a5">impala::DiskIoMgr::ScanRange::meta_data</a></div><div class="ttdeci">void * meta_data() const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00312">disk-io-mgr.h:312</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_afe8b988e8dafada5140b99d7f9688e39"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#afe8b988e8dafada5140b99d7f9688e39">impala::DiskIoMgr::ScanRange::MaxReadChunkSize</a></div><div class="ttdeci">int64_t MaxReadChunkSize() const </div><div class="ttdoc">Maximum length in bytes for hdfsRead() calls. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00343">disk-io-mgr-scan-range.cc:343</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a81505e1ed7d182de96996bfb18e62df0"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a81505e1ed7d182de96996bfb18e62df0">impala::DiskIoMgr::ScanRange::DebugString</a></div><div class="ttdeci">std::string DebugString() const </div><div class="ttdoc">return a descriptive string for debug. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00179">disk-io-mgr-scan-range.cc:179</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ac8e9f578c5a9e278add1859d37cbd08a"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ac8e9f578c5a9e278add1859d37cbd08a">impala::DiskIoMgr::~DiskIoMgr</a></div><div class="ttdeci">~DiskIoMgr()</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00250">disk-io-mgr.cc:250</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a05a2eca77321958ca3e6e3784ab2efcc"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a05a2eca77321958ca3e6e3784ab2efcc">impala::DiskIoMgr::num_unstarted_ranges</a></div><div class="ttdeci">int num_unstarted_ranges(RequestContext *reader) const </div><div class="ttdoc">Returns the number of unstarted scan ranges for this reader. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00416">disk-io-mgr.cc:416</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a83daff34ce9a9d8eadbfff528e28eb56"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a83daff34ce9a9d8eadbfff528e28eb56">impala::DiskIoMgr::WorkLoop</a></div><div class="ttdeci">void WorkLoop(DiskQueue *queue)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00920">disk-io-mgr.cc:920</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ad0c786983470478c771a25f2201212b1"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ad0c786983470478c771a25f2201212b1">impala::DiskIoMgr::ScanRange::ReadFromCache</a></div><div class="ttdeci">Status ReadFromCache(bool *read_succeeded)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00404">disk-io-mgr-scan-range.cc:404</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html">impala::DiskIoMgr::ScanRange</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00295">disk-io-mgr.h:295</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_ac06d77ef42b00861c919df2a5cf32722"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#ac06d77ef42b00861c919df2a5cf32722">impala::DiskIoMgr::ScanRange::Cancel</a></div><div class="ttdeci">void Cancel(const Status &status)</div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00143">disk-io-mgr-scan-range.cc:143</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a9824ef6a01d96312a2c7a9f7c13b7809"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a9824ef6a01d96312a2c7a9f7c13b7809">impala::DiskIoMgr::read_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter read_timer_</div><div class="ttdoc">Total time spent in hdfs reading. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00665">disk-io-mgr.h:665</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_ac5ce912576b754a61f9e1b61f2d2b4ea"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#ac5ce912576b754a61f9e1b61f2d2b4ea">impala::DiskIoMgr::context_status</a></div><div class="ttdeci">Status context_status(RequestContext *context) const </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00411">disk-io-mgr.cc:411</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_html_a54bb2885167cd44d2ca2469d28f0fa52"><div class="ttname"><a href="classimpala_1_1DiskIoMgr.html#a54bb2885167cd44d2ca2469d28f0fa52">impala::DiskIoMgr::num_buffers_in_readers</a></div><div class="ttdeci">int num_buffers_in_readers() const </div><div class="ttdoc">Returns the number of buffers currently owned by all readers. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00608">disk-io-mgr.h:608</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a15f6183f3d2570adb418d200006debc2"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a15f6183f3d2570adb418d200006debc2">impala::DiskIoMgr::ScanRange::Close</a></div><div class="ttdeci">void Close()</div><div class="ttdoc">Closes the file for this range. This function only modifies state in this range. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr-scan-range_8cc_source.html#l00301">disk-io-mgr-scan-range.cc:301</a></div></div> |
| <div class="ttc" id="classimpala_1_1DiskIoMgr_1_1ScanRange_html_a249dcbdcbefd6f92fc6903a689fc9389"><div class="ttname"><a href="classimpala_1_1DiskIoMgr_1_1ScanRange.html#a249dcbdcbefd6f92fc6903a689fc9389">impala::DiskIoMgr::ScanRange::mtime_</a></div><div class="ttdeci">int64_t mtime_</div><div class="ttdoc">Last modified time of the file associated with the scan range. </div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8h_source.html#l00448">disk-io-mgr.h:448</a></div></div> |
| <div class="ttc" id="classDiskIoMgr_1_1RequestContextCache_html"><div class="ttname"><a href="classDiskIoMgr_1_1RequestContextCache.html">impala::DiskIoMgr::RequestContextCache</a></div><div class="ttdef"><b>Definition:</b> <a href="disk-io-mgr_8cc_source.html#l00069">disk-io-mgr.cc:69</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="disk-io-mgr_8h.html">disk-io-mgr.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> |
