| <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> |
| <html xmlns="http://www.w3.org/1999/xhtml"> |
| <head> |
| <meta http-equiv="Content-Type" content="text/xhtml;charset=UTF-8"/> |
| <meta http-equiv="X-UA-Compatible" content="IE=9"/> |
| <meta name="generator" content="Doxygen 1.8.6"/> |
| <title>Impala: be/src/runtime/buffered-tuple-stream-test.cc Source File</title> |
| <link href="tabs.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="jquery.js"></script> |
| <script type="text/javascript" src="dynsections.js"></script> |
| <link href="navtree.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="resize.js"></script> |
| <script type="text/javascript" src="navtree.js"></script> |
| <script type="text/javascript"> |
| $(document).ready(initResizable); |
| $(window).load(resizeHeight); |
| </script> |
| <link href="search/search.css" rel="stylesheet" type="text/css"/> |
| <script type="text/javascript" src="search/search.js"></script> |
| <script type="text/javascript"> |
| $(document).ready(function() { searchBox.OnSelectItem(0); }); |
| </script> |
| <link href="doxygen.css" rel="stylesheet" type="text/css" /> |
| </head> |
| <body> |
| <div id="top"><!-- do not remove this div, it is closed by doxygen! --> |
| <div id="titlearea"> |
| <table cellspacing="0" cellpadding="0"> |
| <tbody> |
| <tr style="height: 56px;"> |
| <td style="padding-left: 0.5em;"> |
| <div id="projectname">Impala |
| </div> |
| <div id="projectbrief">Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.</div> |
| </td> |
| </tr> |
| </tbody> |
| </table> |
| </div> |
| <!-- end header part --> |
| <!-- Generated by Doxygen 1.8.6 --> |
| <script type="text/javascript"> |
| var searchBox = new SearchBox("searchBox", "search",false,'Search'); |
| </script> |
| <div id="navrow1" class="tabs"> |
| <ul class="tablist"> |
| <li><a href="index.html"><span>Main Page</span></a></li> |
| <li><a href="namespaces.html"><span>Namespaces</span></a></li> |
| <li><a href="annotated.html"><span>Classes</span></a></li> |
| <li class="current"><a href="files.html"><span>Files</span></a></li> |
| <li> |
| <div id="MSearchBox" class="MSearchBoxInactive"> |
| <span class="left"> |
| <img id="MSearchSelect" src="search/mag_sel.png" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| alt=""/> |
| <input type="text" id="MSearchField" value="Search" accesskey="S" |
| onfocus="searchBox.OnSearchFieldFocus(true)" |
| onblur="searchBox.OnSearchFieldFocus(false)" |
| onkeyup="searchBox.OnSearchFieldChange(event)"/> |
| </span><span class="right"> |
| <a id="MSearchClose" href="javascript:searchBox.CloseResultsWindow()"><img id="MSearchCloseImg" border="0" src="search/close.png" alt=""/></a> |
| </span> |
| </div> |
| </li> |
| </ul> |
| </div> |
| <div id="navrow2" class="tabs2"> |
| <ul class="tablist"> |
| <li><a href="files.html"><span>File List</span></a></li> |
| <li><a href="globals.html"><span>File Members</span></a></li> |
| </ul> |
| </div> |
| </div><!-- top --> |
| <div id="side-nav" class="ui-resizable side-nav-resizable"> |
| <div id="nav-tree"> |
| <div id="nav-tree-contents"> |
| <div id="nav-sync" class="sync"></div> |
| </div> |
| </div> |
| <div id="splitbar" style="-moz-user-select:none;" |
| class="ui-resizable-handle"> |
| </div> |
| </div> |
| <script type="text/javascript"> |
| $(document).ready(function(){initNavTree('buffered-tuple-stream-test_8cc_source.html','');}); |
| </script> |
| <div id="doc-content"> |
| <!-- window showing the filter options --> |
| <div id="MSearchSelectWindow" |
| onmouseover="return searchBox.OnSearchSelectShow()" |
| onmouseout="return searchBox.OnSearchSelectHide()" |
| onkeydown="return searchBox.OnSearchSelectKey(event)"> |
| <a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(0)"><span class="SelectionMark"> </span>All</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(1)"><span class="SelectionMark"> </span>Classes</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(2)"><span class="SelectionMark"> </span>Namespaces</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(3)"><span class="SelectionMark"> </span>Files</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(4)"><span class="SelectionMark"> </span>Functions</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(5)"><span class="SelectionMark"> </span>Variables</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(6)"><span class="SelectionMark"> </span>Typedefs</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(7)"><span class="SelectionMark"> </span>Enumerations</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(8)"><span class="SelectionMark"> </span>Enumerator</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(9)"><span class="SelectionMark"> </span>Friends</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(10)"><span class="SelectionMark"> </span>Macros</a></div> |
| |
| <!-- iframe showing the search results (closed by default) --> |
| <div id="MSearchResultsWindow"> |
| <iframe src="javascript:void(0)" frameborder="0" |
| name="MSearchResults" id="MSearchResults"> |
| </iframe> |
| </div> |
| |
| <div class="header"> |
| <div class="headertitle"> |
| <div class="title">buffered-tuple-stream-test.cc</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| <a href="buffered-tuple-stream-test_8cc.html">Go to the documentation of this file.</a><div class="fragment"><div class="line"><a name="l00001"></a><span class="lineno"> 1</span> <span class="comment">// Copyright 2012 Cloudera Inc.</span></div> |
| <div class="line"><a name="l00002"></a><span class="lineno"> 2</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00003"></a><span class="lineno"> 3</span> <span class="comment">// Licensed under the Apache License, Version 2.0 (the "License");</span></div> |
| <div class="line"><a name="l00004"></a><span class="lineno"> 4</span> <span class="comment">// you may not use this file except in compliance with the License.</span></div> |
| <div class="line"><a name="l00005"></a><span class="lineno"> 5</span> <span class="comment">// You may obtain a copy of the License at</span></div> |
| <div class="line"><a name="l00006"></a><span class="lineno"> 6</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00007"></a><span class="lineno"> 7</span> <span class="comment">// http://www.apache.org/licenses/LICENSE-2.0</span></div> |
| <div class="line"><a name="l00008"></a><span class="lineno"> 8</span> <span class="comment">//</span></div> |
| <div class="line"><a name="l00009"></a><span class="lineno"> 9</span> <span class="comment">// Unless required by applicable law or agreed to in writing, software</span></div> |
| <div class="line"><a name="l00010"></a><span class="lineno"> 10</span> <span class="comment">// distributed under the License is distributed on an "AS IS" BASIS,</span></div> |
| <div class="line"><a name="l00011"></a><span class="lineno"> 11</span> <span class="comment">// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.</span></div> |
| <div class="line"><a name="l00012"></a><span class="lineno"> 12</span> <span class="comment">// See the License for the specific language governing permissions and</span></div> |
| <div class="line"><a name="l00013"></a><span class="lineno"> 13</span> <span class="comment">// limitations under the License.</span></div> |
| <div class="line"><a name="l00014"></a><span class="lineno"> 14</span> </div> |
| <div class="line"><a name="l00015"></a><span class="lineno"> 15</span> <span class="preprocessor">#include <boost/scoped_ptr.hpp></span></div> |
| <div class="line"><a name="l00016"></a><span class="lineno"> 16</span> <span class="preprocessor">#include <boost/bind.hpp></span></div> |
| <div class="line"><a name="l00017"></a><span class="lineno"> 17</span> <span class="preprocessor">#include <boost/filesystem.hpp></span></div> |
| <div class="line"><a name="l00018"></a><span class="lineno"> 18</span> </div> |
| <div class="line"><a name="l00019"></a><span class="lineno"> 19</span> <span class="preprocessor">#include <gtest/gtest.h></span></div> |
| <div class="line"><a name="l00020"></a><span class="lineno"> 20</span> </div> |
| <div class="line"><a name="l00021"></a><span class="lineno"> 21</span> <span class="preprocessor">#include <string></span></div> |
| <div class="line"><a name="l00022"></a><span class="lineno"> 22</span> <span class="preprocessor">#include <limits></span> <span class="comment">// for std::numeric_limits<int>::max()</span></div> |
| <div class="line"><a name="l00023"></a><span class="lineno"> 23</span> </div> |
| <div class="line"><a name="l00024"></a><span class="lineno"> 24</span> <span class="preprocessor">#include "<a class="code" href="llvm-codegen_8h.html">codegen/llvm-codegen.h</a>"</span></div> |
| <div class="line"><a name="l00025"></a><span class="lineno"> 25</span> <span class="preprocessor">#include "<a class="code" href="init_8h.html">common/init.h</a>"</span></div> |
| <div class="line"><a name="l00026"></a><span class="lineno"> 26</span> <span class="preprocessor">#include "<a class="code" href="buffered-tuple-stream_8inline_8h.html">runtime/buffered-tuple-stream.inline.h</a>"</span></div> |
| <div class="line"><a name="l00027"></a><span class="lineno"> 27</span> <span class="preprocessor">#include "<a class="code" href="row-batch_8h.html">runtime/row-batch.h</a>"</span></div> |
| <div class="line"><a name="l00028"></a><span class="lineno"> 28</span> <span class="preprocessor">#include "<a class="code" href="tmp-file-mgr_8h.html">runtime/tmp-file-mgr.h</a>"</span></div> |
| <div class="line"><a name="l00029"></a><span class="lineno"> 29</span> <span class="preprocessor">#include "<a class="code" href="string-value_8h.html">runtime/string-value.h</a>"</span></div> |
| <div class="line"><a name="l00030"></a><span class="lineno"> 30</span> <span class="preprocessor">#include "<a class="code" href="fe-support_8h.html">service/fe-support.h</a>"</span></div> |
| <div class="line"><a name="l00031"></a><span class="lineno"> 31</span> <span class="preprocessor">#include "<a class="code" href="desc-tbl-builder_8h.html">testutil/desc-tbl-builder.h</a>"</span></div> |
| <div class="line"><a name="l00032"></a><span class="lineno"> 32</span> <span class="preprocessor">#include "<a class="code" href="test-info_8h.html">util/test-info.h</a>"</span></div> |
| <div class="line"><a name="l00033"></a><span class="lineno"> 33</span> </div> |
| <div class="line"><a name="l00034"></a><span class="lineno"> 34</span> <span class="preprocessor">#include "gen-cpp/Types_types.h"</span></div> |
| <div class="line"><a name="l00035"></a><span class="lineno"> 35</span> <span class="preprocessor">#include "gen-cpp/ImpalaInternalService_types.h"</span></div> |
| <div class="line"><a name="l00036"></a><span class="lineno"> 36</span> </div> |
| <div class="line"><a name="l00037"></a><span class="lineno"> 37</span> <span class="preprocessor">#include "<a class="code" href="names_8h.html">common/names.h</a>"</span></div> |
| <div class="line"><a name="l00038"></a><span class="lineno"> 38</span> </div> |
| <div class="line"><a name="l00039"></a><span class="lineno"><a class="line" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f"> 39</a></span> <span class="keyword">const</span> <span class="keywordtype">int</span> <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a> = 250;</div> |
| <div class="line"><a name="l00040"></a><span class="lineno"> 40</span> </div> |
| <div class="line"><a name="l00041"></a><span class="lineno"> 41</span> <span class="keyword">namespace </span>impala {</div> |
| <div class="line"><a name="l00042"></a><span class="lineno"> 42</span> </div> |
| <div class="line"><a name="l00043"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb"> 43</a></span> <span class="keyword">static</span> <span class="keyword">const</span> <a class="code" href="structimpala_1_1StringValue.html">StringValue</a> <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[] = {</div> |
| <div class="line"><a name="l00044"></a><span class="lineno"> 44</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"ABC"</span>),</div> |
| <div class="line"><a name="l00045"></a><span class="lineno"> 45</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"HELLO"</span>),</div> |
| <div class="line"><a name="l00046"></a><span class="lineno"> 46</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"123456789"</span>),</div> |
| <div class="line"><a name="l00047"></a><span class="lineno"> 47</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"FOOBAR"</span>),</div> |
| <div class="line"><a name="l00048"></a><span class="lineno"> 48</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"ONE"</span>),</div> |
| <div class="line"><a name="l00049"></a><span class="lineno"> 49</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"THREE"</span>),</div> |
| <div class="line"><a name="l00050"></a><span class="lineno"> 50</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"abcdefghijklmno"</span>),</div> |
| <div class="line"><a name="l00051"></a><span class="lineno"> 51</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"aaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"</span>),</div> |
| <div class="line"><a name="l00052"></a><span class="lineno"> 52</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>(<span class="stringliteral">"bbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbbb"</span>),</div> |
| <div class="line"><a name="l00053"></a><span class="lineno"> 53</span> };</div> |
| <div class="line"><a name="l00054"></a><span class="lineno"> 54</span> </div> |
| <div class="line"><a name="l00055"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db"> 55</a></span> <span class="keyword">static</span> <span class="keyword">const</span> <span class="keywordtype">int</span> <a class="code" href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db">NUM_STRINGS</a> = <span class="keyword">sizeof</span>(<a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>) / <span class="keyword">sizeof</span>(<a class="code" href="structimpala_1_1StringValue.html">StringValue</a>);</div> |
| <div class="line"><a name="l00056"></a><span class="lineno"> 56</span> </div> |
| <div class="line"><a name="l00057"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html"> 57</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a> : <span class="keyword">public</span> <a class="code" href="cache-hash-test_8cc.html#a18269e3eecadb27e79614c02d898173e">testing::Test</a> {</div> |
| <div class="line"><a name="l00058"></a><span class="lineno"> 58</span>  <span class="keyword">protected</span>:</div> |
| <div class="line"><a name="l00059"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#aebc94f14ef6ae0e05a64686d281df151"> 59</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#aebc94f14ef6ae0e05a64686d281df151">SetUp</a>() {</div> |
| <div class="line"><a name="l00060"></a><span class="lineno"> 60</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911">exec_env_</a>.reset(<span class="keyword">new</span> <a class="code" href="classimpala_1_1ExecEnv.html">ExecEnv</a>);</div> |
| <div class="line"><a name="l00061"></a><span class="lineno"> 61</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911">exec_env_</a>->disk_io_mgr()->Init(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>);</div> |
| <div class="line"><a name="l00062"></a><span class="lineno"> 62</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>.reset(</div> |
| <div class="line"><a name="l00063"></a><span class="lineno"> 63</span>  <span class="keyword">new</span> <a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>(TPlanFragmentInstanceCtx(), <span class="stringliteral">""</span>, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911">exec_env_</a>.get()));</div> |
| <div class="line"><a name="l00064"></a><span class="lineno"> 64</span> </div> |
| <div class="line"><a name="l00065"></a><span class="lineno"> 65</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ac05069bbc3e95609283da5da6c42c297">CreateDescriptors</a>();</div> |
| <div class="line"><a name="l00066"></a><span class="lineno"> 66</span> </div> |
| <div class="line"><a name="l00067"></a><span class="lineno"> 67</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8e47057fc9bd48c9bda08aeb67501e84">mem_pool_</a>.reset(<span class="keyword">new</span> <a class="code" href="classimpala_1_1MemPool.html">MemPool</a>(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>));</div> |
| <div class="line"><a name="l00068"></a><span class="lineno"> 68</span>  }</div> |
| <div class="line"><a name="l00069"></a><span class="lineno"> 69</span> </div> |
| <div class="line"><a name="l00070"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#ac05069bbc3e95609283da5da6c42c297"> 70</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ac05069bbc3e95609283da5da6c42c297">CreateDescriptors</a>() {</div> |
| <div class="line"><a name="l00071"></a><span class="lineno"> 71</span>  vector<bool> nullable_tuples(1, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00072"></a><span class="lineno"> 72</span>  vector<TTupleId> tuple_ids(1, static_cast<TTupleId>(0));</div> |
| <div class="line"><a name="l00073"></a><span class="lineno"> 73</span> </div> |
| <div class="line"><a name="l00074"></a><span class="lineno"> 74</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> int_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00075"></a><span class="lineno"> 75</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00076"></a><span class="lineno"> 76</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00077"></a><span class="lineno"> 77</span>  *int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00078"></a><span class="lineno"> 78</span> </div> |
| <div class="line"><a name="l00079"></a><span class="lineno"> 79</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> string_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00080"></a><span class="lineno"> 80</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00081"></a><span class="lineno"> 81</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00082"></a><span class="lineno"> 82</span>  *string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00083"></a><span class="lineno"> 83</span>  }</div> |
| <div class="line"><a name="l00084"></a><span class="lineno"> 84</span> </div> |
| <div class="line"><a name="l00085"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a8b61b4bff3990576ffa3e2fc0b902344"> 85</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8b61b4bff3990576ffa3e2fc0b902344">TearDown</a>() {</div> |
| <div class="line"><a name="l00086"></a><span class="lineno"> 86</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">block_mgr_</a>.reset();</div> |
| <div class="line"><a name="l00087"></a><span class="lineno"> 87</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae8f58f8ebd4c36234b3cfa9e4507578f">block_mgr_parent_tracker_</a>.reset();</div> |
| <div class="line"><a name="l00088"></a><span class="lineno"> 88</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>.reset();</div> |
| <div class="line"><a name="l00089"></a><span class="lineno"> 89</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911">exec_env_</a>.reset();</div> |
| <div class="line"><a name="l00090"></a><span class="lineno"> 90</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8e47057fc9bd48c9bda08aeb67501e84">mem_pool_</a>->FreeAll();</div> |
| <div class="line"><a name="l00091"></a><span class="lineno"> 91</span>  }</div> |
| <div class="line"><a name="l00092"></a><span class="lineno"> 92</span> </div> |
| <div class="line"><a name="l00093"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a9d12b724587769d53eb61f4f7b624c06"> 93</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a9d12b724587769d53eb61f4f7b624c06">CreateMgr</a>(int64_t limit, <span class="keywordtype">int</span> block_size) {</div> |
| <div class="line"><a name="l00094"></a><span class="lineno"> 94</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = <a class="code" href="classimpala_1_1BufferedBlockMgr.html#a76ef041b360fb6146c687b3e479546e1">BufferedBlockMgr::Create</a>(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>.get(),</div> |
| <div class="line"><a name="l00095"></a><span class="lineno"> 95</span>  &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>->runtime_profile(), limit, block_size, &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">block_mgr_</a>);</div> |
| <div class="line"><a name="l00096"></a><span class="lineno"> 96</span>  EXPECT_TRUE(status.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>());</div> |
| <div class="line"><a name="l00097"></a><span class="lineno"> 97</span>  status = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">block_mgr_</a>->RegisterClient(0, &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>.get(), &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a6ce73724f30a412ae295b42669771241">client_</a>);</div> |
| <div class="line"><a name="l00098"></a><span class="lineno"> 98</span>  EXPECT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00099"></a><span class="lineno"> 99</span>  }</div> |
| <div class="line"><a name="l00100"></a><span class="lineno"> 100</span> </div> |
| <div class="line"><a name="l00101"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#ab3faf0bb3e444230fe8dba269a5f5e16"> 101</a></span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ab3faf0bb3e444230fe8dba269a5f5e16">CreateIntBatch</a>(<span class="keywordtype">int</span> start_val, <span class="keywordtype">int</span> num_rows, <span class="keywordtype">bool</span> gen_null) {</div> |
| <div class="line"><a name="l00102"></a><span class="lineno"> 102</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>(*<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>, num_rows, &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>));</div> |
| <div class="line"><a name="l00103"></a><span class="lineno"> 103</span>  <span class="keywordtype">int</span>* tuple_mem = <span class="keyword">reinterpret_cast<</span><span class="keywordtype">int</span>*<span class="keyword">></span>(</div> |
| <div class="line"><a name="l00104"></a><span class="lineno"> 104</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#a82611d227a12dd5c2e1ca1ba77d86736">tuple_data_pool</a>()-><a class="code" href="classimpala_1_1MemPool.html#a190eb28e39279c901eda3d831a9fe726">Allocate</a>(<span class="keyword">sizeof</span>(<span class="keywordtype">int</span>) * num_rows));</div> |
| <div class="line"><a name="l00105"></a><span class="lineno"> 105</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> int_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00106"></a><span class="lineno"> 106</span>  <span class="keywordflow">if</span> (int_tuples > 1) {</div> |
| <div class="line"><a name="l00107"></a><span class="lineno"> 107</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_rows; ++i) {</div> |
| <div class="line"><a name="l00108"></a><span class="lineno"> 108</span>  <span class="keywordtype">int</span> <a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a> = batch-><a class="code" href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">AddRow</a>();</div> |
| <div class="line"><a name="l00109"></a><span class="lineno"> 109</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(idx);</div> |
| <div class="line"><a name="l00110"></a><span class="lineno"> 110</span>  tuple_mem[i] = i + start_val;</div> |
| <div class="line"><a name="l00111"></a><span class="lineno"> 111</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < int_tuples; ++j) {</div> |
| <div class="line"><a name="l00112"></a><span class="lineno"> 112</span>  <span class="keywordflow">if</span> (!gen_null || (j % 2) == 0) {</div> |
| <div class="line"><a name="l00113"></a><span class="lineno"> 113</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(j, reinterpret_cast<Tuple*>(&tuple_mem[i]));</div> |
| <div class="line"><a name="l00114"></a><span class="lineno"> 114</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00115"></a><span class="lineno"> 115</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(j, NULL);</div> |
| <div class="line"><a name="l00116"></a><span class="lineno"> 116</span>  }</div> |
| <div class="line"><a name="l00117"></a><span class="lineno"> 117</span>  }</div> |
| <div class="line"><a name="l00118"></a><span class="lineno"> 118</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">CommitLastRow</a>();</div> |
| <div class="line"><a name="l00119"></a><span class="lineno"> 119</span>  }</div> |
| <div class="line"><a name="l00120"></a><span class="lineno"> 120</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00121"></a><span class="lineno"> 121</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_rows; ++i) {</div> |
| <div class="line"><a name="l00122"></a><span class="lineno"> 122</span>  <span class="keywordtype">int</span> <a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a> = batch-><a class="code" href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">AddRow</a>();</div> |
| <div class="line"><a name="l00123"></a><span class="lineno"> 123</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(idx);</div> |
| <div class="line"><a name="l00124"></a><span class="lineno"> 124</span>  tuple_mem[i] = i + start_val;</div> |
| <div class="line"><a name="l00125"></a><span class="lineno"> 125</span>  <span class="keywordflow">if</span> (!gen_null || (i % 2) == 0) {</div> |
| <div class="line"><a name="l00126"></a><span class="lineno"> 126</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(0, reinterpret_cast<Tuple*>(&tuple_mem[i]));</div> |
| <div class="line"><a name="l00127"></a><span class="lineno"> 127</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00128"></a><span class="lineno"> 128</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(0, NULL);</div> |
| <div class="line"><a name="l00129"></a><span class="lineno"> 129</span>  }</div> |
| <div class="line"><a name="l00130"></a><span class="lineno"> 130</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">CommitLastRow</a>();</div> |
| <div class="line"><a name="l00131"></a><span class="lineno"> 131</span>  }</div> |
| <div class="line"><a name="l00132"></a><span class="lineno"> 132</span>  }</div> |
| <div class="line"><a name="l00133"></a><span class="lineno"> 133</span>  <span class="keywordflow">return</span> batch;</div> |
| <div class="line"><a name="l00134"></a><span class="lineno"> 134</span>  }</div> |
| <div class="line"><a name="l00135"></a><span class="lineno"> 135</span> </div> |
| <div class="line"><a name="l00136"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#ac342e224b0d27a75a2edc7f66a8ed2ca"> 136</a></span>  <span class="keyword">virtual</span> <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ac342e224b0d27a75a2edc7f66a8ed2ca">CreateStringBatch</a>(<span class="keywordtype">int</span> string_idx, <span class="keywordtype">int</span> num_rows, <span class="keywordtype">bool</span> gen_null) {</div> |
| <div class="line"><a name="l00137"></a><span class="lineno"> 137</span>  <span class="keywordtype">int</span> tuple_size = <span class="keyword">sizeof</span>(<a class="code" href="structimpala_1_1StringValue.html">StringValue</a>) + 1;</div> |
| <div class="line"><a name="l00138"></a><span class="lineno"> 138</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>(*<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a>, num_rows, &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>));</div> |
| <div class="line"><a name="l00139"></a><span class="lineno"> 139</span>  uint8_t* tuple_mem = batch-><a class="code" href="classimpala_1_1RowBatch.html#a82611d227a12dd5c2e1ca1ba77d86736">tuple_data_pool</a>()-><a class="code" href="classimpala_1_1MemPool.html#a190eb28e39279c901eda3d831a9fe726">Allocate</a>(tuple_size * num_rows);</div> |
| <div class="line"><a name="l00140"></a><span class="lineno"> 140</span>  memset(tuple_mem, 0, tuple_size * num_rows);</div> |
| <div class="line"><a name="l00141"></a><span class="lineno"> 141</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> string_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00142"></a><span class="lineno"> 142</span>  <span class="keywordflow">if</span> (string_tuples > 1) {</div> |
| <div class="line"><a name="l00143"></a><span class="lineno"> 143</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_rows; ++i) {</div> |
| <div class="line"><a name="l00144"></a><span class="lineno"> 144</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(batch-><a class="code" href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">AddRow</a>());</div> |
| <div class="line"><a name="l00145"></a><span class="lineno"> 145</span>  string_idx %= <a class="code" href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db">NUM_STRINGS</a>;</div> |
| <div class="line"><a name="l00146"></a><span class="lineno"> 146</span>  *<span class="keyword">reinterpret_cast<</span><a class="code" href="structimpala_1_1StringValue.html">StringValue</a>*<span class="keyword">></span>(tuple_mem + 1) = <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[string_idx];</div> |
| <div class="line"><a name="l00147"></a><span class="lineno"> 147</span>  ++string_idx;</div> |
| <div class="line"><a name="l00148"></a><span class="lineno"> 148</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < string_tuples; ++j) {</div> |
| <div class="line"><a name="l00149"></a><span class="lineno"> 149</span>  <span class="keywordflow">if</span> (!gen_null || (j % 2) == 0) {</div> |
| <div class="line"><a name="l00150"></a><span class="lineno"> 150</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(j, reinterpret_cast<Tuple*>(tuple_mem));</div> |
| <div class="line"><a name="l00151"></a><span class="lineno"> 151</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00152"></a><span class="lineno"> 152</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(j, NULL);</div> |
| <div class="line"><a name="l00153"></a><span class="lineno"> 153</span>  }</div> |
| <div class="line"><a name="l00154"></a><span class="lineno"> 154</span>  }</div> |
| <div class="line"><a name="l00155"></a><span class="lineno"> 155</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">CommitLastRow</a>();</div> |
| <div class="line"><a name="l00156"></a><span class="lineno"> 156</span>  tuple_mem += tuple_size;</div> |
| <div class="line"><a name="l00157"></a><span class="lineno"> 157</span>  }</div> |
| <div class="line"><a name="l00158"></a><span class="lineno"> 158</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00159"></a><span class="lineno"> 159</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_rows; ++i) {</div> |
| <div class="line"><a name="l00160"></a><span class="lineno"> 160</span>  <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row = batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(batch-><a class="code" href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">AddRow</a>());</div> |
| <div class="line"><a name="l00161"></a><span class="lineno"> 161</span>  string_idx %= <a class="code" href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db">NUM_STRINGS</a>;</div> |
| <div class="line"><a name="l00162"></a><span class="lineno"> 162</span>  *<span class="keyword">reinterpret_cast<</span><a class="code" href="structimpala_1_1StringValue.html">StringValue</a>*<span class="keyword">></span>(tuple_mem + 1) = <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[string_idx];</div> |
| <div class="line"><a name="l00163"></a><span class="lineno"> 163</span>  ++string_idx;</div> |
| <div class="line"><a name="l00164"></a><span class="lineno"> 164</span>  <span class="keywordflow">if</span> (!gen_null || (i % 2) == 0) {</div> |
| <div class="line"><a name="l00165"></a><span class="lineno"> 165</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(0, reinterpret_cast<Tuple*>(tuple_mem));</div> |
| <div class="line"><a name="l00166"></a><span class="lineno"> 166</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00167"></a><span class="lineno"> 167</span>  row-><a class="code" href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">SetTuple</a>(0, NULL);</div> |
| <div class="line"><a name="l00168"></a><span class="lineno"> 168</span>  }</div> |
| <div class="line"><a name="l00169"></a><span class="lineno"> 169</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">CommitLastRow</a>();</div> |
| <div class="line"><a name="l00170"></a><span class="lineno"> 170</span>  tuple_mem += tuple_size;</div> |
| <div class="line"><a name="l00171"></a><span class="lineno"> 171</span>  }</div> |
| <div class="line"><a name="l00172"></a><span class="lineno"> 172</span>  }</div> |
| <div class="line"><a name="l00173"></a><span class="lineno"> 173</span>  <span class="keywordflow">return</span> batch;</div> |
| <div class="line"><a name="l00174"></a><span class="lineno"> 174</span>  }</div> |
| <div class="line"><a name="l00175"></a><span class="lineno"> 175</span> </div> |
| <div class="line"><a name="l00176"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a92a20377928d95c6ea3a5e7ffb31cb0b"> 176</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a92a20377928d95c6ea3a5e7ffb31cb0b">AppendRowTuples</a>(<a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row, vector<int>* results) {</div> |
| <div class="line"><a name="l00177"></a><span class="lineno"> 177</span>  DCHECK_NOTNULL(row);</div> |
| <div class="line"><a name="l00178"></a><span class="lineno"> 178</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> int_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00179"></a><span class="lineno"> 179</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < int_tuples; ++i) {</div> |
| <div class="line"><a name="l00180"></a><span class="lineno"> 180</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#af1bea454e316dfab89abcda3a9f881c9">AppendValue</a>(row-><a class="code" href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">GetTuple</a>(i), results);</div> |
| <div class="line"><a name="l00181"></a><span class="lineno"> 181</span>  }</div> |
| <div class="line"><a name="l00182"></a><span class="lineno"> 182</span>  }</div> |
| <div class="line"><a name="l00183"></a><span class="lineno"> 183</span> </div> |
| <div class="line"><a name="l00184"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a955a0e3a24bab770a4163fcc3c33ed44"> 184</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a955a0e3a24bab770a4163fcc3c33ed44">AppendRowTuples</a>(<a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* row, vector<StringValue>* results) {</div> |
| <div class="line"><a name="l00185"></a><span class="lineno"> 185</span>  DCHECK_NOTNULL(row);</div> |
| <div class="line"><a name="l00186"></a><span class="lineno"> 186</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> string_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00187"></a><span class="lineno"> 187</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < string_tuples; ++i) {</div> |
| <div class="line"><a name="l00188"></a><span class="lineno"> 188</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#af1bea454e316dfab89abcda3a9f881c9">AppendValue</a>(row-><a class="code" href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">GetTuple</a>(i), results);</div> |
| <div class="line"><a name="l00189"></a><span class="lineno"> 189</span>  }</div> |
| <div class="line"><a name="l00190"></a><span class="lineno"> 190</span>  }</div> |
| <div class="line"><a name="l00191"></a><span class="lineno"> 191</span> </div> |
| <div class="line"><a name="l00192"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#af1bea454e316dfab89abcda3a9f881c9"> 192</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#af1bea454e316dfab89abcda3a9f881c9">AppendValue</a>(<a class="code" href="classimpala_1_1Tuple.html">Tuple</a>* t, vector<int>* results) {</div> |
| <div class="line"><a name="l00193"></a><span class="lineno"> 193</span>  <span class="keywordflow">if</span> (t == NULL) {</div> |
| <div class="line"><a name="l00194"></a><span class="lineno"> 194</span>  <span class="comment">// For the tests indicate null-ability using the max int value</span></div> |
| <div class="line"><a name="l00195"></a><span class="lineno"> 195</span>  results->push_back(std::numeric_limits<int>::max());</div> |
| <div class="line"><a name="l00196"></a><span class="lineno"> 196</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00197"></a><span class="lineno"> 197</span>  results->push_back(*reinterpret_cast<int*>(t));</div> |
| <div class="line"><a name="l00198"></a><span class="lineno"> 198</span>  }</div> |
| <div class="line"><a name="l00199"></a><span class="lineno"> 199</span>  }</div> |
| <div class="line"><a name="l00200"></a><span class="lineno"> 200</span> </div> |
| <div class="line"><a name="l00201"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a75912f2e5b6853ff0f07f0764dde3ccb"> 201</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a75912f2e5b6853ff0f07f0764dde3ccb">AppendValue</a>(<a class="code" href="classimpala_1_1Tuple.html">Tuple</a>* t, vector<StringValue>* results) {</div> |
| <div class="line"><a name="l00202"></a><span class="lineno"> 202</span>  <span class="keywordflow">if</span> (t == NULL) {</div> |
| <div class="line"><a name="l00203"></a><span class="lineno"> 203</span>  results->push_back(<a class="code" href="structimpala_1_1StringValue.html">StringValue</a>());</div> |
| <div class="line"><a name="l00204"></a><span class="lineno"> 204</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00205"></a><span class="lineno"> 205</span>  uint8_t* mem = <span class="keyword">reinterpret_cast<</span>uint8_t*<span class="keyword">></span>(t);</div> |
| <div class="line"><a name="l00206"></a><span class="lineno"> 206</span>  <a class="code" href="structimpala_1_1StringValue.html">StringValue</a> sv = *<span class="keyword">reinterpret_cast<</span><a class="code" href="structimpala_1_1StringValue.html">StringValue</a>*<span class="keyword">></span>(mem + 1);</div> |
| <div class="line"><a name="l00207"></a><span class="lineno"> 207</span>  uint8_t* copy = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8e47057fc9bd48c9bda08aeb67501e84">mem_pool_</a>->Allocate(sv.<a class="code" href="structimpala_1_1StringValue.html#ab71e42890598d9b239cac64485db276d">len</a>);</div> |
| <div class="line"><a name="l00208"></a><span class="lineno"> 208</span>  memcpy(copy, sv.<a class="code" href="structimpala_1_1StringValue.html#a17f088f03fd1f7b017df20f58f71fe13">ptr</a>, sv.<a class="code" href="structimpala_1_1StringValue.html#ab71e42890598d9b239cac64485db276d">len</a>);</div> |
| <div class="line"><a name="l00209"></a><span class="lineno"> 209</span>  sv.<a class="code" href="structimpala_1_1StringValue.html#a17f088f03fd1f7b017df20f58f71fe13">ptr</a> = <span class="keyword">reinterpret_cast<</span><span class="keywordtype">char</span>*<span class="keyword">></span>(copy);</div> |
| <div class="line"><a name="l00210"></a><span class="lineno"> 210</span>  results->push_back(sv);</div> |
| <div class="line"><a name="l00211"></a><span class="lineno"> 211</span>  }</div> |
| <div class="line"><a name="l00212"></a><span class="lineno"> 212</span>  }</div> |
| <div class="line"><a name="l00213"></a><span class="lineno"> 213</span> </div> |
| <div class="line"><a name="l00214"></a><span class="lineno"> 214</span>  <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a name="l00215"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#ad7fb9ac48a74747bf7209ba696066ef5"> 215</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ad7fb9ac48a74747bf7209ba696066ef5">ReadValues</a>(<a class="code" href="classimpala_1_1BufferedTupleStream.html">BufferedTupleStream</a>* stream, <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>* desc, vector<T>* results,</div> |
| <div class="line"><a name="l00216"></a><span class="lineno"> 216</span>  <span class="keywordtype">int</span> num_batches = -1) {</div> |
| <div class="line"><a name="l00217"></a><span class="lineno"> 217</span>  <span class="keywordtype">bool</span> eos = <span class="keyword">false</span>;</div> |
| <div class="line"><a name="l00218"></a><span class="lineno"> 218</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a> batch(*desc, <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a>, &<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>);</div> |
| <div class="line"><a name="l00219"></a><span class="lineno"> 219</span>  <span class="keywordtype">int</span> batches_read = 0;</div> |
| <div class="line"><a name="l00220"></a><span class="lineno"> 220</span>  <span class="keywordflow">do</span> {</div> |
| <div class="line"><a name="l00221"></a><span class="lineno"> 221</span>  batch.<a class="code" href="classimpala_1_1RowBatch.html#ac351eaf211eb53882564b604db07b824">Reset</a>();</div> |
| <div class="line"><a name="l00222"></a><span class="lineno"> 222</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = stream-><a class="code" href="classimpala_1_1BufferedTupleStream.html#a5277d4ff9fdeb7b31bdf4d520739582d">GetNext</a>(&batch, &eos);</div> |
| <div class="line"><a name="l00223"></a><span class="lineno"> 223</span>  EXPECT_TRUE(status.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>());</div> |
| <div class="line"><a name="l00224"></a><span class="lineno"> 224</span>  ++batches_read;</div> |
| <div class="line"><a name="l00225"></a><span class="lineno"> 225</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < batch.<a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>(); ++i) {</div> |
| <div class="line"><a name="l00226"></a><span class="lineno"> 226</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a92a20377928d95c6ea3a5e7ffb31cb0b">AppendRowTuples</a>(batch.<a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(i), results);</div> |
| <div class="line"><a name="l00227"></a><span class="lineno"> 227</span>  }</div> |
| <div class="line"><a name="l00228"></a><span class="lineno"> 228</span>  } <span class="keywordflow">while</span> (!eos && (num_batches < 0 || batches_read <= num_batches));</div> |
| <div class="line"><a name="l00229"></a><span class="lineno"> 229</span>  }</div> |
| <div class="line"><a name="l00230"></a><span class="lineno"> 230</span> </div> |
| <div class="line"><a name="l00231"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a5db75fcf103aacdaa2b86bb21b29a20a"> 231</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a5db75fcf103aacdaa2b86bb21b29a20a">VerifyResults</a>(<span class="keyword">const</span> vector<int>& results, <span class="keywordtype">int</span> exp_rows, <span class="keywordtype">bool</span> gen_null) {</div> |
| <div class="line"><a name="l00232"></a><span class="lineno"> 232</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> int_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00233"></a><span class="lineno"> 233</span>  EXPECT_EQ(results.size(), exp_rows * int_tuples);</div> |
| <div class="line"><a name="l00234"></a><span class="lineno"> 234</span>  <span class="keywordflow">if</span> (int_tuples > 1) {</div> |
| <div class="line"><a name="l00235"></a><span class="lineno"> 235</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < results.size(); i += int_tuples) {</div> |
| <div class="line"><a name="l00236"></a><span class="lineno"> 236</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < int_tuples; ++j) {</div> |
| <div class="line"><a name="l00237"></a><span class="lineno"> 237</span>  <span class="keywordflow">if</span> (!gen_null || (j % 2) == 0) {</div> |
| <div class="line"><a name="l00238"></a><span class="lineno"> 238</span>  ASSERT_EQ(results[i+j], i / int_tuples)</div> |
| <div class="line"><a name="l00239"></a><span class="lineno"> 239</span>  << <span class="stringliteral">" results["</span> << (i + j) << <span class="stringliteral">"]: "</span> << results[i + j]</div> |
| <div class="line"><a name="l00240"></a><span class="lineno"> 240</span>  << <span class="stringliteral">" != "</span> << (i / int_tuples) << <span class="stringliteral">" gen_null="</span> << gen_null;</div> |
| <div class="line"><a name="l00241"></a><span class="lineno"> 241</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00242"></a><span class="lineno"> 242</span>  ASSERT_TRUE(results[i+j] == std::numeric_limits<int>::max())</div> |
| <div class="line"><a name="l00243"></a><span class="lineno"> 243</span>  << <span class="stringliteral">"i: "</span> << i << <span class="stringliteral">" j: "</span> << j << <span class="stringliteral">" results["</span> << (i + j) << <span class="stringliteral">"]: "</span></div> |
| <div class="line"><a name="l00244"></a><span class="lineno"> 244</span>  << results[i+j] << <span class="stringliteral">" != "</span> << std::numeric_limits<int>::max();</div> |
| <div class="line"><a name="l00245"></a><span class="lineno"> 245</span>  }</div> |
| <div class="line"><a name="l00246"></a><span class="lineno"> 246</span>  }</div> |
| <div class="line"><a name="l00247"></a><span class="lineno"> 247</span>  }</div> |
| <div class="line"><a name="l00248"></a><span class="lineno"> 248</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00249"></a><span class="lineno"> 249</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < results.size(); i += int_tuples) {</div> |
| <div class="line"><a name="l00250"></a><span class="lineno"> 250</span>  <span class="keywordflow">if</span> (!gen_null || (i % 2) == 0) {</div> |
| <div class="line"><a name="l00251"></a><span class="lineno"> 251</span>  ASSERT_TRUE(results[i] == i)</div> |
| <div class="line"><a name="l00252"></a><span class="lineno"> 252</span>  << <span class="stringliteral">" results["</span> << (i) << <span class="stringliteral">"]: "</span> << results[i]</div> |
| <div class="line"><a name="l00253"></a><span class="lineno"> 253</span>  << <span class="stringliteral">" != "</span> << i << <span class="stringliteral">" gen_null="</span> << gen_null;</div> |
| <div class="line"><a name="l00254"></a><span class="lineno"> 254</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00255"></a><span class="lineno"> 255</span>  ASSERT_TRUE(results[i] == std::numeric_limits<int>::max())</div> |
| <div class="line"><a name="l00256"></a><span class="lineno"> 256</span>  << <span class="stringliteral">"i: "</span> << i << <span class="stringliteral">" results["</span> << i << <span class="stringliteral">"]: "</span></div> |
| <div class="line"><a name="l00257"></a><span class="lineno"> 257</span>  << results[i] << <span class="stringliteral">" != "</span> << std::numeric_limits<int>::max();</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="l00260"></a><span class="lineno"> 260</span>  }</div> |
| <div class="line"><a name="l00261"></a><span class="lineno"> 261</span>  }</div> |
| <div class="line"><a name="l00262"></a><span class="lineno"> 262</span> </div> |
| <div class="line"><a name="l00263"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a10f753aa3fafdf98d327ec5cff677fc6"> 263</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a10f753aa3fafdf98d327ec5cff677fc6">VerifyResults</a>(<span class="keyword">const</span> vector<StringValue>& results, <span class="keywordtype">int</span> exp_rows,</div> |
| <div class="line"><a name="l00264"></a><span class="lineno"> 264</span>  <span class="keywordtype">bool</span> gen_null) {</div> |
| <div class="line"><a name="l00265"></a><span class="lineno"> 265</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> string_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00266"></a><span class="lineno"> 266</span>  EXPECT_EQ(results.size(), exp_rows * string_tuples);</div> |
| <div class="line"><a name="l00267"></a><span class="lineno"> 267</span>  <span class="keywordtype">int</span> <a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a> = 0;</div> |
| <div class="line"><a name="l00268"></a><span class="lineno"> 268</span>  <span class="keywordflow">if</span> (string_tuples > 1) {</div> |
| <div class="line"><a name="l00269"></a><span class="lineno"> 269</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < results.size(); i += string_tuples) {</div> |
| <div class="line"><a name="l00270"></a><span class="lineno"> 270</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < string_tuples; ++j) {</div> |
| <div class="line"><a name="l00271"></a><span class="lineno"> 271</span>  <span class="keywordflow">if</span> (!gen_null || (j % 2) == 0) {</div> |
| <div class="line"><a name="l00272"></a><span class="lineno"> 272</span>  ASSERT_TRUE(results[i+j] == <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[idx])</div> |
| <div class="line"><a name="l00273"></a><span class="lineno"> 273</span>  << <span class="stringliteral">"results["</span> << i << <span class="stringliteral">"+"</span> << j << <span class="stringliteral">"] "</span> << results[i+j]</div> |
| <div class="line"><a name="l00274"></a><span class="lineno"> 274</span>  << <span class="stringliteral">" != "</span> << <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[<a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a>] << <span class="stringliteral">" idx="</span> << idx << <span class="stringliteral">" gen_null="</span> << gen_null;</div> |
| <div class="line"><a name="l00275"></a><span class="lineno"> 275</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00276"></a><span class="lineno"> 276</span>  ASSERT_TRUE(results[i+j] == <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>())</div> |
| <div class="line"><a name="l00277"></a><span class="lineno"> 277</span>  << <span class="stringliteral">"results["</span> << i << <span class="stringliteral">"+"</span> << j << <span class="stringliteral">"] "</span> << results[i+j] << <span class="stringliteral">" not NULL"</span>;</div> |
| <div class="line"><a name="l00278"></a><span class="lineno"> 278</span>  }</div> |
| <div class="line"><a name="l00279"></a><span class="lineno"> 279</span>  }</div> |
| <div class="line"><a name="l00280"></a><span class="lineno"> 280</span>  idx = (idx + 1) % <a class="code" href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db">NUM_STRINGS</a>;</div> |
| <div class="line"><a name="l00281"></a><span class="lineno"> 281</span>  }</div> |
| <div class="line"><a name="l00282"></a><span class="lineno"> 282</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00283"></a><span class="lineno"> 283</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < results.size(); i += string_tuples) {</div> |
| <div class="line"><a name="l00284"></a><span class="lineno"> 284</span>  <span class="keywordflow">if</span> (!gen_null || (i % 2) == 0) {</div> |
| <div class="line"><a name="l00285"></a><span class="lineno"> 285</span>  ASSERT_TRUE(results[i] == <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[idx])</div> |
| <div class="line"><a name="l00286"></a><span class="lineno"> 286</span>  << <span class="stringliteral">"results["</span> << i << <span class="stringliteral">"] "</span> << results[i]</div> |
| <div class="line"><a name="l00287"></a><span class="lineno"> 287</span>  << <span class="stringliteral">" != "</span> << <a class="code" href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">STRINGS</a>[<a class="code" href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">idx</a>] << <span class="stringliteral">" idx="</span> << idx << <span class="stringliteral">" gen_null="</span> << gen_null;</div> |
| <div class="line"><a name="l00288"></a><span class="lineno"> 288</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00289"></a><span class="lineno"> 289</span>  ASSERT_TRUE(results[i] == <a class="code" href="structimpala_1_1StringValue.html">StringValue</a>())</div> |
| <div class="line"><a name="l00290"></a><span class="lineno"> 290</span>  << <span class="stringliteral">"results["</span> << i << <span class="stringliteral">"] "</span> << results[i] << <span class="stringliteral">" not NULL"</span>;</div> |
| <div class="line"><a name="l00291"></a><span class="lineno"> 291</span>  }</div> |
| <div class="line"><a name="l00292"></a><span class="lineno"> 292</span>  idx = (idx + 1) % <a class="code" href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db">NUM_STRINGS</a>;</div> |
| <div class="line"><a name="l00293"></a><span class="lineno"> 293</span>  }</div> |
| <div class="line"><a name="l00294"></a><span class="lineno"> 294</span>  }</div> |
| <div class="line"><a name="l00295"></a><span class="lineno"> 295</span>  }</div> |
| <div class="line"><a name="l00296"></a><span class="lineno"> 296</span> </div> |
| <div class="line"><a name="l00297"></a><span class="lineno"> 297</span>  <span class="comment">// Test adding num_batches of ints to the stream and reading them back.</span></div> |
| <div class="line"><a name="l00298"></a><span class="lineno"> 298</span>  <span class="keyword">template</span> <<span class="keyword">typename</span> T></div> |
| <div class="line"><a name="l00299"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#abaeb8139bfbda394008df282a8053087"> 299</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abaeb8139bfbda394008df282a8053087">TestValues</a>(<span class="keywordtype">int</span> num_batches, <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>* desc, <span class="keywordtype">bool</span> gen_null) {</div> |
| <div class="line"><a name="l00300"></a><span class="lineno"> 300</span>  <a class="code" href="classimpala_1_1BufferedTupleStream.html">BufferedTupleStream</a> stream(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>.get(), *desc, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">block_mgr_</a>.get(), <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a6ce73724f30a412ae295b42669771241">client_</a>);</div> |
| <div class="line"><a name="l00301"></a><span class="lineno"> 301</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = stream.Init();</div> |
| <div class="line"><a name="l00302"></a><span class="lineno"> 302</span>  ASSERT_TRUE(status.ok()) << status.<a class="code" href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">GetDetail</a>();</div> |
| <div class="line"><a name="l00303"></a><span class="lineno"> 303</span>  status = stream.UnpinStream();</div> |
| <div class="line"><a name="l00304"></a><span class="lineno"> 304</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00305"></a><span class="lineno"> 305</span> </div> |
| <div class="line"><a name="l00306"></a><span class="lineno"> 306</span>  <span class="comment">// Add rows to the stream</span></div> |
| <div class="line"><a name="l00307"></a><span class="lineno"> 307</span>  <span class="keywordtype">int</span> <a class="code" href="partitioning-throughput-test_8cc.html#ad172ecfd5c31c5df6282c2b4bc322bf7">offset</a> = 0;</div> |
| <div class="line"><a name="l00308"></a><span class="lineno"> 308</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_batches; ++i) {</div> |
| <div class="line"><a name="l00309"></a><span class="lineno"> 309</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = NULL;</div> |
| <div class="line"><a name="l00310"></a><span class="lineno"> 310</span>  <span class="keywordflow">if</span> (<span class="keyword">sizeof</span>(T) == <span class="keyword">sizeof</span>(int)) {</div> |
| <div class="line"><a name="l00311"></a><span class="lineno"> 311</span>  batch = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ab3faf0bb3e444230fe8dba269a5f5e16">CreateIntBatch</a>(offset, <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a>, gen_null);</div> |
| <div class="line"><a name="l00312"></a><span class="lineno"> 312</span>  } <span class="keywordflow">else</span> <span class="keywordflow">if</span> (<span class="keyword">sizeof</span>(T) == <span class="keyword">sizeof</span>(<a class="code" href="structimpala_1_1StringValue.html">StringValue</a>)) {</div> |
| <div class="line"><a name="l00313"></a><span class="lineno"> 313</span>  batch = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ac342e224b0d27a75a2edc7f66a8ed2ca">CreateStringBatch</a>(offset, <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a>, gen_null);</div> |
| <div class="line"><a name="l00314"></a><span class="lineno"> 314</span>  } <span class="keywordflow">else</span> {</div> |
| <div class="line"><a name="l00315"></a><span class="lineno"> 315</span>  DCHECK(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00316"></a><span class="lineno"> 316</span>  }</div> |
| <div class="line"><a name="l00317"></a><span class="lineno"> 317</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < batch-><a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>(); ++j) {</div> |
| <div class="line"><a name="l00318"></a><span class="lineno"> 318</span>  <span class="keywordtype">bool</span> b = stream.AddRow(batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(j));</div> |
| <div class="line"><a name="l00319"></a><span class="lineno"> 319</span>  <span class="keywordflow">if</span> (!b) {</div> |
| <div class="line"><a name="l00320"></a><span class="lineno"> 320</span>  ASSERT_TRUE(stream.using_small_buffers());</div> |
| <div class="line"><a name="l00321"></a><span class="lineno"> 321</span>  <span class="keywordtype">bool</span> got_buffer;</div> |
| <div class="line"><a name="l00322"></a><span class="lineno"> 322</span>  status = stream.SwitchToIoBuffers(&got_buffer);</div> |
| <div class="line"><a name="l00323"></a><span class="lineno"> 323</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00324"></a><span class="lineno"> 324</span>  ASSERT_TRUE(got_buffer);</div> |
| <div class="line"><a name="l00325"></a><span class="lineno"> 325</span>  b = stream.AddRow(batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(j));</div> |
| <div class="line"><a name="l00326"></a><span class="lineno"> 326</span>  }</div> |
| <div class="line"><a name="l00327"></a><span class="lineno"> 327</span>  ASSERT_TRUE(b);</div> |
| <div class="line"><a name="l00328"></a><span class="lineno"> 328</span>  }</div> |
| <div class="line"><a name="l00329"></a><span class="lineno"> 329</span>  offset += batch-><a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>();</div> |
| <div class="line"><a name="l00330"></a><span class="lineno"> 330</span>  <span class="comment">// Reset the batch to make sure the stream handles the memory correctly.</span></div> |
| <div class="line"><a name="l00331"></a><span class="lineno"> 331</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#ac351eaf211eb53882564b604db07b824">Reset</a>();</div> |
| <div class="line"><a name="l00332"></a><span class="lineno"> 332</span>  }</div> |
| <div class="line"><a name="l00333"></a><span class="lineno"> 333</span> </div> |
| <div class="line"><a name="l00334"></a><span class="lineno"> 334</span>  status = stream.PrepareForRead();</div> |
| <div class="line"><a name="l00335"></a><span class="lineno"> 335</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00336"></a><span class="lineno"> 336</span> </div> |
| <div class="line"><a name="l00337"></a><span class="lineno"> 337</span>  <span class="comment">// Read all the rows back</span></div> |
| <div class="line"><a name="l00338"></a><span class="lineno"> 338</span>  vector<T> results;</div> |
| <div class="line"><a name="l00339"></a><span class="lineno"> 339</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ad7fb9ac48a74747bf7209ba696066ef5">ReadValues</a>(&stream, desc, &results);</div> |
| <div class="line"><a name="l00340"></a><span class="lineno"> 340</span> </div> |
| <div class="line"><a name="l00341"></a><span class="lineno"> 341</span>  <span class="comment">// Verify result</span></div> |
| <div class="line"><a name="l00342"></a><span class="lineno"> 342</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a5db75fcf103aacdaa2b86bb21b29a20a">VerifyResults</a>(results, <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a> * num_batches, gen_null);</div> |
| <div class="line"><a name="l00343"></a><span class="lineno"> 343</span> </div> |
| <div class="line"><a name="l00344"></a><span class="lineno"> 344</span>  stream.Close();</div> |
| <div class="line"><a name="l00345"></a><span class="lineno"> 345</span>  }</div> |
| <div class="line"><a name="l00346"></a><span class="lineno"> 346</span> </div> |
| <div class="line"><a name="l00347"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a69d9b58010b66c40e54e58d512c4fe9a"> 347</a></span>  <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a69d9b58010b66c40e54e58d512c4fe9a">TestIntValuesInterleaved</a>(<span class="keywordtype">int</span> num_batches, <span class="keywordtype">int</span> num_batches_before_read) {</div> |
| <div class="line"><a name="l00348"></a><span class="lineno"> 348</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> small_buffers = 0; small_buffers < 2; ++small_buffers) {</div> |
| <div class="line"><a name="l00349"></a><span class="lineno"> 349</span>  <a class="code" href="classimpala_1_1BufferedTupleStream.html">BufferedTupleStream</a> stream(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>.get(), *<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">block_mgr_</a>.get(),</div> |
| <div class="line"><a name="l00350"></a><span class="lineno"> 350</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a6ce73724f30a412ae295b42669771241">client_</a>,</div> |
| <div class="line"><a name="l00351"></a><span class="lineno"> 351</span>  small_buffers == 0, <span class="comment">// initial small buffers</span></div> |
| <div class="line"><a name="l00352"></a><span class="lineno"> 352</span>  <span class="keyword">true</span>, <span class="comment">// delete_on_read</span></div> |
| <div class="line"><a name="l00353"></a><span class="lineno"> 353</span>  <span class="keyword">true</span>); <span class="comment">// read_write</span></div> |
| <div class="line"><a name="l00354"></a><span class="lineno"> 354</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = stream.Init();</div> |
| <div class="line"><a name="l00355"></a><span class="lineno"> 355</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00356"></a><span class="lineno"> 356</span>  status = stream.UnpinStream();</div> |
| <div class="line"><a name="l00357"></a><span class="lineno"> 357</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00358"></a><span class="lineno"> 358</span> </div> |
| <div class="line"><a name="l00359"></a><span class="lineno"> 359</span>  vector<int> results;</div> |
| <div class="line"><a name="l00360"></a><span class="lineno"> 360</span> </div> |
| <div class="line"><a name="l00361"></a><span class="lineno"> 361</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < num_batches; ++i) {</div> |
| <div class="line"><a name="l00362"></a><span class="lineno"> 362</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ab3faf0bb3e444230fe8dba269a5f5e16">CreateIntBatch</a>(i * <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a>, BATCH_SIZE, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00363"></a><span class="lineno"> 363</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j < batch-><a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>(); ++j) {</div> |
| <div class="line"><a name="l00364"></a><span class="lineno"> 364</span>  <span class="keywordtype">bool</span> b = stream.AddRow(batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(j));</div> |
| <div class="line"><a name="l00365"></a><span class="lineno"> 365</span>  ASSERT_TRUE(b);</div> |
| <div class="line"><a name="l00366"></a><span class="lineno"> 366</span>  }</div> |
| <div class="line"><a name="l00367"></a><span class="lineno"> 367</span>  <span class="comment">// Reset the batch to make sure the stream handles the memory correctly.</span></div> |
| <div class="line"><a name="l00368"></a><span class="lineno"> 368</span>  batch-><a class="code" href="classimpala_1_1RowBatch.html#ac351eaf211eb53882564b604db07b824">Reset</a>();</div> |
| <div class="line"><a name="l00369"></a><span class="lineno"> 369</span>  <span class="keywordflow">if</span> (i % num_batches_before_read == 0) {</div> |
| <div class="line"><a name="l00370"></a><span class="lineno"> 370</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ad7fb9ac48a74747bf7209ba696066ef5">ReadValues</a>(&stream, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>, &results,</div> |
| <div class="line"><a name="l00371"></a><span class="lineno"> 371</span>  (rand() % num_batches_before_read) + 1);</div> |
| <div class="line"><a name="l00372"></a><span class="lineno"> 372</span>  }</div> |
| <div class="line"><a name="l00373"></a><span class="lineno"> 373</span>  }</div> |
| <div class="line"><a name="l00374"></a><span class="lineno"> 374</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ad7fb9ac48a74747bf7209ba696066ef5">ReadValues</a>(&stream, <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>, &results);</div> |
| <div class="line"><a name="l00375"></a><span class="lineno"> 375</span> </div> |
| <div class="line"><a name="l00376"></a><span class="lineno"> 376</span>  <span class="comment">// Verify result</span></div> |
| <div class="line"><a name="l00377"></a><span class="lineno"> 377</span>  <span class="keyword">const</span> <span class="keywordtype">int</span> int_tuples = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>-><a class="code" href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">tuple_descriptors</a>().size();</div> |
| <div class="line"><a name="l00378"></a><span class="lineno"> 378</span>  EXPECT_EQ(results.size(), <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a> * num_batches * int_tuples);</div> |
| <div class="line"><a name="l00379"></a><span class="lineno"> 379</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < results.size(); ++i) {</div> |
| <div class="line"><a name="l00380"></a><span class="lineno"> 380</span>  ASSERT_EQ(results[i], i / int_tuples);</div> |
| <div class="line"><a name="l00381"></a><span class="lineno"> 381</span>  }</div> |
| <div class="line"><a name="l00382"></a><span class="lineno"> 382</span> </div> |
| <div class="line"><a name="l00383"></a><span class="lineno"> 383</span>  stream.Close();</div> |
| <div class="line"><a name="l00384"></a><span class="lineno"> 384</span>  }</div> |
| <div class="line"><a name="l00385"></a><span class="lineno"> 385</span>  }</div> |
| <div class="line"><a name="l00386"></a><span class="lineno"> 386</span> </div> |
| <div class="line"><a name="l00387"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911"> 387</a></span>  scoped_ptr<ExecEnv> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911">exec_env_</a>;</div> |
| <div class="line"><a name="l00388"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d"> 388</a></span>  scoped_ptr<RuntimeState> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">runtime_state_</a>;</div> |
| <div class="line"><a name="l00389"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#ae8f58f8ebd4c36234b3cfa9e4507578f"> 389</a></span>  scoped_ptr<MemTracker> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae8f58f8ebd4c36234b3cfa9e4507578f">block_mgr_parent_tracker_</a>;</div> |
| <div class="line"><a name="l00390"></a><span class="lineno"> 390</span> </div> |
| <div class="line"><a name="l00391"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622"> 391</a></span>  shared_ptr<BufferedBlockMgr> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">block_mgr_</a>;</div> |
| <div class="line"><a name="l00392"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a6ce73724f30a412ae295b42669771241"> 392</a></span>  <a class="code" href="structimpala_1_1BufferedBlockMgr_1_1Client.html">BufferedBlockMgr::Client</a>* <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a6ce73724f30a412ae295b42669771241">client_</a>;</div> |
| <div class="line"><a name="l00393"></a><span class="lineno"> 393</span> </div> |
| <div class="line"><a name="l00394"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4"> 394</a></span>  <a class="code" href="classimpala_1_1MemTracker.html">MemTracker</a> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">tracker_</a>;</div> |
| <div class="line"><a name="l00395"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326"> 395</a></span>  <a class="code" href="classimpala_1_1ObjectPool.html">ObjectPool</a> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>;</div> |
| <div class="line"><a name="l00396"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612"> 396</a></span>  <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>* <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a>;</div> |
| <div class="line"><a name="l00397"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82"> 397</a></span>  <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>* <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a>;</div> |
| <div class="line"><a name="l00398"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleTupleStreamTest.html#a8e47057fc9bd48c9bda08aeb67501e84"> 398</a></span>  scoped_ptr<MemPool> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a8e47057fc9bd48c9bda08aeb67501e84">mem_pool_</a>;</div> |
| <div class="line"><a name="l00399"></a><span class="lineno"> 399</span> }; <span class="comment">// SimpleTupleStreamTest</span></div> |
| <div class="line"><a name="l00400"></a><span class="lineno"> 400</span> </div> |
| <div class="line"><a name="l00401"></a><span class="lineno"> 401</span> </div> |
| <div class="line"><a name="l00402"></a><span class="lineno"> 402</span> <span class="comment">// Tests with a non-NULLable tuple per row.</span></div> |
| <div class="line"><a name="l00403"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleNullStreamTest.html"> 403</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1SimpleNullStreamTest.html">SimpleNullStreamTest</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a> {</div> |
| <div class="line"><a name="l00404"></a><span class="lineno"> 404</span>  <span class="keyword">protected</span>:</div> |
| <div class="line"><a name="l00405"></a><span class="lineno"><a class="line" href="classimpala_1_1SimpleNullStreamTest.html#a20cc5398cba08ee58cdbfe1ff08660fa"> 405</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1SimpleNullStreamTest.html#a20cc5398cba08ee58cdbfe1ff08660fa">CreateDescriptors</a>() {</div> |
| <div class="line"><a name="l00406"></a><span class="lineno"> 406</span>  vector<bool> nullable_tuples(1, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00407"></a><span class="lineno"> 407</span>  vector<TTupleId> tuple_ids(1, static_cast<TTupleId>(0));</div> |
| <div class="line"><a name="l00408"></a><span class="lineno"> 408</span> </div> |
| <div class="line"><a name="l00409"></a><span class="lineno"> 409</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> int_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00410"></a><span class="lineno"> 410</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00411"></a><span class="lineno"> 411</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00412"></a><span class="lineno"> 412</span>  *int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00413"></a><span class="lineno"> 413</span> </div> |
| <div class="line"><a name="l00414"></a><span class="lineno"> 414</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> string_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00415"></a><span class="lineno"> 415</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00416"></a><span class="lineno"> 416</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00417"></a><span class="lineno"> 417</span>  *string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00418"></a><span class="lineno"> 418</span>  }</div> |
| <div class="line"><a name="l00419"></a><span class="lineno"> 419</span> }; <span class="comment">// SimpleNullStreamTest</span></div> |
| <div class="line"><a name="l00420"></a><span class="lineno"> 420</span> </div> |
| <div class="line"><a name="l00421"></a><span class="lineno"> 421</span> <span class="comment">// Tests with multiple non-NULLable tuples per row.</span></div> |
| <div class="line"><a name="l00422"></a><span class="lineno"><a class="line" href="classimpala_1_1MultiTupleStreamTest.html"> 422</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1MultiTupleStreamTest.html">MultiTupleStreamTest</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a> {</div> |
| <div class="line"><a name="l00423"></a><span class="lineno"> 423</span>  <span class="keyword">protected</span>:</div> |
| <div class="line"><a name="l00424"></a><span class="lineno"><a class="line" href="classimpala_1_1MultiTupleStreamTest.html#aab039101d5a28d23fa171ec9605cea96"> 424</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1MultiTupleStreamTest.html#aab039101d5a28d23fa171ec9605cea96">CreateDescriptors</a>() {</div> |
| <div class="line"><a name="l00425"></a><span class="lineno"> 425</span>  vector<bool> nullable_tuples;</div> |
| <div class="line"><a name="l00426"></a><span class="lineno"> 426</span>  nullable_tuples.push_back(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00427"></a><span class="lineno"> 427</span>  nullable_tuples.push_back(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00428"></a><span class="lineno"> 428</span>  nullable_tuples.push_back(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00429"></a><span class="lineno"> 429</span> </div> |
| <div class="line"><a name="l00430"></a><span class="lineno"> 430</span>  vector<TTupleId> tuple_ids;</div> |
| <div class="line"><a name="l00431"></a><span class="lineno"> 431</span>  tuple_ids.push_back(static_cast<TTupleId>(0));</div> |
| <div class="line"><a name="l00432"></a><span class="lineno"> 432</span>  tuple_ids.push_back(static_cast<TTupleId>(1));</div> |
| <div class="line"><a name="l00433"></a><span class="lineno"> 433</span>  tuple_ids.push_back(static_cast<TTupleId>(2));</div> |
| <div class="line"><a name="l00434"></a><span class="lineno"> 434</span> </div> |
| <div class="line"><a name="l00435"></a><span class="lineno"> 435</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> int_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00436"></a><span class="lineno"> 436</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00437"></a><span class="lineno"> 437</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00438"></a><span class="lineno"> 438</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00439"></a><span class="lineno"> 439</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00440"></a><span class="lineno"> 440</span>  *int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00441"></a><span class="lineno"> 441</span> </div> |
| <div class="line"><a name="l00442"></a><span class="lineno"> 442</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> string_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00443"></a><span class="lineno"> 443</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00444"></a><span class="lineno"> 444</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00445"></a><span class="lineno"> 445</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00446"></a><span class="lineno"> 446</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00447"></a><span class="lineno"> 447</span>  *string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00448"></a><span class="lineno"> 448</span>  }</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="l00451"></a><span class="lineno"> 451</span> <span class="comment">// Tests with multiple NULLable tuples per row.</span></div> |
| <div class="line"><a name="l00452"></a><span class="lineno"><a class="line" href="classimpala_1_1MultiNullableTupleStreamTest.html"> 452</a></span> <span class="keyword">class </span><a class="code" href="classimpala_1_1MultiNullableTupleStreamTest.html">MultiNullableTupleStreamTest</a> : <span class="keyword">public</span> <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a> {</div> |
| <div class="line"><a name="l00453"></a><span class="lineno"> 453</span>  <span class="keyword">protected</span>:</div> |
| <div class="line"><a name="l00454"></a><span class="lineno"><a class="line" href="classimpala_1_1MultiNullableTupleStreamTest.html#a9d45ddcccff4023f610ebc5b20a0e57b"> 454</a></span>  <span class="keyword">virtual</span> <span class="keywordtype">void</span> <a class="code" href="classimpala_1_1MultiNullableTupleStreamTest.html#a9d45ddcccff4023f610ebc5b20a0e57b">CreateDescriptors</a>() {</div> |
| <div class="line"><a name="l00455"></a><span class="lineno"> 455</span>  vector<bool> nullable_tuples;</div> |
| <div class="line"><a name="l00456"></a><span class="lineno"> 456</span>  nullable_tuples.push_back(<span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00457"></a><span class="lineno"> 457</span>  nullable_tuples.push_back(<span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00458"></a><span class="lineno"> 458</span>  nullable_tuples.push_back(<span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00459"></a><span class="lineno"> 459</span> </div> |
| <div class="line"><a name="l00460"></a><span class="lineno"> 460</span>  vector<TTupleId> tuple_ids;</div> |
| <div class="line"><a name="l00461"></a><span class="lineno"> 461</span>  tuple_ids.push_back(static_cast<TTupleId>(0));</div> |
| <div class="line"><a name="l00462"></a><span class="lineno"> 462</span>  tuple_ids.push_back(static_cast<TTupleId>(1));</div> |
| <div class="line"><a name="l00463"></a><span class="lineno"> 463</span>  tuple_ids.push_back(static_cast<TTupleId>(2));</div> |
| <div class="line"><a name="l00464"></a><span class="lineno"> 464</span> </div> |
| <div class="line"><a name="l00465"></a><span class="lineno"> 465</span>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> int_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00466"></a><span class="lineno"> 466</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00467"></a><span class="lineno"> 467</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00468"></a><span class="lineno"> 468</span>  int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">TYPE_INT</a>;</div> |
| <div class="line"><a name="l00469"></a><span class="lineno"> 469</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">int_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00470"></a><span class="lineno"> 470</span>  *int_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</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>  <a class="code" href="classimpala_1_1DescriptorTblBuilder.html">DescriptorTblBuilder</a> string_builder(&<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>);</div> |
| <div class="line"><a name="l00473"></a><span class="lineno"> 473</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00474"></a><span class="lineno"> 474</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00475"></a><span class="lineno"> 475</span>  string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">DeclareTuple</a>() << <a class="code" href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">TYPE_STRING</a>;</div> |
| <div class="line"><a name="l00476"></a><span class="lineno"> 476</span>  <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">string_desc_</a> = <a class="code" href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">pool_</a>.<a class="code" href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">Add</a>(<span class="keyword">new</span> <a class="code" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>(</div> |
| <div class="line"><a name="l00477"></a><span class="lineno"> 477</span>  *string_builder.<a class="code" href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">Build</a>(), tuple_ids, nullable_tuples));</div> |
| <div class="line"><a name="l00478"></a><span class="lineno"> 478</span>  }</div> |
| <div class="line"><a name="l00479"></a><span class="lineno"> 479</span> };</div> |
| <div class="line"><a name="l00480"></a><span class="lineno"> 480</span> </div> |
| <div class="line"><a name="l00481"></a><span class="lineno"> 481</span> <span class="comment">// Basic API test. No data should be going to disk.</span></div> |
| <div class="line"><a name="l00482"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a0ef8e7b3b6826282b9f75beeb1c02796"> 482</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a>, Basic) {</div> |
| <div class="line"><a name="l00483"></a><span class="lineno"> 483</span>  CreateMgr(-1, 8 * 1024 * 1024);</div> |
| <div class="line"><a name="l00484"></a><span class="lineno"> 484</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00485"></a><span class="lineno"> 485</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00486"></a><span class="lineno"> 486</span>  TestValues<int>(100, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00487"></a><span class="lineno"> 487</span> </div> |
| <div class="line"><a name="l00488"></a><span class="lineno"> 488</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00489"></a><span class="lineno"> 489</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00490"></a><span class="lineno"> 490</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00491"></a><span class="lineno"> 491</span> </div> |
| <div class="line"><a name="l00492"></a><span class="lineno"> 492</span>  TestIntValuesInterleaved(1, 1);</div> |
| <div class="line"><a name="l00493"></a><span class="lineno"> 493</span>  TestIntValuesInterleaved(10, 5);</div> |
| <div class="line"><a name="l00494"></a><span class="lineno"> 494</span>  TestIntValuesInterleaved(100, 15);</div> |
| <div class="line"><a name="l00495"></a><span class="lineno"> 495</span> }</div> |
| <div class="line"><a name="l00496"></a><span class="lineno"> 496</span> </div> |
| <div class="line"><a name="l00497"></a><span class="lineno"> 497</span> <span class="comment">// Test with only 1 buffer.</span></div> |
| <div class="line"><a name="l00498"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a5178a88ed9f1ec03a5bbe5c539b50dac"> 498</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a>, OneBufferSpill) {</div> |
| <div class="line"><a name="l00499"></a><span class="lineno"> 499</span>  <span class="comment">// Each buffer can only hold 100 ints, so this spills quite often.</span></div> |
| <div class="line"><a name="l00500"></a><span class="lineno"> 500</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00501"></a><span class="lineno"> 501</span>  CreateMgr(buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00502"></a><span class="lineno"> 502</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00503"></a><span class="lineno"> 503</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00504"></a><span class="lineno"> 504</span> </div> |
| <div class="line"><a name="l00505"></a><span class="lineno"> 505</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00506"></a><span class="lineno"> 506</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00507"></a><span class="lineno"> 507</span> }</div> |
| <div class="line"><a name="l00508"></a><span class="lineno"> 508</span> </div> |
| <div class="line"><a name="l00509"></a><span class="lineno"> 509</span> <span class="comment">// Test with a few buffers.</span></div> |
| <div class="line"><a name="l00510"></a><span class="lineno"><a class="line" href="namespaceimpala.html#acff08e097afdeff02b30c4902ba85820"> 510</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a>, ManyBufferSpill) {</div> |
| <div class="line"><a name="l00511"></a><span class="lineno"> 511</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00512"></a><span class="lineno"> 512</span>  CreateMgr(10 * buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00513"></a><span class="lineno"> 513</span> </div> |
| <div class="line"><a name="l00514"></a><span class="lineno"> 514</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00515"></a><span class="lineno"> 515</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00516"></a><span class="lineno"> 516</span>  TestValues<int>(100, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00517"></a><span class="lineno"> 517</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00518"></a><span class="lineno"> 518</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00519"></a><span class="lineno"> 519</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00520"></a><span class="lineno"> 520</span> </div> |
| <div class="line"><a name="l00521"></a><span class="lineno"> 521</span>  TestIntValuesInterleaved(1, 1);</div> |
| <div class="line"><a name="l00522"></a><span class="lineno"> 522</span>  TestIntValuesInterleaved(10, 5);</div> |
| <div class="line"><a name="l00523"></a><span class="lineno"> 523</span>  TestIntValuesInterleaved(100, 15);</div> |
| <div class="line"><a name="l00524"></a><span class="lineno"> 524</span> }</div> |
| <div class="line"><a name="l00525"></a><span class="lineno"> 525</span> </div> |
| <div class="line"><a name="l00526"></a><span class="lineno"><a class="line" href="namespaceimpala.html#abbb78bb85327bebb1ac6425d994204c8"> 526</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a>, UnpinPin) {</div> |
| <div class="line"><a name="l00527"></a><span class="lineno"> 527</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00528"></a><span class="lineno"> 528</span>  CreateMgr(3 * buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00529"></a><span class="lineno"> 529</span> </div> |
| <div class="line"><a name="l00530"></a><span class="lineno"> 530</span>  <a class="code" href="classimpala_1_1BufferedTupleStream.html">BufferedTupleStream</a> stream(runtime_state_.get(), *int_desc_, block_mgr_.get(), client_);</div> |
| <div class="line"><a name="l00531"></a><span class="lineno"> 531</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = stream.Init();</div> |
| <div class="line"><a name="l00532"></a><span class="lineno"> 532</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00533"></a><span class="lineno"> 533</span> </div> |
| <div class="line"><a name="l00534"></a><span class="lineno"> 534</span>  <span class="keywordtype">int</span> <a class="code" href="partitioning-throughput-test_8cc.html#ad172ecfd5c31c5df6282c2b4bc322bf7">offset</a> = 0;</div> |
| <div class="line"><a name="l00535"></a><span class="lineno"> 535</span>  <span class="keywordtype">bool</span> full = <span class="keyword">false</span>;</div> |
| <div class="line"><a name="l00536"></a><span class="lineno"> 536</span>  <span class="keywordflow">while</span> (!full) {</div> |
| <div class="line"><a name="l00537"></a><span class="lineno"> 537</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = CreateIntBatch(offset, <a class="code" href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a>, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00538"></a><span class="lineno"> 538</span>  <span class="keywordtype">int</span> j = 0;</div> |
| <div class="line"><a name="l00539"></a><span class="lineno"> 539</span>  <span class="keywordflow">for</span> (; j < batch-><a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>(); ++j) {</div> |
| <div class="line"><a name="l00540"></a><span class="lineno"> 540</span>  full = !stream.AddRow(batch-><a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(j));</div> |
| <div class="line"><a name="l00541"></a><span class="lineno"> 541</span>  <span class="keywordflow">if</span> (full) <span class="keywordflow">break</span>;</div> |
| <div class="line"><a name="l00542"></a><span class="lineno"> 542</span>  }</div> |
| <div class="line"><a name="l00543"></a><span class="lineno"> 543</span>  offset += j;</div> |
| <div class="line"><a name="l00544"></a><span class="lineno"> 544</span>  }</div> |
| <div class="line"><a name="l00545"></a><span class="lineno"> 545</span> </div> |
| <div class="line"><a name="l00546"></a><span class="lineno"> 546</span>  status = stream.UnpinStream();</div> |
| <div class="line"><a name="l00547"></a><span class="lineno"> 547</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00548"></a><span class="lineno"> 548</span> </div> |
| <div class="line"><a name="l00549"></a><span class="lineno"> 549</span>  <span class="keywordtype">bool</span> pinned = <span class="keyword">false</span>;</div> |
| <div class="line"><a name="l00550"></a><span class="lineno"> 550</span>  status = stream.PinStream(<span class="keyword">false</span>, &pinned);</div> |
| <div class="line"><a name="l00551"></a><span class="lineno"> 551</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00552"></a><span class="lineno"> 552</span>  ASSERT_TRUE(pinned);</div> |
| <div class="line"><a name="l00553"></a><span class="lineno"> 553</span> </div> |
| <div class="line"><a name="l00554"></a><span class="lineno"> 554</span>  vector<int> results;</div> |
| <div class="line"><a name="l00555"></a><span class="lineno"> 555</span> </div> |
| <div class="line"><a name="l00556"></a><span class="lineno"> 556</span>  <span class="comment">// Read and verify result a few times. We should be able to reread the stream.</span></div> |
| <div class="line"><a name="l00557"></a><span class="lineno"> 557</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < 3; ++i) {</div> |
| <div class="line"><a name="l00558"></a><span class="lineno"> 558</span>  status = stream.PrepareForRead();</div> |
| <div class="line"><a name="l00559"></a><span class="lineno"> 559</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00560"></a><span class="lineno"> 560</span>  results.clear();</div> |
| <div class="line"><a name="l00561"></a><span class="lineno"> 561</span>  ReadValues(&stream, int_desc_, &results);</div> |
| <div class="line"><a name="l00562"></a><span class="lineno"> 562</span>  VerifyResults(results, offset, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00563"></a><span class="lineno"> 563</span>  }</div> |
| <div class="line"><a name="l00564"></a><span class="lineno"> 564</span> </div> |
| <div class="line"><a name="l00565"></a><span class="lineno"> 565</span>  stream.Close();</div> |
| <div class="line"><a name="l00566"></a><span class="lineno"> 566</span> }</div> |
| <div class="line"><a name="l00567"></a><span class="lineno"> 567</span> </div> |
| <div class="line"><a name="l00568"></a><span class="lineno"><a class="line" href="namespaceimpala.html#aa434b67c3336da631907351ddbb0e4a3"> 568</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1SimpleTupleStreamTest.html">SimpleTupleStreamTest</a>, SmallBuffers) {</div> |
| <div class="line"><a name="l00569"></a><span class="lineno"> 569</span>  <span class="keywordtype">int</span> buffer_size = 8 * 1024 * 1024;</div> |
| <div class="line"><a name="l00570"></a><span class="lineno"> 570</span>  CreateMgr(2 * buffer_size, buffer_size);</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>  <a class="code" href="classimpala_1_1BufferedTupleStream.html">BufferedTupleStream</a> stream(runtime_state_.get(), *int_desc_, block_mgr_.get(), client_);</div> |
| <div class="line"><a name="l00573"></a><span class="lineno"> 573</span>  <a class="code" href="classimpala_1_1Status.html">Status</a> status = stream.Init(NULL, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00574"></a><span class="lineno"> 574</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00575"></a><span class="lineno"> 575</span> </div> |
| <div class="line"><a name="l00576"></a><span class="lineno"> 576</span>  <span class="comment">// Initial buffer should be small.</span></div> |
| <div class="line"><a name="l00577"></a><span class="lineno"> 577</span>  EXPECT_LT(stream.bytes_in_mem(<span class="keyword">false</span>), buffer_size);</div> |
| <div class="line"><a name="l00578"></a><span class="lineno"> 578</span> </div> |
| <div class="line"><a name="l00579"></a><span class="lineno"> 579</span>  <a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch = CreateIntBatch(0, 1024, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00580"></a><span class="lineno"> 580</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < batch->num_rows(); ++i) {</div> |
| <div class="line"><a name="l00581"></a><span class="lineno"> 581</span>  <span class="keywordtype">bool</span> ret = stream.AddRow(batch->GetRow(i));</div> |
| <div class="line"><a name="l00582"></a><span class="lineno"> 582</span>  EXPECT_TRUE(ret);</div> |
| <div class="line"><a name="l00583"></a><span class="lineno"> 583</span>  }</div> |
| <div class="line"><a name="l00584"></a><span class="lineno"> 584</span>  EXPECT_LT(stream.bytes_in_mem(<span class="keyword">false</span>), buffer_size);</div> |
| <div class="line"><a name="l00585"></a><span class="lineno"> 585</span>  EXPECT_LT(stream.byte_size(), buffer_size);</div> |
| <div class="line"><a name="l00586"></a><span class="lineno"> 586</span> </div> |
| <div class="line"><a name="l00587"></a><span class="lineno"> 587</span>  <span class="comment">// 40 MB of ints</span></div> |
| <div class="line"><a name="l00588"></a><span class="lineno"> 588</span>  batch = CreateIntBatch(0, 10 * 1024 * 1024, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00589"></a><span class="lineno"> 589</span>  <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i < batch->num_rows(); ++i) {</div> |
| <div class="line"><a name="l00590"></a><span class="lineno"> 590</span>  <span class="keywordtype">bool</span> ret = stream.AddRow(batch->GetRow(i));</div> |
| <div class="line"><a name="l00591"></a><span class="lineno"> 591</span>  <span class="keywordflow">if</span> (!ret) {</div> |
| <div class="line"><a name="l00592"></a><span class="lineno"> 592</span>  ASSERT_TRUE(stream.using_small_buffers());</div> |
| <div class="line"><a name="l00593"></a><span class="lineno"> 593</span>  <span class="keywordtype">bool</span> got_buffer;</div> |
| <div class="line"><a name="l00594"></a><span class="lineno"> 594</span>  status = stream.SwitchToIoBuffers(&got_buffer);</div> |
| <div class="line"><a name="l00595"></a><span class="lineno"> 595</span>  ASSERT_TRUE(status.ok());</div> |
| <div class="line"><a name="l00596"></a><span class="lineno"> 596</span>  ASSERT_TRUE(got_buffer);</div> |
| <div class="line"><a name="l00597"></a><span class="lineno"> 597</span>  ret = stream.AddRow(batch->GetRow(i));</div> |
| <div class="line"><a name="l00598"></a><span class="lineno"> 598</span>  }</div> |
| <div class="line"><a name="l00599"></a><span class="lineno"> 599</span>  ASSERT_TRUE(ret);</div> |
| <div class="line"><a name="l00600"></a><span class="lineno"> 600</span>  }</div> |
| <div class="line"><a name="l00601"></a><span class="lineno"> 601</span>  EXPECT_EQ(stream.bytes_in_mem(<span class="keyword">false</span>), buffer_size);</div> |
| <div class="line"><a name="l00602"></a><span class="lineno"> 602</span> </div> |
| <div class="line"><a name="l00603"></a><span class="lineno"> 603</span>  stream.Close();</div> |
| <div class="line"><a name="l00604"></a><span class="lineno"> 604</span> }</div> |
| <div class="line"><a name="l00605"></a><span class="lineno"> 605</span> </div> |
| <div class="line"><a name="l00606"></a><span class="lineno"> 606</span> <span class="comment">// Basic API test. No data should be going to disk.</span></div> |
| <div class="line"><a name="l00607"></a><span class="lineno"><a class="line" href="namespaceimpala.html#a4e10fd0186bf4a40cfa3a09b862b7e4f"> 607</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1SimpleNullStreamTest.html">SimpleNullStreamTest</a>, Basic) {</div> |
| <div class="line"><a name="l00608"></a><span class="lineno"> 608</span>  CreateMgr(-1, 8 * 1024 * 1024);</div> |
| <div class="line"><a name="l00609"></a><span class="lineno"> 609</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00610"></a><span class="lineno"> 610</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00611"></a><span class="lineno"> 611</span>  TestValues<int>(100, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00612"></a><span class="lineno"> 612</span>  TestValues<int>(1, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00613"></a><span class="lineno"> 613</span>  TestValues<int>(10, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00614"></a><span class="lineno"> 614</span>  TestValues<int>(100, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00615"></a><span class="lineno"> 615</span> </div> |
| <div class="line"><a name="l00616"></a><span class="lineno"> 616</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00617"></a><span class="lineno"> 617</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00618"></a><span class="lineno"> 618</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00619"></a><span class="lineno"> 619</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00620"></a><span class="lineno"> 620</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00621"></a><span class="lineno"> 621</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00622"></a><span class="lineno"> 622</span> </div> |
| <div class="line"><a name="l00623"></a><span class="lineno"> 623</span>  TestIntValuesInterleaved(1, 1);</div> |
| <div class="line"><a name="l00624"></a><span class="lineno"> 624</span>  TestIntValuesInterleaved(10, 5);</div> |
| <div class="line"><a name="l00625"></a><span class="lineno"> 625</span>  TestIntValuesInterleaved(100, 15);</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="comment">// Test tuple stream with only 1 buffer and rows with multiple tuples.</span></div> |
| <div class="line"><a name="l00629"></a><span class="lineno"><a class="line" href="namespaceimpala.html#ad1ec5daba95c8eb19b92a4f086750c26"> 629</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1MultiTupleStreamTest.html">MultiTupleStreamTest</a>, MultiTupleOneBufferSpill) {</div> |
| <div class="line"><a name="l00630"></a><span class="lineno"> 630</span>  <span class="comment">// Each buffer can only hold 100 ints, so this spills quite often.</span></div> |
| <div class="line"><a name="l00631"></a><span class="lineno"> 631</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00632"></a><span class="lineno"> 632</span>  CreateMgr(buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00633"></a><span class="lineno"> 633</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00634"></a><span class="lineno"> 634</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00635"></a><span class="lineno"> 635</span> </div> |
| <div class="line"><a name="l00636"></a><span class="lineno"> 636</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00637"></a><span class="lineno"> 637</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00638"></a><span class="lineno"> 638</span> }</div> |
| <div class="line"><a name="l00639"></a><span class="lineno"> 639</span> </div> |
| <div class="line"><a name="l00640"></a><span class="lineno"> 640</span> <span class="comment">// Test with a few buffers and rows with multiple tuples.</span></div> |
| <div class="line"><a name="l00641"></a><span class="lineno"><a class="line" href="namespaceimpala.html#aa9231b170b807e583861569386641bc5"> 641</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1MultiTupleStreamTest.html">MultiTupleStreamTest</a>, MultiTupleManyBufferSpill) {</div> |
| <div class="line"><a name="l00642"></a><span class="lineno"> 642</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00643"></a><span class="lineno"> 643</span>  CreateMgr(10 * buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00644"></a><span class="lineno"> 644</span> </div> |
| <div class="line"><a name="l00645"></a><span class="lineno"> 645</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00646"></a><span class="lineno"> 646</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00647"></a><span class="lineno"> 647</span>  TestValues<int>(100, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00648"></a><span class="lineno"> 648</span> </div> |
| <div class="line"><a name="l00649"></a><span class="lineno"> 649</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00650"></a><span class="lineno"> 650</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00651"></a><span class="lineno"> 651</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00652"></a><span class="lineno"> 652</span> </div> |
| <div class="line"><a name="l00653"></a><span class="lineno"> 653</span>  TestIntValuesInterleaved(1, 1);</div> |
| <div class="line"><a name="l00654"></a><span class="lineno"> 654</span>  TestIntValuesInterleaved(10, 5);</div> |
| <div class="line"><a name="l00655"></a><span class="lineno"> 655</span>  TestIntValuesInterleaved(100, 15);</div> |
| <div class="line"><a name="l00656"></a><span class="lineno"> 656</span> }</div> |
| <div class="line"><a name="l00657"></a><span class="lineno"> 657</span> </div> |
| <div class="line"><a name="l00658"></a><span class="lineno"> 658</span> <span class="comment">// Test with rows with multiple nullable tuples.</span></div> |
| <div class="line"><a name="l00659"></a><span class="lineno"><a class="line" href="namespaceimpala.html#aee4349e4e3385b5b3226d457c19f63ba"> 659</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1MultiNullableTupleStreamTest.html">MultiNullableTupleStreamTest</a>, MultiNullableTupleOneBufferSpill) {</div> |
| <div class="line"><a name="l00660"></a><span class="lineno"> 660</span>  <span class="comment">// Each buffer can only hold 100 ints, so this spills quite often.</span></div> |
| <div class="line"><a name="l00661"></a><span class="lineno"> 661</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00662"></a><span class="lineno"> 662</span>  CreateMgr(buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00663"></a><span class="lineno"> 663</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00664"></a><span class="lineno"> 664</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00665"></a><span class="lineno"> 665</span>  TestValues<int>(1, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00666"></a><span class="lineno"> 666</span>  TestValues<int>(10, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00667"></a><span class="lineno"> 667</span> </div> |
| <div class="line"><a name="l00668"></a><span class="lineno"> 668</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00669"></a><span class="lineno"> 669</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00670"></a><span class="lineno"> 670</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00671"></a><span class="lineno"> 671</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00672"></a><span class="lineno"> 672</span> }</div> |
| <div class="line"><a name="l00673"></a><span class="lineno"> 673</span> </div> |
| <div class="line"><a name="l00674"></a><span class="lineno"> 674</span> <span class="comment">// Test with a few buffers.</span></div> |
| <div class="line"><a name="l00675"></a><span class="lineno"><a class="line" href="namespaceimpala.html#adf2bb399b0a43be36546314e40627a16"> 675</a></span> <a class="code" href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">TEST_F</a>(<a class="code" href="classimpala_1_1MultiNullableTupleStreamTest.html">MultiNullableTupleStreamTest</a>, MultiNullableTupleManyBufferSpill) {</div> |
| <div class="line"><a name="l00676"></a><span class="lineno"> 676</span>  <span class="keywordtype">int</span> buffer_size = 100 * <span class="keyword">sizeof</span>(int);</div> |
| <div class="line"><a name="l00677"></a><span class="lineno"> 677</span>  CreateMgr(10 * buffer_size, buffer_size);</div> |
| <div class="line"><a name="l00678"></a><span class="lineno"> 678</span> </div> |
| <div class="line"><a name="l00679"></a><span class="lineno"> 679</span>  TestValues<int>(1, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00680"></a><span class="lineno"> 680</span>  TestValues<int>(10, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00681"></a><span class="lineno"> 681</span>  TestValues<int>(100, int_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00682"></a><span class="lineno"> 682</span>  TestValues<int>(1, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00683"></a><span class="lineno"> 683</span>  TestValues<int>(10, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00684"></a><span class="lineno"> 684</span>  TestValues<int>(100, int_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00685"></a><span class="lineno"> 685</span> </div> |
| <div class="line"><a name="l00686"></a><span class="lineno"> 686</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00687"></a><span class="lineno"> 687</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00688"></a><span class="lineno"> 688</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">false</span>);</div> |
| <div class="line"><a name="l00689"></a><span class="lineno"> 689</span>  TestValues<StringValue>(1, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00690"></a><span class="lineno"> 690</span>  TestValues<StringValue>(10, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00691"></a><span class="lineno"> 691</span>  TestValues<StringValue>(100, string_desc_, <span class="keyword">true</span>);</div> |
| <div class="line"><a name="l00692"></a><span class="lineno"> 692</span> </div> |
| <div class="line"><a name="l00693"></a><span class="lineno"> 693</span>  TestIntValuesInterleaved(1, 1);</div> |
| <div class="line"><a name="l00694"></a><span class="lineno"> 694</span>  TestIntValuesInterleaved(10, 5);</div> |
| <div class="line"><a name="l00695"></a><span class="lineno"> 695</span>  TestIntValuesInterleaved(100, 15);</div> |
| <div class="line"><a name="l00696"></a><span class="lineno"> 696</span> }</div> |
| <div class="line"><a name="l00697"></a><span class="lineno"> 697</span> </div> |
| <div class="line"><a name="l00698"></a><span class="lineno"> 698</span> <span class="comment">// TODO: more tests.</span></div> |
| <div class="line"><a name="l00699"></a><span class="lineno"> 699</span> <span class="comment">// - The stream can operate in many modes</span></div> |
| <div class="line"><a name="l00700"></a><span class="lineno"> 700</span> </div> |
| <div class="line"><a name="l00701"></a><span class="lineno"> 701</span> }</div> |
| <div class="line"><a name="l00702"></a><span class="lineno"> 702</span> </div> |
| <div class="line"><a name="l00703"></a><span class="lineno"><a class="line" href="buffered-tuple-stream-test_8cc.html#a3c04138a5bfe5d72780bb7e82a18e627"> 703</a></span> <span class="keywordtype">int</span> <a class="code" href="buffered-tuple-stream-test_8cc.html#a3c04138a5bfe5d72780bb7e82a18e627">main</a>(<span class="keywordtype">int</span> argc, <span class="keywordtype">char</span>** argv) {</div> |
| <div class="line"><a name="l00704"></a><span class="lineno"> 704</span>  ::testing::InitGoogleTest(&argc, argv);</div> |
| <div class="line"><a name="l00705"></a><span class="lineno"> 705</span>  <a class="code" href="namespaceimpala.html#ad1fa91f70d2090b45d7799aa8ba5a3bc">impala::InitCommonRuntime</a>(argc, argv, <span class="keyword">true</span>, <a class="code" href="classimpala_1_1TestInfo.html#a199d4f93fdaffc93187e901cc512a8e3a220e0a091d5c561103a1b0e38c3ba542">impala::TestInfo::BE_TEST</a>);</div> |
| <div class="line"><a name="l00706"></a><span class="lineno"> 706</span>  <a class="code" href="namespaceimpala.html#ab54e43e58ae94049bdf5010584ee3fb2">impala::InitFeSupport</a>();</div> |
| <div class="line"><a name="l00707"></a><span class="lineno"> 707</span>  <a class="code" href="classimpala_1_1TmpFileMgr.html#a063515578b1b243b8b73b2845c25422b">impala::TmpFileMgr::Init</a>();</div> |
| <div class="line"><a name="l00708"></a><span class="lineno"> 708</span>  <a class="code" href="classimpala_1_1LlvmCodeGen.html#af99b272408ffba7f0efd7e704e386d76">impala::LlvmCodeGen::InitializeLlvm</a>();</div> |
| <div class="line"><a name="l00709"></a><span class="lineno"> 709</span>  <span class="keywordflow">return</span> RUN_ALL_TESTS();</div> |
| <div class="line"><a name="l00710"></a><span class="lineno"> 710</span> }</div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_abf979a74a51392c7ef39ba2e836f75b4"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#abf979a74a51392c7ef39ba2e836f75b4">impala::SimpleTupleStreamTest::tracker_</a></div><div class="ttdeci">MemTracker tracker_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00394">buffered-tuple-stream-test.cc:394</a></div></div> |
| <div class="ttc" id="row-batch_8h_html"><div class="ttname"><a href="row-batch_8h.html">row-batch.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_ad7fb9ac48a74747bf7209ba696066ef5"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#ad7fb9ac48a74747bf7209ba696066ef5">impala::SimpleTupleStreamTest::ReadValues</a></div><div class="ttdeci">void ReadValues(BufferedTupleStream *stream, RowDescriptor *desc, vector< T > *results, int num_batches=-1)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00215">buffered-tuple-stream-test.cc:215</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html">impala::BufferedTupleStream</a></div><div class="ttdoc">The underlying memory management is done by the BufferedBlockMgr. </div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8h_source.html#l00109">buffered-tuple-stream.h:109</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a69d9b58010b66c40e54e58d512c4fe9a"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a69d9b58010b66c40e54e58d512c4fe9a">impala::SimpleTupleStreamTest::TestIntValuesInterleaved</a></div><div class="ttdeci">void TestIntValuesInterleaved(int num_batches, int num_batches_before_read)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00347">buffered-tuple-stream-test.cc:347</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_ac695df3b85ee416b3d99844813ae813d"><div class="ttname"><a href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">impala::RowBatch::num_rows</a></div><div class="ttdeci">int num_rows() const </div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00215">row-batch.h:215</a></div></div> |
| <div class="ttc" id="classimpala_1_1Status_html_adf1a3ee82776f6102bfe873925183159"><div class="ttname"><a href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">impala::Status::GetDetail</a></div><div class="ttdeci">const std::string GetDetail() const </div><div class="ttdef"><b>Definition:</b> <a href="status_8cc_source.html#l00184">status.cc:184</a></div></div> |
| <div class="ttc" id="classimpala_1_1DescriptorTblBuilder_html"><div class="ttname"><a href="classimpala_1_1DescriptorTblBuilder.html">impala::DescriptorTblBuilder</a></div><div class="ttdef"><b>Definition:</b> <a href="desc-tbl-builder_8h_source.html#l00036">desc-tbl-builder.h:36</a></div></div> |
| <div class="ttc" id="init_8h_html"><div class="ttname"><a href="init_8h.html">init.h</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_ab54e43e58ae94049bdf5010584ee3fb2"><div class="ttname"><a href="namespaceimpala.html#ab54e43e58ae94049bdf5010584ee3fb2">impala::InitFeSupport</a></div><div class="ttdeci">void InitFeSupport()</div><div class="ttdef"><b>Definition:</b> <a href="fe-support_8cc_source.html#l00346">fe-support.cc:346</a></div></div> |
| <div class="ttc" id="structimpala_1_1StringValue_html"><div class="ttname"><a href="structimpala_1_1StringValue.html">impala::StringValue</a></div><div class="ttdef"><b>Definition:</b> <a href="string-value_8h_source.html#l00033">string-value.h:33</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a948c2ae3514c507725410a2de0e64634"><div class="ttname"><a href="namespaceimpala.html#a948c2ae3514c507725410a2de0e64634">impala::TEST_F</a></div><div class="ttdeci">TEST_F(InstructionCounterTest, Count)</div><div class="ttdef"><b>Definition:</b> <a href="instruction-counter-test_8cc_source.html#l00069">instruction-counter-test.cc:69</a></div></div> |
| <div class="ttc" id="classimpala_1_1TupleRow_html_aed3092e531291470b27fc48afa901600"><div class="ttname"><a href="classimpala_1_1TupleRow.html#aed3092e531291470b27fc48afa901600">impala::TupleRow::GetTuple</a></div><div class="ttdeci">Tuple * GetTuple(int tuple_idx)</div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00030">tuple-row.h:30</a></div></div> |
| <div class="ttc" id="classimpala_1_1MultiTupleStreamTest_html_aab039101d5a28d23fa171ec9605cea96"><div class="ttname"><a href="classimpala_1_1MultiTupleStreamTest.html#aab039101d5a28d23fa171ec9605cea96">impala::MultiTupleStreamTest::CreateDescriptors</a></div><div class="ttdeci">virtual void CreateDescriptors()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00424">buffered-tuple-stream-test.cc:424</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html">impala::SimpleTupleStreamTest</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00057">buffered-tuple-stream-test.cc:57</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a24c3c541b1c9eb15dcb5644d8259414d"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a24c3c541b1c9eb15dcb5644d8259414d">impala::SimpleTupleStreamTest::runtime_state_</a></div><div class="ttdeci">scoped_ptr< RuntimeState > runtime_state_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00388">buffered-tuple-stream-test.cc:388</a></div></div> |
| <div class="ttc" id="buffered-tuple-stream-test_8cc_html_a3c04138a5bfe5d72780bb7e82a18e627"><div class="ttname"><a href="buffered-tuple-stream-test_8cc.html#a3c04138a5bfe5d72780bb7e82a18e627">main</a></div><div class="ttdeci">int main(int argc, char **argv)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00703">buffered-tuple-stream-test.cc:703</a></div></div> |
| <div class="ttc" id="classimpala_1_1Tuple_html"><div class="ttname"><a href="classimpala_1_1Tuple.html">impala::Tuple</a></div><div class="ttdoc">A tuple with 0 materialised slots is represented as NULL. </div><div class="ttdef"><b>Definition:</b> <a href="tuple_8h_source.html#l00048">tuple.h:48</a></div></div> |
| <div class="ttc" id="structimpala_1_1StringValue_html_ab71e42890598d9b239cac64485db276d"><div class="ttname"><a href="structimpala_1_1StringValue.html#ab71e42890598d9b239cac64485db276d">impala::StringValue::len</a></div><div class="ttdeci">int len</div><div class="ttdef"><b>Definition:</b> <a href="string-value_8h_source.html#l00038">string-value.h:38</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_ac05069bbc3e95609283da5da6c42c297"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#ac05069bbc3e95609283da5da6c42c297">impala::SimpleTupleStreamTest::CreateDescriptors</a></div><div class="ttdeci">virtual void CreateDescriptors()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00070">buffered-tuple-stream-test.cc:70</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a3467236bf4092160044b3e367da9c911"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a3467236bf4092160044b3e367da9c911">impala::SimpleTupleStreamTest::exec_env_</a></div><div class="ttdeci">scoped_ptr< ExecEnv > exec_env_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00387">buffered-tuple-stream-test.cc:387</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_ab3faf0bb3e444230fe8dba269a5f5e16"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#ab3faf0bb3e444230fe8dba269a5f5e16">impala::SimpleTupleStreamTest::CreateIntBatch</a></div><div class="ttdeci">virtual RowBatch * CreateIntBatch(int start_val, int num_rows, bool gen_null)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00101">buffered-tuple-stream-test.cc:101</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_af1bea454e316dfab89abcda3a9f881c9"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#af1bea454e316dfab89abcda3a9f881c9">impala::SimpleTupleStreamTest::AppendValue</a></div><div class="ttdeci">void AppendValue(Tuple *t, vector< int > *results)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00192">buffered-tuple-stream-test.cc:192</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_ad1fa91f70d2090b45d7799aa8ba5a3bc"><div class="ttname"><a href="namespaceimpala.html#ad1fa91f70d2090b45d7799aa8ba5a3bc">impala::InitCommonRuntime</a></div><div class="ttdeci">void InitCommonRuntime(int argc, char **argv, bool init_jvm, TestInfo::Mode m=TestInfo::NON_TEST)</div><div class="ttdef"><b>Definition:</b> <a href="init_8cc_source.html#l00122">init.cc:122</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_a9320ed986b0717ef26d73d871f3b3a42"><div class="ttname"><a href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">impala::RowBatch::GetRow</a></div><div class="ttdeci">TupleRow * GetRow(int row_idx)</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00140">row-batch.h:140</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a35d08ebddcf9676acd7795711cf9c9cb"><div class="ttname"><a href="namespaceimpala.html#a35d08ebddcf9676acd7795711cf9c9cb">impala::STRINGS</a></div><div class="ttdeci">static const StringValue STRINGS[]</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00043">buffered-tuple-stream-test.cc:43</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleNullStreamTest_html"><div class="ttname"><a href="classimpala_1_1SimpleNullStreamTest.html">impala::SimpleNullStreamTest</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00403">buffered-tuple-stream-test.cc:403</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a75912f2e5b6853ff0f07f0764dde3ccb"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a75912f2e5b6853ff0f07f0764dde3ccb">impala::SimpleTupleStreamTest::AppendValue</a></div><div class="ttdeci">void AppendValue(Tuple *t, vector< StringValue > *results)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00201">buffered-tuple-stream-test.cc:201</a></div></div> |
| <div class="ttc" id="structimpala_1_1BufferedBlockMgr_1_1Client_html"><div class="ttname"><a href="structimpala_1_1BufferedBlockMgr_1_1Client.html">impala::BufferedBlockMgr::Client</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-block-mgr_8cc_source.html#l00045">buffered-block-mgr.cc:45</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowDescriptor_html"><div class="ttname"><a href="classimpala_1_1RowDescriptor.html">impala::RowDescriptor</a></div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00373">descriptors.h:373</a></div></div> |
| <div class="ttc" id="classimpala_1_1ObjectPool_html"><div class="ttname"><a href="classimpala_1_1ObjectPool.html">impala::ObjectPool</a></div><div class="ttdef"><b>Definition:</b> <a href="object-pool_8h_source.html#l00030">object-pool.h:30</a></div></div> |
| <div class="ttc" id="buffered-tuple-stream_8inline_8h_html"><div class="ttname"><a href="buffered-tuple-stream_8inline_8h.html">buffered-tuple-stream.inline.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1TmpFileMgr_html_a063515578b1b243b8b73b2845c25422b"><div class="ttname"><a href="classimpala_1_1TmpFileMgr.html#a063515578b1b243b8b73b2845c25422b">impala::TmpFileMgr::Init</a></div><div class="ttdeci">static Status Init()</div><div class="ttdef"><b>Definition:</b> <a href="tmp-file-mgr_8cc_source.html#l00047">tmp-file-mgr.cc:47</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_a7e823da164a27afd1c0c70f599d942db"><div class="ttname"><a href="namespaceimpala.html#a7e823da164a27afd1c0c70f599d942db">impala::NUM_STRINGS</a></div><div class="ttdeci">static const int NUM_STRINGS</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00055">buffered-tuple-stream-test.cc:55</a></div></div> |
| <div class="ttc" id="llvm-codegen_8h_html"><div class="ttname"><a href="llvm-codegen_8h.html">llvm-codegen.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a8a4e1f0aa016ad6c03e3cccd28027622"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a8a4e1f0aa016ad6c03e3cccd28027622">impala::SimpleTupleStreamTest::block_mgr_</a></div><div class="ttdeci">shared_ptr< BufferedBlockMgr > block_mgr_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00391">buffered-tuple-stream-test.cc:391</a></div></div> |
| <div class="ttc" id="classimpala_1_1TupleRow_html"><div class="ttname"><a href="classimpala_1_1TupleRow.html">impala::TupleRow</a></div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00028">tuple-row.h:28</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_abaeb8139bfbda394008df282a8053087"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#abaeb8139bfbda394008df282a8053087">impala::SimpleTupleStreamTest::TestValues</a></div><div class="ttdeci">void TestValues(int num_batches, RowDescriptor *desc, bool gen_null)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00299">buffered-tuple-stream-test.cc:299</a></div></div> |
| <div class="ttc" id="buffered-tuple-stream-test_8cc_html_ac1d895cb4479f043958ccc5cb92d630f"><div class="ttname"><a href="buffered-tuple-stream-test_8cc.html#ac1d895cb4479f043958ccc5cb92d630f">BATCH_SIZE</a></div><div class="ttdeci">const int BATCH_SIZE</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00039">buffered-tuple-stream-test.cc:39</a></div></div> |
| <div class="ttc" id="classimpala_1_1MultiNullableTupleStreamTest_html_a9d45ddcccff4023f610ebc5b20a0e57b"><div class="ttname"><a href="classimpala_1_1MultiNullableTupleStreamTest.html#a9d45ddcccff4023f610ebc5b20a0e57b">impala::MultiNullableTupleStreamTest::CreateDescriptors</a></div><div class="ttdeci">virtual void CreateDescriptors()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00454">buffered-tuple-stream-test.cc:454</a></div></div> |
| <div class="ttc" id="classimpala_1_1DescriptorTblBuilder_html_af73f3a690dd7c994cc553918fa97b6f8"><div class="ttname"><a href="classimpala_1_1DescriptorTblBuilder.html#af73f3a690dd7c994cc553918fa97b6f8">impala::DescriptorTblBuilder::Build</a></div><div class="ttdeci">DescriptorTbl * Build()</div><div class="ttdef"><b>Definition:</b> <a href="desc-tbl-builder_8cc_source.html#l00059">desc-tbl-builder.cc:59</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="namespaceimpala_html_aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944"><div class="ttname"><a href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a8e892339c263b2aaa3712139b0a0c944">impala::TYPE_INT</a></div><div class="ttdef"><b>Definition:</b> <a href="types_8h_source.html#l00033">types.h:33</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_ae743d78af5c0de45046d3f2ece75b326"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#ae743d78af5c0de45046d3f2ece75b326">impala::SimpleTupleStreamTest::pool_</a></div><div class="ttdeci">ObjectPool pool_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00395">buffered-tuple-stream-test.cc:395</a></div></div> |
| <div class="ttc" id="classimpala_1_1MemPool_html"><div class="ttname"><a href="classimpala_1_1MemPool.html">impala::MemPool</a></div><div class="ttdef"><b>Definition:</b> <a href="mem-pool_8h_source.html#l00077">mem-pool.h:77</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_ac351eaf211eb53882564b604db07b824"><div class="ttname"><a href="classimpala_1_1RowBatch.html#ac351eaf211eb53882564b604db07b824">impala::RowBatch::Reset</a></div><div class="ttdeci">void Reset()</div><div class="ttdoc">Resets the row batch, returning all resources it has accumulated. </div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8cc_source.html#l00224">row-batch.cc:224</a></div></div> |
| <div class="ttc" id="classimpala_1_1RuntimeState_html"><div class="ttname"><a href="classimpala_1_1RuntimeState.html">impala::RuntimeState</a></div><div class="ttdef"><b>Definition:</b> <a href="runtime-state_8h_source.html#l00069">runtime-state.h:69</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a955a0e3a24bab770a4163fcc3c33ed44"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a955a0e3a24bab770a4163fcc3c33ed44">impala::SimpleTupleStreamTest::AppendRowTuples</a></div><div class="ttdeci">void AppendRowTuples(TupleRow *row, vector< StringValue > *results)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00184">buffered-tuple-stream-test.cc:184</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a5db75fcf103aacdaa2b86bb21b29a20a"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a5db75fcf103aacdaa2b86bb21b29a20a">impala::SimpleTupleStreamTest::VerifyResults</a></div><div class="ttdeci">virtual void VerifyResults(const vector< int > &results, int exp_rows, bool gen_null)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00231">buffered-tuple-stream-test.cc:231</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedBlockMgr_html_a76ef041b360fb6146c687b3e479546e1"><div class="ttname"><a href="classimpala_1_1BufferedBlockMgr.html#a76ef041b360fb6146c687b3e479546e1">impala::BufferedBlockMgr::Create</a></div><div class="ttdeci">static Status Create(RuntimeState *state, MemTracker *parent, RuntimeProfile *profile, int64_t mem_limit, int64_t buffer_size, boost::shared_ptr< BufferedBlockMgr > *block_mgr)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-block-mgr_8cc_source.html#l00199">buffered-block-mgr.cc:199</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a92a20377928d95c6ea3a5e7ffb31cb0b"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a92a20377928d95c6ea3a5e7ffb31cb0b">impala::SimpleTupleStreamTest::AppendRowTuples</a></div><div class="ttdeci">void AppendRowTuples(TupleRow *row, vector< int > *results)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00176">buffered-tuple-stream-test.cc:176</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a1085ffd26acc139f096eea3db39f2612"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a1085ffd26acc139f096eea3db39f2612">impala::SimpleTupleStreamTest::int_desc_</a></div><div class="ttdeci">RowDescriptor * int_desc_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00396">buffered-tuple-stream-test.cc:396</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_1SimpleTupleStreamTest_html_aebc94f14ef6ae0e05a64686d281df151"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#aebc94f14ef6ae0e05a64686d281df151">impala::SimpleTupleStreamTest::SetUp</a></div><div class="ttdeci">virtual void SetUp()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00059">buffered-tuple-stream-test.cc:59</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_aef978a61ab3f47c2b9e53e304eead853"><div class="ttname"><a href="classimpala_1_1RowBatch.html#aef978a61ab3f47c2b9e53e304eead853">impala::RowBatch::CommitLastRow</a></div><div class="ttdeci">void CommitLastRow()</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00109">row-batch.h:109</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a6ce73724f30a412ae295b42669771241"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a6ce73724f30a412ae295b42669771241">impala::SimpleTupleStreamTest::client_</a></div><div class="ttdeci">BufferedBlockMgr::Client * client_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00392">buffered-tuple-stream-test.cc:392</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html"><div class="ttname"><a href="classimpala_1_1RowBatch.html">impala::RowBatch</a></div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00066">row-batch.h:66</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleNullStreamTest_html_a20cc5398cba08ee58cdbfe1ff08660fa"><div class="ttname"><a href="classimpala_1_1SimpleNullStreamTest.html#a20cc5398cba08ee58cdbfe1ff08660fa">impala::SimpleNullStreamTest::CreateDescriptors</a></div><div class="ttdeci">virtual void CreateDescriptors()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00405">buffered-tuple-stream-test.cc:405</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_a82611d227a12dd5c2e1ca1ba77d86736"><div class="ttname"><a href="classimpala_1_1RowBatch.html#a82611d227a12dd5c2e1ca1ba77d86736">impala::RowBatch::tuple_data_pool</a></div><div class="ttdeci">MemPool * tuple_data_pool()</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00148">row-batch.h:148</a></div></div> |
| <div class="ttc" id="cache-hash-test_8cc_html_a18269e3eecadb27e79614c02d898173e"><div class="ttname"><a href="cache-hash-test_8cc.html#a18269e3eecadb27e79614c02d898173e">Test</a></div><div class="ttdeci">uint64_t Test(T *ht, const ProbeTuple *input, uint64_t num_tuples)</div><div class="ttdef"><b>Definition:</b> <a href="cache-hash-test_8cc_source.html#l00067">cache-hash-test.cc:67</a></div></div> |
| <div class="ttc" id="structimpala_1_1StringValue_html_a17f088f03fd1f7b017df20f58f71fe13"><div class="ttname"><a href="structimpala_1_1StringValue.html#a17f088f03fd1f7b017df20f58f71fe13">impala::StringValue::ptr</a></div><div class="ttdeci">char * ptr</div><div class="ttdef"><b>Definition:</b> <a href="string-value_8h_source.html#l00037">string-value.h:37</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a10f753aa3fafdf98d327ec5cff677fc6"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a10f753aa3fafdf98d327ec5cff677fc6">impala::SimpleTupleStreamTest::VerifyResults</a></div><div class="ttdeci">virtual void VerifyResults(const vector< StringValue > &results, int exp_rows, bool gen_null)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00263">buffered-tuple-stream-test.cc:263</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowDescriptor_html_a3d57439c68d08fe374c33370529a855c"><div class="ttname"><a href="classimpala_1_1RowDescriptor.html#a3d57439c68d08fe374c33370529a855c">impala::RowDescriptor::tuple_descriptors</a></div><div class="ttdeci">const std::vector< TupleDescriptor * > & tuple_descriptors() const </div><div class="ttdoc">Return descriptors for all tuples in this row, in order of appearance. </div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00412">descriptors.h:412</a></div></div> |
| <div class="ttc" id="classimpala_1_1TupleRow_html_aaf1d69b97c90eec7da3d07bdc40f5665"><div class="ttname"><a href="classimpala_1_1TupleRow.html#aaf1d69b97c90eec7da3d07bdc40f5665">impala::TupleRow::SetTuple</a></div><div class="ttdeci">void SetTuple(int tuple_idx, Tuple *tuple)</div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00034">tuple-row.h:34</a></div></div> |
| <div class="ttc" id="classimpala_1_1LlvmCodeGen_html_af99b272408ffba7f0efd7e704e386d76"><div class="ttname"><a href="classimpala_1_1LlvmCodeGen.html#af99b272408ffba7f0efd7e704e386d76">impala::LlvmCodeGen::InitializeLlvm</a></div><div class="ttdeci">static void InitializeLlvm(bool load_backend=false)</div><div class="ttdef"><b>Definition:</b> <a href="llvm-codegen_8cc_source.html#l00078">llvm-codegen.cc:78</a></div></div> |
| <div class="ttc" id="classimpala_1_1DescriptorTblBuilder_html_af6ec606565d14ba2a9d77849fc8051de"><div class="ttname"><a href="classimpala_1_1DescriptorTblBuilder.html#af6ec606565d14ba2a9d77849fc8051de">impala::DescriptorTblBuilder::DeclareTuple</a></div><div class="ttdeci">TupleDescBuilder & DeclareTuple()</div><div class="ttdef"><b>Definition:</b> <a href="desc-tbl-builder_8cc_source.html#l00028">desc-tbl-builder.cc:28</a></div></div> |
| <div class="ttc" id="classimpala_1_1MultiTupleStreamTest_html"><div class="ttname"><a href="classimpala_1_1MultiTupleStreamTest.html">impala::MultiTupleStreamTest</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00422">buffered-tuple-stream-test.cc:422</a></div></div> |
| <div class="ttc" id="classimpala_1_1RowBatch_html_a34b82362d8ad1e89c433e04999a6a0cb"><div class="ttname"><a href="classimpala_1_1RowBatch.html#a34b82362d8ad1e89c433e04999a6a0cb">impala::RowBatch::AddRow</a></div><div class="ttdeci">int AddRow()</div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00100">row-batch.h:100</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_ae8f58f8ebd4c36234b3cfa9e4507578f"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#ae8f58f8ebd4c36234b3cfa9e4507578f">impala::SimpleTupleStreamTest::block_mgr_parent_tracker_</a></div><div class="ttdeci">scoped_ptr< MemTracker > block_mgr_parent_tracker_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00389">buffered-tuple-stream-test.cc:389</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_ac342e224b0d27a75a2edc7f66a8ed2ca"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#ac342e224b0d27a75a2edc7f66a8ed2ca">impala::SimpleTupleStreamTest::CreateStringBatch</a></div><div class="ttdeci">virtual RowBatch * CreateStringBatch(int string_idx, int num_rows, bool gen_null)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00136">buffered-tuple-stream-test.cc:136</a></div></div> |
| <div class="ttc" id="partitioning-throughput-test_8cc_html_ad172ecfd5c31c5df6282c2b4bc322bf7"><div class="ttname"><a href="partitioning-throughput-test_8cc.html#ad172ecfd5c31c5df6282c2b4bc322bf7">offset</a></div><div class="ttdeci">uint8_t offset[7 *64-sizeof(uint64_t)]</div><div class="ttdef"><b>Definition:</b> <a href="partitioning-throughput-test_8cc_source.html#l00037">partitioning-throughput-test.cc:37</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a9d12b724587769d53eb61f4f7b624c06"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a9d12b724587769d53eb61f4f7b624c06">impala::SimpleTupleStreamTest::CreateMgr</a></div><div class="ttdeci">void CreateMgr(int64_t limit, int block_size)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00093">buffered-tuple-stream-test.cc:93</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a8b61b4bff3990576ffa3e2fc0b902344"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a8b61b4bff3990576ffa3e2fc0b902344">impala::SimpleTupleStreamTest::TearDown</a></div><div class="ttdeci">virtual void TearDown()</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00085">buffered-tuple-stream-test.cc:85</a></div></div> |
| <div class="ttc" id="names_8h_html"><div class="ttname"><a href="names_8h.html">names.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1ObjectPool_html_ab191078c99825682a0a9915ca1e0c05c"><div class="ttname"><a href="classimpala_1_1ObjectPool.html#ab191078c99825682a0a9915ca1e0c05c">impala::ObjectPool::Add</a></div><div class="ttdeci">T * Add(T *t)</div><div class="ttdef"><b>Definition:</b> <a href="object-pool_8h_source.html#l00042">object-pool.h:42</a></div></div> |
| <div class="ttc" id="namespaceimpala_html_aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359"><div class="ttname"><a href="namespaceimpala.html#aa5bce0d3309643287a67504146c2f871a81087da87fdc569ea9ad101e34391359">impala::TYPE_STRING</a></div><div class="ttdef"><b>Definition:</b> <a href="types_8h_source.html#l00038">types.h:38</a></div></div> |
| <div class="ttc" id="desc-tbl-builder_8h_html"><div class="ttname"><a href="desc-tbl-builder_8h.html">desc-tbl-builder.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1ExecEnv_html"><div class="ttname"><a href="classimpala_1_1ExecEnv.html">impala::ExecEnv</a></div><div class="ttdef"><b>Definition:</b> <a href="exec-env_8h_source.html#l00053">exec-env.h:53</a></div></div> |
| <div class="ttc" id="classimpala_1_1TestInfo_html_a199d4f93fdaffc93187e901cc512a8e3a220e0a091d5c561103a1b0e38c3ba542"><div class="ttname"><a href="classimpala_1_1TestInfo.html#a199d4f93fdaffc93187e901cc512a8e3a220e0a091d5c561103a1b0e38c3ba542">impala::TestInfo::BE_TEST</a></div><div class="ttdef"><b>Definition:</b> <a href="test-info_8h_source.html#l00026">test-info.h:26</a></div></div> |
| <div class="ttc" id="namespacegen__ir__descriptions_html_a0d6572990c8dd576a55a21ff11d6deb7"><div class="ttname"><a href="namespacegen__ir__descriptions.html#a0d6572990c8dd576a55a21ff11d6deb7">gen_ir_descriptions.idx</a></div><div class="ttdeci">int idx</div><div class="ttdef"><b>Definition:</b> <a href="gen__ir__descriptions_8py_source.html#l00215">gen_ir_descriptions.py:215</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a1d3b29d840b452b046051a7d84f07b82"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a1d3b29d840b452b046051a7d84f07b82">impala::SimpleTupleStreamTest::string_desc_</a></div><div class="ttdeci">RowDescriptor * string_desc_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00397">buffered-tuple-stream-test.cc:397</a></div></div> |
| <div class="ttc" id="classimpala_1_1Status_html_a95ba859e42fe93445b340533220836ac"><div class="ttname"><a href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">impala::Status::ok</a></div><div class="ttdeci">bool ok() const </div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00172">status.h:172</a></div></div> |
| <div class="ttc" id="tmp-file-mgr_8h_html"><div class="ttname"><a href="tmp-file-mgr_8h.html">tmp-file-mgr.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1MultiNullableTupleStreamTest_html"><div class="ttname"><a href="classimpala_1_1MultiNullableTupleStreamTest.html">impala::MultiNullableTupleStreamTest</a></div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00452">buffered-tuple-stream-test.cc:452</a></div></div> |
| <div class="ttc" id="classimpala_1_1BufferedTupleStream_html_a5277d4ff9fdeb7b31bdf4d520739582d"><div class="ttname"><a href="classimpala_1_1BufferedTupleStream.html#a5277d4ff9fdeb7b31bdf4d520739582d">impala::BufferedTupleStream::GetNext</a></div><div class="ttdeci">Status GetNext(RowBatch *batch, bool *eos, std::vector< RowIdx > *indices=NULL)</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream_8cc_source.html#l00447">buffered-tuple-stream.cc:447</a></div></div> |
| <div class="ttc" id="classimpala_1_1SimpleTupleStreamTest_html_a8e47057fc9bd48c9bda08aeb67501e84"><div class="ttname"><a href="classimpala_1_1SimpleTupleStreamTest.html#a8e47057fc9bd48c9bda08aeb67501e84">impala::SimpleTupleStreamTest::mem_pool_</a></div><div class="ttdeci">scoped_ptr< MemPool > mem_pool_</div><div class="ttdef"><b>Definition:</b> <a href="buffered-tuple-stream-test_8cc_source.html#l00398">buffered-tuple-stream-test.cc:398</a></div></div> |
| <div class="ttc" id="string-value_8h_html"><div class="ttname"><a href="string-value_8h.html">string-value.h</a></div></div> |
| <div class="ttc" id="classimpala_1_1MemPool_html_a190eb28e39279c901eda3d831a9fe726"><div class="ttname"><a href="classimpala_1_1MemPool.html#a190eb28e39279c901eda3d831a9fe726">impala::MemPool::Allocate</a></div><div class="ttdeci">uint8_t * Allocate(int size)</div><div class="ttdef"><b>Definition:</b> <a href="mem-pool_8h_source.html#l00092">mem-pool.h:92</a></div></div> |
| <div class="ttc" id="fe-support_8h_html"><div class="ttname"><a href="fe-support_8h.html">fe-support.h</a></div></div> |
| <div class="ttc" id="test-info_8h_html"><div class="ttname"><a href="test-info_8h.html">test-info.h</a></div></div> |
| </div><!-- fragment --></div><!-- contents --> |
| </div><!-- doc-content --> |
| <!-- start footer part --> |
| <div id="nav-path" class="navpath"><!-- id is needed for treeview function! --> |
| <ul> |
| <li class="navelem"><a class="el" href="dir_e5d120be6b5e8a44336cbfd013b25604.html">be</a></li><li class="navelem"><a class="el" href="dir_68cf7cafb51a962d5bc4848b83cab0de.html">src</a></li><li class="navelem"><a class="el" href="dir_1ef28ab5153adb64262182d038c65543.html">runtime</a></li><li class="navelem"><a class="el" href="buffered-tuple-stream-test_8cc.html">buffered-tuple-stream-test.cc</a></li> |
| <li class="footer">Generated on Thu May 7 2015 16:10:36 for Impala by |
| <a href="http://www.doxygen.org/index.html"> |
| <img class="footer" src="doxygen.png" alt="doxygen"/></a> 1.8.6 </li> |
| </ul> |
| </div> |
| </body> |
| </html> |
