Package | Description |
---|---|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.deploy |
Module and deployment utility and parser.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
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 |
---|---|
void |
ContextControllerPartitionedFilterCallback.destroy(FilterService filterService) |
void |
ContextControllerHashedFilterCallback.destroy(FilterService filterService) |
Modifier and Type | Method and Description |
---|---|
static List<EventType> |
EPLModuleUtil.undeployTypes(Set<String> referencedTypes,
StatementEventTypeRef statementEventTypeRef,
EventAdapterService eventAdapterService,
FilterService filterService) |
Constructor and Description |
---|
EPDeploymentAdminImpl(EPAdministratorSPI epService,
ManagedReadWriteLock eventProcessingRWLock,
DeploymentStateService deploymentStateService,
StatementEventTypeRef statementEventTypeRef,
EventAdapterService eventAdapterService,
StatementIsolationService statementIsolationService,
FilterService filterService,
TimeZone timeZone,
ConfigurationEngineDefaults.ExceptionHandling.UndeployRethrowPolicy undeployRethrowPolicy) |
Modifier and Type | Method and Description |
---|---|
FilterService |
StatementContext.getFilterService()
Returns the filter service.
|
FilterService |
EPServiceProviderSPI.getFilterService()
Returns the filter service.
|
FilterService |
EPServiceProviderImpl.getFilterService() |
Modifier and Type | Method and Description |
---|---|
void |
StatementContext.setFilterService(FilterService filterService)
Sets the filter service
|
Constructor and Description |
---|
ConfigurationOperationsImpl(EventAdapterService eventAdapterService,
EventTypeIdGenerator eventTypeIdGenerator,
EngineImportService engineImportService,
VariableService variableService,
EngineSettingsService engineSettingsService,
ValueAddEventService valueAddEventService,
MetricReportingService metricReportingService,
StatementEventTypeRef statementEventTypeRef,
StatementVariableRef statementVariableRef,
PluggableObjectCollection plugInViews,
FilterService filterService,
PatternSubexpressionPoolEngineSvc patternSubexpressionPoolSvc,
MatchRecognizeStatePoolEngineSvc matchRecognizeStatePoolEngineSvc,
TableService tableService,
Map<String,Object> transientConfiguration) |
StatementContext(StatementContextEngineServices stmtEngineServices,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
EPStatementHandle epStatementHandle,
ViewResolutionService viewResultionService,
PatternObjectResolutionService patternResolutionService,
StatementExtensionSvcContext statementExtensionSvcContext,
StatementStopService statementStopService,
PatternContextFactory patternContextFactory,
FilterService filterService,
StatementResultService statementResultService,
InternalEventRouteDest internalEventEngineRouteDest,
Annotation[] annotations,
StatementAIResourceRegistry statementAgentInstanceRegistry,
StatementAgentInstanceLock defaultAgentInstanceLock,
ContextDescriptor contextDescriptor,
PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc,
boolean statelessSelect,
ContextControllerFactoryService contextControllerFactoryService,
AgentInstanceScriptContext defaultAgentInstanceScriptContext,
AggregationServiceFactoryService aggregationServiceFactoryService,
boolean writesToTables,
Object statementUserObject,
StatementSemiAnonymousTypeRegistry statementSemiAnonymousTypeRegistry,
int priority) |
Modifier and Type | Interface and Description |
---|---|
interface |
FilterServiceSPI
Service provider interface for filter service.
|
Modifier and Type | Class and Description |
---|---|
class |
FilterServiceBase
Implementation of the filter service interface.
|
class |
FilterServiceLockCoarse |
class |
FilterServiceLockFine |
Modifier and Type | Method and Description |
---|---|
FilterService |
PatternContext.getFilterService()
Returns service to use for filter evaluation.
|
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.
|