template<typename K, typename V>
class ignite::thin::cache::query::continuous::ContinuousQueryClient< K, V >
Continuous query client.
Continuous query client allow to register a listener for cache update events. On any update to the related cache an event is sent to the client that has executed the query and listener is notified on that client.
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::thin::cache::CacheClient::QueryContinuous().
template<typename K , typename V >
Gets a value indicating whether to notify about Expired events.
If true
, then the listener will get notifications about expired cache entries. Otherwise, only Created, Updated, and Removed events will be passed to the listener.
Defaults to false
.
- Returns
- Flag value.
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 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.
- Returns
- Time interval.
template<typename K , typename V >
Sets a value indicating whether to notify about Expired events.
If true
, then the listener will get notifications about expired cache entries. Otherwise, only Created, Updated, and Removed events will be passed to the listener.
Defaults to false
.
- Parameters
-
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. |