Package | Description |
---|---|
com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
Modifier and Type | Method and Description |
---|---|
FilterSet |
FilterServiceSPI.take(Set<Integer> statementId)
Take a set of statements of out the active filters, returning a save-set of filters.
|
FilterSet |
FilterServiceLockFine.take(Set<Integer> statementId) |
FilterSet |
FilterServiceLockCoarse.take(Set<Integer> statementId) |
FilterSet |
EventTypeIndexBuilder.take(Set<Integer> statementIds)
Returns filters for the statement ids.
|
protected FilterSet |
FilterServiceBase.takeInternal(Set<Integer> statementIds) |
Modifier and Type | Method and Description |
---|---|
void |
FilterServiceSPI.apply(FilterSet filterSet)
Apply a set of previously taken filters.
|
void |
FilterServiceLockFine.apply(FilterSet filterSet) |
void |
FilterServiceLockCoarse.apply(FilterSet filterSet) |
void |
EventTypeIndexBuilder.apply(FilterSet filterSet,
FilterServiceGranularLockFactory lockFactory)
Add the filters, from previously-taken filters.
|
protected void |
FilterServiceBase.applyInternal(FilterSet filterSet) |