com.hazelcast.map.impl.event

Class QueryCacheNaturalFilteringStrategy

java.lang.Object

com.hazelcast.map.impl.event.AbstractFilteringStrategy

com.hazelcast.map.impl.event.QueryCacheNaturalFilteringStrategy

All Implemented Interfaces:

FilteringStrategy

public class QueryCacheNaturalFilteringStrategy
extends AbstractFilteringStrategy

A filtering strategy that preserves the default behavior in most cases, but processes entry events for listeners with predicates to fit with "query cache" concept. For example when the original event indicates an update from an old value that does not match the predicate to a new value that does match, then the entry listener will be notified with an ADDED event. This affects only map listeners with predicates and the way entry updates are handled. Put/remove operations are not affected, neither are listeners without predicates. This filtering strategy is used when Hazelcast property hazelcast.map.entry.filtering.natural.event.types is set to true. The complete decision matrix for event types published with this filtering strategy.

Old value	New value	Published event type
Match	Mismatch	REMOVED
Match	Match	UPDATED
Mismatch	Mismatch	NO MATCH (no event is triggered)
Mismatch	Match	ADDED

Field Summary

Fields inherited from class com.hazelcast.map.impl.event.AbstractFilteringStrategy

mapServiceContext, serializationService

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

FILTER_DOES_NOT_MATCH

Constructor Summary

Constructors

Constructor and Description
QueryCacheNaturalFilteringStrategy(InternalSerializationService serializationService, MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
int	doFilter(EventFilter filter, Data dataKey, Object oldValue, Object dataValue, EntryEventType eventType, String mapNameOrNull) Main entry point for filtering events according to given filter.
EntryEventDataCache	getEntryEventDataCache()
String	toString()

Methods inherited from class com.hazelcast.map.impl.event.AbstractFilteringStrategy

evaluateQueryEventFilter, getThisNodesAddress, processEntryEventFilter

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryCacheNaturalFilteringStrategy

public QueryCacheNaturalFilteringStrategy(InternalSerializationService serializationService,
                                          MapServiceContext mapServiceContext)

Method Detail

doFilter

public int doFilter(EventFilter filter,
                    Data dataKey,
                    Object oldValue,
                    Object dataValue,
                    EntryEventType eventType,
                    String mapNameOrNull)

Description copied from interface: FilteringStrategy

Main entry point for filtering events according to given filter.

Parameters:

filter - the event filter

dataKey - the event entry key

oldValue - the old value of the event entry

dataValue - the new value of the event entry

eventType - the event type

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

Returns:

FilteringStrategy.FILTER_DOES_NOT_MATCH if the event does not match the filter, otherwise the integer event type of the event to be published. This allows a filtering strategy to alter the type of event that is actually published, depending on the attributes of the individual event registration.

getEntryEventDataCache

public EntryEventDataCache getEntryEventDataCache()

Returns:

a new instance of EntryEventDataCache implementation to be used with this filtering strategy

toString

public String toString()

Overrides:

toString in class Object