|
| ~ContinuousQuery () |
| Destructor.
|
|
| ContinuousQuery (Reference< event::CacheEntryEventListener< K, V > > lsnr) |
| Constructor. More...
|
|
| ContinuousQuery (Reference< event::CacheEntryEventListener< K, V > > lsnr, bool loc) |
| Constructor. More...
|
|
template<typename F > |
| ContinuousQuery (Reference< event::CacheEntryEventListener< K, V > > lsnr, const Reference< F > &remoteFilter) |
| Constructor. More...
|
|
template<typename F > |
| ContinuousQuery (Reference< event::CacheEntryEventListener< K, V > > lsnr, const Reference< F > &remoteFilter, bool loc) |
| Constructor. More...
|
|
void | SetLocal (bool val) |
| Set local flag. More...
|
|
bool | GetLocal () const |
| Get local flag. More...
|
|
void | SetBufferSize (int32_t val) |
| Set buffer size. More...
|
|
int32_t | GetBufferSize () const |
| Get buffer size. More...
|
|
void | SetTimeInterval (int64_t val) |
| Set time interval. More...
|
|
int64_t | GetTimeInterval () const |
| Get time interval. More...
|
|
void | SetListener (Reference< event::CacheEntryEventListener< K, V > > lsnr) |
| Set cache entry event listener. More...
|
|
const event::CacheEntryEventListener< K, V > & | GetListener () const |
| Get cache entry event listener. More...
|
|
event::CacheEntryEventListener< K, V > & | GetListener () |
| Get cache entry event listener. More...
|
|
template<typename K, typename V>
class ignite::cache::query::continuous::ContinuousQuery< K, V >
Continuous query.
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.
Continuous query can either be executed on the whole topology or only on local node.
To execute the query over the cache use method ignite::cache::Cache::QueryContinuous().
template<typename K, typename V>
Get time interval.
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.
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.
- Returns
- Time interval.
template<typename K, typename V>
Set time interval.
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.
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.
- Parameters
-
val | Time interval in miliseconds. |