com.espertech.esper.epl.named

Interface NamedWindowDispatchService

All Known Implementing Classes:

NamedWindowDispatchServiceImpl

public interface NamedWindowDispatchService

Service to manage named window dispatches, locks and processors on an engine level.

Method Summary

Modifier and Type	Method and Description
void	addDispatch(NamedWindowConsumerLatchFactory latchFactory, NamedWindowDeltaData delta, Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumers) For use to add a result of a named window that must be dispatched to consuming views.
NamedWindowProcessor	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)
NamedWindowTailView	createTailView(EventType eventType, NamedWindowMgmtService namedWindowMgmtService, NamedWindowDispatchService namedWindowDispatchService, StatementResultService statementResultService, ValueAddEventProcessor revisionProcessor, boolean prioritized, boolean parentBatchWindow, String contextName, TimeSourceService timeSourceService, ConfigurationEngineDefaults.Threading threadingConfig)
void	destroy() Destroy service.
boolean	dispatch() Dispatch events of the insert and remove stream of named windows to consumers, as part of the main event processing or dispatch loop.

Method Detail

createProcessor

NamedWindowProcessor 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)

createTailView

NamedWindowTailView createTailView(EventType eventType,
                                   NamedWindowMgmtService namedWindowMgmtService,
                                   NamedWindowDispatchService namedWindowDispatchService,
                                   StatementResultService statementResultService,
                                   ValueAddEventProcessor revisionProcessor,
                                   boolean prioritized,
                                   boolean parentBatchWindow,
                                   String contextName,
                                   TimeSourceService timeSourceService,
                                   ConfigurationEngineDefaults.Threading threadingConfig)

dispatch

boolean dispatch()

Dispatch events of the insert and remove stream of named windows to consumers, as part of the main event processing or dispatch loop.

Returns:

send events to consuming statements

addDispatch

void addDispatch(NamedWindowConsumerLatchFactory latchFactory,
                 NamedWindowDeltaData delta,
                 Map<EPStatementAgentInstanceHandle,List<NamedWindowConsumerView>> consumers)

For use to add a result of a named window that must be dispatched to consuming views.

Parameters:

delta - is the result to dispatch

consumers - is the destination of the dispatch, a map of statements to one or more consuming views

latchFactory - latch factory

destroy

void destroy()

Destroy service.