Package | Description |
---|---|
com.espertech.esper.adapter |
Adapter shared classes.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
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.metrics.instrumentation |
EPL instrumentation helpers.
|
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 | Class and Description |
---|---|
class |
ContextControllerHashedFilterCallback |
class |
ContextControllerPartitionedFilterCallback |
Modifier and Type | Method and Description |
---|---|
static boolean |
StatementAgentInstanceUtil.evaluateFilterForStatement(EPServicesContext servicesContext,
EventBean theEvent,
AgentInstanceContext agentInstanceContext,
FilterHandle filterHandle) |
Modifier and Type | Class and Description |
---|---|
class |
EPStatementHandleCallback
Statement resource handle and callback for use with
FilterService and
SchedulingService . |
Modifier and Type | Field and Description |
---|---|
protected ThreadLocal<ArrayBackedCollection<FilterHandle>> |
EPRuntimeIsolatedImpl.matchesArrayThreadLocal |
protected ThreadLocal<ArrayBackedCollection<FilterHandle>> |
EPRuntimeImpl.matchesArrayThreadLocal |
Modifier and Type | Class and Description |
---|---|
class |
EventBusSource |
Modifier and Type | Interface and Description |
---|---|
interface |
FilterHandleCallback
Interface for a callback method to be called when an event matches a filter specification.
|
Modifier and Type | Method and Description |
---|---|
FilterHandle |
FilterSetEntry.getHandle()
Returns the handle.
|
Modifier and Type | Method and Description |
---|---|
Set<FilterHandle> |
FilterHandleSetNode.getCallbackSet() |
Modifier and Type | Method and Description |
---|---|
void |
FilterHandleSetNode.add(FilterHandle filterCallback)
Add a filter callback.
|
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) |
boolean |
FilterHandleSetNode.contains(FilterHandle filterCallback)
Returns an indication whether the filter callback exists in this node.
|
static void |
IndexTreeBuilder.remove(EventType eventType,
FilterHandle filterCallback,
EventTypeIndexBuilderIndexLookupablePair[] treePathInfo,
FilterHandleSetNode topNode)
Remove an filterCallback from the given top node.
|
boolean |
FilterHandleSetNode.remove(FilterHandle filterCallback)
Remove a filter callback, returning true if it was found and removed or false if not in collection.
|
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 | Method and Description |
---|---|
long |
FilterServiceLockFine.evaluate(EventBean theEvent,
Collection<FilterHandle> matches) |
long |
FilterServiceLockCoarse.evaluate(EventBean theEvent,
Collection<FilterHandle> matches) |
long |
FilterService.evaluate(EventBean theEvent,
Collection<FilterHandle> matches)
Finds matching filters to the event passed in and collects their associated callback method.
|
long |
FilterServiceLockFine.evaluate(EventBean theEvent,
Collection<FilterHandle> matches,
int statementId) |
long |
FilterServiceLockCoarse.evaluate(EventBean theEvent,
Collection<FilterHandle> matches,
int statementId) |
long |
FilterService.evaluate(EventBean theEvent,
Collection<FilterHandle> matches,
int statementId)
Finds matching filters to the event passed in and collects their associated callback method, for a particular statement only
|
protected long |
FilterServiceBase.evaluateInternal(EventBean theEvent,
Collection<FilterHandle> matches) |
protected long |
FilterServiceBase.evaluateInternal(EventBean theEvent,
Collection<FilterHandle> matches,
int statementId) |
void |
FilterServiceListener.filtering(EventBean theEvent,
Collection<FilterHandle> matches,
Integer statementId)
Indicates an event being filtered.
|
void |
FilterParamIndexStringRangeInverted.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexStringRange.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexQuadTreePointRegion.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexQuadTreeMXCIF.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexNotIn.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexNotEqualsIs.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexNotEquals.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexIn.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexEqualsIs.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexEquals.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexDoubleRangeInverted.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexDoubleRange.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexCompareString.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexCompare.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterParamIndexBooleanExpr.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
FilterHandleSetNode.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches)
Evaluate an event by asking each index to match the event.
|
void |
EventTypeIndex.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches) |
void |
EventEvaluator.matchEvent(EventBean theEvent,
Collection<FilterHandle> matches)
Perform the matching of an event based on the event property values,
adding any callbacks for matches found to the matches list.
|
Constructor and Description |
---|
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) |
void |
InstrumentationDefault.qFilterRemove(FilterHandle filterCallback,
EventTypeIndexBuilderValueIndexesPair pair) |
void |
Instrumentation.qFilterRemove(FilterHandle filterCallback,
EventTypeIndexBuilderValueIndexesPair pair) |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.aFilter(Collection<FilterHandle> matches) |
void |
Instrumentation.aFilter(Collection<FilterHandle> matches) |
void |
InstrumentationDefault.qaFilterHandleSetCallbacks(Set<FilterHandle> callbackSet) |
void |
Instrumentation.qaFilterHandleSetCallbacks(Set<FilterHandle> callbackSet) |
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.
|