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

Class CacheContinuousQueryManager

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheManagerAdapter

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

All Implemented Interfaces:

GridCacheManager

public class CacheContinuousQueryManager
extends GridCacheManagerAdapter

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	beforeExchange(AffinityTopologyVersion topVer)
void	cancelInternalQuery(UUID routineId)
void	cancelJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg)
UUID	executeInternalQuery(javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr, CacheEntryEventSerializableFilter rmtFilter, boolean loc, boolean notifyExisting)
void	executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg, boolean onStart, boolean keepBinary)
UUID	executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr, CacheEntryEventSerializableFilter rmtFilter, int bufSize, long timeInterval, boolean autoUnsubscribe, boolean loc, boolean keepBinary)
void	onEntryExpired(GridCacheEntryEx e, KeyCacheObject key, CacheObject oldVal)
void	onEntryUpdated(KeyCacheObject key, CacheObject newVal, CacheObject oldVal, boolean internal, int partId, boolean primary, boolean preload, long updateCntr, AffinityTopologyVersion topVer)
protected void	onKernalStart0()
protected void	onKernalStop0(boolean cancel)
void	onPartitionEvicted(int part) Partition evicted callback.
void	skipUpdateEvent(KeyCacheObject key, int partId, long updCntr, AffinityTopologyVersion topVer)
protected void	start0()

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

context, kernalStartInfo, kernalStopInfo, log, onDisconnected, 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

Throws:

IgniteCheckedException - If failed.

onKernalStart0

protected void onKernalStart0()
                       throws IgniteCheckedException

Overrides:

onKernalStart0 in class GridCacheManagerAdapter

Throws:

IgniteCheckedException - If failed.

onKernalStop0

protected void onKernalStop0(boolean cancel)

Overrides:

onKernalStop0 in class GridCacheManagerAdapter

Parameters:

cancel - Cancel flag.

skipUpdateEvent

public void skipUpdateEvent(KeyCacheObject key,
                   int partId,
                   long updCntr,
                   AffinityTopologyVersion topVer)

Parameters:

partId - Partition id.

updCntr - Updated counter.

topVer - Topology version.

onEntryUpdated

public void onEntryUpdated(KeyCacheObject key,
                  CacheObject newVal,
                  CacheObject oldVal,
                  boolean internal,
                  int partId,
                  boolean primary,
                  boolean preload,
                  long updateCntr,
                  AffinityTopologyVersion topVer)
                    throws IgniteCheckedException

Parameters:

key - Key.

newVal - New value.

oldVal - Old value.

internal - Internal entry (internal key or not user cache),

primary - True if called on primary node.

preload - Whether update happened during preloading.

updateCntr - Update counter.

topVer - Topology version.

Throws:

IgniteCheckedException - In case of error.

onEntryExpired

public void onEntryExpired(GridCacheEntryEx e,
                  KeyCacheObject key,
                  CacheObject oldVal)
                    throws IgniteCheckedException

Parameters:

e - Entry.

key - Key.

oldVal - Old value.

Throws:

IgniteCheckedException - In case of error.

executeQuery

public UUID executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr,
                CacheEntryEventSerializableFilter rmtFilter,
                int bufSize,
                long timeInterval,
                boolean autoUnsubscribe,
                boolean loc,
                boolean keepBinary)
                  throws IgniteCheckedException

Parameters:

locLsnr - Local listener.

rmtFilter - Remote filter.

bufSize - Buffer size.

timeInterval - Time interval.

autoUnsubscribe - Auto unsubscribe flag.

loc - Local flag.

Returns:

Continuous routine ID.

Throws:

IgniteCheckedException - In case of error.

executeInternalQuery

public UUID executeInternalQuery(javax.cache.event.CacheEntryUpdatedListener<?,?> locLsnr,
                        CacheEntryEventSerializableFilter 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)

Parameters:

routineId - Consume ID.

executeJCacheQuery

public void executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg,
                      boolean onStart,
                      boolean keepBinary)
                        throws IgniteCheckedException

Parameters:

cfg - Listener configuration.

onStart - Whether listener is created on node start.

Throws:

IgniteCheckedException - If failed.

cancelJCacheQuery

public void cancelJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration cfg)
                       throws IgniteCheckedException

Parameters:

cfg - Listener configuration.

Throws:

IgniteCheckedException - In case of error.

beforeExchange

public void beforeExchange(AffinityTopologyVersion topVer)

Parameters:

topVer - Topology version.

onPartitionEvicted

public void onPartitionEvicted(int part)

Partition evicted callback.

Parameters:

part - Partition number.