Package | Description |
---|---|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.dataflow.ops |
Data flow built-in operators.
|
com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
com.espertech.esper.pattern |
Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active
pattern instance
|
Constructor and Description |
---|
ViewableActivatorFilterProxyStopCallback(ViewableActivatorFilterProxy parent,
EPStatementHandleCallback filterHandle,
FilterServiceEntry filterServiceEntry) |
Modifier and Type | Field and Description |
---|---|
protected FilterServiceEntry |
EventBusSource.filterServiceEntry |
Modifier and Type | Class and Description |
---|---|
class |
EventTypeIndexBuilderValueIndexesPair |
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.
|
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) |
Modifier and Type | Method and Description |
---|---|
void |
FilterServiceLockFine.remove(FilterHandle callback,
FilterServiceEntry filterServiceEntry) |
void |
FilterServiceLockCoarse.remove(FilterHandle callback,
FilterServiceEntry filterServiceEntry) |
void |
FilterService.remove(FilterHandle callback,
FilterServiceEntry filterServiceEntry)
Remove a filter callback.
|
void |
EventTypeIndexBuilder.remove(FilterHandle filterCallback,
FilterServiceEntry filterServiceEntry)
Remove a filter callback from the given index node.
|
protected void |
FilterServiceBase.removeInternal(FilterHandle filterCallback,
FilterServiceEntry filterServiceEntry) |
Modifier and Type | Field and Description |
---|---|
protected FilterServiceEntry |
EvalFilterStateNode.filterServiceEntry |