Package | Description |
---|---|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.spec.util |
Statement spec utilities
|
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
|
com.espertech.esper.view.stream |
View to event stream relationship service
|
Modifier and Type | Method and Description |
---|---|
FilterSpecCompiled |
ViewableActivatorFilterProxy.getFilterSpec() |
Modifier and Type | Method and Description |
---|---|
ViewableActivator |
ViewableActivatorFactoryDefault.createFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
Annotation[] annotations,
boolean subselect,
InstrumentationAgent instrumentationAgentSubquery,
boolean isCanIterate,
Integer streamNumFromClause) |
ViewableActivator |
ViewableActivatorFactory.createFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
Annotation[] annotations,
boolean subselect,
InstrumentationAgent instrumentationAgentSubquery,
boolean isCanIterate,
Integer streamNumFromClause) |
Constructor and Description |
---|
ViewableActivatorFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
Annotation[] annotations,
boolean subSelect,
InstrumentationAgent instrumentationAgent,
boolean isCanIterate) |
Modifier and Type | Method and Description |
---|---|
IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> |
ContextInternalFilterAddendum.getFilterAddendum() |
List<FilterSpecCompiled> |
ContextControllerStatementCtxCacheFilters.getFilterSpecs() |
Modifier and Type | Method and Description |
---|---|
static ContextDetailHashItem |
ContextControllerHashFactoryBase.findHashItemSpec(ContextDetailHash hashSpec,
FilterSpecCompiled filterSpec) |
FilterValueSetParam[][] |
AgentInstanceFilterProxyImpl.getAddendumFilters(FilterSpecCompiled filterSpec) |
FilterValueSetParam[][] |
AgentInstanceFilterProxy.getAddendumFilters(FilterSpecCompiled filterSpec) |
static FilterValueSetParam[][] |
ContextControllerHashFactoryBase.getAddendumFilters(FilterSpecCompiled filterSpecCompiled,
int hashCode,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc) |
static FilterValueSetParam[][] |
ContextControllerPartitionedUtil.getAddendumFilters(Object keyValue,
FilterSpecCompiled filtersSpec,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled) |
FilterValueSetParam[][] |
ContextInternalFilterAddendum.getFilterAddendum(FilterSpecCompiled filterSpecCompiled) |
Modifier and Type | Method and Description |
---|---|
static void |
StatementLifecycleSvcUtil.assignFilterSpecIds(FilterSpecCompiled filterSpec,
FilterSpecCompiled[] filterSpecsAll) |
static void |
StatementLifecycleSvcUtil.assignFilterSpecIds(FilterSpecCompiled filterSpec,
FilterSpecCompiled[] filterSpecsAll) |
Modifier and Type | Method and Description |
---|---|
FilterSpecCompiled |
FilterStreamSpecCompiled.getFilterSpec()
Returns filter specification for which events the stream will getSelectListEvents.
|
FilterSpecCompiled |
ContextDetailPartitionItem.getFilterSpecCompiled() |
FilterSpecCompiled |
ContextDetailHashItem.getFilterSpecCompiled() |
FilterSpecCompiled |
ContextDetailConditionFilter.getFilterSpecCompiled() |
FilterSpecCompiled |
ContextDetailCategory.getFilterSpecCompiled() |
FilterSpecCompiled[] |
StatementSpecCompiled.getFilterSpecsOverall() |
Modifier and Type | Method and Description |
---|---|
void |
ContextDetailCategoryItem.setCompiledFilter(FilterSpecCompiled filterSpec,
AgentInstanceContext agentInstanceContext) |
void |
FilterStreamSpecCompiled.setFilterSpec(FilterSpecCompiled filterSpec)
Sets a filter specification.
|
void |
ContextDetailPartitionItem.setFilterSpecCompiled(FilterSpecCompiled filterSpecCompiled) |
void |
ContextDetailHashItem.setFilterSpecCompiled(FilterSpecCompiled filterSpecCompiled) |
void |
ContextDetailConditionFilter.setFilterSpecCompiled(FilterSpecCompiled filterSpecCompiled) |
void |
ContextDetailCategory.setFilterSpecCompiled(FilterSpecCompiled filterSpec) |
void |
StatementSpecCompiled.setFilterSpecsOverall(FilterSpecCompiled[] filterSpecsOverall) |
Constructor and Description |
---|
FilterStreamSpecCompiled(FilterSpecCompiled filterSpec,
ViewSpec[] viewSpecs,
String optionalStreamName,
StreamSpecOptions streamSpecOptions)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
List<FilterSpecCompiled> |
StatementSpecCompiledAnalyzerResult.getFilters() |
Constructor and Description |
---|
StatementSpecCompiledAnalyzerResult(List<FilterSpecCompiled> filters,
List<NamedWindowConsumerStreamSpec> namedWindowConsumers) |
Modifier and Type | Method and Description |
---|---|
static FilterSpecCompiled |
FilterSpecCompiler.build(List<ExprNode> validatedNodes,
EventType eventType,
String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
StatementContext stmtContext,
Collection<Integer> assignedTypeNumberStack) |
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(List<ExprNode> validatedFilterNodes,
EventType eventType,
String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
Collection<Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ConfigurationInformation configurationInformation,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext) |
static FilterSpecCompiled |
FilterSpecCompiler.makeFilterSpec(EventType eventType,
String eventTypeName,
List<ExprNode> filterExpessions,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
StatementContext statementContext,
Collection<Integer> assignedTypeNumberStack)
Factory method for compiling filter expressions into a filter specification
for use with filter service.
|
Modifier and Type | Method and Description |
---|---|
boolean |
FilterSpecCompiled.equalsTypeAndFilter(FilterSpecCompiled other)
Compares only the type and filter portion and not the property evaluation portion.
|
int |
FilterSpecCompiled.getFilterSpecIndexAmongAll(FilterSpecCompiled[] filterSpecAll) |
Modifier and Type | Method and Description |
---|---|
FilterSpecCompiled |
EvalFilterFactoryNode.getFilterSpec()
Returns filter specification.
|
Modifier and Type | Method and Description |
---|---|
void |
EvalFilterFactoryNode.setFilterSpec(FilterSpecCompiled filterSpec)
Sets a validated and optimized filter specification
|
Modifier and Type | Method and Description |
---|---|
Pair<EventStream,StatementAgentInstanceLock> |
StreamFactorySvcImpl.createStream(int statementId,
FilterSpecCompiled filterSpec,
FilterService filterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
boolean isJoin,
AgentInstanceContext agentInstanceContext,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
Annotation[] annotations,
boolean stateless,
int streamNum,
boolean isCanIterateUnbound)
See the method of the same name in
StreamFactoryService . |
Pair<EventStream,StatementAgentInstanceLock> |
StreamFactoryService.createStream(int statementId,
FilterSpecCompiled filterSpec,
FilterService filterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
boolean isJoin,
AgentInstanceContext agentInstanceContext,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
Annotation[] annotations,
boolean stateless,
int streamNum,
boolean isCanIterateUnbound)
Create or reuse existing EventStream instance representing that event filter.
|
void |
StreamFactorySvcImpl.dropStream(FilterSpecCompiled filterSpec,
FilterService filterService,
boolean isJoin,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
boolean stateless)
See the method of the same name in
StreamFactoryService . |
void |
StreamFactoryService.dropStream(FilterSpecCompiled filterSpec,
FilterService filterService,
boolean isJoin,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
boolean stateless)
Drop the event stream associated with the filter passed in.
|
static EventStream |
EventStreamProxy.getAuditProxy(String engineURI,
String statementName,
Annotation[] annotations,
FilterSpecCompiled filterSpec,
EventStream designated) |