Uses of Interface
org.apache.ignite.cache.query.ContinuousQueryWithTransformer.EventListener

Packages that use ContinuousQueryWithTransformer.EventListener

Package	Description
org.apache.ignite.cache.query	Contains APIs for creating and executing cache queries.
org.apache.ignite.internal.processors.cache.query.continuous

Uses of ContinuousQueryWithTransformer.EventListener in org.apache.ignite.cache.query

Methods in org.apache.ignite.cache.query that return ContinuousQueryWithTransformer.EventListener

Modifier and Type	Method and Description
ContinuousQueryWithTransformer.EventListener<T>	ContinuousQueryWithTransformer.getLocalListener() Gets local transformed event listener

Methods in org.apache.ignite.cache.query with parameters of type ContinuousQueryWithTransformer.EventListener

Modifier and Type	Method and Description
ContinuousQueryWithTransformer<K,V,T>	ContinuousQueryWithTransformer.setLocalListener(ContinuousQueryWithTransformer.EventListener<T> locLsnr) Sets local callback.

Uses of ContinuousQueryWithTransformer.EventListener in org.apache.ignite.internal.processors.cache.query.continuous

Methods in org.apache.ignite.internal.processors.cache.query.continuous that return ContinuousQueryWithTransformer.EventListener

Modifier and Type	Method and Description
protected ContinuousQueryWithTransformer.EventListener<?>	CacheContinuousQueryHandlerV3.localTransformedEventListener()
protected ContinuousQueryWithTransformer.EventListener<?>	CacheContinuousQueryHandler.localTransformedEventListener()

Methods in org.apache.ignite.internal.processors.cache.query.continuous with parameters of type ContinuousQueryWithTransformer.EventListener

Modifier and Type

Method and Description

UUID

CacheContinuousQueryManager.executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr, ContinuousQueryWithTransformer.EventListener locTransLsnr, CacheEntryEventSerializableFilter rmtFilter, javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter> rmtFilterFactory, javax.cache.configuration.Factory<? extends IgniteClosure> rmtTransFactory, int bufSize, long timeInterval, boolean autoUnsubscribe, boolean loc, boolean keepBinary, boolean includeExpired)

Constructors in org.apache.ignite.internal.processors.cache.query.continuous with parameters of type ContinuousQueryWithTransformer.EventListener

Constructor and Description

CacheContinuousQueryHandlerV3(String cacheName, Object topic, ContinuousQueryWithTransformer.EventListener<?> locTransLsnr, javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory, javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>> rmtTransFactory, boolean oldValRequired, boolean sync, boolean ignoreExpired, boolean ignoreClsNotFound)