|  |   Apache Ignite C++
    | 
 
 
 
Go to the documentation of this file.
   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> 
   37         template<
typename K, 
typename V>
 
   38         class IGNITE_IMPORT_EXPORT Cache;
 
   58                 template<
typename K, 
typename V>
 
   61                     friend class Cache<K, V>;
 
   67                     enum { DEFAULT_BUFFER_SIZE = 1 };
 
   72                     enum { DEFAULT_TIME_INTERVAL = 0 };
 
   89                         impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, false))
 
  102                         impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, loc))
 
  117                         impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, false, remoteFilter))
 
  133                         impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, loc, remoteFilter))
 
  147                             impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, false, remoteFilter))
 
  162                             impl(new impl::cache::query::continuous::ContinuousQueryImpl<K, V>(lsnr, loc, remoteFilter))
 
  176                         impl.Get()->SetLocal(val);
 
  188                         return impl.Get()->GetLocal();
 
  203                         impl.Get()->SetBufferSize(val);
 
  218                         return impl.Get()->GetBufferSize();
 
  238                         impl.Get()->SetTimeInterval(val);
 
  258                         return impl.Get()->GetTimeInterval();
 
  270                         impl.Get()->SetListener(lsnr);
 
  280                         return impl.Get()->GetListener();
 
  290                         return impl.Get()->GetListener();
 
  295                     common::concurrent::SharedPointer<impl::cache::query::continuous::ContinuousQueryImpl<K, V> > impl;
 
  302 #endif //_IGNITE_CACHE_QUERY_CONTINUOUS_CONTINUOUS_QUERY 
  
void SetBufferSize(int32_t val)
Set buffer size.
Definition: continuous_query.h:201
event::CacheEntryEventListener< K, V > & GetListener()
Get cache entry event listener.
Definition: continuous_query.h:288
~ContinuousQuery()
Destructor.
Definition: continuous_query.h:77
Apache Ignite API.
Definition: cache.h:48
const event::CacheEntryEventListener< K, V > & GetListener() const
Get cache entry event listener.
Definition: continuous_query.h:278
Main entry point for all Data Grid APIs.
Definition: cache.h:68
bool GetLocal() const
Get local flag.
Definition: continuous_query.h:186
Java cache entry event filter.
Definition: core/include/ignite/cache/event/java_cache_entry_event_filter.h:55
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, bool loc)
Constructor.
Definition: continuous_query.h:101
void SetLocal(bool val)
Set local flag.
Definition: continuous_query.h:174
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, const event::JavaCacheEntryEventFilter &remoteFilter, bool loc)
Constructor.
Definition: continuous_query.h:160
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr)
Constructor.
Definition: continuous_query.h:88
void SetListener(Reference< event::CacheEntryEventListener< K, V > > lsnr)
Set cache entry event listener.
Definition: continuous_query.h:268
Continuous query.
Definition: continuous_query.h:59
int64_t GetTimeInterval() const
Get time interval.
Definition: continuous_query.h:256
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, const Reference< F > &remoteFilter)
Constructor.
Definition: continuous_query.h:115
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, const event::JavaCacheEntryEventFilter &remoteFilter)
Constructor.
Definition: continuous_query.h:145
Reference class.
Definition: reference.h:35
void SetTimeInterval(int64_t val)
Set time interval.
Definition: continuous_query.h:236
Cache entry event listener.
Definition: core/include/ignite/cache/event/cache_entry_event_listener.h:40
ContinuousQuery(Reference< event::CacheEntryEventListener< K, V > > lsnr, const Reference< F > &remoteFilter, bool loc)
Constructor.
Definition: continuous_query.h:131
int32_t GetBufferSize() const
Get buffer size.
Definition: continuous_query.h:216