23 #ifndef _IGNITE_CACHE_QUERY_CONTINUOUS_CONTINUOUS_QUERY 24 #define _IGNITE_CACHE_QUERY_CONTINUOUS_CONTINUOUS_QUERY 26 #include <ignite/impl/cache/query/continuous/continuous_query_impl.h> 36 template<
typename K,
typename V>
37 class IGNITE_IMPORT_EXPORT Cache;
57 template<
typename K,
typename V>
60 friend class Cache<K, V>;
66 enum { DEFAULT_BUFFER_SIZE = 1 };
71 enum { DEFAULT_TIME_INTERVAL = 0 };
88 impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, false))
101 impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, loc))
116 impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, false, remoteFilter))
132 impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, loc, remoteFilter))
146 impl.Get()->SetLocal(val);
158 return impl.Get()->GetLocal();
173 impl.Get()->SetBufferSize(val);
188 return impl.Get()->GetBufferSize();
208 impl.Get()->SetTimeInterval(val);
228 return impl.Get()->GetTimeInterval();
240 impl.Get()->SetListener(lsnr);
250 return impl.Get()->GetListener();
260 return impl.Get()->GetListener();
265 common::concurrent::SharedPointer<impl::cache::query::continuous::ContinuousQueryImpl<K, V> > impl;
272 #endif //_IGNITE_CACHE_QUERY_CONTINUOUS_CONTINUOUS_QUERY ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, const Reference< F > &remoteFilter, bool loc)
Constructor.
Definition: continuous_query.h:130
~ContinuousQuery()
Destructor.
Definition: continuous_query.h:76
const event::CacheEntryEventListener< K, V > & GetListener() const
Get cache entry event listener.
Definition: continuous_query.h:248
Main entry point for all Data Grid APIs.
Definition: cache.h:68
Continuous query.
Definition: continuous_query.h:58
void SetBufferSize(int32_t val)
Set buffer size.
Definition: continuous_query.h:171
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, const Reference< F > &remoteFilter)
Constructor.
Definition: continuous_query.h:114
void SetLocal(bool val)
Set local flag.
Definition: continuous_query.h:144
event::CacheEntryEventListener< K, V > & GetListener()
Get cache entry event listener.
Definition: continuous_query.h:258
Declares ignite::cache::event::CacheEntryEventListener class.
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, bool loc)
Constructor.
Definition: continuous_query.h:100
int32_t GetBufferSize() const
Get buffer size.
Definition: continuous_query.h:186
bool GetLocal() const
Get local flag.
Definition: continuous_query.h:156
Reference class.
Definition: reference.h:35
Declares ignite::cache::event::CacheEntryEventFilter class.
void SetTimeInterval(int64_t val)
Set time interval.
Definition: continuous_query.h:206
Apache Ignite API.
Definition: cache.h:48
int64_t GetTimeInterval() const
Get time interval.
Definition: continuous_query.h:226
void SetListener(Reference< event::CacheEntryEventListener< K, V > > lsnr)
Set cache entry event listener.
Definition: continuous_query.h:238
Cache entry event listener.
Definition: cache_entry_event_listener.h:40
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr)
Constructor.
Definition: continuous_query.h:87