Package | Description |
---|---|
com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
Modifier and Type | Class and Description |
---|---|
class |
FilterValueSetImpl
Container for filter values for use by the
FilterService to filter and distribute incoming events. |
Modifier and Type | Method and Description |
---|---|
FilterValueSet |
FilterSetEntry.getFilterValueSet()
Returns filters.
|
FilterValueSet |
EventTypeIndexBuilderValueIndexesPair.getFilterValueSet() |
FilterValueSet |
FilterSpecCompiled.getValueSet(MatchedEventMap matchedEvents,
AgentInstanceContext agentInstanceContext,
FilterValueSetParam[][] addendum)
Returns the values for the filter, using the supplied result events to ask filter parameters
for the value to filter for.
|
Modifier and Type | Method and Description |
---|---|
FilterServiceEntry |
FilterServiceLockFine.add(FilterValueSet filterValueSet,
FilterHandle callback) |
FilterServiceEntry |
FilterServiceLockCoarse.add(FilterValueSet filterValueSet,
FilterHandle callback) |
FilterServiceEntry |
FilterService.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.
|
static ArrayDeque<EventTypeIndexBuilderIndexLookupablePair>[] |
IndexTreeBuilder.add(FilterValueSet filterValueSet,
FilterHandle filterCallback,
FilterHandleSetNode topNode,
FilterServiceGranularLockFactory lockFactory)
Add a filter callback according to the filter specification to the top node returning
information to be used to remove the filter callback.
|
FilterServiceEntry |
EventTypeIndexBuilder.add(FilterValueSet filterValueSet,
FilterHandle filterCallback,
FilterServiceGranularLockFactory lockFactory)
Add a filter to the event type index structure, and to the filter subtree.
|
protected FilterServiceEntry |
FilterServiceBase.addInternal(FilterValueSet filterValueSet,
FilterHandle filterCallback) |
Constructor and Description |
---|
EventTypeIndexBuilderValueIndexesPair(FilterValueSet filterValueSet,
EventTypeIndexBuilderIndexLookupablePair[][] indexPairs) |
FilterSetEntry(FilterHandle handle,
FilterValueSet filterValueSet)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qFilterAdd(FilterValueSet filterValueSet,
FilterHandle filterCallback) |
void |
Instrumentation.qFilterAdd(FilterValueSet filterValueSet,
FilterHandle filterCallback) |