| <!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: impala::DataStreamSender Class Reference</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 class="current"><a href="annotated.html"><span>Classes</span></a></li> |
| <li><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="annotated.html"><span>Class List</span></a></li> |
| <li><a href="classes.html"><span>Class Index</span></a></li> |
| <li><a href="inherits.html"><span>Class Hierarchy</span></a></li> |
| <li><a href="functions.html"><span>Class 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('classimpala_1_1DataStreamSender.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="summary"> |
| <a href="#nested-classes">Classes</a> | |
| <a href="#pub-methods">Public Member Functions</a> | |
| <a href="#pub-static-methods">Static Public Member Functions</a> | |
| <a href="#pro-attribs">Protected Attributes</a> | |
| <a href="#pri-attribs">Private Attributes</a> | |
| <a href="classimpala_1_1DataStreamSender-members.html">List of all members</a> </div> |
| <div class="headertitle"> |
| <div class="title">impala::DataStreamSender Class Reference</div> </div> |
| </div><!--header--> |
| <div class="contents"> |
| |
| <p><code>#include <<a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>></code></p> |
| <div class="dynheader"> |
| Inheritance diagram for impala::DataStreamSender:</div> |
| <div class="dyncontent"> |
| <div class="center"><div class="zoom"><iframe scrolling="no" frameborder="0" src="classimpala_1_1DataStreamSender__inherit__graph.svg" width="100%" height="600"><p><b>This browser is not able to show SVG: try Firefox, Chrome, Safari, or Opera instead.</b></p></iframe></div></div> |
| </div> |
| <div class="dynheader"> |
| Collaboration diagram for impala::DataStreamSender:</div> |
| <div class="dyncontent"> |
| <div class="center"><div class="zoom"><iframe scrolling="no" frameborder="0" src="classimpala_1_1DataStreamSender__coll__graph.svg" width="100%" height="600"><p><b>This browser is not able to show SVG: try Firefox, Chrome, Safari, or Opera instead.</b></p></iframe></div></div> |
| </div> |
| <table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="nested-classes"></a> |
| Classes</h2></td></tr> |
| <tr class="memitem:"><td class="memItemLeft" align="right" valign="top">class  </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender_1_1Channel.html">Channel</a></td></tr> |
| <tr class="separator:"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-methods"></a> |
| Public Member Functions</h2></td></tr> |
| <tr class="memitem:af0f6ed4d7c05379050ff946652597a70"><td class="memItemLeft" align="right" valign="top"> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#af0f6ed4d7c05379050ff946652597a70">DataStreamSender</a> (<a class="el" href="classimpala_1_1ObjectPool.html">ObjectPool</a> *<a class="el" href="expr-benchmark_8cc.html#a3a5de7bd423fbc0afc4cf935c166ca6b">pool</a>, int sender_id, const <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a> &<a class="el" href="namespaceimpala.html#aa98447566dd6700a2faaaaf3059f4d95">row_desc</a>, const TDataStreamSink &sink, const std::vector< TPlanFragmentDestination > &destinations, int per_channel_buffer_size)</td></tr> |
| <tr class="separator:af0f6ed4d7c05379050ff946652597a70"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9d54e519344431380d62139e583bb6be"><td class="memItemLeft" align="right" valign="top">virtual </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a9d54e519344431380d62139e583bb6be">~DataStreamSender</a> ()</td></tr> |
| <tr class="separator:a9d54e519344431380d62139e583bb6be"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:acef39c14c7ed4b85122aa3c0cde80247"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#acef39c14c7ed4b85122aa3c0cde80247">Prepare</a> (<a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> *state)</td></tr> |
| <tr class="separator:acef39c14c7ed4b85122aa3c0cde80247"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a441b986df33ba936a2de32af7e84c9d8"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a441b986df33ba936a2de32af7e84c9d8">Open</a> (<a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> *state)</td></tr> |
| <tr class="separator:a441b986df33ba936a2de32af7e84c9d8"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9b36b9b654831d4757e22f131196343b"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send</a> (<a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> *state, <a class="el" href="classimpala_1_1RowBatch.html">RowBatch</a> *batch, <a class="el" href="classbool.html">bool</a> eos)</td></tr> |
| <tr class="separator:a9b36b9b654831d4757e22f131196343b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a54b74afd5299ec9465d49cc748485d00"><td class="memItemLeft" align="right" valign="top">virtual void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">Close</a> (<a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> *state)</td></tr> |
| <tr class="separator:a54b74afd5299ec9465d49cc748485d00"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:abbbddecac6016f222fb67ba610050385"><td class="memItemLeft" align="right" valign="top">void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#abbbddecac6016f222fb67ba610050385">SerializeBatch</a> (<a class="el" href="classimpala_1_1RowBatch.html">RowBatch</a> *src, TRowBatch *dest, int num_receivers=1)</td></tr> |
| <tr class="separator:abbbddecac6016f222fb67ba610050385"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae93db027f9d0cb4c50e8dd962d92a624"><td class="memItemLeft" align="right" valign="top">int64_t </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#ae93db027f9d0cb4c50e8dd962d92a624">GetNumDataBytesSent</a> () const </td></tr> |
| <tr class="separator:ae93db027f9d0cb4c50e8dd962d92a624"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aad9605700b73457dfec1ce13604ae6d2"><td class="memItemLeft" align="right" valign="top">virtual <a class="el" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#aad9605700b73457dfec1ce13604ae6d2">profile</a> ()</td></tr> |
| <tr class="memdesc:aad9605700b73457dfec1ce13604ae6d2"><td class="mdescLeft"> </td><td class="mdescRight">Returns the runtime profile for the sink. <a href="#aad9605700b73457dfec1ce13604ae6d2">More...</a><br/></td></tr> |
| <tr class="separator:aad9605700b73457dfec1ce13604ae6d2"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-static-methods"></a> |
| Static Public Member Functions</h2></td></tr> |
| <tr class="memitem:a21b9c84435c65a4f0870fb5055c990e6"><td class="memItemLeft" align="right" valign="top">static <a class="el" href="classimpala_1_1Status.html">Status</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataSink.html#a21b9c84435c65a4f0870fb5055c990e6">CreateDataSink</a> (<a class="el" href="classimpala_1_1ObjectPool.html">ObjectPool</a> *<a class="el" href="expr-benchmark_8cc.html#a3a5de7bd423fbc0afc4cf935c166ca6b">pool</a>, const TDataSink &thrift_sink, const std::vector< TExpr > &output_exprs, const TPlanFragmentExecParams &params, const <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a> &<a class="el" href="namespaceimpala.html#aa98447566dd6700a2faaaaf3059f4d95">row_desc</a>, boost::scoped_ptr< <a class="el" href="classimpala_1_1DataSink.html">DataSink</a> > *sink)</td></tr> |
| <tr class="separator:a21b9c84435c65a4f0870fb5055c990e6"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ab95c1680a2c851bed71977e502139b32"><td class="memItemLeft" align="right" valign="top">static void </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataSink.html#ab95c1680a2c851bed71977e502139b32">MergeInsertStats</a> (const TInsertStats &src_stats, TInsertStats *dst_stats)</td></tr> |
| <tr class="separator:ab95c1680a2c851bed71977e502139b32"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:acb54f550a23683ce30805c392d24ebc7"><td class="memItemLeft" align="right" valign="top">static std::string </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataSink.html#acb54f550a23683ce30805c392d24ebc7">OutputInsertStats</a> (const <a class="el" href="namespaceimpala.html#a38c499092e6bf592abe6b171cce4eb15">PartitionStatusMap</a> &stats, const std::string &prefix="")</td></tr> |
| <tr class="memdesc:acb54f550a23683ce30805c392d24ebc7"><td class="mdescLeft"> </td><td class="mdescRight">Outputs the insert stats contained in the map of insert partition updates to a string. <a href="#acb54f550a23683ce30805c392d24ebc7">More...</a><br/></td></tr> |
| <tr class="separator:acb54f550a23683ce30805c392d24ebc7"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pro-attribs"></a> |
| Protected Attributes</h2></td></tr> |
| <tr class="memitem:a0a447d23b1d3b6df7b2720439f3e486d"><td class="memItemLeft" align="right" valign="top">boost::scoped_ptr< <a class="el" href="classimpala_1_1MemTracker.html">MemTracker</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataSink.html#a0a447d23b1d3b6df7b2720439f3e486d">expr_mem_tracker_</a></td></tr> |
| <tr class="separator:a0a447d23b1d3b6df7b2720439f3e486d"><td class="memSeparator" colspan="2"> </td></tr> |
| </table><table class="memberdecls"> |
| <tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pri-attribs"></a> |
| Private Attributes</h2></td></tr> |
| <tr class="memitem:a317d26e2a8aa9dcc15dbe994338bd15d"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a317d26e2a8aa9dcc15dbe994338bd15d">sender_id_</a></td></tr> |
| <tr class="memdesc:a317d26e2a8aa9dcc15dbe994338bd15d"><td class="mdescLeft"> </td><td class="mdescRight">Sender instance id, unique within a fragment. <a href="#a317d26e2a8aa9dcc15dbe994338bd15d">More...</a><br/></td></tr> |
| <tr class="separator:a317d26e2a8aa9dcc15dbe994338bd15d"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ac212459ad24f6386484ee23856d8020a"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#ac212459ad24f6386484ee23856d8020a">state_</a></td></tr> |
| <tr class="separator:ac212459ad24f6386484ee23856d8020a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a78b2b85b58341c703f2ae9d1492fc0c2"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1ObjectPool.html">ObjectPool</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a78b2b85b58341c703f2ae9d1492fc0c2">pool_</a></td></tr> |
| <tr class="separator:a78b2b85b58341c703f2ae9d1492fc0c2"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a29aee1e5cf5534019c438874836c248b"><td class="memItemLeft" align="right" valign="top">const <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a> & </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a29aee1e5cf5534019c438874836c248b">row_desc_</a></td></tr> |
| <tr class="separator:a29aee1e5cf5534019c438874836c248b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a5001d5f3c979d1ac348e964d032d6ce6"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classbool.html">bool</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a5001d5f3c979d1ac348e964d032d6ce6">broadcast_</a></td></tr> |
| <tr class="separator:a5001d5f3c979d1ac348e964d032d6ce6"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9712721a0c91210b32f65329e18edec4"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classbool.html">bool</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a9712721a0c91210b32f65329e18edec4">random_</a></td></tr> |
| <tr class="separator:a9712721a0c91210b32f65329e18edec4"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad48f0843f4e4db5ed5abf45c68796b0b"><td class="memItemLeft" align="right" valign="top">int </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#ad48f0843f4e4db5ed5abf45c68796b0b">current_channel_idx_</a></td></tr> |
| <tr class="separator:ad48f0843f4e4db5ed5abf45c68796b0b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a425142ace64ba49e8122f069c79603e0"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classbool.html">bool</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a425142ace64ba49e8122f069c79603e0">closed_</a></td></tr> |
| <tr class="memdesc:a425142ace64ba49e8122f069c79603e0"><td class="mdescLeft"> </td><td class="mdescRight">If true, this sender has been closed. Not valid to call <a class="el" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send()</a> anymore. <a href="#a425142ace64ba49e8122f069c79603e0">More...</a><br/></td></tr> |
| <tr class="separator:a425142ace64ba49e8122f069c79603e0"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a8efd4d7e7db1a831ec30ca0f6b26f23a"><td class="memItemLeft" align="right" valign="top">TRowBatch </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a8efd4d7e7db1a831ec30ca0f6b26f23a">thrift_batch1_</a></td></tr> |
| <tr class="separator:a8efd4d7e7db1a831ec30ca0f6b26f23a"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a33cfb26543180cf9e27ef48595719135"><td class="memItemLeft" align="right" valign="top">TRowBatch </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a33cfb26543180cf9e27ef48595719135">thrift_batch2_</a></td></tr> |
| <tr class="separator:a33cfb26543180cf9e27ef48595719135"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:af88aec7b54580fa5254895fae593f9ee"><td class="memItemLeft" align="right" valign="top">TRowBatch * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#af88aec7b54580fa5254895fae593f9ee">current_thrift_batch_</a></td></tr> |
| <tr class="separator:af88aec7b54580fa5254895fae593f9ee"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a628bdb9621325d09e0d23d0c82c8b651"><td class="memItemLeft" align="right" valign="top">std::vector< <a class="el" href="classimpala_1_1ExprContext.html">ExprContext</a> * > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a628bdb9621325d09e0d23d0c82c8b651">partition_expr_ctxs_</a></td></tr> |
| <tr class="separator:a628bdb9621325d09e0d23d0c82c8b651"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aa7c52712676f0849f95b4913a50432c8"><td class="memItemLeft" align="right" valign="top">std::vector< <a class="el" href="classimpala_1_1DataStreamSender_1_1Channel.html">Channel</a> * > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#aa7c52712676f0849f95b4913a50432c8">channels_</a></td></tr> |
| <tr class="separator:aa7c52712676f0849f95b4913a50432c8"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9c12706a6222a87cb545099a725c3a2b"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a9c12706a6222a87cb545099a725c3a2b">profile_</a></td></tr> |
| <tr class="separator:a9c12706a6222a87cb545099a725c3a2b"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a267f05a34f49154c4213778f69ca0e02"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a267f05a34f49154c4213778f69ca0e02">serialize_batch_timer_</a></td></tr> |
| <tr class="separator:a267f05a34f49154c4213778f69ca0e02"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a9af4aaaa29c37202f3d1ee90746058b2"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a9af4aaaa29c37202f3d1ee90746058b2">thrift_transmit_timer_</a></td></tr> |
| <tr class="separator:a9af4aaaa29c37202f3d1ee90746058b2"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:afb8209f4ee653757ec84277a03734e31"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#afb8209f4ee653757ec84277a03734e31">bytes_sent_counter_</a></td></tr> |
| <tr class="separator:afb8209f4ee653757ec84277a03734e31"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ad494bafc728fd45ff9965005c672a023"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#ad494bafc728fd45ff9965005c672a023">uncompressed_bytes_counter_</a></td></tr> |
| <tr class="separator:ad494bafc728fd45ff9965005c672a023"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:ae79c8af712dd169b821cdb61b761a9bd"><td class="memItemLeft" align="right" valign="top">boost::scoped_ptr< <a class="el" href="classimpala_1_1MemTracker.html">MemTracker</a> > </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#ae79c8af712dd169b821cdb61b761a9bd">mem_tracker_</a></td></tr> |
| <tr class="separator:ae79c8af712dd169b821cdb61b761a9bd"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a96873c121e5ddecadbb7d509b277b413"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a96873c121e5ddecadbb7d509b277b413">network_throughput_</a></td></tr> |
| <tr class="memdesc:a96873c121e5ddecadbb7d509b277b413"><td class="mdescLeft"> </td><td class="mdescRight">Throughput per time spent in TransmitData. <a href="#a96873c121e5ddecadbb7d509b277b413">More...</a><br/></td></tr> |
| <tr class="separator:a96873c121e5ddecadbb7d509b277b413"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:aeb6427e9059b1b7384f78cd25b8cd8d7"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a> * </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#aeb6427e9059b1b7384f78cd25b8cd8d7">overall_throughput_</a></td></tr> |
| <tr class="memdesc:aeb6427e9059b1b7384f78cd25b8cd8d7"><td class="mdescLeft"> </td><td class="mdescRight">Throughput per total time spent in sender. <a href="#aeb6427e9059b1b7384f78cd25b8cd8d7">More...</a><br/></td></tr> |
| <tr class="separator:aeb6427e9059b1b7384f78cd25b8cd8d7"><td class="memSeparator" colspan="2"> </td></tr> |
| <tr class="memitem:a0da91963ba5b4e8299392661e8215cdd"><td class="memItemLeft" align="right" valign="top"><a class="el" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> </td><td class="memItemRight" valign="bottom"><a class="el" href="classimpala_1_1DataStreamSender.html#a0da91963ba5b4e8299392661e8215cdd">dest_node_id_</a></td></tr> |
| <tr class="memdesc:a0da91963ba5b4e8299392661e8215cdd"><td class="mdescLeft"> </td><td class="mdescRight">Identifier of the destination plan node. <a href="#a0da91963ba5b4e8299392661e8215cdd">More...</a><br/></td></tr> |
| <tr class="separator:a0da91963ba5b4e8299392661e8215cdd"><td class="memSeparator" colspan="2"> </td></tr> |
| </table> |
| <a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2> |
| <div class="textblock"><p>Single sender of an m:n data stream. Row batch data is routed to destinations based on the provided partitioning specification. <em>Not</em> thread-safe. TODO: capture stats that describe distribution of rows/data volume across channels. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00046">46</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| </div><h2 class="groupheader">Constructor & Destructor Documentation</h2> |
| <a class="anchor" id="af0f6ed4d7c05379050ff946652597a70"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">impala::DataStreamSender::DataStreamSender </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1ObjectPool.html">ObjectPool</a> * </td> |
| <td class="paramname"><em>pool</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">int </td> |
| <td class="paramname"><em>sender_id</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a> & </td> |
| <td class="paramname"><em>row_desc</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TDataStreamSink & </td> |
| <td class="paramname"><em>sink</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::vector< TPlanFragmentDestination > & </td> |
| <td class="paramname"><em>destinations</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">int </td> |
| <td class="paramname"><em>per_channel_buffer_size</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Construct a sender according to the output specification (sink), sending to the given destinations. sender_id identifies this sender instance, and is unique within a fragment. Per_channel_buffer_size is the buffer size allocated to each channel and is specified in bytes. The <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a> must live until <a class="el" href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">Close()</a> is called. NOTE: supported partition types are UNPARTITIONED (broadcast), HASH_PARTITIONED, and RANDOM. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00310">310</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00100">broadcast_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00114">channels_</a>, <a class="el" href="expr_8cc_source.html#l00149">impala::Expr::CreateExprTrees()</a>, <a class="el" href="status_8h_source.html#l00172">impala::Status::ok()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00113">partition_expr_ctxs_</a>, and <a class="el" href="data-stream-sender_8h_source.html#l00101">random_</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a9d54e519344431380d62139e583bb6be"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">impala::DataStreamSender::~DataStreamSender </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00354">354</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00114">channels_</a>.</p> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Member Function Documentation</h2> |
| <a class="anchor" id="a54b74afd5299ec9465d49cc748485d00"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::DataStreamSender::Close </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> * </td> |
| <td class="paramname"><em>state</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Flush all buffered data and close all existing channels to destination hosts. Further <a class="el" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send()</a> calls are illegal after calling <a class="el" href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">Close()</a>. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1DataSink.html#a969d37af186687d51ef7c3a369882e3b">impala::DataSink</a>.</p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00450">450</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00114">channels_</a>, <a class="el" href="classimpala_1_1Expr.html#a70300b0ba7c91fddb9adfaeb0dfc09a5">impala::Expr::Close()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00105">closed_</a>, and <a class="el" href="data-stream-sender_8h_source.html#l00113">partition_expr_ctxs_</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-test_8cc_source.html#l00468">impala::DataStreamTest::Sender()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a21b9c84435c65a4f0870fb5055c990e6"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::DataSink::CreateDataSink </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1ObjectPool.html">ObjectPool</a> * </td> |
| <td class="paramname"><em>pool</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TDataSink & </td> |
| <td class="paramname"><em>thrift_sink</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::vector< TExpr > & </td> |
| <td class="paramname"><em>output_exprs</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const TPlanFragmentExecParams & </td> |
| <td class="paramname"><em>params</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a> & </td> |
| <td class="paramname"><em>row_desc</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">boost::scoped_ptr< <a class="el" href="classimpala_1_1DataSink.html">DataSink</a> > * </td> |
| <td class="paramname"><em>sink</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">static</span><span class="mlabel">inherited</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Creates a new data sink from thrift_sink. A pointer to the new sink is written to *sink, and is owned by the caller. </p> |
| |
| <p>Definition at line <a class="el" href="data-sink_8cc_source.html#l00034">34</a> of file <a class="el" href="data-sink_8cc_source.html">data-sink.cc</a>.</p> |
| |
| <p>References <a class="el" href="status_8h_source.html#l00087">impala::Status::OK</a>.</p> |
| |
| <p>Referenced by <a class="el" href="plan-fragment-executor_8cc_source.html#l00080">impala::PlanFragmentExecutor::Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ae93db027f9d0cb4c50e8dd962d92a624"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">int64_t impala::DataStreamSender::GetNumDataBytesSent </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td> const</td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Return total number of bytes sent in TRowBatch.data. If batches are broadcast to multiple receivers, they are counted once per receiver. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00469">469</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00114">channels_</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-test_8cc_source.html#l00468">impala::DataStreamTest::Sender()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ab95c1680a2c851bed71977e502139b32"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::DataSink::MergeInsertStats </td> |
| <td>(</td> |
| <td class="paramtype">const TInsertStats & </td> |
| <td class="paramname"><em>src_stats</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">TInsertStats * </td> |
| <td class="paramname"><em>dst_stats</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">static</span><span class="mlabel">inherited</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Merges one update to the insert stats for a partition. dst_stats will have the combined stats of src_stats and dst_stats after this method returns. </p> |
| |
| <p>Definition at line <a class="el" href="data-sink_8cc_source.html#l00090">90</a> of file <a class="el" href="data-sink_8cc_source.html">data-sink.cc</a>.</p> |
| |
| <p>Referenced by <a class="el" href="hdfs-table-sink_8cc_source.html#l00565">impala::HdfsTableSink::FinalizePartitionFile()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a441b986df33ba936a2de32af7e84c9d8"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::DataStreamSender::Open </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> * </td> |
| <td class="paramname"><em>state</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Must be called before <a class="el" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send()</a> or <a class="el" href="classimpala_1_1DataStreamSender.html#a54b74afd5299ec9465d49cc748485d00">Close()</a>, and after the codegen'd IR module is compiled (i.e. in an <a class="el" href="classimpala_1_1ExecNode.html">ExecNode</a>'s <a class="el" href="classimpala_1_1DataStreamSender.html#a441b986df33ba936a2de32af7e84c9d8">Open()</a> function). </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1DataSink.html#a945b469ea9707748efd39273535952c0">impala::DataSink</a>.</p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00397">397</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="classimpala_1_1Expr.html#aad1111f87951868de4d8f8b2dfe87c5f">impala::Expr::Open()</a>, and <a class="el" href="data-stream-sender_8h_source.html#l00113">partition_expr_ctxs_</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-test_8cc_source.html#l00468">impala::DataStreamTest::Sender()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="acb54f550a23683ce30805c392d24ebc7"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">string impala::DataSink::OutputInsertStats </td> |
| <td>(</td> |
| <td class="paramtype">const <a class="el" href="namespaceimpala.html#a38c499092e6bf592abe6b171cce4eb15">PartitionStatusMap</a> & </td> |
| <td class="paramname"><em>stats</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">const std::string & </td> |
| <td class="paramname"><em>prefix</em> = <code>""</code> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">static</span><span class="mlabel">inherited</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Outputs the insert stats contained in the map of insert partition updates to a string. </p> |
| |
| <p>Definition at line <a class="el" href="data-sink_8cc_source.html#l00103">103</a> of file <a class="el" href="data-sink_8cc_source.html">data-sink.cc</a>.</p> |
| |
| <p>References <a class="el" href="pretty-printer_8h_source.html#l00033">impala::PrettyPrinter::Print()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="acef39c14c7ed4b85122aa3c0cde80247"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::DataStreamSender::Prepare </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> * </td> |
| <td class="paramname"><em>state</em></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Must be called before other API calls, and before the codegen'd IR module is compiled (i.e. in an <a class="el" href="classimpala_1_1ExecNode.html">ExecNode</a>'s <a class="el" href="classimpala_1_1DataStreamSender.html#acef39c14c7ed4b85122aa3c0cde80247">Prepare()</a> function). </p> |
| |
| <p>Reimplemented from <a class="el" href="classimpala_1_1DataSink.html#ad1d8007e6e079be3695d5db545ecc446">impala::DataSink</a>.</p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00362">362</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="object-pool_8h_source.html#l00042">impala::ObjectPool::Add()</a>, <a class="el" href="runtime-profile_8h_source.html#l00047">ADD_COUNTER</a>, <a class="el" href="runtime-profile_8h_source.html#l00050">ADD_TIMER</a>, <a class="el" href="runtime-profile_8cc_source.html#l00447">impala::RuntimeProfile::AddDerivedCounter()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00119">bytes_sent_counter_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00114">channels_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00130">dest_node_id_</a>, <a class="el" href="runtime-state_8h_source.html#l00140">impala::RuntimeState::instance_mem_tracker()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00121">mem_tracker_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00124">network_throughput_</a>, <a class="el" href="status_8h_source.html#l00087">impala::Status::OK</a>, <a class="el" href="data-stream-sender_8h_source.html#l00127">overall_throughput_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00113">partition_expr_ctxs_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00098">pool_</a>, <a class="el" href="classimpala_1_1Expr.html#a3ae02e50debba50ac5c7b6dd9f8016e7">impala::Expr::Prepare()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00090">profile()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00116">profile_</a>, <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>, <a class="el" href="data-stream-sender_8h_source.html#l00099">row_desc_</a>, <a class="el" href="runtime-profile_8h_source.html#l00053">SCOPED_TIMER</a>, <a class="el" href="data-stream-sender_8h_source.html#l00117">serialize_batch_timer_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00097">state_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00118">thrift_transmit_timer_</a>, <a class="el" href="runtime-profile_8h_source.html#l00453">impala::RuntimeProfile::total_time_counter()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00120">uncompressed_bytes_counter_</a>, and <a class="el" href="runtime-profile_8cc_source.html#l00733">impala::RuntimeProfile::UnitsPerSecond()</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-test_8cc_source.html#l00468">impala::DataStreamTest::Sender()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aad9605700b73457dfec1ce13604ae6d2"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">virtual <a class="el" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* impala::DataStreamSender::profile </td> |
| <td>(</td> |
| <td class="paramname"></td><td>)</td> |
| <td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">inline</span><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Returns the runtime profile for the sink. </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1DataSink.html#af916d5b1c2071e0b1a1101e36e912ddb">impala::DataSink</a>.</p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00090">90</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00116">profile_</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a9b36b9b654831d4757e22f131196343b"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1Status.html">Status</a> impala::DataStreamSender::Send </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a> * </td> |
| <td class="paramname"><em>state</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RowBatch.html">RowBatch</a> * </td> |
| <td class="paramname"><em>batch</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype"><a class="el" href="classbool.html">bool</a> </td> |
| <td class="paramname"><em>eos</em> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">virtual</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Send data in 'batch' to destination nodes according to partitioning specification provided in c'tor. Blocks until all rows in batch are placed in their appropriate outgoing buffers (ie, blocks if there are still in-flight rpcs from the last <a class="el" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send()</a> call). </p> |
| |
| <p>Implements <a class="el" href="classimpala_1_1DataSink.html#ab73b647642f7623ceb2ba4457292d276">impala::DataSink</a>.</p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00401">401</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00100">broadcast_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00114">channels_</a>, <a class="el" href="runtime-state_8cc_source.html#l00286">impala::RuntimeState::CheckQueryState()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00105">closed_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00102">current_channel_idx_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00111">current_thrift_batch_</a>, <a class="el" href="hash-util_8h_source.html#l00099">impala::HashUtil::FNV_SEED</a>, <a class="el" href="expr-context_8cc_source.html#l00109">impala::ExprContext::FreeLocalAllocations()</a>, <a class="el" href="raw-value_8h_source.html#l00196">impala::RawValue::GetHashValueFnv()</a>, <a class="el" href="row-batch_8h_source.html#l00140">impala::RowBatch::GetRow()</a>, <a class="el" href="expr-context_8cc_source.html#l00200">impala::ExprContext::GetValue()</a>, <a class="el" href="row-batch_8h_source.html#l00215">impala::RowBatch::num_rows()</a>, <a class="el" href="status_8h_source.html#l00087">impala::Status::OK</a>, <a class="el" href="data-stream-sender_8h_source.html#l00113">partition_expr_ctxs_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00116">profile_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00101">random_</a>, <a class="el" href="status_8h_source.html#l00242">RETURN_IF_ERROR</a>, <a class="el" href="expr-context_8h_source.html#l00105">impala::ExprContext::root()</a>, <a class="el" href="runtime-profile_8h_source.html#l00053">SCOPED_TIMER</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00159">impala::DataStreamSender::Channel::SendBatch()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00459">SerializeBatch()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00105">impala::DataStreamSender::Channel::thrift_batch()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00109">thrift_batch1_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00110">thrift_batch2_</a>, <a class="el" href="runtime-profile_8h_source.html#l00453">impala::RuntimeProfile::total_time_counter()</a>, <a class="el" href="expr_8h_source.html#l00145">impala::Expr::type()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00219">impala::DataStreamSender::Channel::WaitForRpc()</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-test_8cc_source.html#l00468">impala::DataStreamTest::Sender()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="abbbddecac6016f222fb67ba610050385"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">void impala::DataStreamSender::SerializeBatch </td> |
| <td>(</td> |
| <td class="paramtype"><a class="el" href="classimpala_1_1RowBatch.html">RowBatch</a> * </td> |
| <td class="paramname"><em>src</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">TRowBatch * </td> |
| <td class="paramname"><em>dest</em>, </td> |
| </tr> |
| <tr> |
| <td class="paramkey"></td> |
| <td></td> |
| <td class="paramtype">int </td> |
| <td class="paramname"><em>num_receivers</em> = <code>1</code> </td> |
| </tr> |
| <tr> |
| <td></td> |
| <td>)</td> |
| <td></td><td></td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>Serializes the src batch into the dest thrift batch. Maintains metrics. num_receivers is the number of receivers this batch will be sent to. Only used to maintain metrics. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8cc_source.html#l00459">459</a> of file <a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a>.</p> |
| |
| <p>References <a class="el" href="data-stream-sender_8h_source.html#l00119">bytes_sent_counter_</a>, <a class="el" href="runtime-profile_8h_source.html#l00055">COUNTER_ADD</a>, <a class="el" href="row-batch_8cc_source.html#l00264">impala::RowBatch::GetBatchSize()</a>, <a class="el" href="row-batch_8h_source.html#l00215">impala::RowBatch::num_rows()</a>, <a class="el" href="runtime-profile_8h_source.html#l00053">SCOPED_TIMER</a>, <a class="el" href="row-batch_8cc_source.html#l00147">impala::RowBatch::Serialize()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00117">serialize_batch_timer_</a>, <a class="el" href="data-stream-sender_8h_source.html#l00120">uncompressed_bytes_counter_</a>, and <a class="el" href="logging_8h_source.html#l00059">VLOG_ROW</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <h2 class="groupheader">Member Data Documentation</h2> |
| <a class="anchor" id="a5001d5f3c979d1ac348e964d032d6ce6"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classbool.html">bool</a> impala::DataStreamSender::broadcast_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00100">100</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00310">DataStreamSender()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="afb8209f4ee653757ec84277a03734e31"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* impala::DataStreamSender::bytes_sent_counter_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00119">119</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00459">SerializeBatch()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aa7c52712676f0849f95b4913a50432c8"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">std::vector<<a class="el" href="classimpala_1_1DataStreamSender_1_1Channel.html">Channel</a>*> impala::DataStreamSender::channels_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00114">114</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00450">Close()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00310">DataStreamSender()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00469">GetNumDataBytesSent()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00354">~DataStreamSender()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a425142ace64ba49e8122f069c79603e0"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classbool.html">bool</a> impala::DataStreamSender::closed_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>If true, this sender has been closed. Not valid to call <a class="el" href="classimpala_1_1DataStreamSender.html#a9b36b9b654831d4757e22f131196343b">Send()</a> anymore. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00105">105</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00450">Close()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ad48f0843f4e4db5ed5abf45c68796b0b"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">int impala::DataStreamSender::current_channel_idx_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00102">102</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="af88aec7b54580fa5254895fae593f9ee"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">TRowBatch* impala::DataStreamSender::current_thrift_batch_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00111">111</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a0da91963ba5b4e8299392661e8215cdd"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="namespaceimpala.html#aca80061c98b44477ea84e4332993b7e7">PlanNodeId</a> impala::DataStreamSender::dest_node_id_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Identifier of the destination plan node. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00130">130</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a0a447d23b1d3b6df7b2720439f3e486d"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">boost::scoped_ptr<<a class="el" href="classimpala_1_1MemTracker.html">MemTracker</a>> impala::DataSink::expr_mem_tracker_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">protected</span><span class="mlabel">inherited</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-sink_8h_source.html#l00085">85</a> of file <a class="el" href="data-sink_8h_source.html">data-sink.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-sink_8cc_source.html#l00136">impala::DataSink::Prepare()</a>, and <a class="el" href="hdfs-table-sink_8cc_source.html#l00072">impala::HdfsTableSink::PrepareExprs()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ae79c8af712dd169b821cdb61b761a9bd"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">boost::scoped_ptr<<a class="el" href="classimpala_1_1MemTracker.html">MemTracker</a>> impala::DataStreamSender::mem_tracker_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00121">121</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a96873c121e5ddecadbb7d509b277b413"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* impala::DataStreamSender::network_throughput_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Throughput per time spent in TransmitData. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00124">124</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="aeb6427e9059b1b7384f78cd25b8cd8d7"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* impala::DataStreamSender::overall_throughput_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Throughput per total time spent in sender. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00127">127</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a628bdb9621325d09e0d23d0c82c8b651"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">std::vector<<a class="el" href="classimpala_1_1ExprContext.html">ExprContext</a>*> impala::DataStreamSender::partition_expr_ctxs_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00113">113</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00450">Close()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00310">DataStreamSender()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00397">Open()</a>, <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a78b2b85b58341c703f2ae9d1492fc0c2"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1ObjectPool.html">ObjectPool</a>* impala::DataStreamSender::pool_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00098">98</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a9c12706a6222a87cb545099a725c3a2b"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile.html">RuntimeProfile</a>* impala::DataStreamSender::profile_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00116">116</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>, <a class="el" href="data-stream-sender_8h_source.html#l00090">profile()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a9712721a0c91210b32f65329e18edec4"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classbool.html">bool</a> impala::DataStreamSender::random_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00101">101</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00310">DataStreamSender()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a29aee1e5cf5534019c438874836c248b"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">const <a class="el" href="classimpala_1_1RowDescriptor.html">RowDescriptor</a>& impala::DataStreamSender::row_desc_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00099">99</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a317d26e2a8aa9dcc15dbe994338bd15d"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">int impala::DataStreamSender::sender_id_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Sender instance id, unique within a fragment. </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00093">93</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a267f05a34f49154c4213778f69ca0e02"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* impala::DataStreamSender::serialize_batch_timer_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00117">117</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00459">SerializeBatch()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ac212459ad24f6386484ee23856d8020a"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeState.html">RuntimeState</a>* impala::DataStreamSender::state_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00097">97</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a8efd4d7e7db1a831ec30ca0f6b26f23a"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">TRowBatch impala::DataStreamSender::thrift_batch1_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| <p>serialized batches for broadcasting; we need two so we can write one while the other one is still being sent </p> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00109">109</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a33cfb26543180cf9e27ef48595719135"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname">TRowBatch impala::DataStreamSender::thrift_batch2_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00110">110</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00401">Send()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="a9af4aaaa29c37202f3d1ee90746058b2"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* impala::DataStreamSender::thrift_transmit_timer_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00118">118</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>.</p> |
| |
| </div> |
| </div> |
| <a class="anchor" id="ad494bafc728fd45ff9965005c672a023"></a> |
| <div class="memitem"> |
| <div class="memproto"> |
| <table class="mlabels"> |
| <tr> |
| <td class="mlabels-left"> |
| <table class="memname"> |
| <tr> |
| <td class="memname"><a class="el" href="classimpala_1_1RuntimeProfile_1_1Counter.html">RuntimeProfile::Counter</a>* impala::DataStreamSender::uncompressed_bytes_counter_</td> |
| </tr> |
| </table> |
| </td> |
| <td class="mlabels-right"> |
| <span class="mlabels"><span class="mlabel">private</span></span> </td> |
| </tr> |
| </table> |
| </div><div class="memdoc"> |
| |
| <p>Definition at line <a class="el" href="data-stream-sender_8h_source.html#l00120">120</a> of file <a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a>.</p> |
| |
| <p>Referenced by <a class="el" href="data-stream-sender_8cc_source.html#l00362">Prepare()</a>, and <a class="el" href="data-stream-sender_8cc_source.html#l00459">SerializeBatch()</a>.</p> |
| |
| </div> |
| </div> |
| <hr/>The documentation for this class was generated from the following files:<ul> |
| <li>be/src/runtime/<a class="el" href="data-stream-sender_8h_source.html">data-stream-sender.h</a></li> |
| <li>be/src/runtime/<a class="el" href="data-stream-sender_8cc_source.html">data-stream-sender.cc</a></li> |
| </ul> |
| </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="namespaceimpala.html">impala</a></li><li class="navelem"><a class="el" href="classimpala_1_1DataStreamSender.html">DataStreamSender</a></li> |
| <li class="footer">Generated on Thu May 7 2015 16:10:49 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> |
