Google Git
Sign in
apache / impala / asf-site / . / doc / html / hbase-table-writer_8cc_source.html
blob: 05911182e7db1115077a9c85136ce1b0fab03a48 [file] [log] [blame]
<!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/exec/hbase-table-writer.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&#160;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&#160;List</span></a></li>
<li><a href="globals.html"><span>File&#160;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('hbase-table-writer_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">&#160;</span>All</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(1)"><span class="SelectionMark">&#160;</span>Classes</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(2)"><span class="SelectionMark">&#160;</span>Namespaces</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(3)"><span class="SelectionMark">&#160;</span>Files</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(4)"><span class="SelectionMark">&#160;</span>Functions</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(5)"><span class="SelectionMark">&#160;</span>Variables</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(6)"><span class="SelectionMark">&#160;</span>Typedefs</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(7)"><span class="SelectionMark">&#160;</span>Enumerations</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(8)"><span class="SelectionMark">&#160;</span>Enumerator</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(9)"><span class="SelectionMark">&#160;</span>Friends</a><a class="SelectItem" href="javascript:void(0)" onclick="searchBox.OnSelectItem(10)"><span class="SelectionMark">&#160;</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">hbase-table-writer.cc</div> </div>
</div><!--header-->
<div class="contents">
<a href="hbase-table-writer_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>&#160;<span class="comment">// Copyright 2012 Cloudera Inc.</span></div>
<div class="line"><a name="l00002"></a><span class="lineno"> 2</span>&#160;<span class="comment">//</span></div>
<div class="line"><a name="l00003"></a><span class="lineno"> 3</span>&#160;<span class="comment">// Licensed under the Apache License, Version 2.0 (the &quot;License&quot;);</span></div>
<div class="line"><a name="l00004"></a><span class="lineno"> 4</span>&#160;<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>&#160;<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>&#160;<span class="comment">//</span></div>
<div class="line"><a name="l00007"></a><span class="lineno"> 7</span>&#160;<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>&#160;<span class="comment">//</span></div>
<div class="line"><a name="l00009"></a><span class="lineno"> 9</span>&#160;<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>&#160;<span class="comment">// distributed under the License is distributed on an &quot;AS IS&quot; BASIS,</span></div>
<div class="line"><a name="l00011"></a><span class="lineno"> 11</span>&#160;<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>&#160;<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>&#160;<span class="comment">// limitations under the License.</span></div>
<div class="line"><a name="l00014"></a><span class="lineno"> 14</span>&#160;</div>
<div class="line"><a name="l00015"></a><span class="lineno"> 15</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="hbase-table-writer_8h.html">exec/hbase-table-writer.h</a>&quot;</span></div>
<div class="line"><a name="l00016"></a><span class="lineno"> 16</span>&#160;</div>
<div class="line"><a name="l00017"></a><span class="lineno"> 17</span>&#160;<span class="preprocessor">#include &lt;boost/foreach.hpp&gt;</span></div>
<div class="line"><a name="l00018"></a><span class="lineno"> 18</span>&#160;<span class="preprocessor">#include &lt;boost/scoped_array.hpp&gt;</span></div>
<div class="line"><a name="l00019"></a><span class="lineno"> 19</span>&#160;<span class="preprocessor">#include &lt;sstream&gt;</span></div>
<div class="line"><a name="l00020"></a><span class="lineno"> 20</span>&#160;</div>
<div class="line"><a name="l00021"></a><span class="lineno"> 21</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="logging_8h.html">common/logging.h</a>&quot;</span></div>
<div class="line"><a name="l00022"></a><span class="lineno"> 22</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="expr-context_8h.html">exprs/expr-context.h</a>&quot;</span></div>
<div class="line"><a name="l00023"></a><span class="lineno"> 23</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="hbase-table-factory_8h.html">runtime/hbase-table-factory.h</a>&quot;</span></div>
<div class="line"><a name="l00024"></a><span class="lineno"> 24</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="bit-util_8h.html">util/bit-util.h</a>&quot;</span></div>
<div class="line"><a name="l00025"></a><span class="lineno"> 25</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="jni-util_8h.html">util/jni-util.h</a>&quot;</span></div>
<div class="line"><a name="l00026"></a><span class="lineno"> 26</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="expr_8h.html">exprs/expr.h</a>&quot;</span></div>
<div class="line"><a name="l00027"></a><span class="lineno"> 27</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="raw-value_8h.html">runtime/raw-value.h</a>&quot;</span></div>
<div class="line"><a name="l00028"></a><span class="lineno"> 28</span>&#160;</div>
<div class="line"><a name="l00029"></a><span class="lineno"> 29</span>&#160;<span class="preprocessor">#include &quot;<a class="code" href="names_8h.html">common/names.h</a>&quot;</span></div>
<div class="line"><a name="l00030"></a><span class="lineno"> 30</span>&#160;</div>
<div class="line"><a name="l00031"></a><span class="lineno"> 31</span>&#160;<span class="keyword">namespace </span>impala {</div>
<div class="line"><a name="l00032"></a><span class="lineno"> 32</span>&#160;</div>
<div class="line"><a name="l00033"></a><span class="lineno"> 33</span>&#160;jclass <a class="code" href="classimpala_1_1HBaseTableWriter.html#a1beb44475c480235b4715868b0923dff">HBaseTableWriter::put_cl_</a> = NULL;</div>
<div class="line"><a name="l00034"></a><span class="lineno"> 34</span>&#160;jclass <a class="code" href="classimpala_1_1HBaseTableWriter.html#a646f7fb13ececd4275c3916d0ed8439d">HBaseTableWriter::list_cl_</a> = NULL;</div>
<div class="line"><a name="l00035"></a><span class="lineno"> 35</span>&#160;</div>
<div class="line"><a name="l00036"></a><span class="lineno"> 36</span>&#160;jmethodID <a class="code" href="classimpala_1_1HBaseTableWriter.html#a652d5ab8a9a3c71975ba44ff9352c0b2">HBaseTableWriter::put_ctor_</a> = NULL;</div>
<div class="line"><a name="l00037"></a><span class="lineno"> 37</span>&#160;jmethodID <a class="code" href="classimpala_1_1HBaseTableWriter.html#a558e02c7aa8b722f4e4b01b6b4d903a9">HBaseTableWriter::list_ctor_</a> = NULL;</div>
<div class="line"><a name="l00038"></a><span class="lineno"> 38</span>&#160;jmethodID <a class="code" href="classimpala_1_1HBaseTableWriter.html#a4cb49d4f68419ce023abbc343d5c80d2">HBaseTableWriter::list_add_id_</a> = NULL;</div>
<div class="line"><a name="l00039"></a><span class="lineno"> 39</span>&#160;</div>
<div class="line"><a name="l00040"></a><span class="lineno"> 40</span>&#160;jmethodID <a class="code" href="classimpala_1_1HBaseTableWriter.html#a9d500c0c63bc7e317a46a9d39fabe2d9">HBaseTableWriter::put_add_id_</a> = NULL;</div>
<div class="line"><a name="l00041"></a><span class="lineno"> 41</span>&#160;</div>
<div class="line"><a name="l00042"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a07e8156cf50c03617fc0f93d909c3ac9"> 42</a></span>&#160;<a class="code" href="classimpala_1_1HBaseTableWriter.html#a07e8156cf50c03617fc0f93d909c3ac9">HBaseTableWriter::HBaseTableWriter</a>(<a class="code" href="classimpala_1_1HBaseTableDescriptor.html">HBaseTableDescriptor</a>* table_desc,</div>
<div class="line"><a name="l00043"></a><span class="lineno"> 43</span>&#160; <span class="keyword">const</span> vector&lt;ExprContext*&gt;&amp; output_expr_ctxs,</div>
<div class="line"><a name="l00044"></a><span class="lineno"> 44</span>&#160; <a class="code" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* profile)</div>
<div class="line"><a name="l00045"></a><span class="lineno"> 45</span>&#160; : table_desc_(table_desc),</div>
<div class="line"><a name="l00046"></a><span class="lineno"> 46</span>&#160; table_(NULL),</div>
<div class="line"><a name="l00047"></a><span class="lineno"> 47</span>&#160; output_expr_ctxs_(output_expr_ctxs),</div>
<div class="line"><a name="l00048"></a><span class="lineno"> 48</span>&#160; put_list_(NULL),</div>
<div class="line"><a name="l00049"></a><span class="lineno"> 49</span>&#160; runtime_profile_(profile) {</div>
<div class="line"><a name="l00050"></a><span class="lineno"> 50</span>&#160;};</div>
<div class="line"><a name="l00051"></a><span class="lineno"> 51</span>&#160;</div>
<div class="line"><a name="l00052"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a7a8a70a214583b08d1952f3b00f3a7ad"> 52</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#a7a8a70a214583b08d1952f3b00f3a7ad">HBaseTableWriter::Init</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state) {</div>
<div class="line"><a name="l00053"></a><span class="lineno"> 53</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(state-&gt;<a class="code" href="classimpala_1_1RuntimeState.html#a69bb347b0e276c6bfd7116a83f9a67af">htable_factory</a>()-&gt;<a class="code" href="classimpala_1_1HBaseTableFactory.html#ae2c95838564669dd767c071cde9afac4">GetTable</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#afec49084fee7e68a8c8e032218a72020">table_desc_</a>-&gt;<a class="code" href="classimpala_1_1TableDescriptor.html#a19048794c0423d3f06e991f411fd073f">name</a>(),</div>
<div class="line"><a name="l00054"></a><span class="lineno"> 54</span>&#160; &amp;<a class="code" href="classimpala_1_1HBaseTableWriter.html#a268dbd14d180568a87f13136f84c4b79">table_</a>));</div>
<div class="line"><a name="l00055"></a><span class="lineno"> 55</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a0fc4b8ce805f76d34dee78597de78066">encoding_timer_</a> = <a class="code" href="runtime-profile_8h.html#a8841ca205b2a05d608e82d443bad3a77">ADD_TIMER</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#afc1906d19739fc1859e66bcd84f8db8c">runtime_profile_</a>, <span class="stringliteral">&quot;EncodingTimer&quot;</span>);</div>
<div class="line"><a name="l00056"></a><span class="lineno"> 56</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a687f9d86b8867c456159291201d429d9">htable_put_timer_</a> = <a class="code" href="runtime-profile_8h.html#a8841ca205b2a05d608e82d443bad3a77">ADD_TIMER</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#afc1906d19739fc1859e66bcd84f8db8c">runtime_profile_</a>, <span class="stringliteral">&quot;HTablePutTimer&quot;</span>);</div>
<div class="line"><a name="l00057"></a><span class="lineno"> 57</span>&#160;</div>
<div class="line"><a name="l00058"></a><span class="lineno"> 58</span>&#160; <span class="keywordtype">int</span> num_col = <a class="code" href="classimpala_1_1HBaseTableWriter.html#afec49084fee7e68a8c8e032218a72020">table_desc_</a>-&gt;<a class="code" href="classimpala_1_1TableDescriptor.html#a665ceaf9c184ec39544c3ecc448c0d11">num_cols</a>();</div>
<div class="line"><a name="l00059"></a><span class="lineno"> 59</span>&#160; <span class="keywordflow">if</span> (num_col &lt; 2) {</div>
<div class="line"><a name="l00060"></a><span class="lineno"> 60</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">&quot;HBase tables must contain at least&quot;</span></div>
<div class="line"><a name="l00061"></a><span class="lineno"> 61</span>&#160; <span class="stringliteral">&quot; one column in addition to the row key.&quot;</span>);</div>
<div class="line"><a name="l00062"></a><span class="lineno"> 62</span>&#160; }</div>
<div class="line"><a name="l00063"></a><span class="lineno"> 63</span>&#160;</div>
<div class="line"><a name="l00064"></a><span class="lineno"> 64</span>&#160; JNIEnv* env = <a class="code" href="jni-util_8h.html#a5469ac47d225e5773fe76593a75f29c6">getJNIEnv</a>();</div>
<div class="line"><a name="l00065"></a><span class="lineno"> 65</span>&#160; <span class="keywordflow">if</span> (env == NULL) <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">&quot;Error getting JNIEnv.&quot;</span>);</div>
<div class="line"><a name="l00066"></a><span class="lineno"> 66</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a683e556af539cd2c5c8de112f3ee0d47">output_exprs_byte_sizes_</a>.resize(num_col);</div>
<div class="line"><a name="l00067"></a><span class="lineno"> 67</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a632e6f821eb7f2a9ee582be33cb670ea">cf_arrays_</a>.reserve(num_col - 1);</div>
<div class="line"><a name="l00068"></a><span class="lineno"> 68</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a7852cd9a07cf55c10fa29fb88f105ff7">qual_arrays_</a>.reserve(num_col - 1);</div>
<div class="line"><a name="l00069"></a><span class="lineno"> 69</span>&#160; <span class="keywordflow">for</span> (<span class="keywordtype">int</span> i = 0; i &lt; num_col; ++i) {</div>
<div class="line"><a name="l00070"></a><span class="lineno"> 70</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a683e556af539cd2c5c8de112f3ee0d47">output_exprs_byte_sizes_</a>[i] = <a class="code" href="classimpala_1_1HBaseTableWriter.html#adba8f6898c11de5172902f1a3e8cd093">output_expr_ctxs_</a>[i]-&gt;root()-&gt;type().GetByteSize();</div>
<div class="line"><a name="l00071"></a><span class="lineno"> 71</span>&#160;</div>
<div class="line"><a name="l00072"></a><span class="lineno"> 72</span>&#160; <span class="keywordflow">if</span> (i == 0) <span class="keywordflow">continue</span>;</div>
<div class="line"><a name="l00073"></a><span class="lineno"> 73</span>&#160;</div>
<div class="line"><a name="l00074"></a><span class="lineno"> 74</span>&#160; <span class="comment">// Setup column family and qualifier byte array for non-rowkey column</span></div>
<div class="line"><a name="l00075"></a><span class="lineno"> 75</span>&#160; <span class="keyword">const</span> <a class="code" href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html">HBaseTableDescriptor::HBaseColumnDescriptor</a>&amp; col = <a class="code" href="classimpala_1_1HBaseTableWriter.html#afec49084fee7e68a8c8e032218a72020">table_desc_</a>-&gt;<a class="code" href="classimpala_1_1HBaseTableDescriptor.html#ad7391db6ea0fd800e03aa752307fe3ff">cols</a>()[i];</div>
<div class="line"><a name="l00076"></a><span class="lineno"> 76</span>&#160; jbyteArray byte_array;</div>
<div class="line"><a name="l00077"></a><span class="lineno"> 77</span>&#160; jobject global_ref;</div>
<div class="line"><a name="l00078"></a><span class="lineno"> 78</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">CreateByteArray</a>(env, col.<a class="code" href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html#a0ab041345d0dc75a68025dde83fd6b6a">family</a>, &amp;byte_array));</div>
<div class="line"><a name="l00079"></a><span class="lineno"> 79</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1JniUtil.html#ac5f0573aba66e777c5b430e743bd2232">JniUtil::LocalToGlobalRef</a>(env, byte_array, &amp;global_ref));</div>
<div class="line"><a name="l00080"></a><span class="lineno"> 80</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a632e6f821eb7f2a9ee582be33cb670ea">cf_arrays_</a>.push_back(reinterpret_cast&lt;jbyteArray&gt;(global_ref));</div>
<div class="line"><a name="l00081"></a><span class="lineno"> 81</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">CreateByteArray</a>(env, col.<a class="code" href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html#abcce36de8dfa6619f3a1480ef781fb37">qualifier</a>, &amp;byte_array));</div>
<div class="line"><a name="l00082"></a><span class="lineno"> 82</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1JniUtil.html#ac5f0573aba66e777c5b430e743bd2232">JniUtil::LocalToGlobalRef</a>(env, byte_array, &amp;global_ref));</div>
<div class="line"><a name="l00083"></a><span class="lineno"> 83</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a7852cd9a07cf55c10fa29fb88f105ff7">qual_arrays_</a>.push_back(reinterpret_cast&lt;jbyteArray&gt;(global_ref));</div>
<div class="line"><a name="l00084"></a><span class="lineno"> 84</span>&#160; }</div>
<div class="line"><a name="l00085"></a><span class="lineno"> 85</span>&#160;</div>
<div class="line"><a name="l00086"></a><span class="lineno"> 86</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00087"></a><span class="lineno"> 87</span>&#160;}</div>
<div class="line"><a name="l00088"></a><span class="lineno"> 88</span>&#160;</div>
<div class="line"><a name="l00089"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a78edef1d7d3c5f47b616c23d327f8608"> 89</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#a78edef1d7d3c5f47b616c23d327f8608">HBaseTableWriter::InitJNI</a>() {</div>
<div class="line"><a name="l00090"></a><span class="lineno"> 90</span>&#160; JNIEnv* env = <a class="code" href="jni-util_8h.html#a5469ac47d225e5773fe76593a75f29c6">getJNIEnv</a>();</div>
<div class="line"><a name="l00091"></a><span class="lineno"> 91</span>&#160; <span class="keywordflow">if</span> (env == NULL) <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">&quot;Error getting JNIEnv.&quot;</span>);</div>
<div class="line"><a name="l00092"></a><span class="lineno"> 92</span>&#160;</div>
<div class="line"><a name="l00093"></a><span class="lineno"> 93</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(</div>
<div class="line"><a name="l00094"></a><span class="lineno"> 94</span>&#160; <a class="code" href="classimpala_1_1JniUtil.html#a2fdf8d5fc6c01982968faec681f792a9">JniUtil::GetGlobalClassRef</a>(</div>
<div class="line"><a name="l00095"></a><span class="lineno"> 95</span>&#160; env, <span class="stringliteral">&quot;org/apache/hadoop/hbase/client/Put&quot;</span>, &amp;<a class="code" href="classimpala_1_1HBaseTableWriter.html#a1beb44475c480235b4715868b0923dff">put_cl_</a>));</div>
<div class="line"><a name="l00096"></a><span class="lineno"> 96</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00097"></a><span class="lineno"> 97</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a652d5ab8a9a3c71975ba44ff9352c0b2">put_ctor_</a> = env-&gt;GetMethodID(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a1beb44475c480235b4715868b0923dff">put_cl_</a>, <span class="stringliteral">&quot;&lt;init&gt;&quot;</span>, <span class="stringliteral">&quot;([B)V&quot;</span>);</div>
<div class="line"><a name="l00098"></a><span class="lineno"> 98</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00099"></a><span class="lineno"> 99</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a9d500c0c63bc7e317a46a9d39fabe2d9">put_add_id_</a> = env-&gt;GetMethodID(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a1beb44475c480235b4715868b0923dff">put_cl_</a>, <span class="stringliteral">&quot;add&quot;</span>,</div>
<div class="line"><a name="l00100"></a><span class="lineno"> 100</span>&#160; <span class="stringliteral">&quot;([B[B[B)Lorg/apache/hadoop/hbase/client/Put;&quot;</span>);</div>
<div class="line"><a name="l00101"></a><span class="lineno"> 101</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00102"></a><span class="lineno"> 102</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(</div>
<div class="line"><a name="l00103"></a><span class="lineno"> 103</span>&#160; <a class="code" href="classimpala_1_1JniUtil.html#a2fdf8d5fc6c01982968faec681f792a9">JniUtil::GetGlobalClassRef</a>(env, <span class="stringliteral">&quot;java/util/ArrayList&quot;</span>, &amp;<a class="code" href="classimpala_1_1HBaseTableWriter.html#a646f7fb13ececd4275c3916d0ed8439d">list_cl_</a>));</div>
<div class="line"><a name="l00104"></a><span class="lineno"> 104</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a558e02c7aa8b722f4e4b01b6b4d903a9">list_ctor_</a> = env-&gt;GetMethodID(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a646f7fb13ececd4275c3916d0ed8439d">list_cl_</a>, <span class="stringliteral">&quot;&lt;init&gt;&quot;</span>, <span class="stringliteral">&quot;(I)V&quot;</span>);</div>
<div class="line"><a name="l00105"></a><span class="lineno"> 105</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00106"></a><span class="lineno"> 106</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a4cb49d4f68419ce023abbc343d5c80d2">list_add_id_</a> = env-&gt;GetMethodID(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a646f7fb13ececd4275c3916d0ed8439d">list_cl_</a>, <span class="stringliteral">&quot;add&quot;</span>, <span class="stringliteral">&quot;(Ljava/lang/Object;)Z&quot;</span>);</div>
<div class="line"><a name="l00107"></a><span class="lineno"> 107</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00108"></a><span class="lineno"> 108</span>&#160;</div>
<div class="line"><a name="l00109"></a><span class="lineno"> 109</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00110"></a><span class="lineno"> 110</span>&#160;}</div>
<div class="line"><a name="l00111"></a><span class="lineno"> 111</span>&#160;</div>
<div class="line"><a name="l00112"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#afb25855dd3f771023b388f3eb5888cbe"> 112</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#afb25855dd3f771023b388f3eb5888cbe">HBaseTableWriter::AppendRowBatch</a>(<a class="code" href="classimpala_1_1RowBatch.html">RowBatch</a>* batch) {</div>
<div class="line"><a name="l00113"></a><span class="lineno"> 113</span>&#160; JNIEnv* env = <a class="code" href="jni-util_8h.html#a5469ac47d225e5773fe76593a75f29c6">getJNIEnv</a>();</div>
<div class="line"><a name="l00114"></a><span class="lineno"> 114</span>&#160; <span class="keywordflow">if</span> (env == NULL) <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">&quot;Error getting JNIEnv.&quot;</span>);</div>
<div class="line"><a name="l00115"></a><span class="lineno"> 115</span>&#160;</div>
<div class="line"><a name="l00116"></a><span class="lineno"> 116</span>&#160; <span class="keywordtype">int</span> limit = batch-&gt;<a class="code" href="classimpala_1_1RowBatch.html#ac695df3b85ee416b3d99844813ae813d">num_rows</a>();</div>
<div class="line"><a name="l00117"></a><span class="lineno"> 117</span>&#160; <span class="keywordflow">if</span> (limit == 0) <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00118"></a><span class="lineno"> 118</span>&#160; <span class="keywordtype">int</span> num_cols = <a class="code" href="classimpala_1_1HBaseTableWriter.html#afec49084fee7e68a8c8e032218a72020">table_desc_</a>-&gt;<a class="code" href="classimpala_1_1TableDescriptor.html#a665ceaf9c184ec39544c3ecc448c0d11">num_cols</a>();</div>
<div class="line"><a name="l00119"></a><span class="lineno"> 119</span>&#160; DCHECK_GE(num_cols, 2);</div>
<div class="line"><a name="l00120"></a><span class="lineno"> 120</span>&#160;</div>
<div class="line"><a name="l00121"></a><span class="lineno"> 121</span>&#160; <span class="comment">// Create the array list.</span></div>
<div class="line"><a name="l00122"></a><span class="lineno"> 122</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a6f49b560a239ac8e8c18dd2ec05637b4">CreatePutList</a>(env, limit));</div>
<div class="line"><a name="l00123"></a><span class="lineno"> 123</span>&#160;</div>
<div class="line"><a name="l00124"></a><span class="lineno"> 124</span>&#160; <span class="comment">// For every TupleRow in the row batch create a put, assign the row key,</span></div>
<div class="line"><a name="l00125"></a><span class="lineno"> 125</span>&#160; <span class="comment">// and add all of the values generated from the expressions.</span></div>
<div class="line"><a name="l00126"></a><span class="lineno"> 126</span>&#160; <span class="keywordtype">string</span> string_value; <span class="comment">// text encoded value</span></div>
<div class="line"><a name="l00127"></a><span class="lineno"> 127</span>&#160; <span class="keywordtype">char</span> binary_value[8]; <span class="comment">// binary encoded value; at most 8 bytes</span></div>
<div class="line"><a name="l00128"></a><span class="lineno"> 128</span>&#160; <span class="keyword">const</span> <span class="keywordtype">void</span>* data; <span class="comment">// pointer to the column value in bytes</span></div>
<div class="line"><a name="l00129"></a><span class="lineno"> 129</span>&#160; <span class="keywordtype">int</span> data_len; <span class="comment">// length of the column value in bytes</span></div>
<div class="line"><a name="l00130"></a><span class="lineno"> 130</span>&#160; {</div>
<div class="line"><a name="l00131"></a><span class="lineno"> 131</span>&#160; <a class="code" href="runtime-profile_8h.html#aaa9a2971c6368e3ddd3f5140a0295eb7">SCOPED_TIMER</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a0fc4b8ce805f76d34dee78597de78066">encoding_timer_</a>);</div>
<div class="line"><a name="l00132"></a><span class="lineno"> 132</span>&#160; <span class="keywordflow">for</span> (<span class="keywordtype">int</span> idx_batch = 0; idx_batch &lt; limit; idx_batch++) {</div>
<div class="line"><a name="l00133"></a><span class="lineno"> 133</span>&#160; <a class="code" href="classimpala_1_1TupleRow.html">TupleRow</a>* current_row = batch-&gt;<a class="code" href="classimpala_1_1RowBatch.html#a9320ed986b0717ef26d73d871f3b3a42">GetRow</a>(idx_batch);</div>
<div class="line"><a name="l00134"></a><span class="lineno"> 134</span>&#160; jobject put = NULL;</div>
<div class="line"><a name="l00135"></a><span class="lineno"> 135</span>&#160;</div>
<div class="line"><a name="l00136"></a><span class="lineno"> 136</span>&#160; <span class="keywordflow">if</span> (<a class="code" href="classimpala_1_1HBaseTableWriter.html#adba8f6898c11de5172902f1a3e8cd093">output_expr_ctxs_</a>[0]-&gt;GetValue(current_row) == NULL) {</div>
<div class="line"><a name="l00137"></a><span class="lineno"> 137</span>&#160; <span class="comment">// HBase row key must not be null.</span></div>
<div class="line"><a name="l00138"></a><span class="lineno"> 138</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">&quot;Cannot insert into HBase with a null row key.&quot;</span>);</div>
<div class="line"><a name="l00139"></a><span class="lineno"> 139</span>&#160; }</div>
<div class="line"><a name="l00140"></a><span class="lineno"> 140</span>&#160;</div>
<div class="line"><a name="l00141"></a><span class="lineno"> 141</span>&#160; <span class="keywordflow">for</span> (<span class="keywordtype">int</span> j = 0; j &lt; num_cols; j++) {</div>
<div class="line"><a name="l00142"></a><span class="lineno"> 142</span>&#160; <span class="keyword">const</span> <a class="code" href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html">HBaseTableDescriptor::HBaseColumnDescriptor</a>&amp; col = <a class="code" href="classimpala_1_1HBaseTableWriter.html#afec49084fee7e68a8c8e032218a72020">table_desc_</a>-&gt;<a class="code" href="classimpala_1_1HBaseTableDescriptor.html#ad7391db6ea0fd800e03aa752307fe3ff">cols</a>()[j];</div>
<div class="line"><a name="l00143"></a><span class="lineno"> 143</span>&#160; <span class="keywordtype">void</span>* value = <a class="code" href="classimpala_1_1HBaseTableWriter.html#adba8f6898c11de5172902f1a3e8cd093">output_expr_ctxs_</a>[j]-&gt;GetValue(current_row);</div>
<div class="line"><a name="l00144"></a><span class="lineno"> 144</span>&#160;</div>
<div class="line"><a name="l00145"></a><span class="lineno"> 145</span>&#160; <span class="keywordflow">if</span> (value != NULL) {</div>
<div class="line"><a name="l00146"></a><span class="lineno"> 146</span>&#160; <span class="keywordflow">if</span> (!col.<a class="code" href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html#ab97f59b48e70acd42c0a2aa183a14b44">binary_encoded</a>) {</div>
<div class="line"><a name="l00147"></a><span class="lineno"> 147</span>&#160; <span class="comment">// Text encoded</span></div>
<div class="line"><a name="l00148"></a><span class="lineno"> 148</span>&#160; string_value.clear();</div>
<div class="line"><a name="l00149"></a><span class="lineno"> 149</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#adba8f6898c11de5172902f1a3e8cd093">output_expr_ctxs_</a>[j]-&gt;PrintValue(value, &amp;string_value);</div>
<div class="line"><a name="l00150"></a><span class="lineno"> 150</span>&#160; data = string_value.data();</div>
<div class="line"><a name="l00151"></a><span class="lineno"> 151</span>&#160; data_len = string_value.length();</div>
<div class="line"><a name="l00152"></a><span class="lineno"> 152</span>&#160; } <span class="keywordflow">else</span> {</div>
<div class="line"><a name="l00153"></a><span class="lineno"> 153</span>&#160; <span class="comment">// Binary encoded</span></div>
<div class="line"><a name="l00154"></a><span class="lineno"> 154</span>&#160; <span class="comment">// Only bool, tinyint, smallint, int, bigint, float and double can be binary</span></div>
<div class="line"><a name="l00155"></a><span class="lineno"> 155</span>&#160; <span class="comment">// encoded. Convert the value to big-endian.</span></div>
<div class="line"><a name="l00156"></a><span class="lineno"> 156</span>&#160; data = binary_value;</div>
<div class="line"><a name="l00157"></a><span class="lineno"> 157</span>&#160; data_len = <a class="code" href="classimpala_1_1HBaseTableWriter.html#a683e556af539cd2c5c8de112f3ee0d47">output_exprs_byte_sizes_</a>[j];</div>
<div class="line"><a name="l00158"></a><span class="lineno"> 158</span>&#160; DCHECK(data_len == 1 || data_len == 2 || data_len == 4 || data_len == 8)</div>
<div class="line"><a name="l00159"></a><span class="lineno"> 159</span>&#160; &lt;&lt; data_len;</div>
<div class="line"><a name="l00160"></a><span class="lineno"> 160</span>&#160; <a class="code" href="classimpala_1_1BitUtil.html#a0687eb3f3f797999ba3c05d6786ef757">BitUtil::ByteSwap</a>(binary_value, value, data_len);</div>
<div class="line"><a name="l00161"></a><span class="lineno"> 161</span>&#160; }</div>
<div class="line"><a name="l00162"></a><span class="lineno"> 162</span>&#160;</div>
<div class="line"><a name="l00163"></a><span class="lineno"> 163</span>&#160; <span class="keywordflow">if</span> (j == 0) {</div>
<div class="line"><a name="l00164"></a><span class="lineno"> 164</span>&#160; DCHECK(put == NULL);</div>
<div class="line"><a name="l00165"></a><span class="lineno"> 165</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a9f1e535a6a69e050558398cc0149bae4">CreatePut</a>(env, data, data_len, &amp;put));</div>
<div class="line"><a name="l00166"></a><span class="lineno"> 166</span>&#160; } <span class="keywordflow">else</span> {</div>
<div class="line"><a name="l00167"></a><span class="lineno"> 167</span>&#160; DCHECK(put != NULL) &lt;&lt; <span class="stringliteral">&quot;Put shouldn&#39;t be NULL for non-key cols.&quot;</span>;</div>
<div class="line"><a name="l00168"></a><span class="lineno"> 168</span>&#160; jbyteArray val_array;</div>
<div class="line"><a name="l00169"></a><span class="lineno"> 169</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">CreateByteArray</a>(env, data, data_len, &amp;val_array));</div>
<div class="line"><a name="l00170"></a><span class="lineno"> 170</span>&#160; env-&gt;CallObjectMethod(put, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a9d500c0c63bc7e317a46a9d39fabe2d9">put_add_id_</a>, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a632e6f821eb7f2a9ee582be33cb670ea">cf_arrays_</a>[j-1], <a class="code" href="classimpala_1_1HBaseTableWriter.html#a7852cd9a07cf55c10fa29fb88f105ff7">qual_arrays_</a>[j-1],</div>
<div class="line"><a name="l00171"></a><span class="lineno"> 171</span>&#160; val_array);</div>
<div class="line"><a name="l00172"></a><span class="lineno"> 172</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00173"></a><span class="lineno"> 173</span>&#160;</div>
<div class="line"><a name="l00174"></a><span class="lineno"> 174</span>&#160; <span class="comment">// Clean up the local references.</span></div>
<div class="line"><a name="l00175"></a><span class="lineno"> 175</span>&#160; env-&gt;DeleteLocalRef(val_array);</div>
<div class="line"><a name="l00176"></a><span class="lineno"> 176</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00177"></a><span class="lineno"> 177</span>&#160; }</div>
<div class="line"><a name="l00178"></a><span class="lineno"> 178</span>&#160; }</div>
<div class="line"><a name="l00179"></a><span class="lineno"> 179</span>&#160; }</div>
<div class="line"><a name="l00180"></a><span class="lineno"> 180</span>&#160;</div>
<div class="line"><a name="l00181"></a><span class="lineno"> 181</span>&#160; DCHECK(put != NULL);</div>
<div class="line"><a name="l00182"></a><span class="lineno"> 182</span>&#160; env-&gt;DeleteLocalRef(put);</div>
<div class="line"><a name="l00183"></a><span class="lineno"> 183</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00184"></a><span class="lineno"> 184</span>&#160; }</div>
<div class="line"><a name="l00185"></a><span class="lineno"> 185</span>&#160; }</div>
<div class="line"><a name="l00186"></a><span class="lineno"> 186</span>&#160;</div>
<div class="line"><a name="l00187"></a><span class="lineno"> 187</span>&#160; <span class="comment">// Send the array list to HTable.</span></div>
<div class="line"><a name="l00188"></a><span class="lineno"> 188</span>&#160; {</div>
<div class="line"><a name="l00189"></a><span class="lineno"> 189</span>&#160; <a class="code" href="runtime-profile_8h.html#aaa9a2971c6368e3ddd3f5140a0295eb7">SCOPED_TIMER</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a687f9d86b8867c456159291201d429d9">htable_put_timer_</a>);</div>
<div class="line"><a name="l00190"></a><span class="lineno"> 190</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a268dbd14d180568a87f13136f84c4b79">table_</a>-&gt;Put(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a>));</div>
<div class="line"><a name="l00191"></a><span class="lineno"> 191</span>&#160; }</div>
<div class="line"><a name="l00192"></a><span class="lineno"> 192</span>&#160; <span class="comment">// Now clean put_list_.</span></div>
<div class="line"><a name="l00193"></a><span class="lineno"> 193</span>&#160; env-&gt;DeleteGlobalRef(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a>);</div>
<div class="line"><a name="l00194"></a><span class="lineno"> 194</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00195"></a><span class="lineno"> 195</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a> = NULL;</div>
<div class="line"><a name="l00196"></a><span class="lineno"> 196</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00197"></a><span class="lineno"> 197</span>&#160;}</div>
<div class="line"><a name="l00198"></a><span class="lineno"> 198</span>&#160;</div>
<div class="line"><a name="l00199"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#aa53696cb0ded8ecf2abb626ad4ecce5b"> 199</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#aa53696cb0ded8ecf2abb626ad4ecce5b">HBaseTableWriter::CleanUpJni</a>() {</div>
<div class="line"><a name="l00200"></a><span class="lineno"> 200</span>&#160; JNIEnv* env = <a class="code" href="jni-util_8h.html#a5469ac47d225e5773fe76593a75f29c6">getJNIEnv</a>();</div>
<div class="line"><a name="l00201"></a><span class="lineno"> 201</span>&#160; <span class="keywordflow">if</span> (env == NULL) <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html">Status</a>(<span class="stringliteral">&quot;Error getting JNIEnv.&quot;</span>);</div>
<div class="line"><a name="l00202"></a><span class="lineno"> 202</span>&#160;</div>
<div class="line"><a name="l00203"></a><span class="lineno"> 203</span>&#160; <span class="keywordflow">if</span> (<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a> != NULL) {</div>
<div class="line"><a name="l00204"></a><span class="lineno"> 204</span>&#160; env-&gt;DeleteGlobalRef(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a>);</div>
<div class="line"><a name="l00205"></a><span class="lineno"> 205</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00206"></a><span class="lineno"> 206</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a> = NULL;</div>
<div class="line"><a name="l00207"></a><span class="lineno"> 207</span>&#160; }</div>
<div class="line"><a name="l00208"></a><span class="lineno"> 208</span>&#160;</div>
<div class="line"><a name="l00209"></a><span class="lineno"> 209</span>&#160; BOOST_FOREACH(jbyteArray ref, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a632e6f821eb7f2a9ee582be33cb670ea">cf_arrays_</a>) {</div>
<div class="line"><a name="l00210"></a><span class="lineno"> 210</span>&#160; env-&gt;DeleteGlobalRef(reinterpret_cast&lt;jobject&gt;(ref));</div>
<div class="line"><a name="l00211"></a><span class="lineno"> 211</span>&#160; }</div>
<div class="line"><a name="l00212"></a><span class="lineno"> 212</span>&#160; BOOST_FOREACH(jbyteArray ref, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a7852cd9a07cf55c10fa29fb88f105ff7">qual_arrays_</a>) {</div>
<div class="line"><a name="l00213"></a><span class="lineno"> 213</span>&#160; env-&gt;DeleteGlobalRef(reinterpret_cast&lt;jobject&gt;(ref));</div>
<div class="line"><a name="l00214"></a><span class="lineno"> 214</span>&#160; }</div>
<div class="line"><a name="l00215"></a><span class="lineno"> 215</span>&#160;</div>
<div class="line"><a name="l00216"></a><span class="lineno"> 216</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00217"></a><span class="lineno"> 217</span>&#160;}</div>
<div class="line"><a name="l00218"></a><span class="lineno"> 218</span>&#160;</div>
<div class="line"><a name="l00219"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a6f49b560a239ac8e8c18dd2ec05637b4"> 219</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#a6f49b560a239ac8e8c18dd2ec05637b4">HBaseTableWriter::CreatePutList</a>(JNIEnv* env, <span class="keywordtype">int</span> num_puts) {</div>
<div class="line"><a name="l00220"></a><span class="lineno"> 220</span>&#160; DCHECK(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a> == NULL);</div>
<div class="line"><a name="l00221"></a><span class="lineno"> 221</span>&#160; jobject local_put_list = env-&gt;NewObject(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a646f7fb13ececd4275c3916d0ed8439d">list_cl_</a>, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a558e02c7aa8b722f4e4b01b6b4d903a9">list_ctor_</a>, num_puts);</div>
<div class="line"><a name="l00222"></a><span class="lineno"> 222</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00223"></a><span class="lineno"> 223</span>&#160;</div>
<div class="line"><a name="l00224"></a><span class="lineno"> 224</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1JniUtil.html#ac5f0573aba66e777c5b430e743bd2232">JniUtil::LocalToGlobalRef</a>(env, local_put_list, &amp;<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a>));</div>
<div class="line"><a name="l00225"></a><span class="lineno"> 225</span>&#160;</div>
<div class="line"><a name="l00226"></a><span class="lineno"> 226</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00227"></a><span class="lineno"> 227</span>&#160;}</div>
<div class="line"><a name="l00228"></a><span class="lineno"> 228</span>&#160;</div>
<div class="line"><a name="l00229"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a9f1e535a6a69e050558398cc0149bae4"> 229</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#a9f1e535a6a69e050558398cc0149bae4">HBaseTableWriter::CreatePut</a>(JNIEnv* env, <span class="keyword">const</span> <span class="keywordtype">void</span>* rk, <span class="keywordtype">int</span> rk_len,</div>
<div class="line"><a name="l00230"></a><span class="lineno"> 230</span>&#160; jobject* put) {</div>
<div class="line"><a name="l00231"></a><span class="lineno"> 231</span>&#160; <span class="comment">// Create the row key byte array.</span></div>
<div class="line"><a name="l00232"></a><span class="lineno"> 232</span>&#160; jbyteArray rk_array;</div>
<div class="line"><a name="l00233"></a><span class="lineno"> 233</span>&#160; <a class="code" href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a>(<a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">CreateByteArray</a>(env, rk, rk_len, &amp;rk_array));</div>
<div class="line"><a name="l00234"></a><span class="lineno"> 234</span>&#160;</div>
<div class="line"><a name="l00235"></a><span class="lineno"> 235</span>&#160; (*put) = env-&gt;NewObject(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a1beb44475c480235b4715868b0923dff">put_cl_</a>, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a652d5ab8a9a3c71975ba44ff9352c0b2">put_ctor_</a>, rk_array);</div>
<div class="line"><a name="l00236"></a><span class="lineno"> 236</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00237"></a><span class="lineno"> 237</span>&#160;</div>
<div class="line"><a name="l00238"></a><span class="lineno"> 238</span>&#160; <span class="comment">// Add the put to the list.</span></div>
<div class="line"><a name="l00239"></a><span class="lineno"> 239</span>&#160; env-&gt;CallObjectMethod(<a class="code" href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">put_list_</a>, <a class="code" href="classimpala_1_1HBaseTableWriter.html#a4cb49d4f68419ce023abbc343d5c80d2">list_add_id_</a>, *put);</div>
<div class="line"><a name="l00240"></a><span class="lineno"> 240</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00241"></a><span class="lineno"> 241</span>&#160;</div>
<div class="line"><a name="l00242"></a><span class="lineno"> 242</span>&#160; env-&gt;DeleteLocalRef(rk_array);</div>
<div class="line"><a name="l00243"></a><span class="lineno"> 243</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00244"></a><span class="lineno"> 244</span>&#160;</div>
<div class="line"><a name="l00245"></a><span class="lineno"> 245</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00246"></a><span class="lineno"> 246</span>&#160;}</div>
<div class="line"><a name="l00247"></a><span class="lineno"> 247</span>&#160;</div>
<div class="line"><a name="l00248"></a><span class="lineno"> 248</span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">HBaseTableWriter::CreateByteArray</a>(JNIEnv* env, <span class="keyword">const</span> <span class="keywordtype">string</span>&amp; s,</div>
<div class="line"><a name="l00249"></a><span class="lineno"> 249</span>&#160; jbyteArray* j_array) {</div>
<div class="line"><a name="l00250"></a><span class="lineno"> 250</span>&#160; <span class="keywordtype">int</span> s_len = s.size();</div>
<div class="line"><a name="l00251"></a><span class="lineno"> 251</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">CreateByteArray</a>(env, s.data(), s_len, j_array);</div>
<div class="line"><a name="l00252"></a><span class="lineno"> 252</span>&#160;}</div>
<div class="line"><a name="l00253"></a><span class="lineno"> 253</span>&#160;</div>
<div class="line"><a name="l00254"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a82c8608980dfe6e69524578475249d9d"> 254</a></span>&#160;<a class="code" href="classimpala_1_1Status.html">Status</a> <a class="code" href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">HBaseTableWriter::CreateByteArray</a>(JNIEnv* env, <span class="keyword">const</span> <span class="keywordtype">void</span>* data, <span class="keywordtype">int</span> data_len,</div>
<div class="line"><a name="l00255"></a><span class="lineno"> 255</span>&#160; jbyteArray* j_array) {</div>
<div class="line"><a name="l00256"></a><span class="lineno"> 256</span>&#160; (*j_array) = env-&gt;NewByteArray(data_len);</div>
<div class="line"><a name="l00257"></a><span class="lineno"> 257</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00258"></a><span class="lineno"> 258</span>&#160; env-&gt;SetByteArrayRegion((*j_array), 0, data_len, reinterpret_cast&lt;const jbyte*&gt;(data));</div>
<div class="line"><a name="l00259"></a><span class="lineno"> 259</span>&#160; <a class="code" href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a>(env);</div>
<div class="line"><a name="l00260"></a><span class="lineno"> 260</span>&#160; <span class="keywordflow">return</span> <a class="code" href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">Status::OK</a>;</div>
<div class="line"><a name="l00261"></a><span class="lineno"> 261</span>&#160;}</div>
<div class="line"><a name="l00262"></a><span class="lineno"> 262</span>&#160;</div>
<div class="line"><a name="l00263"></a><span class="lineno"><a class="line" href="classimpala_1_1HBaseTableWriter.html#a246b43dbba1041df3611839be0ccfd39"> 263</a></span>&#160;<span class="keywordtype">void</span> <a class="code" href="classimpala_1_1HBaseTableWriter.html#a246b43dbba1041df3611839be0ccfd39">HBaseTableWriter::Close</a>(<a class="code" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* state) {</div>
<div class="line"><a name="l00264"></a><span class="lineno"> 264</span>&#160; <span class="comment">// Guard against double closing.</span></div>
<div class="line"><a name="l00265"></a><span class="lineno"> 265</span>&#160; <span class="keywordflow">if</span> (<a class="code" href="classimpala_1_1HBaseTableWriter.html#a268dbd14d180568a87f13136f84c4b79">table_</a>.get() != NULL) {</div>
<div class="line"><a name="l00266"></a><span class="lineno"> 266</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a268dbd14d180568a87f13136f84c4b79">table_</a>-&gt;Close(state);</div>
<div class="line"><a name="l00267"></a><span class="lineno"> 267</span>&#160; <a class="code" href="classimpala_1_1HBaseTableWriter.html#a268dbd14d180568a87f13136f84c4b79">table_</a>.reset();</div>
<div class="line"><a name="l00268"></a><span class="lineno"> 268</span>&#160; }</div>
<div class="line"><a name="l00269"></a><span class="lineno"> 269</span>&#160;</div>
<div class="line"><a name="l00270"></a><span class="lineno"> 270</span>&#160; <span class="comment">// The jni should already have everything cleaned at this point</span></div>
<div class="line"><a name="l00271"></a><span class="lineno"> 271</span>&#160; <span class="comment">// but try again just in case there was an error that caused</span></div>
<div class="line"><a name="l00272"></a><span class="lineno"> 272</span>&#160; <span class="comment">// AppendRowBatch to exit out before calling CleanUpJni.</span></div>
<div class="line"><a name="l00273"></a><span class="lineno"> 273</span>&#160; <a class="code" href="classimpala_1_1Status.html">Status</a> status = <a class="code" href="classimpala_1_1HBaseTableWriter.html#aa53696cb0ded8ecf2abb626ad4ecce5b">CleanUpJni</a>();</div>
<div class="line"><a name="l00274"></a><span class="lineno"> 274</span>&#160; <span class="keywordflow">if</span> (!status.<a class="code" href="classimpala_1_1Status.html#a95ba859e42fe93445b340533220836ac">ok</a>()) {</div>
<div class="line"><a name="l00275"></a><span class="lineno"> 275</span>&#160; stringstream ss;</div>
<div class="line"><a name="l00276"></a><span class="lineno"> 276</span>&#160; ss &lt;&lt; <span class="stringliteral">&quot;HBaseTableWriter::Close ran into an issue: &quot;</span> &lt;&lt; status.<a class="code" href="classimpala_1_1Status.html#adf1a3ee82776f6102bfe873925183159">GetDetail</a>();</div>
<div class="line"><a name="l00277"></a><span class="lineno"> 277</span>&#160; state-&gt;<a class="code" href="classimpala_1_1RuntimeState.html#aaf076b1879d9e712b08ba3a6e24607b9">LogError</a>(<a class="code" href="classimpala_1_1ErrorMsg.html">ErrorMsg</a>(TErrorCode::GENERAL, ss.str()));</div>
<div class="line"><a name="l00278"></a><span class="lineno"> 278</span>&#160; }</div>
<div class="line"><a name="l00279"></a><span class="lineno"> 279</span>&#160;}</div>
<div class="line"><a name="l00280"></a><span class="lineno"> 280</span>&#160;</div>
<div class="line"><a name="l00281"></a><span class="lineno"> 281</span>&#160;} <span class="comment">// namespace impala</span></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a9d500c0c63bc7e317a46a9d39fabe2d9"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a9d500c0c63bc7e317a46a9d39fabe2d9">impala::HBaseTableWriter::put_add_id_</a></div><div class="ttdeci">static jmethodID put_add_id_</div><div class="ttdoc">Put::add(byte[], byte[], byte[]) </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00104">hbase-table-writer.h:104</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a3610983bb5a977386a05c23cda1c60e7"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a3610983bb5a977386a05c23cda1c60e7">impala::HBaseTableWriter::put_list_</a></div><div class="ttdeci">jobject put_list_</div><div class="ttdoc">jni ArrayList&lt;Put&gt; </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00095">hbase-table-writer.h:95</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a6f49b560a239ac8e8c18dd2ec05637b4"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a6f49b560a239ac8e8c18dd2ec05637b4">impala::HBaseTableWriter::CreatePutList</a></div><div class="ttdeci">Status CreatePutList(JNIEnv *env, int num_puts)</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00219">hbase-table-writer.cc:219</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_1HBaseTableWriter_html_a683e556af539cd2c5c8de112f3ee0d47"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a683e556af539cd2c5c8de112f3ee0d47">impala::HBaseTableWriter::output_exprs_byte_sizes_</a></div><div class="ttdeci">std::vector&lt; int &gt; output_exprs_byte_sizes_</div><div class="ttdoc">output_exprs_byte_sizes_[i] is the byte size of output_expr_ctxs_[i]-&gt;root()&#39;s type. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00092">hbase-table-writer.h:92</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a7852cd9a07cf55c10fa29fb88f105ff7"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a7852cd9a07cf55c10fa29fb88f105ff7">impala::HBaseTableWriter::qual_arrays_</a></div><div class="ttdeci">std::vector&lt; jbyteArray &gt; qual_arrays_</div><div class="ttdoc">qual_arrays_[i-1] is the column family qualifier jbyteArray for column i. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00119">hbase-table-writer.h:119</a></div></div>
<div class="ttc" id="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor_html_abcce36de8dfa6619f3a1480ef781fb37"><div class="ttname"><a href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html#abcce36de8dfa6619f3a1480ef781fb37">impala::HBaseTableDescriptor::HBaseColumnDescriptor::qualifier</a></div><div class="ttdeci">std::string qualifier</div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00271">descriptors.h:271</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a652d5ab8a9a3c71975ba44ff9352c0b2"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a652d5ab8a9a3c71975ba44ff9352c0b2">impala::HBaseTableWriter::put_ctor_</a></div><div class="ttdeci">static jmethodID put_ctor_</div><div class="ttdoc">new Put(byte[]) </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00101">hbase-table-writer.h:101</a></div></div>
<div class="ttc" id="status_8h_html_a85f7d0e774e15eb35b74f53264305e16"><div class="ttname"><a href="status_8h.html#a85f7d0e774e15eb35b74f53264305e16">RETURN_IF_ERROR</a></div><div class="ttdeci">#define RETURN_IF_ERROR(stmt)</div><div class="ttdoc">some generally useful macros </div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00242">status.h:242</a></div></div>
<div class="ttc" id="raw-value_8h_html"><div class="ttname"><a href="raw-value_8h.html">raw-value.h</a></div></div>
<div class="ttc" id="classimpala_1_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="runtime-profile_8h_html_a8841ca205b2a05d608e82d443bad3a77"><div class="ttname"><a href="runtime-profile_8h.html#a8841ca205b2a05d608e82d443bad3a77">ADD_TIMER</a></div><div class="ttdeci">#define ADD_TIMER(profile, name)</div><div class="ttdef"><b>Definition:</b> <a href="runtime-profile_8h_source.html#l00050">runtime-profile.h:50</a></div></div>
<div class="ttc" id="expr-context_8h_html"><div class="ttname"><a href="expr-context_8h.html">expr-context.h</a></div></div>
<div class="ttc" id="hbase-table-factory_8h_html"><div class="ttname"><a href="hbase-table-factory_8h.html">hbase-table-factory.h</a></div></div>
<div class="ttc" id="classimpala_1_1TableDescriptor_html_a665ceaf9c184ec39544c3ecc448c0d11"><div class="ttname"><a href="classimpala_1_1TableDescriptor.html#a665ceaf9c184ec39544c3ecc448c0d11">impala::TableDescriptor::num_cols</a></div><div class="ttdeci">int num_cols() const </div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00152">descriptors.h:152</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a9f1e535a6a69e050558398cc0149bae4"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a9f1e535a6a69e050558398cc0149bae4">impala::HBaseTableWriter::CreatePut</a></div><div class="ttdeci">Status CreatePut(JNIEnv *env, const void *rk, int rk_len, jobject *put)</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00229">hbase-table-writer.cc:229</a></div></div>
<div class="ttc" id="classimpala_1_1RuntimeState_html_a69bb347b0e276c6bfd7116a83f9a67af"><div class="ttname"><a href="classimpala_1_1RuntimeState.html#a69bb347b0e276c6bfd7116a83f9a67af">impala::RuntimeState::htable_factory</a></div><div class="ttdeci">HBaseTableFactory * htable_factory()</div><div class="ttdef"><b>Definition:</b> <a href="runtime-state_8h_source.html#l00132">runtime-state.h:132</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableFactory_html_ae2c95838564669dd767c071cde9afac4"><div class="ttname"><a href="classimpala_1_1HBaseTableFactory.html#ae2c95838564669dd767c071cde9afac4">impala::HBaseTableFactory::GetTable</a></div><div class="ttdeci">Status GetTable(const std::string &amp;table_name, boost::scoped_ptr&lt; HBaseTable &gt; *hbase_table)</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-factory_8cc_source.html#l00107">hbase-table-factory.cc:107</a></div></div>
<div class="ttc" id="logging_8h_html"><div class="ttname"><a href="logging_8h.html">logging.h</a></div></div>
<div class="ttc" id="classimpala_1_1TupleRow_html"><div class="ttname"><a href="classimpala_1_1TupleRow.html">impala::TupleRow</a></div><div class="ttdef"><b>Definition:</b> <a href="tuple-row_8h_source.html#l00028">tuple-row.h:28</a></div></div>
<div class="ttc" id="runtime-profile_8h_html_aaa9a2971c6368e3ddd3f5140a0295eb7"><div class="ttname"><a href="runtime-profile_8h.html#aaa9a2971c6368e3ddd3f5140a0295eb7">SCOPED_TIMER</a></div><div class="ttdeci">#define SCOPED_TIMER(c)</div><div class="ttdef"><b>Definition:</b> <a href="runtime-profile_8h_source.html#l00053">runtime-profile.h:53</a></div></div>
<div class="ttc" id="classimpala_1_1BitUtil_html_a0687eb3f3f797999ba3c05d6786ef757"><div class="ttname"><a href="classimpala_1_1BitUtil.html#a0687eb3f3f797999ba3c05d6786ef757">impala::BitUtil::ByteSwap</a></div><div class="ttdeci">static int64_t ByteSwap(int64_t value)</div><div class="ttdoc">Swaps the byte order (i.e. endianess) </div><div class="ttdef"><b>Definition:</b> <a href="bit-util_8h_source.html#l00149">bit-util.h:149</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a4cb49d4f68419ce023abbc343d5c80d2"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a4cb49d4f68419ce023abbc343d5c80d2">impala::HBaseTableWriter::list_add_id_</a></div><div class="ttdeci">static jmethodID list_add_id_</div><div class="ttdoc">ArrayList::add(V);. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00113">hbase-table-writer.h:113</a></div></div>
<div class="ttc" id="classimpala_1_1JniUtil_html_ac5f0573aba66e777c5b430e743bd2232"><div class="ttname"><a href="classimpala_1_1JniUtil.html#ac5f0573aba66e777c5b430e743bd2232">impala::JniUtil::LocalToGlobalRef</a></div><div class="ttdeci">static Status LocalToGlobalRef(JNIEnv *env, jobject local_ref, jobject *global_ref)</div><div class="ttdef"><b>Definition:</b> <a href="jni-util_8cc_source.html#l00067">jni-util.cc:67</a></div></div>
<div class="ttc" id="classimpala_1_1Status_html"><div class="ttname"><a href="classimpala_1_1Status.html">impala::Status</a></div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00081">status.h:81</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a632e6f821eb7f2a9ee582be33cb670ea"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a632e6f821eb7f2a9ee582be33cb670ea">impala::HBaseTableWriter::cf_arrays_</a></div><div class="ttdeci">std::vector&lt; jbyteArray &gt; cf_arrays_</div><div class="ttdoc">cf_arrays_[i-1] is the column family jbyteArray for column i. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00116">hbase-table-writer.h:116</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableDescriptor_html_ad7391db6ea0fd800e03aa752307fe3ff"><div class="ttname"><a href="classimpala_1_1HBaseTableDescriptor.html#ad7391db6ea0fd800e03aa752307fe3ff">impala::HBaseTableDescriptor::cols</a></div><div class="ttdeci">const std::vector&lt; HBaseColumnDescriptor &gt; &amp; cols() const </div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00281">descriptors.h:281</a></div></div>
<div class="ttc" id="classimpala_1_1RuntimeState_html_aaf076b1879d9e712b08ba3a6e24607b9"><div class="ttname"><a href="classimpala_1_1RuntimeState.html#aaf076b1879d9e712b08ba3a6e24607b9">impala::RuntimeState::LogError</a></div><div class="ttdeci">bool LogError(const ErrorMsg &amp;msg)</div><div class="ttdef"><b>Definition:</b> <a href="runtime-state_8cc_source.html#l00224">runtime-state.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_1HBaseTableWriter_html_adba8f6898c11de5172902f1a3e8cd093"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#adba8f6898c11de5172902f1a3e8cd093">impala::HBaseTableWriter::output_expr_ctxs_</a></div><div class="ttdeci">const std::vector&lt; ExprContext * &gt; output_expr_ctxs_</div><div class="ttdoc">The expressions that are run to create tuples to be written to hbase. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00089">hbase-table-writer.h:89</a></div></div>
<div class="ttc" id="bit-util_8h_html"><div class="ttname"><a href="bit-util_8h.html">bit-util.h</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_afc1906d19739fc1859e66bcd84f8db8c"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#afc1906d19739fc1859e66bcd84f8db8c">impala::HBaseTableWriter::runtime_profile_</a></div><div class="ttdeci">RuntimeProfile * runtime_profile_</div><div class="ttdoc">Parent table sink&#39;s profile. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00122">hbase-table-writer.h:122</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_aa53696cb0ded8ecf2abb626ad4ecce5b"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#aa53696cb0ded8ecf2abb626ad4ecce5b">impala::HBaseTableWriter::CleanUpJni</a></div><div class="ttdeci">Status CleanUpJni()</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00199">hbase-table-writer.cc:199</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a1beb44475c480235b4715868b0923dff"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a1beb44475c480235b4715868b0923dff">impala::HBaseTableWriter::put_cl_</a></div><div class="ttdeci">static jclass put_cl_</div><div class="ttdoc">org.apache.hadoop.hbase.client.Put </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00098">hbase-table-writer.h:98</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a78edef1d7d3c5f47b616c23d327f8608"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a78edef1d7d3c5f47b616c23d327f8608">impala::HBaseTableWriter::InitJNI</a></div><div class="ttdeci">static Status InitJNI()</div><div class="ttdoc">Grab all of the Java classes needed to get data into and out of HBase. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00089">hbase-table-writer.cc:89</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a07e8156cf50c03617fc0f93d909c3ac9"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a07e8156cf50c03617fc0f93d909c3ac9">impala::HBaseTableWriter::HBaseTableWriter</a></div><div class="ttdeci">HBaseTableWriter(HBaseTableDescriptor *table_desc, const std::vector&lt; ExprContext * &gt; &amp;output_expr_ctxs, RuntimeProfile *profile)</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00042">hbase-table-writer.cc:42</a></div></div>
<div class="ttc" id="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor_html_ab97f59b48e70acd42c0a2aa183a14b44"><div class="ttname"><a href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html#ab97f59b48e70acd42c0a2aa183a14b44">impala::HBaseTableDescriptor::HBaseColumnDescriptor::binary_encoded</a></div><div class="ttdeci">bool binary_encoded</div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00272">descriptors.h:272</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a687f9d86b8867c456159291201d429d9"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a687f9d86b8867c456159291201d429d9">impala::HBaseTableWriter::htable_put_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * htable_put_timer_</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00124">hbase-table-writer.h:124</a></div></div>
<div class="ttc" id="hbase-table-writer_8h_html"><div class="ttname"><a href="hbase-table-writer_8h.html">hbase-table-writer.h</a></div></div>
<div class="ttc" id="classimpala_1_1RowBatch_html"><div class="ttname"><a href="classimpala_1_1RowBatch.html">impala::RowBatch</a></div><div class="ttdef"><b>Definition:</b> <a href="row-batch_8h_source.html#l00066">row-batch.h:66</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a7a8a70a214583b08d1952f3b00f3a7ad"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a7a8a70a214583b08d1952f3b00f3a7ad">impala::HBaseTableWriter::Init</a></div><div class="ttdeci">Status Init(RuntimeState *state)</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00052">hbase-table-writer.cc:52</a></div></div>
<div class="ttc" id="classimpala_1_1TableDescriptor_html_a19048794c0423d3f06e991f411fd073f"><div class="ttname"><a href="classimpala_1_1TableDescriptor.html#a19048794c0423d3f06e991f411fd073f">impala::TableDescriptor::name</a></div><div class="ttdeci">const std::string &amp; name() const </div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00163">descriptors.h:163</a></div></div>
<div class="ttc" id="jni-util_8h_html_a2070c5a22a08170e919312a008ce0ce7"><div class="ttname"><a href="jni-util_8h.html#a2070c5a22a08170e919312a008ce0ce7">RETURN_ERROR_IF_EXC</a></div><div class="ttdeci">#define RETURN_ERROR_IF_EXC(env)</div><div class="ttdef"><b>Definition:</b> <a href="jni-util_8h_source.html#l00099">jni-util.h:99</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_abec12e5f94b2fcc0a0b6651ab3d9cd58"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#abec12e5f94b2fcc0a0b6651ab3d9cd58">impala::HBaseTableWriter::CreateByteArray</a></div><div class="ttdeci">Status CreateByteArray(JNIEnv *env, const std::string &amp;s, jbyteArray *j_array)</div><div class="ttdoc">Create a byte array containing the string&#39;s chars. </div></div>
<div class="ttc" id="classimpala_1_1RuntimeProfile_html"><div class="ttname"><a href="classimpala_1_1RuntimeProfile.html">impala::RuntimeProfile</a></div><div class="ttdef"><b>Definition:</b> <a href="runtime-profile_8h_source.html#l00083">runtime-profile.h:83</a></div></div>
<div class="ttc" id="classimpala_1_1ErrorMsg_html"><div class="ttname"><a href="classimpala_1_1ErrorMsg.html">impala::ErrorMsg</a></div><div class="ttdef"><b>Definition:</b> <a href="error-util_8h_source.html#l00047">error-util.h:47</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableDescriptor_html"><div class="ttname"><a href="classimpala_1_1HBaseTableDescriptor.html">impala::HBaseTableDescriptor</a></div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00263">descriptors.h:263</a></div></div>
<div class="ttc" id="classimpala_1_1Status_html_a580565665ea944eb64f3f495b1bee1e0"><div class="ttname"><a href="classimpala_1_1Status.html#a580565665ea944eb64f3f495b1bee1e0">impala::Status::OK</a></div><div class="ttdeci">static const Status OK</div><div class="ttdef"><b>Definition:</b> <a href="status_8h_source.html#l00087">status.h:87</a></div></div>
<div class="ttc" id="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor_html_a0ab041345d0dc75a68025dde83fd6b6a"><div class="ttname"><a href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html#a0ab041345d0dc75a68025dde83fd6b6a">impala::HBaseTableDescriptor::HBaseColumnDescriptor::family</a></div><div class="ttdeci">std::string family</div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00270">descriptors.h:270</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_afb25855dd3f771023b388f3eb5888cbe"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#afb25855dd3f771023b388f3eb5888cbe">impala::HBaseTableWriter::AppendRowBatch</a></div><div class="ttdeci">Status AppendRowBatch(RowBatch *batch)</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00112">hbase-table-writer.cc:112</a></div></div>
<div class="ttc" id="classimpala_1_1JniUtil_html_a2fdf8d5fc6c01982968faec681f792a9"><div class="ttname"><a href="classimpala_1_1JniUtil.html#a2fdf8d5fc6c01982968faec681f792a9">impala::JniUtil::GetGlobalClassRef</a></div><div class="ttdeci">static Status GetGlobalClassRef(JNIEnv *env, const char *class_str, jclass *class_ref)</div><div class="ttdef"><b>Definition:</b> <a href="jni-util_8cc_source.html#l00056">jni-util.cc:56</a></div></div>
<div class="ttc" id="jni-util_8h_html"><div class="ttname"><a href="jni-util_8h.html">jni-util.h</a></div></div>
<div class="ttc" id="expr_8h_html"><div class="ttname"><a href="expr_8h.html">expr.h</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_1HBaseTableWriter_html_a0fc4b8ce805f76d34dee78597de78066"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a0fc4b8ce805f76d34dee78597de78066">impala::HBaseTableWriter::encoding_timer_</a></div><div class="ttdeci">RuntimeProfile::Counter * encoding_timer_</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00123">hbase-table-writer.h:123</a></div></div>
<div class="ttc" id="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor_html"><div class="ttname"><a href="structimpala_1_1HBaseTableDescriptor_1_1HBaseColumnDescriptor.html">impala::HBaseTableDescriptor::HBaseColumnDescriptor</a></div><div class="ttdef"><b>Definition:</b> <a href="descriptors_8h_source.html#l00269">descriptors.h:269</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="classimpala_1_1HBaseTableWriter_html_a646f7fb13ececd4275c3916d0ed8439d"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a646f7fb13ececd4275c3916d0ed8439d">impala::HBaseTableWriter::list_cl_</a></div><div class="ttdeci">static jclass list_cl_</div><div class="ttdoc">java.util.ArrayList </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00107">hbase-table-writer.h:107</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a246b43dbba1041df3611839be0ccfd39"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a246b43dbba1041df3611839be0ccfd39">impala::HBaseTableWriter::Close</a></div><div class="ttdeci">void Close(RuntimeState *state)</div><div class="ttdoc">Calls to Close release the HBaseTable. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8cc_source.html#l00263">hbase-table-writer.cc:263</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_afec49084fee7e68a8c8e032218a72020"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#afec49084fee7e68a8c8e032218a72020">impala::HBaseTableWriter::table_desc_</a></div><div class="ttdeci">HBaseTableDescriptor * table_desc_</div><div class="ttdoc">Owned by RuntimeState not by this object. </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00081">hbase-table-writer.h:81</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a558e02c7aa8b722f4e4b01b6b4d903a9"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a558e02c7aa8b722f4e4b01b6b4d903a9">impala::HBaseTableWriter::list_ctor_</a></div><div class="ttdeci">static jmethodID list_ctor_</div><div class="ttdoc">new ArrayList&lt;V&gt;(starting_capacity) </div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00110">hbase-table-writer.h:110</a></div></div>
<div class="ttc" id="classimpala_1_1HBaseTableWriter_html_a268dbd14d180568a87f13136f84c4b79"><div class="ttname"><a href="classimpala_1_1HBaseTableWriter.html#a268dbd14d180568a87f13136f84c4b79">impala::HBaseTableWriter::table_</a></div><div class="ttdeci">boost::scoped_ptr&lt; HBaseTable &gt; table_</div><div class="ttdef"><b>Definition:</b> <a href="hbase-table-writer_8h_source.html#l00086">hbase-table-writer.h:86</a></div></div>
<div class="ttc" id="jni-util_8h_html_a5469ac47d225e5773fe76593a75f29c6"><div class="ttname"><a href="jni-util_8h.html#a5469ac47d225e5773fe76593a75f29c6">getJNIEnv</a></div><div class="ttdeci">JNIEnv * getJNIEnv(void)</div><div class="ttdoc">C linkage for helper functions in hdfsJniHelper.h. </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_479336c0a15f2c0737bcafcf969f884c.html">exec</a></li><li class="navelem"><a class="el" href="hbase-table-writer_8cc.html">hbase-table-writer.cc</a></li>
<li class="footer">Generated on Thu May 7 2015 16:10:35 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>