| Package | Description |
|---|---|
| com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
| com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
| com.espertech.esper.core.context.subselect |
Subselect implementation.
|
| com.espertech.esper.core.start |
Classes related to start and stop of statements
|
| com.espertech.esper.epl.named |
Named window classes are in this package
|
| Modifier and Type | Method and Description |
|---|---|
ViewableActivator |
ViewableActivatorFactoryDefault.createNamedWindow(NamedWindowProcessor processor,
NamedWindowConsumerStreamSpec streamSpec,
StatementContext statementContext) |
ViewableActivator |
ViewableActivatorFactory.createNamedWindow(NamedWindowProcessor processor,
NamedWindowConsumerStreamSpec streamSpec,
StatementContext statementContext) |
| Constructor and Description |
|---|
ViewableActivatorNamedWindow(NamedWindowProcessor processor,
List<ExprNode> filterExpressions,
PropertyEvaluator optPropertyEvaluator,
EngineImportService engineImportService,
String statementName) |
| Constructor and Description |
|---|
StatementAgentInstanceFactoryCreateIndex(EPServicesContext services,
CreateIndexDesc spec,
Viewable finalView,
NamedWindowProcessor namedWindowProcessor,
String tableName,
String contextName,
QueryPlanIndexItem explicitIndexDesc) |
StatementAgentInstanceFactoryOnTriggerNamedWindow(StatementContext statementContext,
StatementSpecCompiled statementSpec,
EPServicesContext services,
ViewableActivator activator,
SubSelectStrategyCollection subSelectStrategyCollection,
ResultSetProcessorFactoryDesc resultSetProcessorPrototype,
ExprNode validatedJoin,
ResultSetProcessorFactoryDesc outputResultSetProcessorPrototype,
NamedWindowOnExprFactory onExprFactory,
OutputProcessViewFactory outputProcessViewFactory,
EventType activatorResultEventType,
NamedWindowProcessor processor,
List<StopCallback> stopCallbacks) |
| Constructor and Description |
|---|
SubSelectStrategyFactoryIndexShare(String statementName,
int statementId,
int subqueryNum,
EventType[] outerEventTypesSelect,
NamedWindowProcessor optionalNamedWindowProcessor,
TableMetadata optionalTableMetadata,
boolean fullTableScan,
IndexHint optionalIndexHint,
SubordPropPlan joinedPropPlan,
ExprEvaluator filterExprEval,
AggregationServiceFactoryDesc aggregationServiceFactory,
ExprEvaluator[] groupByKeys,
TableService tableService,
Annotation[] annotations,
StatementStopService statementStopService,
EngineImportService engineImportService) |
| Modifier and Type | Method and Description |
|---|---|
NamedWindowProcessor |
FireAndForgetProcessorNamedWindow.getNamedWindowProcessor() |
| Constructor and Description |
|---|
FireAndForgetProcessorNamedWindow(NamedWindowProcessor namedWindowProcessor) |
| Modifier and Type | Method and Description |
|---|---|
NamedWindowProcessor |
NamedWindowMgmtServiceImpl.addProcessor(String name,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow,
NamedWindowDispatchService namedWindowDispatchService) |
NamedWindowProcessor |
NamedWindowMgmtService.addProcessor(String name,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow,
NamedWindowDispatchService namedWindowDispatchService) |
NamedWindowProcessor |
NamedWindowDispatchServiceImpl.createProcessor(String name,
NamedWindowMgmtServiceImpl namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean enableQueryPlanLog,
MetricReportingService metricReportingService,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow) |
NamedWindowProcessor |
NamedWindowDispatchService.createProcessor(String name,
NamedWindowMgmtServiceImpl namedWindowMgmtService,
NamedWindowDispatchService namedWindowDispatchService,
String contextName,
EventType eventType,
StatementResultService statementResultService,
ValueAddEventProcessor revisionProcessor,
String eplExpression,
String statementName,
boolean isPrioritized,
boolean isEnableSubqueryIndexShare,
boolean enableQueryPlanLog,
MetricReportingService metricReportingService,
boolean isBatchingDataWindow,
boolean isVirtualDataWindow,
Set<String> optionalUniqueKeyProps,
String eventTypeAsName,
StatementContext statementContextCreateWindow) |
NamedWindowProcessor |
NamedWindowLifecycleEvent.getProcessor()
Return the processor originating the event.
|
NamedWindowProcessor |
NamedWindowMgmtServiceImpl.getProcessor(String name) |
NamedWindowProcessor |
NamedWindowMgmtService.getProcessor(String name)
Returns the processing instance for a given named window.
|
| Constructor and Description |
|---|
NamedWindowLifecycleEvent(String name,
NamedWindowProcessor processor,
NamedWindowLifecycleEvent.LifecycleEventType eventType,
Object... parameters)
Ctor.
|
NamedWindowProcessorInstance(Integer agentInstanceId,
NamedWindowProcessor processor,
AgentInstanceContext agentInstanceContext) |
NamedWindowTailViewInstance(NamedWindowRootViewInstance rootViewInstance,
NamedWindowTailView tailView,
NamedWindowProcessor namedWindowProcessor,
AgentInstanceContext agentInstanceContext) |