Package com.espertech.esper.common.internal.epl.namedwindow.consume

Interface NamedWindowDispatchService

public interface NamedWindowDispatchService

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

Method Summary

Modifier and Type	Method	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.
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 Details

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

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

destroy

void destroy()

Destroy service.