org.apache.ignite.internal.processors.cache.query.continuous

Class CacheContinuousQueryManager<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter<K,V>

org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

public class CacheContinuousQueryManager<K,V>
extends GridCacheManagerAdapter<K,V>

Continuous queries manager.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
CacheContinuousQueryManager()

Method Summary

Methods

Modifier and Type	Method and Description
void	cancelInternalQuery(UUID routineId)
void	cancelJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg)
UUID	executeInternalQuery(javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr, javax.cache.event.CacheEntryEventFilter<K,V> rmtFilter, boolean loc, boolean notifyExisting)
void	executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg, boolean onStart)
UUID	executeQuery(javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr, javax.cache.event.CacheEntryEventFilter<K,V> rmtFilter, int bufSize, long timeInterval, boolean autoUnsubscribe, ClusterGroup grp)
void	onEntryExpired(GridCacheEntryEx<K,V> e, K key, V oldVal, GridCacheValueBytes oldBytes)
void	onEntryUpdated(GridCacheEntryEx<K,V> e, K key, V newVal, GridCacheValueBytes newBytes, V oldVal, GridCacheValueBytes oldBytes, boolean preload)
protected void	onKernalStart0()
protected void	onKernalStop0(boolean cancel)
protected void	start0()

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

context, kernalStartInfo, kernalStopInfo, log, onKernalStart, onKernalStop, printMemoryStats, start, startInfo, stop, stop0, stopInfo, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CacheContinuousQueryManager

public CacheContinuousQueryManager()

Method Detail

start0

protected void start0()
               throws IgniteCheckedException

Overrides:

start0 in class GridCacheManagerAdapter<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStart0

protected void onKernalStart0()
                       throws IgniteCheckedException

Overrides:

onKernalStart0 in class GridCacheManagerAdapter<K,V>

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter<K,V>

Parameters:

cancel - Cancel flag.

onEntryUpdated

public void onEntryUpdated(GridCacheEntryEx<K,V> e,
                  K key,
                  V newVal,
                  GridCacheValueBytes newBytes,
                  V oldVal,
                  GridCacheValueBytes oldBytes,
                  boolean preload)
                    throws IgniteCheckedException

Parameters:

e - Cache entry.

key - Key.

newVal - New value.

newBytes - New value bytes.

oldVal - Old value.

oldBytes - Old value bytes.

preload - Whether update happened during preloading.

Throws:

IgniteCheckedException - In case of error.

onEntryExpired

public void onEntryExpired(GridCacheEntryEx<K,V> e,
                  K key,
                  V oldVal,
                  GridCacheValueBytes oldBytes)
                    throws IgniteCheckedException

Parameters:

e - Entry.

key - Key.

oldVal - Old value.

oldBytes - Old value bytes.

Throws:

IgniteCheckedException - In case of error.

executeQuery

public UUID executeQuery(javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr,
                javax.cache.event.CacheEntryEventFilter<K,V> rmtFilter,
                int bufSize,
                long timeInterval,
                boolean autoUnsubscribe,
                ClusterGroup grp)
                  throws IgniteCheckedException

Parameters:

locLsnr - Local listener.

rmtFilter - Remote filter.

bufSize - Buffer size.

timeInterval - Time interval.

autoUnsubscribe - Auto unsubscribe flag.

grp - Cluster group.

Returns:

Continuous routine ID.

Throws:

IgniteCheckedException - In case of error.

executeInternalQuery

public UUID executeInternalQuery(javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr,
                        javax.cache.event.CacheEntryEventFilter<K,V> rmtFilter,
                        boolean loc,
                        boolean notifyExisting)
                          throws IgniteCheckedException

Parameters:

locLsnr - Local listener.

rmtFilter - Remote filter.

loc - Local flag.

notifyExisting - Notify existing flag.

Returns:

Continuous routine ID.

Throws:

IgniteCheckedException - In case of error.

cancelInternalQuery

public void cancelInternalQuery(UUID routineId)

executeJCacheQuery

public void executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg,
                      boolean onStart)
                        throws IgniteCheckedException

Parameters:

cfg - Listener configuration.

onStart - Whether listener is created on node start.

Throws:

IgniteCheckedException

cancelJCacheQuery

public void cancelJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg)
                       throws IgniteCheckedException

Parameters:

cfg - Listener configuration.

Throws:

IgniteCheckedException - In case of error.