com.espertech.esper.filter

Interface FilterServiceSPI

All Superinterfaces:

FilterService

All Known Implementing Classes:

FilterServiceBase, FilterServiceLockCoarse, FilterServiceLockFine

public interface FilterServiceSPI
extends FilterService

Service provider interface for filter service.

Method Summary

Modifier and Type	Method and Description
void	acquireWriteLock()
void	addFilterServiceListener(FilterServiceListener filterServiceListener) Add activity listener.void acquireWriteLock();
void	apply(FilterSet filterSet) Apply a set of previously taken filters.
int	getCountTypes()
int	getFilterCountApprox()
void	init() Initialization is optional and provides a chance to preload things after statements are available.
boolean	isSupportsTakeApply()
void	releaseWriteLock()
void	removeFilterServiceListener(FilterServiceListener filterServiceListener) Remove activity listener.
FilterSet	take(Set<Integer> statementId) Take a set of statements of out the active filters, returning a save-set of filters.

Methods inherited from interface com.espertech.esper.filter.FilterService

add, destroy, evaluate, evaluate, getFiltersVersion, getNumEventsEvaluated, remove, removeType, resetStats

Method Detail

isSupportsTakeApply

boolean isSupportsTakeApply()

take

FilterSet take(Set<Integer> statementId)

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

void apply(FilterSet filterSet)

Apply a set of previously taken filters.

Parameters:

filterSet - to apply

addFilterServiceListener

void addFilterServiceListener(FilterServiceListener filterServiceListener)

Add activity listener.void acquireWriteLock();

Parameters:

filterServiceListener - to add

removeFilterServiceListener

void removeFilterServiceListener(FilterServiceListener filterServiceListener)

Remove activity listener.

Parameters:

filterServiceListener - to remove

getFilterCountApprox

int getFilterCountApprox()

getCountTypes

int getCountTypes()

acquireWriteLock

void acquireWriteLock()

releaseWriteLock

void releaseWriteLock()

init

void init()

Initialization is optional and provides a chance to preload things after statements are available.