org.gridgain.grid.kernal.processors.cache.query.continuous

Class GridCacheContinuousQueryManager<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.query.continuous.GridCacheContinuousQueryManager<K,V>

All Implemented Interfaces:

GridCacheManager<K,V>

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

Continuous queries manager.

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

cctx, log

Constructor Summary

Constructors

Constructor and Description
GridCacheContinuousQueryManager()

Method Summary

Methods

Modifier and Type	Method and Description
GridCacheContinuousQuery<K,V>	createQuery(GridPredicate<GridCacheEntry<K,V>> prjPred)
void	onEntryUpdate(GridCacheEntryEx<K,V> e, K key, V val, GridCacheValueBytes valBytes, boolean unwind)

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheManagerAdapter

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

Methods inherited from class java.lang.Object

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

Constructor Detail

GridCacheContinuousQueryManager

public GridCacheContinuousQueryManager()

Method Detail

createQuery

public GridCacheContinuousQuery<K,V> createQuery(@Nullable
                                        GridPredicate<GridCacheEntry<K,V>> prjPred)

Parameters:

prjPred - Projection predicate.

Returns:

New continuous query.

onEntryUpdate

public void onEntryUpdate(GridCacheEntryEx<K,V> e,
                 K key,
                 @Nullable
                 V val,
                 @Nullable
                 GridCacheValueBytes valBytes,
                 boolean unwind)
                   throws GridException

Parameters:

e - Cache entry.

key - Key.

val - Value.

valBytes - Value bytes.

unwind - Whether to unwind after entry is added to buffer.

Throws:

GridException - In case of error.