com.hazelcast.map.impl.event

Class AbstractFilteringStrategy

java.lang.Object

com.hazelcast.map.impl.event.AbstractFilteringStrategy

All Implemented Interfaces:

FilteringStrategy

Direct Known Subclasses:

DefaultEntryEventFilteringStrategy, QueryCacheNaturalFilteringStrategy

public abstract class AbstractFilteringStrategy
extends Object
implements FilteringStrategy

A common abstract class to support implementations of filtering strategies.

See Also:

DefaultEntryEventFilteringStrategy, QueryCacheNaturalFilteringStrategy

Field Summary

Fields

Modifier and Type	Field and Description
protected MapServiceContext	mapServiceContext
protected InternalSerializationService	serializationService

Fields inherited from interface com.hazelcast.map.impl.event.FilteringStrategy

FILTER_DOES_NOT_MATCH

Constructor Summary

Constructors

Constructor and Description
AbstractFilteringStrategy(InternalSerializationService serializationService, MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
protected boolean	evaluateQueryEventFilter(EventFilter filter, Data dataKey, Object testValue, String mapNameOrNull) Evalues the filter using a CachedQueryEntry together with the value Extractors configured for this map.
protected String	getThisNodesAddress()
protected boolean	processEntryEventFilter(EventFilter filter, Data dataKey) Evaluates filters of EntryEventFilter type.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.map.impl.event.FilteringStrategy

doFilter, getEntryEventDataCache

Field Detail

serializationService

protected final InternalSerializationService serializationService

mapServiceContext

protected final MapServiceContext mapServiceContext

Constructor Detail

AbstractFilteringStrategy

public AbstractFilteringStrategy(InternalSerializationService serializationService,
                                 MapServiceContext mapServiceContext)

Method Detail

getThisNodesAddress

protected String getThisNodesAddress()

processEntryEventFilter

protected boolean processEntryEventFilter(EventFilter filter,
                                          Data dataKey)

Evaluates filters of EntryEventFilter type.

Parameters:

filter - the filter which must be a EntryEventFilter

dataKey - the event entry key

Returns:

true if the filter matches

evaluateQueryEventFilter

protected boolean evaluateQueryEventFilter(EventFilter filter,
                                           Data dataKey,
                                           Object testValue,
                                           String mapNameOrNull)

Evalues the filter using a CachedQueryEntry together with the value Extractors configured for this map. The filter must be of QueryEventFilter type.

Parameters:

filter - a QueryEventFilter filter

dataKey - the entry key

testValue - the value used to evaluate the filter

mapNameOrNull - the map name. May be null if this is not a map event (e.g. cache event)

Returns:

true if the entry matches the query event filter