blob: fbe460f45ca29adb4beb70b05a7b8bc9371e2816 [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>
<link rel="canonical" href="https://ignite.apache.org/releases/2.9.0/cppdoc/classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html" />
<META NAME="ROBOTS" CONTENT="NOINDEX">
<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.13"/>
<meta name="viewport" content="width=device-width, initial-scale=1"/>
<title>&nbsp; Apache Ignite C++: ignite::cache::query::continuous::ContinuousQuery&lt; K, V &gt; Class Template 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="search/search.css" rel="stylesheet" type="text/css"/>
<script type="text/javascript" src="search/searchdata.js"></script>
<script type="text/javascript" src="search/search.js"></script>
<link href="doxygen.css" rel="stylesheet" type="text/css" />
<script>
(function(i,s,o,g,r,a,m){i['GoogleAnalyticsObject']=r;i[r]=i[r]||function(){
(i[r].q=i[r].q||[]).push(arguments)},i[r].l=1*new Date();a=s.createElement(o),
m=s.getElementsByTagName(o)[0];a.async=1;a.src=g;m.parentNode.insertBefore(a,m)
})(window,document,'script','https://www.google-analytics.com/analytics.js','ga');
ga('create', 'UA-61232409-1', 'auto');
ga('send', 'pageview');
</script></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 id="projectlogo"><img alt="Logo" src="ignite_logo.png"/></td>
<td id="projectalign" style="padding-left: 0.5em;">
<div id="projectname">&nbsp; Apache Ignite C++
</div>
</td>
</tr>
</tbody>
</table>
</div>
<!-- end header part -->
<!-- Generated by Doxygen 1.8.13 -->
<script type="text/javascript">
var searchBox = new SearchBox("searchBox", "search",false,'Search');
</script>
<script type="text/javascript" src="menudata.js"></script>
<script type="text/javascript" src="menu.js"></script>
<script type="text/javascript">
$(function() {
initMenu('',true,false,'search.php','Search');
$(document).ready(function() { init_search(); });
});
</script>
<div id="main-nav"></div>
<!-- window showing the filter options -->
<div id="MSearchSelectWindow"
onmouseover="return searchBox.OnSearchSelectShow()"
onmouseout="return searchBox.OnSearchSelectHide()"
onkeydown="return searchBox.OnSearchSelectKey(event)">
</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 id="nav-path" class="navpath">
<ul>
<li class="navelem"><a class="el" href="namespaceignite.html">ignite</a></li><li class="navelem"><a class="el" href="namespaceignite_1_1cache.html">cache</a></li><li class="navelem"><a class="el" href="namespaceignite_1_1cache_1_1query.html">query</a></li><li class="navelem"><a class="el" href="namespaceignite_1_1cache_1_1query_1_1continuous.html">continuous</a></li><li class="navelem"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ContinuousQuery</a></li> </ul>
</div>
</div><!-- top -->
<div class="header">
<div class="summary">
<a href="#pub-types">Public Types</a> &#124;
<a href="#pub-methods">Public Member Functions</a> &#124;
<a href="#friends">Friends</a> &#124;
<a href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery-members.html">List of all members</a> </div>
<div class="headertitle">
<div class="title">ignite::cache::query::continuous::ContinuousQuery&lt; K, V &gt; Class Template Reference</div> </div>
</div><!--header-->
<div class="contents">
<p>Continuous query.
<a href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#details">More...</a></p>
<p><code>#include &lt;<a class="el" href="continuous__query_8h_source.html">continuous_query.h</a>&gt;</code></p>
<table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="pub-types"></a>
Public Types</h2></td></tr>
<tr class="memitem:a87b3f345a39de870ecb906fa72eab72d"><td class="memItemLeft" align="right" valign="top"><a id="a87b3f345a39de870ecb906fa72eab72d"></a>enum &#160;</td><td class="memItemRight" valign="bottom">{ <b>DEFAULT_BUFFER_SIZE</b> = 1
}<tr class="memdesc:a87b3f345a39de870ecb906fa72eab72d"><td class="mdescLeft">&#160;</td><td class="mdescRight">Default value for the buffer size. <br /></td></tr>
</td></tr>
<tr class="separator:a87b3f345a39de870ecb906fa72eab72d"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a2a26bcd1e7cb94e26b828b7e16efb483"><td class="memItemLeft" align="right" valign="top"><a id="a2a26bcd1e7cb94e26b828b7e16efb483"></a>enum &#160;</td><td class="memItemRight" valign="bottom">{ <b>DEFAULT_TIME_INTERVAL</b> = 0
}<tr class="memdesc:a2a26bcd1e7cb94e26b828b7e16efb483"><td class="mdescLeft">&#160;</td><td class="mdescRight">Default value for the time interval. <br /></td></tr>
</td></tr>
<tr class="separator:a2a26bcd1e7cb94e26b828b7e16efb483"><td class="memSeparator" colspan="2">&#160;</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:aaf1d6a4d053cefd163bdfa034374473f"><td class="memItemLeft" align="right" valign="top"><a id="aaf1d6a4d053cefd163bdfa034374473f"></a>
&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#aaf1d6a4d053cefd163bdfa034374473f">~ContinuousQuery</a> ()</td></tr>
<tr class="memdesc:aaf1d6a4d053cefd163bdfa034374473f"><td class="mdescLeft">&#160;</td><td class="mdescRight">Destructor. <br /></td></tr>
<tr class="separator:aaf1d6a4d053cefd163bdfa034374473f"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:abe45cb17c5dc2754d064ff92cde29db4"><td class="memItemLeft" align="right" valign="top">&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#abe45cb17c5dc2754d064ff92cde29db4">ContinuousQuery</a> (<a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt; lsnr)</td></tr>
<tr class="memdesc:abe45cb17c5dc2754d064ff92cde29db4"><td class="mdescLeft">&#160;</td><td class="mdescRight">Constructor. <a href="#abe45cb17c5dc2754d064ff92cde29db4">More...</a><br /></td></tr>
<tr class="separator:abe45cb17c5dc2754d064ff92cde29db4"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aff44341b171e303d2cfe302498037519"><td class="memItemLeft" align="right" valign="top">&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#aff44341b171e303d2cfe302498037519">ContinuousQuery</a> (<a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt; lsnr, bool loc)</td></tr>
<tr class="memdesc:aff44341b171e303d2cfe302498037519"><td class="mdescLeft">&#160;</td><td class="mdescRight">Constructor. <a href="#aff44341b171e303d2cfe302498037519">More...</a><br /></td></tr>
<tr class="separator:aff44341b171e303d2cfe302498037519"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a26c51c268827890cecb1cbee1f917c67"><td class="memTemplParams" colspan="2">template&lt;typename F &gt; </td></tr>
<tr class="memitem:a26c51c268827890cecb1cbee1f917c67"><td class="memTemplItemLeft" align="right" valign="top">&#160;</td><td class="memTemplItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#a26c51c268827890cecb1cbee1f917c67">ContinuousQuery</a> (<a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt; lsnr, const <a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; F &gt; &amp;remoteFilter)</td></tr>
<tr class="memdesc:a26c51c268827890cecb1cbee1f917c67"><td class="mdescLeft">&#160;</td><td class="mdescRight">Constructor. <a href="#a26c51c268827890cecb1cbee1f917c67">More...</a><br /></td></tr>
<tr class="separator:a26c51c268827890cecb1cbee1f917c67"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a96f3773844787f170bbf8871bf408e73"><td class="memTemplParams" colspan="2">template&lt;typename F &gt; </td></tr>
<tr class="memitem:a96f3773844787f170bbf8871bf408e73"><td class="memTemplItemLeft" align="right" valign="top">&#160;</td><td class="memTemplItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#a96f3773844787f170bbf8871bf408e73">ContinuousQuery</a> (<a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt; lsnr, const <a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; F &gt; &amp;remoteFilter, bool loc)</td></tr>
<tr class="memdesc:a96f3773844787f170bbf8871bf408e73"><td class="mdescLeft">&#160;</td><td class="mdescRight">Constructor. <a href="#a96f3773844787f170bbf8871bf408e73">More...</a><br /></td></tr>
<tr class="separator:a96f3773844787f170bbf8871bf408e73"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aef8dbf5f7809d8104963fb50aa7db40c"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#aef8dbf5f7809d8104963fb50aa7db40c">SetLocal</a> (bool val)</td></tr>
<tr class="memdesc:aef8dbf5f7809d8104963fb50aa7db40c"><td class="mdescLeft">&#160;</td><td class="mdescRight">Set local flag. <a href="#aef8dbf5f7809d8104963fb50aa7db40c">More...</a><br /></td></tr>
<tr class="separator:aef8dbf5f7809d8104963fb50aa7db40c"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:abfe935f2ff9733df3dff5cf9c72b9240"><td class="memItemLeft" align="right" valign="top">bool&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#abfe935f2ff9733df3dff5cf9c72b9240">GetLocal</a> () const</td></tr>
<tr class="memdesc:abfe935f2ff9733df3dff5cf9c72b9240"><td class="mdescLeft">&#160;</td><td class="mdescRight">Get local flag. <a href="#abfe935f2ff9733df3dff5cf9c72b9240">More...</a><br /></td></tr>
<tr class="separator:abfe935f2ff9733df3dff5cf9c72b9240"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a755b5cf8a7ea00e0b19c37b6b589efc3"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#a755b5cf8a7ea00e0b19c37b6b589efc3">SetBufferSize</a> (int32_t val)</td></tr>
<tr class="memdesc:a755b5cf8a7ea00e0b19c37b6b589efc3"><td class="mdescLeft">&#160;</td><td class="mdescRight">Set buffer size. <a href="#a755b5cf8a7ea00e0b19c37b6b589efc3">More...</a><br /></td></tr>
<tr class="separator:a755b5cf8a7ea00e0b19c37b6b589efc3"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:ab4300aa0cfc839a4f103c8b51fbbdcc6"><td class="memItemLeft" align="right" valign="top">int32_t&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#ab4300aa0cfc839a4f103c8b51fbbdcc6">GetBufferSize</a> () const</td></tr>
<tr class="memdesc:ab4300aa0cfc839a4f103c8b51fbbdcc6"><td class="mdescLeft">&#160;</td><td class="mdescRight">Get buffer size. <a href="#ab4300aa0cfc839a4f103c8b51fbbdcc6">More...</a><br /></td></tr>
<tr class="separator:ab4300aa0cfc839a4f103c8b51fbbdcc6"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a6abb33c89aab001f5035ea913c200fdb"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#a6abb33c89aab001f5035ea913c200fdb">SetTimeInterval</a> (int64_t val)</td></tr>
<tr class="memdesc:a6abb33c89aab001f5035ea913c200fdb"><td class="mdescLeft">&#160;</td><td class="mdescRight">Set time interval. <a href="#a6abb33c89aab001f5035ea913c200fdb">More...</a><br /></td></tr>
<tr class="separator:a6abb33c89aab001f5035ea913c200fdb"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a35e04d430f74fa4eba6a0d35ca74292a"><td class="memItemLeft" align="right" valign="top">int64_t&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#a35e04d430f74fa4eba6a0d35ca74292a">GetTimeInterval</a> () const</td></tr>
<tr class="memdesc:a35e04d430f74fa4eba6a0d35ca74292a"><td class="mdescLeft">&#160;</td><td class="mdescRight">Get time interval. <a href="#a35e04d430f74fa4eba6a0d35ca74292a">More...</a><br /></td></tr>
<tr class="separator:a35e04d430f74fa4eba6a0d35ca74292a"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:a88f43a94603ad2b6a0bb39cff88eaded"><td class="memItemLeft" align="right" valign="top">void&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#a88f43a94603ad2b6a0bb39cff88eaded">SetListener</a> (<a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt; lsnr)</td></tr>
<tr class="memdesc:a88f43a94603ad2b6a0bb39cff88eaded"><td class="mdescLeft">&#160;</td><td class="mdescRight">Set cache entry event listener. <a href="#a88f43a94603ad2b6a0bb39cff88eaded">More...</a><br /></td></tr>
<tr class="separator:a88f43a94603ad2b6a0bb39cff88eaded"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:aeaff542cb0aaad67aaf2d62e6b01010d"><td class="memItemLeft" align="right" valign="top">const <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#aeaff542cb0aaad67aaf2d62e6b01010d">GetListener</a> () const</td></tr>
<tr class="memdesc:aeaff542cb0aaad67aaf2d62e6b01010d"><td class="mdescLeft">&#160;</td><td class="mdescRight">Get cache entry event listener. <a href="#aeaff542cb0aaad67aaf2d62e6b01010d">More...</a><br /></td></tr>
<tr class="separator:aeaff542cb0aaad67aaf2d62e6b01010d"><td class="memSeparator" colspan="2">&#160;</td></tr>
<tr class="memitem:acd0367fd5ed691d9b19f19fddc04a762"><td class="memItemLeft" align="right" valign="top"><a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &amp;&#160;</td><td class="memItemRight" valign="bottom"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html#acd0367fd5ed691d9b19f19fddc04a762">GetListener</a> ()</td></tr>
<tr class="memdesc:acd0367fd5ed691d9b19f19fddc04a762"><td class="mdescLeft">&#160;</td><td class="mdescRight">Get cache entry event listener. <a href="#acd0367fd5ed691d9b19f19fddc04a762">More...</a><br /></td></tr>
<tr class="separator:acd0367fd5ed691d9b19f19fddc04a762"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table><table class="memberdecls">
<tr class="heading"><td colspan="2"><h2 class="groupheader"><a name="friends"></a>
Friends</h2></td></tr>
<tr class="memitem:a2ff17d034adb679b2fa14a69efa5da96"><td class="memItemLeft" align="right" valign="top"><a id="a2ff17d034adb679b2fa14a69efa5da96"></a>
class&#160;</td><td class="memItemRight" valign="bottom"><b>Cache&lt; K, V &gt;</b></td></tr>
<tr class="separator:a2ff17d034adb679b2fa14a69efa5da96"><td class="memSeparator" colspan="2">&#160;</td></tr>
</table>
<a name="details" id="details"></a><h2 class="groupheader">Detailed Description</h2>
<div class="textblock"><h3>template&lt;typename K, typename V&gt;<br />
class ignite::cache::query::continuous::ContinuousQuery&lt; K, V &gt;</h3>
<p>Continuous query. </p>
<p>Continuous queries allow to register a remote and a listener for cache update events. On any update to the related cache an event is sent to the node that has executed the query and listener is notified on that node.</p>
<p>Continuous query can either be executed on the whole topology or only on local node.</p>
<p>To execute the query over the cache use method <a class="el" href="classignite_1_1cache_1_1Cache.html#aa593e6059eaad9122a1ea2c7d55386cb" title="Start continuous query execution. ">ignite::cache::Cache::QueryContinuous()</a>. </p>
</div><h2 class="groupheader">Constructor &amp; Destructor Documentation</h2>
<a id="abe45cb17c5dc2754d064ff92cde29db4"></a>
<h2 class="memtitle"><span class="permalink"><a href="#abe45cb17c5dc2754d064ff92cde29db4">&#9670;&nbsp;</a></span>ContinuousQuery() <span class="overload">[1/4]</span></h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::<a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ContinuousQuery</a> </td>
<td>(</td>
<td class="paramtype"><a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt;&#160;</td>
<td class="paramname"><em>lsnr</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Constructor. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">lsnr</td><td>Event listener. Invoked on the node where continuous query execution has been started. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<a id="aff44341b171e303d2cfe302498037519"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aff44341b171e303d2cfe302498037519">&#9670;&nbsp;</a></span>ContinuousQuery() <span class="overload">[2/4]</span></h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::<a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ContinuousQuery</a> </td>
<td>(</td>
<td class="paramtype"><a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt;&#160;</td>
<td class="paramname"><em>lsnr</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">bool&#160;</td>
<td class="paramname"><em>loc</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Constructor. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">lsnr</td><td>Event listener Invoked on the node where continuous query execution has been started. </td></tr>
<tr><td class="paramname">loc</td><td>Whether query should be executed locally. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<a id="a26c51c268827890cecb1cbee1f917c67"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a26c51c268827890cecb1cbee1f917c67">&#9670;&nbsp;</a></span>ContinuousQuery() <span class="overload">[3/4]</span></h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<div class="memtemplate">
template&lt;typename F &gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::<a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ContinuousQuery</a> </td>
<td>(</td>
<td class="paramtype"><a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt;&#160;</td>
<td class="paramname"><em>lsnr</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">const <a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; F &gt; &amp;&#160;</td>
<td class="paramname"><em>remoteFilter</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Constructor. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">lsnr</td><td>Event listener. Invoked on the node where continuous query execution has been started. </td></tr>
<tr><td class="paramname">remoteFilter</td><td>Remote filter. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<a id="a96f3773844787f170bbf8871bf408e73"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a96f3773844787f170bbf8871bf408e73">&#9670;&nbsp;</a></span>ContinuousQuery() <span class="overload">[4/4]</span></h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<div class="memtemplate">
template&lt;typename F &gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::<a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ContinuousQuery</a> </td>
<td>(</td>
<td class="paramtype"><a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt;&#160;</td>
<td class="paramname"><em>lsnr</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">const <a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; F &gt; &amp;&#160;</td>
<td class="paramname"><em>remoteFilter</em>, </td>
</tr>
<tr>
<td class="paramkey"></td>
<td></td>
<td class="paramtype">bool&#160;</td>
<td class="paramname"><em>loc</em>&#160;</td>
</tr>
<tr>
<td></td>
<td>)</td>
<td></td><td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Constructor. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">lsnr</td><td>Event listener Invoked on the node where continuous query execution has been started. </td></tr>
<tr><td class="paramname">remoteFilter</td><td>Remote filter. </td></tr>
<tr><td class="paramname">loc</td><td>Whether query should be executed locally. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<h2 class="groupheader">Member Function Documentation</h2>
<a id="ab4300aa0cfc839a4f103c8b51fbbdcc6"></a>
<h2 class="memtitle"><span class="permalink"><a href="#ab4300aa0cfc839a4f103c8b51fbbdcc6">&#9670;&nbsp;</a></span>GetBufferSize()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">int32_t <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::GetBufferSize </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Get buffer size. </p>
<p>When a cache update happens, entry is first put into a buffer. Entries from buffer will be sent to the master node only if the buffer is full or time provided via timeInterval is exceeded.</p>
<dl class="section return"><dt>Returns</dt><dd>Buffer size. </dd></dl>
</div>
</div>
<a id="aeaff542cb0aaad67aaf2d62e6b01010d"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aeaff542cb0aaad67aaf2d62e6b01010d">&#9670;&nbsp;</a></span>GetListener() <span class="overload">[1/2]</span></h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">const <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt;K, V&gt;&amp; <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::GetListener </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Get cache entry event listener. </p>
<dl class="section return"><dt>Returns</dt><dd><a class="el" href="classignite_1_1cache_1_1Cache.html" title="Main entry point for all Data Grid APIs. ">Cache</a> entry event listener. </dd></dl>
</div>
</div>
<a id="acd0367fd5ed691d9b19f19fddc04a762"></a>
<h2 class="memtitle"><span class="permalink"><a href="#acd0367fd5ed691d9b19f19fddc04a762">&#9670;&nbsp;</a></span>GetListener() <span class="overload">[2/2]</span></h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname"><a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt;K, V&gt;&amp; <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::GetListener </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> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Get cache entry event listener. </p>
<dl class="section return"><dt>Returns</dt><dd><a class="el" href="classignite_1_1cache_1_1Cache.html" title="Main entry point for all Data Grid APIs. ">Cache</a> entry event listener. </dd></dl>
</div>
</div>
<a id="abfe935f2ff9733df3dff5cf9c72b9240"></a>
<h2 class="memtitle"><span class="permalink"><a href="#abfe935f2ff9733df3dff5cf9c72b9240">&#9670;&nbsp;</a></span>GetLocal()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">bool <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::GetLocal </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Get local flag. </p>
<dl class="section return"><dt>Returns</dt><dd>Value of the flag. If true, query will be executed only on local node, so only local entries will be returned as query result. </dd></dl>
</div>
</div>
<a id="a35e04d430f74fa4eba6a0d35ca74292a"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a35e04d430f74fa4eba6a0d35ca74292a">&#9670;&nbsp;</a></span>GetTimeInterval()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">int64_t <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::GetTimeInterval </td>
<td>(</td>
<td class="paramname"></td><td>)</td>
<td> const</td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Get time interval. </p>
<p>When a cache update happens, entry is first put into a buffer. Entries from buffer are sent to the master node only if the buffer is full (its size can be changed via SetBufferSize) or time provided via SetTimeInterval method is exceeded.</p>
<p>Default value is DEFAULT_TIME_INTERVAL, i.e. 0, which means that time check is disabled and entries will be sent only when buffer is full.</p>
<dl class="section return"><dt>Returns</dt><dd><a class="el" href="classignite_1_1Time.html" title="Time type. ">Time</a> interval. </dd></dl>
</div>
</div>
<a id="a755b5cf8a7ea00e0b19c37b6b589efc3"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a755b5cf8a7ea00e0b19c37b6b589efc3">&#9670;&nbsp;</a></span>SetBufferSize()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::SetBufferSize </td>
<td>(</td>
<td class="paramtype">int32_t&#160;</td>
<td class="paramname"><em>val</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Set buffer size. </p>
<p>When a cache update happens, entry is first put into a buffer. Entries from buffer will be sent to the master node only if the buffer is full or time provided via timeInterval is exceeded.</p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">val</td><td>Buffer size. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<a id="a88f43a94603ad2b6a0bb39cff88eaded"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a88f43a94603ad2b6a0bb39cff88eaded">&#9670;&nbsp;</a></span>SetListener()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::SetListener </td>
<td>(</td>
<td class="paramtype"><a class="el" href="classignite_1_1Reference.html">Reference</a>&lt; <a class="el" href="classignite_1_1cache_1_1event_1_1CacheEntryEventListener.html">event::CacheEntryEventListener</a>&lt; K, V &gt; &gt;&#160;</td>
<td class="paramname"><em>lsnr</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Set cache entry event listener. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">lsnr</td><td><a class="el" href="classignite_1_1cache_1_1Cache.html" title="Main entry point for all Data Grid APIs. ">Cache</a> entry event listener. Invoked on the node where continuous query execution has been started. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<a id="aef8dbf5f7809d8104963fb50aa7db40c"></a>
<h2 class="memtitle"><span class="permalink"><a href="#aef8dbf5f7809d8104963fb50aa7db40c">&#9670;&nbsp;</a></span>SetLocal()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::SetLocal </td>
<td>(</td>
<td class="paramtype">bool&#160;</td>
<td class="paramname"><em>val</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Set local flag. </p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">val</td><td>Value of the flag. If true, query will be executed only on local node, so only local entries will be returned as query result. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<a id="a6abb33c89aab001f5035ea913c200fdb"></a>
<h2 class="memtitle"><span class="permalink"><a href="#a6abb33c89aab001f5035ea913c200fdb">&#9670;&nbsp;</a></span>SetTimeInterval()</h2>
<div class="memitem">
<div class="memproto">
<div class="memtemplate">
template&lt;typename K, typename V&gt; </div>
<table class="mlabels">
<tr>
<td class="mlabels-left">
<table class="memname">
<tr>
<td class="memname">void <a class="el" href="classignite_1_1cache_1_1query_1_1continuous_1_1ContinuousQuery.html">ignite::cache::query::continuous::ContinuousQuery</a>&lt; K, V &gt;::SetTimeInterval </td>
<td>(</td>
<td class="paramtype">int64_t&#160;</td>
<td class="paramname"><em>val</em></td><td>)</td>
<td></td>
</tr>
</table>
</td>
<td class="mlabels-right">
<span class="mlabels"><span class="mlabel">inline</span></span> </td>
</tr>
</table>
</div><div class="memdoc">
<p>Set time interval. </p>
<p>When a cache update happens, entry is first put into a buffer. Entries from buffer are sent to the master node only if the buffer is full (its size can be changed via SetBufferSize) or time provided via this method is exceeded.</p>
<p>Default value is DEFAULT_TIME_INTERVAL, i.e. 0, which means that time check is disabled and entries will be sent only when buffer is full.</p>
<dl class="params"><dt>Parameters</dt><dd>
<table class="params">
<tr><td class="paramname">val</td><td><a class="el" href="classignite_1_1Time.html" title="Time type. ">Time</a> interval in miliseconds. </td></tr>
</table>
</dd>
</dl>
</div>
</div>
<hr/>The documentation for this class was generated from the following file:<ul>
<li><a class="el" href="continuous__query_8h_source.html">continuous_query.h</a></li>
</ul>
</div><!-- contents -->
<!-- start footer part -->
<hr class="footer"/><address class="footer"><small>
Generated on Thu Oct 15 2020 12:17:18 for &nbsp; Apache Ignite C++ by &#160;<a href="http://www.doxygen.org/index.html">
<img class="footer" src="doxygen.png" alt="doxygen"/>
</a> 1.8.13
</small></address>
</body>
</html>