com.espertech.esper.epl.named
Class NamedWindowTailView

java.lang.Object
  com.espertech.esper.epl.named.NamedWindowTailView

public class NamedWindowTailView
extends java.lang.Object

This view is hooked into a named window's view chain as the last view and handles dispatching of named window insert and remove stream results via NamedWindowMgmtService to consuming statements.

Constructor Summary

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

Method Summary

NamedWindowConsumerView	addConsumer(NamedWindowConsumerDesc consumerDesc)
void	addDispatches(java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumersInContext, NamedWindowDeltaData delta, AgentInstanceContext agentInstanceContext)
java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>>	getConsumersNonContext()
EventType	getEventType()
NamedWindowDispatchService	getNamedWindowDispatchService()
NamedWindowMgmtService	getNamedWindowMgmtService()
ValueAddEventProcessor	getRevisionProcessor()
StatementResultService	getStatementResultService()
boolean	isParentBatchWindow() Returns true to indicate that the data window view is a batch view.
boolean	isPrioritized()
void	removeConsumer(NamedWindowConsumerView namedWindowConsumerView) Called by the consumer view to indicate it was stopped or destroyed, such that the consumer can be deregistered and further dispatches disregard this consumer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NamedWindowTailView

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

Method Detail

isParentBatchWindow

public boolean isParentBatchWindow()

Returns true to indicate that the data window view is a batch view.

Returns:

true if batch view

getEventType

public EventType getEventType()

getStatementResultService

public StatementResultService getStatementResultService()

getNamedWindowMgmtService

public NamedWindowMgmtService getNamedWindowMgmtService()

getNamedWindowDispatchService

public NamedWindowDispatchService getNamedWindowDispatchService()

isPrioritized

public boolean isPrioritized()

getRevisionProcessor

public ValueAddEventProcessor getRevisionProcessor()

getConsumersNonContext

public java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> getConsumersNonContext()

addConsumer

public NamedWindowConsumerView addConsumer(NamedWindowConsumerDesc consumerDesc)

removeConsumer

public void removeConsumer(NamedWindowConsumerView namedWindowConsumerView)

Called by the consumer view to indicate it was stopped or destroyed, such that the consumer can be deregistered and further dispatches disregard this consumer.

Parameters:

namedWindowConsumerView - is the consumer representative view

addDispatches

public void addDispatches(java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumersInContext,
                          NamedWindowDeltaData delta,
                          AgentInstanceContext agentInstanceContext)