com.espertech.esper.filter

Class FilterServiceLockCoarse

java.lang.Object

com.espertech.esper.filter.FilterServiceBase

com.espertech.esper.filter.FilterServiceLockCoarse

All Implemented Interfaces:

FilterService, FilterServiceSPI

public final class FilterServiceLockCoarse
extends FilterServiceBase

Constructor Summary

Constructors

Constructor and Description
FilterServiceLockCoarse(boolean allowIsolation)

Method Summary

Modifier and Type	Method and Description
void	acquireWriteLock()
FilterServiceEntry	add(FilterValueSet filterValueSet, FilterHandle callback) Add a filter for events as defined by the filter specification, and register a callback to be invoked upon evaluation of an event that matches the filter spec.
void	apply(FilterSet filterSet) Apply a set of previously taken filters.
long	evaluate(EventBean theEvent, Collection<FilterHandle> matches) Finds matching filters to the event passed in and collects their associated callback method.
long	evaluate(EventBean theEvent, Collection<FilterHandle> matches, int statementId) Finds matching filters to the event passed in and collects their associated callback method, for a particular statement only
void	releaseWriteLock()
void	remove(FilterHandle callback, FilterServiceEntry filterServiceEntry) Remove a filter callback.
void	removeType(EventType type)
FilterSet	take(Set<Integer> statementId) Take a set of statements of out the active filters, returning a save-set of filters.

Methods inherited from class com.espertech.esper.filter.FilterServiceBase

addFilterServiceListener, addInternal, applyInternal, destroy, evaluateInternal, evaluateInternal, getCountTypes, getFilterCountApprox, getFiltersVersion, getNumEventsEvaluated, init, isSupportsTakeApply, removeFilterServiceListener, removeInternal, removeTypeInternal, resetStats, takeInternal

Methods inherited from class java.lang.Object

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

Constructor Detail

FilterServiceLockCoarse

public FilterServiceLockCoarse(boolean allowIsolation)

Method Detail

acquireWriteLock

public void acquireWriteLock()

releaseWriteLock

public void releaseWriteLock()

take

public FilterSet take(Set<Integer> statementId)

Description copied from interface: FilterServiceSPI

Take a set of statements of out the active filters, returning a save-set of filters.

Parameters:

statementId - statement ids to remove

Returns:

filters

apply

public void apply(FilterSet filterSet)

Description copied from interface: FilterServiceSPI

Apply a set of previously taken filters.

Parameters:

filterSet - to apply

evaluate

public long evaluate(EventBean theEvent,
                     Collection<FilterHandle> matches)

Description copied from interface: FilterService

Finds matching filters to the event passed in and collects their associated callback method.

Parameters:

theEvent - is the event to be matched against filters

matches - is a collection that is populated via add method with any handles for matching filters

Returns:

filter current version

evaluate

public long evaluate(EventBean theEvent,
                     Collection<FilterHandle> matches,
                     int statementId)

Description copied from interface: FilterService

Finds matching filters to the event passed in and collects their associated callback method, for a particular statement only

Parameters:

theEvent - is the event to be matched against filters

matches - is a collection that is populated via add method with any handles for matching filters

statementId - statement for which to return results for

Returns:

filter current version

add

public FilterServiceEntry add(FilterValueSet filterValueSet,
                              FilterHandle callback)

Description copied from interface: FilterService

Add a filter for events as defined by the filter specification, and register a callback to be invoked upon evaluation of an event that matches the filter spec.

Parameters:

filterValueSet - is a specification of filter parameters, contains event type information, event property values and operators

callback - is the callback to be invoked when the filter matches an event

Returns:

entry

remove

public void remove(FilterHandle callback,
                   FilterServiceEntry filterServiceEntry)

Description copied from interface: FilterService

Remove a filter callback.

Parameters:

callback - is the callback to be removed

filterServiceEntry - entry

removeType

public void removeType(EventType type)