Package | Description |
---|---|
com.espertech.esper.adapter |
Adapter shared classes.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.service.multimatch |
Core service multi-match handlers.
|
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
|
Modifier and Type | Class and Description |
---|---|
class |
BaseSubscription
Subscription is a concept for selecting events for processing out of all events available from an engine instance.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
BaseSubscription.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |
Modifier and Type | Class and Description |
---|---|
class |
ContextControllerHashedFilterCallback |
class |
ContextControllerPartitionedFilterCallback |
Modifier and Type | Method and Description |
---|---|
void |
ContextControllerPartitionedFilterCallback.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |
void |
ContextControllerHashedFilterCallback.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |
Modifier and Type | Field and Description |
---|---|
protected ThreadLocal<Map<EPStatementAgentInstanceHandle,ArrayDeque<FilterHandleCallback>>> |
EPRuntimeIsolatedImpl.matchesPerStmtThreadLocal |
Modifier and Type | Method and Description |
---|---|
FilterHandleCallback |
EPStatementHandleCallback.getFilterCallback()
Returns the statement filter callback, or null if this is a schedule callback handle.
|
Modifier and Type | Method and Description |
---|---|
void |
EPStatementHandleCallback.setFilterCallback(FilterHandleCallback filterCallback) |
Modifier and Type | Method and Description |
---|---|
void |
EPRuntimeIsolatedImpl.processStatementFilterMultiple(EPStatementAgentInstanceHandle handle,
ArrayDeque<FilterHandleCallback> callbackList,
EventBean theEvent)
Processing multiple filter matches for a statement.
|
Constructor and Description |
---|
EPStatementHandleCallback(EPStatementAgentInstanceHandle agentInstanceHandle,
FilterHandleCallback callback)
Ctor.
|
Modifier and Type | Field and Description |
---|---|
protected static ThreadLocal<LinkedHashSet<FilterHandleCallback>> |
MultiMatchHandlerNoSubqueryWDedup.DEDUPS |
Modifier and Type | Method and Description |
---|---|
void |
MultiMatchHandlerSubqueryWDedup.handle(Collection<FilterHandleCallback> callbacks,
EventBean theEvent) |
void |
MultiMatchHandlerSubqueryPreevalNoDedup.handle(Collection<FilterHandleCallback> callbacks,
EventBean theEvent) |
void |
MultiMatchHandlerSubqueryPostevalNoDedup.handle(Collection<FilterHandleCallback> callbacks,
EventBean theEvent) |
void |
MultiMatchHandlerNoSubqueryWDedup.handle(Collection<FilterHandleCallback> callbacks,
EventBean theEvent) |
void |
MultiMatchHandlerNoSubqueryNoDedup.handle(Collection<FilterHandleCallback> callbacks,
EventBean theEvent) |
void |
MultiMatchHandler.handle(Collection<FilterHandleCallback> callbacks,
EventBean theEvent) |
Modifier and Type | Class and Description |
---|---|
class |
EventBusSource |
Modifier and Type | Method and Description |
---|---|
void |
EventBusSource.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |
Modifier and Type | Method and Description |
---|---|
void |
FilterHandleCallback.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches)
Indicate that an event was evaluated by the
FilterService
which matches the filter specification FilterSpecCompiled associated with this callback. |
Modifier and Type | Class and Description |
---|---|
class |
EvalFilterStateNode
This class contains the state of a single filter expression in the evaluation state tree.
|
class |
EvalFilterStateNodeConsumeImpl
This class contains the state of a single filter expression in the evaluation state tree.
|
Modifier and Type | Method and Description |
---|---|
void |
EvalFilterStateNodeConsumeImpl.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |
void |
EvalFilterStateNode.matchFound(EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |
static void |
EvalFilterStateNodeConsumeImpl.processMatches(EvalFilterConsumptionHandler handler,
EventBean theEvent,
Collection<FilterHandleCallback> allStmtMatches) |