com.espertech.esper.filter
Class FilterParamIndexEqualsBase

java.lang.Object
  com.espertech.esper.filter.FilterParamIndexBase
      com.espertech.esper.filter.FilterParamIndexLookupableBase
          com.espertech.esper.filter.FilterParamIndexEqualsBase

All Implemented Interfaces:

EventEvaluator

Direct Known Subclasses:

FilterParamIndexEquals, FilterParamIndexEqualsIs

public abstract class FilterParamIndexEqualsBase
extends FilterParamIndexLookupableBase

Index for filter parameter constants to match using the equals (=) operator. The implementation is based on a regular HashMap.

Field Summary

protected java.util.Map<java.lang.Object,EventEvaluator>	constantsMap
protected java.util.concurrent.locks.ReadWriteLock	constantsMapRWLock

Fields inherited from class com.espertech.esper.filter.FilterParamIndexLookupableBase

lookupable

Constructor Summary

protected

FilterParamIndexEqualsBase(FilterSpecLookupable lookupable, java.util.concurrent.locks.ReadWriteLock readWriteLock, FilterOperator filterOperator)

Method Summary

EventEvaluator	get(java.lang.Object filterConstant) Get the event evaluation instance associated with the constant.
java.util.concurrent.locks.ReadWriteLock	getReadWriteLock() Supplies the lock for protected access.
void	put(java.lang.Object filterConstant, EventEvaluator evaluator) Store the event evaluation instance for the given constant.
boolean	remove(java.lang.Object filterConstant) Remove the event evaluation instance for the given constant.
int	size() Return the number of distinct filter parameter constants stored.

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

getLookupable, toString

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

getFilterOperator

Methods inherited from class java.lang.Object

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

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

matchEvent

Field Detail

constantsMap

protected final java.util.Map<java.lang.Object,EventEvaluator> constantsMap

constantsMapRWLock

protected final java.util.concurrent.locks.ReadWriteLock constantsMapRWLock

Constructor Detail

FilterParamIndexEqualsBase

protected FilterParamIndexEqualsBase(FilterSpecLookupable lookupable,
                                     java.util.concurrent.locks.ReadWriteLock readWriteLock,
                                     FilterOperator filterOperator)

Method Detail

get

public final EventEvaluator get(java.lang.Object filterConstant)

Description copied from class: FilterParamIndexLookupableBase

Get the event evaluation instance associated with the constant. Returns null if no entry found for the constant. The calling class must make sure that access to the underlying resource is protected for multi-threaded access, the getReadWriteLock() method must supply a lock for this purpose.

Specified by:

get in class FilterParamIndexLookupableBase

Parameters:

filterConstant - is the constant supplied in the event filter parameter

Returns:

event evaluator stored for the filter constant, or null if not found

put

public final void put(java.lang.Object filterConstant,
                      EventEvaluator evaluator)

Description copied from class: FilterParamIndexLookupableBase

Store the event evaluation instance for the given constant. Can override an existing value for the same constant. The calling class must make sure that access to the underlying resource is protected for multi-threaded access, the getReadWriteLock() method must supply a lock for this purpose.

Specified by:

put in class FilterParamIndexLookupableBase

Parameters:

filterConstant - is the constant supplied in the filter parameter

evaluator - to be stored for the constant

remove

public final boolean remove(java.lang.Object filterConstant)

Description copied from class: FilterParamIndexLookupableBase

Remove the event evaluation instance for the given constant. Returns true if the constant was found, or false if not. The calling class must make sure that access to the underlying resource is protected for multi-threaded writes, the getReadWriteLock() method must supply a lock for this purpose.

Specified by:

remove in class FilterParamIndexLookupableBase

Parameters:

filterConstant - is the value supplied in the filter paremeter

Returns:

true if found and removed, false if not found

size

public final int size()

Description copied from class: FilterParamIndexLookupableBase

Return the number of distinct filter parameter constants stored. The calling class must make sure that access to the underlying resource is protected for multi-threaded writes, the getReadWriteLock() method must supply a lock for this purpose.

Specified by:

size in class FilterParamIndexLookupableBase

Returns:

Number of entries in index

getReadWriteLock

public final java.util.concurrent.locks.ReadWriteLock getReadWriteLock()

Description copied from class: FilterParamIndexLookupableBase

Supplies the lock for protected access.

Specified by:

getReadWriteLock in class FilterParamIndexLookupableBase

Returns:

lock