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.context.util |
Context partition utility or reference classes.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.service.speccompiled | |
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.util |
EPL utility classes.
|
com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
com.espertech.esper.filterspec | |
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,
java.lang.annotation.Annotation[] annotations,
boolean subselect,
InstrumentationAgent instrumentationAgentSubquery,
boolean isCanIterate,
java.lang.Integer streamNumFromClause) |
ViewableActivator |
ViewableActivatorFactory.createFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
java.lang.annotation.Annotation[] annotations,
boolean subselect,
InstrumentationAgent instrumentationAgentSubquery,
boolean isCanIterate,
java.lang.Integer streamNumFromClause) |
Constructor and Description |
---|
ViewableActivatorFilterProxy(EPServicesContext services,
FilterSpecCompiled filterSpec,
java.lang.annotation.Annotation[] annotations,
boolean subSelect,
InstrumentationAgent instrumentationAgent,
boolean isCanIterate) |
Modifier and Type | Method and Description |
---|---|
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> |
ContextInternalFilterAddendum.getFilterAddendum() |
java.util.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(java.lang.Object keyValue,
FilterSpecCompiled filtersSpec,
ContextDetailPartitioned segmentedSpec,
boolean includePartition,
StatementSpecCompiled optionalStatementSpecCompiled) |
FilterValueSetParam[][] |
ContextInternalFilterAddendum.getFilterAddendum(FilterSpecCompiled filterSpecCompiled) |
Modifier and Type | Method and Description |
---|---|
static void |
ContextControllerHashFactoryBase.getAddendumFilters(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums,
int hashCode,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc) |
static void |
ContextControllerHashFactoryBase.getAddendumFilters(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums,
int hashCode,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailHash hashSpec,
ContextControllerStatementDesc statementDesc) |
ContextControllerFactory |
ContextControllerFactoryFactorySvcImpl.make(ContextControllerFactoryContext factoryContext,
ContextDetail detail,
java.util.List<FilterSpecCompiled> optFiltersNested) |
ContextControllerFactory |
ContextControllerFactoryFactorySvc.make(ContextControllerFactoryContext factoryContext,
ContextDetail detail,
java.util.List<FilterSpecCompiled> optFiltersNested) |
static void |
ContextControllerPartitionedUtil.populateAddendumFilters(java.lang.Object keyValue,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums) |
static void |
ContextControllerPartitionedUtil.populateAddendumFilters(java.lang.Object keyValue,
java.util.List<FilterSpecCompiled> filtersSpecs,
ContextDetailPartitioned segmentedSpec,
StatementSpecCompiled optionalStatementSpecCompiled,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> addendums) |
void |
ContextControllerPartitionedFactoryBase.populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
ContextControllerStatementDesc statement,
java.lang.Object key,
int contextId) |
void |
ContextControllerInitTermFactoryBase.populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
ContextControllerStatementDesc statement,
java.lang.Object key,
int contextId) |
void |
ContextControllerHashFactoryBase.populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
ContextControllerStatementDesc statement,
java.lang.Object key,
int contextId) |
void |
ContextControllerFactory.populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
ContextControllerStatementDesc statement,
java.lang.Object key,
int contextId) |
void |
ContextControllerCategoryFactoryBase.populateFilterAddendums(java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum,
ContextControllerStatementDesc statement,
java.lang.Object categoryIndex,
int contextId) |
Constructor and Description |
---|
ContextControllerPartitionedFilterCallback(EPServicesContext servicesContext,
AgentInstanceContext agentInstanceContextCreateContext,
EventPropertyGetter[] getters,
FilterSpecCompiled filterSpec,
ContextControllerPartitionedInstanceManageCallback callback,
ContextInternalFilterAddendum filterAddendum,
java.lang.String optionInitConditionName) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<FilterSpecCompiled> |
ContextDetailUtil.getFilterSpecIfAny(ContextDetailCondition detail) |
static java.util.List<FilterSpecCompiled> |
ContextDetailUtil.getFilterSpecs(ContextDetail detail) |
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[] |
StatementSpecCompiled.getFilterSpecsOverall() |
Modifier and Type | Method and Description |
---|---|
void |
StatementSpecCompiled.setFilterSpecsOverall(FilterSpecCompiled[] filterSpecsOverall) |
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() |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
FilterStreamSpecCompiled(FilterSpecCompiled filterSpec,
ViewSpec[] viewSpecs,
java.lang.String optionalStreamName,
StreamSpecOptions streamSpecOptions)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<FilterSpecCompiled> |
StatementSpecCompiledAnalyzerResult.getFilters() |
Constructor and Description |
---|
StatementSpecCompiledAnalyzerResult(java.util.List<FilterSpecCompiled> filters,
java.util.List<NamedWindowConsumerStreamSpec> namedWindowConsumers) |
Modifier and Type | Method and Description |
---|---|
static FilterSpecCompiled |
FilterSpecCompiler.build(java.util.List<ExprNode> validatedNodes,
EventType eventType,
java.lang.String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
StatementContext stmtContext,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack) |
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(java.util.List<ExprNode> validatedFilterNodes,
EventType eventType,
java.lang.String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
int statementId,
java.lang.String statementName,
java.lang.annotation.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,
java.lang.String eventTypeName,
java.util.List<ExprNode> filterExpessions,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
StatementContext statementContext,
java.util.Collection<java.lang.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 |
---|---|
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> |
PatternAgentInstanceContext.getFilterAddendum() |
Modifier and Type | Method and Description |
---|---|
void |
EvalFilterFactoryNode.setFilterSpec(FilterSpecCompiled filterSpec)
Sets a validated and optimized filter specification
|
Modifier and Type | Method and Description |
---|---|
PatternAgentInstanceContext |
PatternContextFactoryDefault.createPatternAgentContext(PatternContext patternContext,
AgentInstanceContext agentInstanceContext,
boolean hasConsumingFilter,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum) |
PatternAgentInstanceContext |
PatternContextFactory.createPatternAgentContext(PatternContext patternContext,
AgentInstanceContext agentInstanceContext,
boolean hasConsumingFilter,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum) |
Constructor and Description |
---|
PatternAgentInstanceContext(PatternContext patternContext,
AgentInstanceContext agentInstanceContext,
boolean hasConsumingFilter,
java.util.IdentityHashMap<FilterSpecCompiled,FilterValueSetParam[][]> filterAddendum) |
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,
java.lang.annotation.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,
java.lang.annotation.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(java.lang.String engineURI,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
FilterSpecCompiled filterSpec,
EventStream designated) |